私は使用しています:
- psvcopg2
- python3.6
- postgresql-11.2
- クブンツ 18.10
行を正常に挿入していますが、cursor.fetchall()が発生しています
psycopg2.ProgrammingError: no results to fetch
IDを取得するためにSQL内でRETURNINGを使用している場合でも。
私はcursor.descriptionについて知りましたが、空です(cursor.description == None)。
SQL は psql ターミナル内で正しく使用され、要求どおりに ID を返します。
パイソンコード:
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)