当前位置: 首页 > 面试题库 >

获取在psycopg2中插入的多行的ID

薄欣怿
2023-03-14
问题内容

我想将psycopg2用于INSERT多行,然后id使用单个查询(按顺序)返回所有s。这就是PostgreSQLRETURNING扩展的目的,并且似乎可以使用正常工作cursor.execute

cursor.execute(
    "INSERT INTO my_table (field_1, field_2) "
    "VALUES (0, 0), (0, 0) RETURNING id;"
)
print cursor.fetchall()

[(1,), (2,)]

现在,为了传递动态生成的数据,似乎cursor.executemany是一种方法:

data = [(0, 0), (0, 0)]

cursor.executemany(
    "INSERT INTO my_table (field_1, field_2) "
    "VALUES (%s, %s) RETURNING id;",
    data
)

但是,在这种情况下,将cursor.fetchall()产生以下内容:

[(4,), (None,)]

我如何才能正确返回所有ids而不是仅返回一个?


问题答案:

您不应该从executemany以下位置获得结果:

该功能对于更新数据库的命令最有用:查询返回的任何结果集都将被丢弃。

根据psycopg2 docs。

您最好不要insert在事务中循环使用单个值,或者使用多值insert... returning,尽管在后一种情况下,您必须小心使用另一个输入值来匹配返回的ID,您不能仅仅假设返回的ID的顺序与输入VALUES列表相同。

当我在本地运行测试时,它只会失败:

>>> import psycopg2
>>> conn = psycopg2.connect("dbname=regress")
>>> curs = conn.cursor()
>>> curs.execute("create table my_table(id serial primary key, field_1 integer, field_2 integer);")
>>> data = [(0, 0), (0, 0)]
>>> curs.executemany(
...     "INSERT INTO my_table (field_1, field_2) "
...     "VALUES (%s, %s) RETURNING id;",
...     data
... )
>>> 
>>> curs.fetchall()
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
psycopg2.ProgrammingError: no results to fetch

用psycopg2 2.5.1测试。



 类似资料:
  • 问题内容: 我正在使用Python和psycopg2连接到Postgres。 当我插入一行时… …如何获取刚刚插入的行的ID?试: 使用时返回错误: 简单地返回。 更新:也是(即使直接在postgres中使用此命令也可以): 有人可以建议吗? 谢谢! 问题答案: 并且,请不要手动构建包含值的SQL字符串。您可以(并且应该!)单独传递值,从而不必进行转义和SQL注入: 有关更多详细信息,请参见psy

  • 这是我的密码: 如您所知,它会在数据库中插入一个新行。现在我需要获取插入行的。我怎么能得到这个? 注意,我知道,如果我使用

  • 问题内容: 我使用此命令在两列表中插入一些单词: 如何获取每个单词插入行的ID(主键)。我的意思是执行后返回“ 55,56,57”之类的值。MySQL有这样的反应吗? 术语列是。如果一个术语已经存在,MySQL将不会插入它。是否可以返回该重复项的引用(即该术语所在行的ID)?像“55,A响应 12 ,56”。 问题答案: 您可以通过调用框架或MySQL库(使用任何语言)来获取它。 那行不通。插入后

  • 问题内容: 我需要用一个查询插入多行(行数不是常数),所以我需要像这样执行查询: 我知道的唯一方法是 但我想要一些更简单的方法。 问题答案: 我构建了一个程序,该程序将多行插入到位于另一个城市的服务器上。 我发现使用此方法的速度大约是的10倍。就我而言,tup是一个包含约2000行的元组。使用此方法大约花了10秒钟: 使用此方法需要2分钟:

  • 问题内容: 如果我有一个带有自动递增ID列的表,我希望能够在该表中插入一行,并获取刚刚创建的行的ID。我知道,通常,StackOverflow问题需要某种经过尝试或研究的代码,但是我不确定从Snowflake入手。我已经翻阅了他们的文档,却对此一无所获。 到目前为止,我能做的最好的事情是try和,但是这些操作并没有为我提供有关所插入行的任何相关信息,只是向我确认已插入行。 我相信我要的是与MS S

  • 问题内容: 我有一个很大的桌子,主键为。 该表大约有1700万行。Cron作业每小时都会使用该语法尝试向该表中插入多达50,000个新条目。 cronjob中的每个插入都具有1,000个值(多个插入)。如何从此查询获取插入表中的行数?我前后都无法进行行计数,因为大约有1700万行,而且查询过于昂贵。 在手册中mysql说,对于插入的行,受影响的行数为,对于更新的字段为,这意味着在我的1000 IN