如何在不创建conn.cursor()的情况下检查/打印psycopg2动态查询组合
在不创建conn.cursor()的情况下，检查/打印psycopg2动态查询组合，可以通过以下步骤实现：
- 首先，确保已经建立了与数据库的连接
conn。 - 使用
conn.cursor()方法创建一个游标对象cur，该游标对象用于执行SQL查询和操作。 - 使用
cur.mogrify()方法将动态查询组合成一个完整的SQL语句，并返回该SQL语句的字符串表示。cur.mogrify()方法接受两个参数：SQL查询字符串和查询参数。查询参数可以是一个单独的值，也可以是一个包含多个值的元组或列表。 - 使用
print()函数打印组合后的SQL语句，以便检查查询是否正确。
以下是一个示例代码：
import psycopg2
# 建立与数据库的连接
conn = psycopg2.connect(database="your_database", user="your_username", password="your_password", host="your_host", port="your_port")
# 组合动态查询
query = "SELECT * FROM your_table WHERE column1 = %s AND column2 = %s"
params = ('value1', 'value2')
sql = conn.cursor().mogrify(query, params)
# 打印组合后的SQL语句
print(sql)
# 关闭数据库连接
conn.close()在上述示例中，我们使用cur.mogrify()方法将查询字符串query和查询参数params组合成一个完整的SQL语句，并将结果赋值给变量sql。然后，我们使用print()函数打印sql，以便检查查询是否正确。
请注意，上述示例中的数据库连接参数需要根据实际情况进行替换。另外，psycopg2是一个用于连接PostgreSQL数据库的Python库，如果你使用的是其他数据库，可能需要使用相应的库和连接方式。
推荐的腾讯云相关产品：腾讯云数据库PostgreSQL，详情请参考腾讯云数据库PostgreSQL。
相关·内容
使用psycopg2进行查询的最佳模式是什么？
这一条：
# get_connection is a function that returns a connection to the db.
with get_connection() as conn:
with conn.cursor() as cursor:
cursor.execute("SELECT * FROM test_table")
or simply this:
with get_connection() as conn:
cursor = conn.cursor()
浏览 2提问于2012-11-12得票数 5
回答已采纳
2回答
如何防止psycopg2锁定表
、、、、
我在PostgreSQL 9.1服务器上有这样一个表：
CREATE TABLE foo(id integer PRIMARY KEY);
在与psycopg2 (≥2.4.2)交互的Python中，我可能启动一个连接和游标，并查询这个表：
import psycopg2
conn = psycopg2.connect('dbname=...')
curs = conn.cursor()
curs.execute('SELECT * FROM foo;')
curs.fetchall()
但是，如果我随后尝试修改表：
ALTER TABLE foo ADD CO
浏览 4提问于2016-04-21得票数 11
回答已采纳
我正在尝试从psycopg2调用一个函数，如下所示：
conn = psycopg2.connect(host="name.host.ex", user="username", password="secret")
cur = conn.cursor()
cur.callproc("f_do_action", ["aaa", "bbb"])
cur.close()
conn.close()
当从psql调用这个函数时，一切正常，但是使用psycopg2似乎什么都没有发生。我也不例外。它只是不调用实际
浏览 0提问于2011-11-13得票数 14
回答已采纳
我正在制作一个使用postgreSQL查询psycopg2数据库的Flask应用程序。数据库有一列时间戳，格式为YYYY DD:MI:SS。我只想打印与当前时间相匹配的结果，直到分钟(查询数据库的那一刻)。我想我要找的是一个动态查询。
例如，这里我要打印当前活动的用户数。
def userCount(conn):
cur = conn.cursor()
cur.execute("SELECT * from user_list WHERE timestamps = ?")
print 'Users currently active: ' +
浏览 1提问于2017-06-15得票数 3
回答已采纳
我已经运行了psycopg2，并且可以成功地查询我的数据库中的表。这是一个查询表my_table的工作示例：
import psycopg2
try:
conn_string="dbname='my_dbname' user='user' host='localhost' password='password'"
print "Connecting to database\n->%s" % (conn_string)
conn = psycopg2.connect(conn_st
浏览 0提问于2012-11-09得票数 2
回答已采纳
我们有一个真正的大数据查询过程。到目前为止，我们使用原始sql查询来获取数据，并使用python db api游标在其中执行它们。
import psycopg2
conn = psycopg2.connection("DB_connection_string")
cursor = conn.cursor()
cursor.execute("select * from so_so")
这提出了一个性能问题的主题，我们认为这些游标与Sql游标相同，这对性能不好。
它们是一样的吗？如果是这样的话，有人能建议一种更快的方法吗？
SQLALCHEMY或ORM模式比这种方
浏览 13提问于2017-06-30得票数 0
回答已采纳
我构建了一个类，它可以获取任意Postgres SQL查询、获取数据并创建CSV文件。我使用cursor.description来获取列名，并将其作为我的csv头传递。然而，数据集变得太大，我将转向服务器端游标。
服务器端游标似乎没有任何数据在描述中。当我运行时：
import psycopg2
conn = psycopg2.connect(**conn_info)
cursor = conn.cursor("server_side")
cursor.execute("select * from foo")
print(cursor.description)
浏览 0提问于2019-07-21得票数 5
我使用pip install opcopg2-binary安装了install copg2-binary包。但是什么时候我可以在Python中使用它呢？
import psycopg2 as pg2
conn = pg2.connect(database = 'dvdrental', user = 'postgres', password = secret)
cur = conn.cursor()
cur.execure('select * from actor')
cur.fetchmany(5)
----------------------
浏览 2提问于2020-01-19得票数 2
3回答
我正在使用psycopg2在我的postgres数据库上运行python脚本中的大型查询(我升级到了2.5版)。查询完成后，我关闭游标和连接，甚至运行gc，但该过程仍然消耗大量内存(确切地说是7.3gb)。我是不是错过了一个清理步骤？
import psycopg2
conn = psycopg2.connect("dbname='dbname' user='user' host='host'")
cursor = conn.cursor()
cursor.execute("""large query
浏览 8提问于2013-06-20得票数 26
回答已采纳
我正在尝试使用Postgres执行一些psycopg2查询。
import psycopg2
conn = psycopg2.connect(
host="test.postgres.database.azure.com",
database="postgres",
user="test",
password="test")
cur = conn.cursor()
sql = "select site_panel from test.ws_sites"
cur.execute(
浏览 1提问于2022-06-17得票数 1
回答已采纳
1回答
以这段涉及两个SELECT的psycopg2调用为例： import psycopg2
with psycopg2.connect("dbname=test user=postgres") as conn:
with conn.cursor() as cur:
cur.execute("SELECT a, b, c FROM table WHERE a > 5 and d < 10;")
r1 = cur.fetchall()
cur.execute("SELECT a, b, c
浏览 21提问于2019-10-03得票数 1
回答已采纳
8回答
我正在使用Python2.7和PostgreSQL9.1。为了从查询中获取字典，我尝试了下面描述的代码：
import psycopg2
import psycopg2.extras
conn = psycopg2.connect("dbname=mydb host=localhost user=user password=password")
cur = conn.cursor(cursor_factory=psycopg2.extras.DictCursor)
cur.execute ("select * from port")
type(cur.fetch
浏览 28提问于2014-01-16得票数 41
回答已采纳
我在PostgreSQL和psycopg2中使用服务器端游标，基于。
with conn.cursor(name='name_of_cursor') as cursor:
query = "SELECT * FROM tbl FOR UPDATE"
cursor.execute(query)
for row in cursor:
# process row
在处理每一行时，我想使用PostgreSQL的UPDATE tbl SET ... WHERE CURRENT OF name_of_cursor ()更新行中的几个字
浏览 0提问于2021-05-26得票数 0
回答已采纳
2回答
我已经定义了一个模块，它使用psycopg2模块从db中查询一些东西。
当我将这个模块导入到我的代码中时，由于某种原因，名称错误：NameError: global name 'psycopg2' is not defined
模块查询为：
import psycopg2
import pandas as pd
def queryRedshift(query):
conn_string = """db details"""
conn = psycopg2.connect(conn_string)
浏览 0提问于2016-03-22得票数 0
使用psycopg2更新用户密码似乎成功运行，但密码保持不变。
下面是我使用的代码：
conn = psycopg2.connect("dbname='my_db' user='my_user' host='localhost' password='dbpass'")
cur = conn.cursor()
update_password_query = """ALTER USER my_user WITH PASSWORD %(password)s"""
cur
浏览 1提问于2016-06-28得票数 1
2回答
我希望通过psycopg2调用plpgsql函数，并查看警告消息。也就是说，我有这个功能：
create or replace function test_warning() returns void as $$
begin
raise warning 'this is only a test';
end;
$$
language plpgsql;
并在python中这样称呼它：
import psycopg2
conn = psycopg2.connect(conn_string)
cursor = conn.cursor()
cursor.callproc("te
浏览 11提问于2014-12-01得票数 24
回答已采纳
1回答
我能够连接Python3.4和Postgres，但我的查询没有成功执行。例如，下面的表没有被创建
import psycopg2
from psycopg2 import connect
try:
conn = psycopg2.connect("dbname='postgres' user='postgres' host='localhost' password='postgres'")
print("Database connected!")
cur = conn.cursor()
cur
浏览 3提问于2015-02-04得票数 0
回答已采纳
2回答
我可以连接到我的数据库，但psycopg2找不到我的任何表。以下内容将在尝试获取我的用户时出错：
import psycopg2
try:
conn = psycopg2.connect("dbname='pdb' user='postgres' host='localhost' password='password'")
except:
print 'failed to connect'
cur = conn.cursor()
cur.execute(""
浏览 0提问于2014-12-12得票数 5
回答已采纳
我使用psycopg2查询以数字+ ".district“开头的数据库，因此我的代码如下：
number = 2345
cur = conn.cursor()
myquery = """ SELECT *
FROM {0}.districts
;""".format(number)
cur.execute("""{0};""".format(query))
data = cur.fetchall()
conn.close()
和我
浏览 2提问于2017-03-23得票数 0
1回答
我可能很困惑，但这正是我问这个问题的原因。使用psycopg2的程序可以在不使用光标的情况下对数据库执行命令吗？我见过的每个都使用cur = conn.cursor()，然后使用像cur.execute("""SELECT datname from pg_database""")这样的execute语句
我的问题是，没有cur，SELECT datname from pg_database可以做吗？
游标的psycopg2概念是否与实际的相同，即是否存在1-1关系？
在阅读之后，我感到有点困惑，因为他们似乎说得好像游标不是刻度符号(但我猜，当通过
浏览 3提问于2015-08-26得票数 2
回答已采纳
2回答
我想使用psycopg2的sql子模块来编写干净的动态SQL：
from psycopg2 import sql
...
cursor.execute(sql.SQL("SELECT * FROM {}").format(sql.Identifier('myschema.mytable'))
这将创建以下查询：
SELECT * FROM "myschema.mytable"
这里我得到一个Relation "myschema.mytable" not found.异常。
如何正确处理架构名称？下面的语句可以工作，但是如何使用ps
浏览 0提问于2018-06-05得票数 7
回答已采纳
我正在尝试查询我的PostgreSQL数据库以检索我的表。我一直陷入Psycopg2的错误
import psycopg2
try:
conn = pyscopg2.connect(database='wildlife', user='postgres', password='P@$$w0rd', host='localhost' port='5432')
print "successfully connected to database"
except:
print &
浏览 0提问于2018-10-23得票数 0
回答已采纳
我正在使用数据库，我想通过选择一个特定的rental_date来限制租用表。
当我打印rental_date的内容时，我收到一个表，如下所示：
[(datetime.datetime(2005，5，24，22，54，33)，)，(datetime.datetime(2005，5，24，23，3，39)，)，.
我试图使用这样的代码来限制我的租房表：
import psycopg2 as pg
conn = pg.connect(host='localhost', port='5432', dbname='dvdrental', user=
浏览 1提问于2022-07-31得票数 1
回答已采纳
1回答
当我尝试在AWS Lambda中运行psycopg2时，我得到了以下错误：
psycopg2.OperationalError: authentication method 10 not supported
我尝试从头开始构建，就像在中一样，但仍然有相同的错误。
有人能帮我一下吗？
import psycopg2
conn = psycopg2.connect(port=5432,database=xxxxx,user=XXXX,password=xxxxx)
def lambda_handler(event, context):
cur= conn.cursor()
XXXX
浏览 0提问于2020-09-20得票数 0
2回答
我正在使用psycopg2 2.6.1。我有一堆查询需要按顺序执行。
conn = psycopg2.connect(database=redshift_database,
user=redshift_user,
password=os.environ.get("PGPASSWORD"),
host=redshift_cluster,
port=redshift_port)
cursor
浏览 0提问于2016-02-26得票数 16
回答已采纳
我试图编写一个脚本，在Postgres数据库中创建一个新表，并使用psycopg2库将现有的csv文件复制到该表中。为了明确起见，我严格地尝试用psycopg2来实现这一点，而不是使用其他方法，比如psql.exe或ogr2ogr.，我可以连接、创建表，并对现有的表进行测试查询。*注:该数据库有多个模式。我创建了一个名为'test‘的表。
import os
import sys
import csv
import psycopg2
from os import path
from datetime import datetime
csv_file = r"C:\Projec
浏览 1提问于2021-12-06得票数 0
在python中通过psycopg2调用我的postgres存储过程后，我正在尝试获取列名列表...
这是我的代码
# create a connection to the database
conn = psycopg2.connect(...)
# create a cursor object for execution
curs = conn.cursor()
curs.callproc('usp_my_stored_proc', ['mySP'])
# now open a new cursor & "steal" the r
浏览 10提问于2018-02-28得票数 1
回答已采纳
我有下面的python代码，它试图从SQL查询中提取一些数据。然而，我得到了一个错误
TypeError: not all arguments converted during string formatting
下面给出的是我使用的代码
import pandas as pd
import psycopg2
from psycopg2 import sql
import xlsxwriter
def func(input):
db_details = conn.cursor() # set DB Cursor
db_details.execute(sql.SQL("
浏览 0提问于2018-10-17得票数 0
2回答
首先，我要说，我对Python相当陌生，如果这里不是这个问题的合适位置，我很抱歉。
我正在使用psycopg2模块来操作PostgreSQL数据库。一般用法如下所示：
# Example 1
import psycopg2
conn = psycopg2.connect(database="mydb", user="postgres")
cur = conn.cursor()
cur.execute ("SELECT * FROM mytable;")
rows = cur.fetchall()
for i, row in enumerat
浏览 1提问于2016-05-27得票数 8
回答已采纳
1回答
我在使用psycopg2在psql db上执行多个查询时遇到了问题。示例：
#!/usr/bin/env python
#-*- coding: utf-8 -*-
import psycopg2
from psycopg2.extras import RealDictCursor
def CreateUser(user, mySchema):
conn = psycopg2.connect("dbname='postgres' user='root' password='somePassword' host='lo
浏览 1提问于2017-09-10得票数 4
回答已采纳
我正在使用psycopg2访问postgres数据库，使用下面的查询。为了从执行的查询中返回字典，我在游标中使用了DictCursor，但我的输出仍然是一个列表，而不是一个字典。
下面是程序和输出。
import psycopg2.extras
try:
conn = psycopg2.connect("user='postgres' host='localhost' password='postgres'",
)
except:
print "I
浏览 3提问于2018-06-03得票数 5
1回答
我正在通过PostgreSQL库查询psycopg2数据库。这种方式的查询响应是。由于查询的大小，我试图避免重新查询它，而是将查询结果保存为。
不幸的是，当我试图执行代码时：
import psycopg2
import pickle
# Connect to an existing database
conn = psycopg2.connect(dbname="DB", user="my_user", password="****", host="12.34.56.78")
# Open a cursor to perfo
浏览 6提问于2020-02-19得票数 0
回答已采纳
我正在尝试使用psycog2对查询结果执行操作。因此，我必须将结果转换为熊猫DataFrame。但是当我使用以下代码进行打印时，只有列名而不是行被打印出来。我也使用了'pd.DataFrame.from_records‘，但这不起作用。
import psycopg2
import pandas as pd
import numpy as np
conn_string = "Connect_Info"
conn = psycopg2.connect(conn_string)
cursor = conn.cursor()
cursor.execute(query)
row
浏览 0提问于2015-07-17得票数 3
回答已采纳
我对python PostgreSQL有问题。我正在使用psycopg2。下面是我的postgres DB的样子：
Database: qcdata
---information_schema
---pg_catalog
---prod
---activation
--- *** Many other table ***
---public
我想提取schema: prod - table: activation中的信息
这是我的代码
import psycopg2
conn = psycopg2.connect(host=
浏览 4提问于2014-05-10得票数 0
1回答
#!/usr/bin/env python
import pika
def doQuery( conn, i ) :
cur = conn.cursor()
cur.execute("SELECT * FROM table OFFSET %s LIMIT 100000", (i,))
return cur.fetchall()
print "Using psycopg2"
import psycopg2
myConnection = psycopg2.connect( host=hostname, user=username
浏览 2提问于2017-09-28得票数 0
来自
PostgreSQL没有自动提交工具，这意味着所有查询都将在事务内执行。
在事务中执行是一件非常好的事情，它确保数据的完整性，并允许适当的错误处理。但是，有些查询不能在事务中运行。以下面的例子为例。
#/usr/bin/python2.4 #导入psycopg2 #尝试连接conn=psycopg2.connect:conn=psycopg2.connect(“dbname=‘template1 1’user='dbuser‘password='mypass'")，但打印”我无法连接到数据库“。cur = conn.cursor() try: cur.e
浏览 0提问于2018-08-15得票数 0
回答已采纳
我在Python中与库psycopg2一起使用postgres。连接到数据库后，我将尝试检查具有给定名称的表是否存在。在postgres，我是这样做的：
\connect myDB
select exists(select * from pg_tables where schemaname='public' AND tablename='mytable';)
如果该表存在，但如果不存在，则可以这样做。在python中，我使用以下行进行操作：
import psycopg2 as pg
from psycopg2.extensions import ISOLATI
浏览 0提问于2020-12-12得票数 1
回答已采纳
3回答
Python事件
、、、
我正在使用psycopg2，并且在将事件(执行的查询、通知、错误)记录到文件时遇到了问题。我想得到效果，就像在PgAdmin历史窗口。
例如，我正在执行以下查询：
insert into city(id, name, countrycode, district, population) values (4080,'Savilla', 'ESP', 'andalucia', 1000000)
在PgAdmin中，我看到了这样的效果：
Executing query:
insert into city(id, name, countrycode,
浏览 5提问于2012-12-30得票数 8
1回答
我正在阅读psycopg2 &想知道如何用名称将表的SQL标识符参数化？下面是一个示例：
import psycopg2
conn = psycopg2.connect()
cursor = conn.cursor()
cursor.execute(
"SELECT * FROM %(my_table)s LIMIT %(my_limit)s;"
vars={
"my_limit": 42, # parametrizing literals works fine.
"
浏览 9提问于2022-02-16得票数 0
回答已采纳
DataBase已经创建(PostgreSQL)
有一份清单：
data =
['param_1', 0],
['amp', 0],
['voltage', 1],
['params', 1],
['antenna', 1],
['freq', 0.00011000000085914508]
我试过了
import psycopg2
from psycopg2 import sql
with psycopg2.connect(dbname='db_name'
浏览 1提问于2019-10-16得票数 1
回答已采纳
3回答
我正在Linux上使用Cython构建一个独立的可执行文件。
我有以下代码：
import psycopg2 as pg
conn = pg.connect('dbname=**** user=**** password=****')
cur = conn.cursor()
cur.execute('SELECT version()')
print(cur.fetchone())
问题是当机器没有安装package psycopg2时，引发以下异常：
Traceback (most recent call last):
File "test.py
浏览 3提问于2014-03-21得票数 9
回答已采纳
2回答
我在awsλ上的代码：
import sys, boto3, logging, rds_config, psycopg2
rds_host = "hostname"
name = rds_config.db_username
password = rds_config.db_password
db_name = rds_config.db_name
s3 = boto3.resource('s3')
rds_client = boto3.client('rds',aws_access_key_id=Access_Key,aws_secret_
浏览 1提问于2018-09-20得票数 2
回答已采纳
1回答
我正在使用python3、postgress 10和Psycopg2来查询多条记录，如下所示
import psycopg2
conn = psycopg2.connect(<my connection string>)
with conn:
with conn.cursor() as cur:
cur.execute('select id,field1 from table1')
for id, field1 from cur.fetchall():
print(id,field1)
浏览 0提问于2018-12-09得票数 1
3回答
如何使用pyscopg2 ( python Postgres驱动程序)取消查询语句的执行？
举个例子，假设我有以下代码：
import psycopg2
cnx_string = "something_appropriate"
conn = psycopg2.connect(cnx_string)
cur = conn.cursor()
cur.execute("long_running_query")
然后，我想从另一个线程取消那个长时间运行的查询的执行--我必须在connection/cursor对象上调用什么方法才能做到这一点？
浏览 0提问于2010-01-11得票数 5
回答已采纳
无法执行psycopg2插入查询(Postgres )，该查询使用最佳实践%s符号进行插入，并包含包含%符号的LIKE语句。
%登录相似语句被解释为插入占位符。
'IndexError:元组索引超出范围‘抛出。
试着用反斜杠转义%，但没有成功。
with psycopg2.connect(some_url) as conn:
with conn.cursor() as cur:
query = """
SELECT id
FROM users
WHERE surname IN %s AND
浏览 0提问于2019-08-05得票数 1
回答已采纳
1回答
我是SQL和psycopg2的新手。我正在尝试寻找如何显示查询结果的方法。我有一个小脚本，我在其中建立到数据库的连接，并创建一个游标来运行查询。 from psycopg2 import connect
conn = connect(host="localhost", user="postgres", dbname="portfolio",
password="empty")
cur = conn.cursor()
cur.execute("SELECT * FROM portfoli
浏览 20提问于2019-05-02得票数 0
回答已采纳
我可以发送带有任何问题的select查询，但是当我发送update和insert查询时，它开始等待线程，并且不再响应。我不能确定，但它看起来像一个循环。
我知道我们必须使用"commit()“来应用更改，但它不起作用。
下面是我的代码：
import psycopg2
conn = psycopg2.connect("dbname='test' user='postgres' host='localhost' password='xx");
cursor = conn.cursor()
cursor.execute
浏览 0提问于2011-09-18得票数 11
回答已采纳
目前，我正在使用psycopg2编写一个关于数据库条目的教程，但我似乎无法让脚本找到它。使用pip安装，我的脚本是用Atom编写的。当我在命令提示符中导入psycopg2时，它可以正常工作，但是我的Atom无法运行：
原子脚本
import sys
sys.path.append('c:\\users\j.meiring\appdata\local\programs\python\python36-32\lib\site-packages')
print(sys.path)
import psycopg2
def create_table():
conn=psycop
浏览 0提问于2018-06-20得票数 3
我正在尝试使用psycopg2包动态构建查询和执行。下面的查询如下所示
def get_employees_for_dept(dept_id):
sql = '''SELECT
emp.FirstName,
emp.LastName,
dep.DepartmentName
FROM Employee emp
JOIN Department dep
ON
dp.EmployeeID = emp.Id
WHERE
浏览 3提问于2017-05-02得票数 1
回答已采纳
1回答
我想对返回所有结果的通配符执行SQL查询。
SELECT *
FROM my_table
WHERE column1 IN ('*');
这样做的目的是按需求注入物品，例如：
import psycopg2
conn = psycopg2.connect(DSN)
curs = conn.cursor()
def my_func(filter='*'):
curs.execute("""SELECT *
FROM my_table
WHERE col
浏览 2提问于2015-09-19得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
