python – 处理psycopg2中的错误 psycopg2.errors.InFailedSqlTransaction: current transaction is aborted, comm

studyer_domi 于 2020-10-21 19:53:38 发布

import psycopg2
# 数据库连接参数
conn = psycopg2.connect(database="xxx", user="xx", password="xxx", host="192.168.1.2", port="5432")
cur = conn.cursor()
cur.execute("SELECT * FROM test;")
rows = cur.fetchall()        # all rows in table
print(rows)
for i in rows:
    print(i)
conn.commit()
cur.close()
conn.close()

通过psycopg2，调用数据的时候报错psycopg2.errors.InFailedSqlTransaction: current transaction is aborted, comm

改为下面的代码就正常访问到了数据库信息

import psycopg2
   connection = psycopg2.connect(user="xxx",
                                  password="xx@#29",
                                  host="127.0.0.1",
                                  port="5432",
                                  database="xxx")
   cursor = connection.cursor()
   postgreSQL_select_Query = "select * from xxx"
   cursor.execute(postgreSQL_select_Query)
   mobile_records = cursor.fetchall() 
   for row in mobile_records:
       print("Id = ", row[0], )
       print("Model = ", row[1])
       print("Price  = ", row[2], "\n")
except (Exception, psycopg2.Error) as error :
    print ("Error while fetching data from PostgreSQL", error)
finally:
    #closing database connection.
    if(connection):
        cursor.close()
        connection.close()
        print("PostgreSQL connection is closed")

python – 处理psycopg2中的错误 psycopg2.errors.InFailedSqlTransaction: current transaction is aborted, comm 问题import psycopg2# 数据库连接参数conn = psycopg2.connect(database="xxx", user="xx", password="xxx", host="192.168.1.2", port="5432")cur = conn.cursor()cur.execute("SELECT * FROM test;")rows = cur.fetchall() # all rows in tableprint(rows)for i in self.cur.execute( sql ,Json(dict(item))) builtins.TypeError: ‘Json’ object does not support indexing 这个函数的第二个参数是参数列表,是[],而JSON不能索引化，就是指不能转化成列表 self.cur.execute( sql ,json.dumps(dict(item))) builtins.TypeError: not all arguments convert ed during string f