如何在for循环python 3中执行psycopg查询

Question

**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)

Answer 1

这可能有用。

这就是 Postgres 所做的when a query produces an error and you try to run another query without first rolling back the transaction。 （您可能会将其视为一项安全功能，以防止您损坏数据。）

来源：https://stackoverflow.com/a/2979389/8074624