时间戳

首页 > 解决方案 > 如何避免在数据库中创建“假”ID？

python - 如何避免在数据库中创建“假”ID？

问题描述

我有将新记录推送到 db 到列信息的 python 代码。

   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 psycopg2
def 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"

这是正常的。

我计算数据库中的行数：25000 条记录。但我的最后一个 id 以 60000+ 开头。

Duplicate exception记录新身份证？如何避免这种情况？

标签： pythonpostgresql

解决方案

还有另一个表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))

推荐阅读