Python3 psycopg2: «Нет результатов для извлечения» с помощью RETURNING - PullRequest
Новая
       74

Python3 psycopg2: «Нет результатов для извлечения» с помощью RETURNING

0 голосов
/ 28 марта 2019

Я использую:

  • psvcopg2
  • python3.6
  • 11,2-PostgreSQL
  • Кубунту 18.10

и я успешно вставляю строку, но курсор.fetchall () вызывает 

psycopg2.ProgrammingError: no results to fetch

даже когда я использую RETURNING внутри SQL для получения идентификатора.

Я узнал о cursor.description, но оно пустое (cursor.description == Нет).

SQL работает правильно, используется в терминале psql, возвращая идентификатор в соответствии с запросом.

код питона : 

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)

1 Ответ

0 голосов
/ 29 марта 2019

Мой плохой. Я не заметил этого в документах: 

The function is mostly useful for commands that update the database: any result set returned by the query is discarded.
...