我在用:
我成功地插入了一行,但是cursor.fetchall()引发了
psycopg2.ProgrammingError: no results to fetch
即使在使用返回SQL中检索id时也是如此。
我发现了cursor.description,但它是空的(cursor.description、==、None)。
SQL在psql终端中正确使用,根据请求返回id。
python代码
import psycopg2
from psycopg2.pool import ThreadedConnectionPool
pool = ThreadedConnectionPool(3, 20,
user="user",
password='xxxxxxxxx',
host="127.0.0.1",
port="5432",
database="my_database")
query = 'INSERT INTO market.item(item_store_id, title, price, url, image_url, aff_url, store_id) ' \
'VALUES(%(item_store_id)s, %(title)s, %(price)s, %(url)s, %(image_url)s, %(aff_url)s, %(store_id)s) ' \
'ON CONFLICT (item_store_id) DO ' \
'UPDATE SET (price, url, image_url, aff_url) = (excluded.price, excluded.url, excluded.image_url, excluded.aff_url) ' \
'RETURNING item_id '
args = [{
'item_store_id': 1,
'title': 'My title',
'price': 15,
'url': 'http://www.url.com',
'image_url': 'http://www.url.com',
'aff_url': 'http://www.url.com',
'store_id': 1,
}]
try:
result = []
connection = pool.getconn()
connection.autocommit = True
with connection.cursor() as cursor:
try:
cursor.executemany(query, args)
if cursor.rownumber > 0:
subresult = cursor.fetchall()
result.append(subresult)
print(result)
except (Exception, psycopg2.DatabaseError) as e:
raise
except (Exception, psycopg2.DatabaseError) as error:
print(e)
else:
print(result)
finally:
pool.putconn(connection)
发布于 2019-03-29 13:46:31
是我的错。我在文档里没注意到这个:
The function is mostly useful for commands that update the database: any result set returned by the query is discarded.
https://stackoverflow.com/questions/55400707
复制相似问题