我有 python 代码将新记录推送到 db 到列信息。 try: db.add_new_record(info) except Exception as e: log.error(e) db.db.rollback() continue我使用标准的sql查询INSERT INTO mydb (info, desc) VALUES ('value1', 'value2')Python:import psycopg2def add_new_record(self, info): info['table'] = self.table query = "INSERT INTO {table} (c1, c2) VALUES ('{val1}', '{val2}')".format(**self.make_dct(info)) self.make_execute(query) self.db_commit() return True有时我看到异常 exception: duplicate key value violates unique constraint "mydb_info_key"这是正常的。我计算 db 中的行数:25000 条记录。但我最后的 ID 以 60000+ 开头。Duplicate exception记录新ID?如何避免这种情况?
1 回答
慕斯王
TA贡献1864条经验 获得超2个赞
还有另一个表mydb_seq
告诉sql下一个要使用的索引是什么(你可以看看它是什么SELECT * FROM mydb_seq;
)
在其他地方,您主动将 ID 设置为比此指针更高的值,因此有时此指针指向表中已存在的索引
您可以使用以下逻辑确定位置
首先找到 next_id 的指针
SELECT * FROM mydb_seq;
然后在你的表中查询任何具有更大 id 的东西
SELECT id FROM mydb WHERE id > $next_id; // replace $next_id... with the value from above
顺便说一句,你应该真的真的 真的使用 cursor.execute 变量插入......你现在正在做的是疯狂的,这会让你注入 sql
qry = "INSERT INTO {table} (field1,field2,field3) VALUES (%s,%s,%s)".format(table="my_db") cursor.execute(query,(var1,var2,var3))
添加回答
举报
0/150
提交
取消