服务器端游标的 Psycopg2 行数
我正在查询 Postgres 数据库以获取大量结果，并希望使用服务器端游标将结果流式传输到我的客户端.看起来当我这样做时，游标的 rowcount 属性现在在我执行查询后设置为 -1.我正在像这样创建光标: 以 db.cursor('cursor_name') 作为游标: 有没有办法在从数据库流式传输结果时找到查询的结果数量?(我可以做一个 SELECT COUNT(*)，但我想避免这
..
psycopg2相关内容
检查 psycopg2/postgresql 中 python 值列表的存在
我有一个 Python 值列表和一个包含特定列的 postgresql 表.我想知道我的 python 列表中的每个元素在表中是否有具有该 ID 的行. 例如，假设我有这个 python 列表: vals = [4, 8, 15, 16, 23, 42] 还有那个查询: 从 my_table 中选择 my_col； 给出: [4, 5, 6, 7, 8] 然后我想要一个返回的查询
..
python + psycopg2 = 未知类型?
似乎当我使用 callproc() 时，psycopg2 没有正确地将字符串转换为文本或字符变化. 例如: values = [pid, 4, 4, 'bureau ama', 0, 130, row['report_dte'], row['report_dte'], 1, 1, 1, None, None, 'published', 行['report_dte']]cur.callpro
..
如何在 psycopg2 连接方法中指定 Schema?
使用 psycopg2 模块通过 python 连接到 PostgreSQL 数据库.我可以使用以下连接方法执行所有查询.现在我想指定一个不同的模式而不是 public 来执行我的 SQL 语句.有没有办法在连接方法中指定schema名称? conn = psycopg2.connect(host="localhost",端口=“5432"，用户 =“postgres"，密码=“密码"，数据库=
..
连接后psycopg2找不到任何表
我可以连接到我的数据库，但是 psycopg2 无法找到我的任何表.尝试获取我的用户时会出现以下错误: 导入psycopg2尝试:conn = psycopg2.connect("dbname='pdb' user='postgres' host='localhost' password='password'")除了:打印“连接失败"cur = conn.cursor()cur.execute(
..
TimescaleDB:高效选择最后一行
我有一个带有 timescaledb 扩展名的 postgres 数据库. 我的主索引是一个时间戳，我想选择最新的行. 如果我碰巧知道在某个时间之后发生的最新行，那么我可以使用如下查询: query = 'select * from price where time >%(dt)s' 这里我指定了一个日期时间，并使用 psycopg2 执行查询: # 2018-01-10 11:
..
Psycopg2 查询返回 Decimal('value')
我在 Python 中查询 postgresql 数据库(通过 psycopg2).我的代码将值返回为 Decimal('VALUE').有没有办法在数据库中转换它?代码示例: query = "SELECT id FROM table;"cur.execute(查询)结果 = cur.fetchall()# Results = Decimal('某个值') 有没有办法把它转换成只显示没有“D
..
psycopg2:DictCursor 与 RealDictCursor
AFAIU 和文档中的 RealDictCursor 是一个专门的 DictCursor，它只能从键(又名列名)访问列，而 DictCursor 可以从键或索引号访问数据. 我想知道如果 DictCursor 提供了更大的灵活性，为什么要实现 RealDictCursor?它在性能方面(或内存方面)是否如此不同(我认为有利于 RealDictCursor ......)? 换句话说，什么是 R
..
sqlalchemy with postgres:插入到列有括号的表中
假设您在 postgres 中有一个表 "foo"，列名为 "col (parens) name".psql 命令 INSERT INTO "foo" ("col (parens) name") VALUES ('bar'); 工作正常.但是，如果我尝试使用 sqlalchemy(0.9.7 版)执行相同操作，则生成的 Python 代码将失败: conn = sqlalchemy.crea
..
PostgreSQL 类型错误:并非所有参数都在字符串格式化期间转换
我正在 psycopg2 中执行一个与 PostgreSQL 数据库链接的查询.这是有问题的代码: with open('dataFile.txt', 'r') as f:行 = f.readlines()newLines = [line[:-1] for line in lines]curr=conn.cursor()lineString = ','.join(newLines)curr.ex
..
获取 OperationalError: FATAL: 抱歉，已经有太多客户在使用 psycopg2
我收到错误 OperationalError: FATAL: 抱歉，使用 psycopg2 时已经有太多客户端了.完成后，我在我的连接实例上调用 close 方法.我不确定是什么原因造成的，这是我第一次使用 python 和 postgresql，但我有几年使用 php、asp.net、mysql 和 sql server 的经验. 编辑:我在本地运行它，如果连接像它们应该的那样关闭，那么我
..
在 psycopg2 中打开 postgres 连接导致 python 崩溃
当我尝试打开与 postgres 数据库的连接时收到以下错误消息.也许它与 OpenSSL 有关，但我无法理解错误消息.有人可以帮忙吗? >>>导入 psycopg2>>>conn = psycopg2.connect(host = '', port = , dbname= '', 用户 = '', 密码 = '')自动配置失败12848:错误:02001015:系统库:fopen:是一个目录:
..
无法安装 psycopg2 Ubuntu
试图为 django 项目准备一个服务器，但我在设置 postgres 时遇到了一些问题. 我正在遵循本指南:https://jee-appy.blogspot.com/2017/01/deply-django-with-nginx.html 我在第 5 步: 现在，我们需要配置 postgreSQL，以便它可以与我们的 Django 应用程序进行通信.为此，安装 psycopg
..
为什么我只能使用一次查询结果?
我是 SQL 和 psycopg2 的新手.我玩了一会儿，试图找到我们如何显示查询结果.我有一个小脚本，用于连接到数据库并创建一个游标来运行查询. from psycopg2 import connectconn = connect(host="localhost", user="postgres", dbname="portfolio",密码=“空")cur = conn.cursor()cu
..
如何从qdateEdit获取用户输入并从postgres的数据库中选择它
我想知道如何在 QDateEdit 中获取用户输入并在 postgres 的表中选择它?这是我的代码 def date(self):尝试:日期 = self.dateEdit.date()打印(日期)conn = psycopg2.connect(dbname="sample", user="postgres", password="admin", host="localhost", port
..
如何使用 Python/psycopg2 有效地更新大型 PostgreSQL 表中的列?
我有一张大桌子，上面放着大约.PostgreSQL 9.4 数据库中有 1000 万行.它看起来有点像这样: gid |编号 1 |随机 |结果|...1 |2 |空 |空 |...2 |15 |空 |空 |...... |... |... |... |... 现在我想将 random 和 result 列更新为 number1 的函数.这意味着至少需要在数据库外的脚本中生成 random.由
..
psycopg2 使用列名而不是列号来获取行数据
所以目前当我执行 SELECT 查询并检索数据时，我必须得到这样的结果: connection = psycopg2.connect(user="admin",密码=“管理员"，主机="127.0.0.1",端口=“5432"，数据库=“postgres_db")游标 = connection.cursor()cursor.execute("SELECT * FROM user")用户 = cu
..
ValueError 不支持格式字符 'd' 与 psycopg2
我有这样的代码: print "company_id = %d" % company_id...db.cursor.execute("insert into person (company_id, first, last, type) values (%d, '%s', '%s', %d);", (company_id, name[0], name[1], 类型)) 我得到以下输出: com
..
在 psycopg2 中构建动态更新查询
我必须为 postgresql 构建一个动态更新查询.它是动态的，因为我必须事先确定要更新哪些列. 给定一个示例表: create table foo (id int, a int, b int, c int) 然后我会以编程方式构造“set"子句 _set = {}_set['a'] = 10_set['c'] = NULL 之后我必须构建更新查询.我被困在这里.我必须构造这个 s
..
psycopg2:使用元组元组中的值更新表中的多行
我正在尝试使用元组元组一次更新多行.我想出了如何从 这篇文章 构建 sql 语句，但事实证明，在 psycopg2 中实现它更具挑战性.这是我所拥有的: c = db.cursor()new_values = (("Richard",29),("Ronald",30))sql = """UPDATE my_table AS tSET 名称 = e.nameFROM (VALUES %s) AS
..