Как выполнить запрос psycopg внутри для l oop python 3 - PullRequest
0 голосов
/ 14 февраля 2020

** psycopg2.errors.InFailedSqlTransaction: текущая транзакция прервана, команды игнорируются до конца блока транзакции ** ошибка произошла после исключения

import pandas as pd
conn = ...
cur = conn.cursor()
fb_csv_file = "File_path"
table = pd.read_csv(fb_csv_file, encoding = 'latin1')
try:
    for index,row in table.iterrows():
        sql =  'DELETE FROM public."tbl_Name"  WHERE "col_1" =\'' +str(row['col_1']) + '\' \
                    AND "col_2"=\'' + str(row['col_2'])+'\';'     
        cur.execute(sql)
        conn.commit()
except Exception as e :             
    print("Error  : ",e)

1 Ответ

0 голосов
/ 14 февраля 2020

Это может быть полезно.

Это то, что Postgres делает when a query produces an error and you try to run another query without first rolling back the transaction. (Вы можете подумать, что это средство безопасности, чтобы не повредить ваши данные.)

Источник: { ссылка }

...