如何使用pyodbc executemany()处理主键约束冲突
如何使用pyodbc executemany()处理主键约束冲突
提问于 2019-01-22 04:28:43
我有一个脚本可以使用DataFrame在表中插入executemany()。
问题是，该表的ID为主键，有时可能会插入具有相同ID的行。
我想知道是否有一种简单的方法来处理这种异常并继续执行executemany()。
我想的另一种方法是检查表中的所有IDs，并在插入数据库之前删除它们.但我不知道这会不会是表演..。
我的代码：
params = (tuple(row) for _, row in df.iterrows())
sql = '''INSERT INTO stilingue.stalker_comments values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)'''
start = time.time()
try:
self.cursor.executemany(sql, params)
self.conn.commit()
except Exception as e:
print(e)
self.conn.rollback()
print('Something went wrong...')
end = time.time()
print('Execution time: {0:.2f} seconds.'.format(end-start))DataFrame
channel followers gender hashtags interactions likes location mentions name page_comment ... text themes uid user_image_url user_url username verified videoplays business rt_count
0 Inbox do Facebook 0 Não Definido 0 0 Midiam Mendes False ... Sacanagem isso né?? Poorq vocês dizeram que o ... 1995608377159933 https://storage.googleapis.com/usersstilingue/... False 0 Itaú 0
1 Inbox do Facebook 0 Não Definido 0 0 Midiam Mendes False ... Eu tenho provas , e posso processar vocês!! 1995608377159933 https://storage.googleapis.com/usersstilingue/... False 0 Itaú 0
2 Inbox do Facebook 0 Não Definido 0 0 Midiam Mendes False ... Isso é um absurdo 1995608377159933 https://storage.googleapis.com/usersstilingue/... False 0 Itaú 0回溯
('23000', "[23000] [Microsoft][ODBC SQL Server Driver][SQL Server]Violation of PRIMARY KEY constraint 'PK__stalker___DD37D91A4691B0F7'. Cannot insert duplicate key in object 'stilingue.stalker_comments'. The duplicate key value is (m__g64-pbys7OlEvp8xmfyktlNIHrUPQPiNrcKrPVOF_Lj84OJfN4WtAJ92lj7YnzAOQ1B7EDCJf85k_UcwB0-4Q). (2627) (SQLExecDirectW); [23000] [Microsoft][ODBC SQL Server Driver][SQL Server]The statement has been terminated. (3621)")回答 1
Stack Overflow用户
发布于 2019-01-22 05:24:57
如果数据不是很大，最简单的方法是在数据库中创建一个没有PK的临时表。然后将数据插入到临时表中，从临时表中删除复制(如果您有server，可以使用以下语法删除复制)，并将数据插入主表中。
WITH table_1 AS
(SELECT *,RN=ROW_NUMBER() OVER(PARTITION BY [pk_field]
order by date)
FROM [temporary_table])
DELETE FROM table_1 WHERE RN>1页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/54308346
复制
相似问题
使用用于fast_executemany的pyodbc连接到fast_executemany
如何在pyodbc中使用executemany运行多个SELECT查询
pyodbc executemany不是批处理插入SQL server插入非常慢。
executemany(sql，value)不会执行。python pyodbc
插入MySQL表主键约束冲突
添加站长 进交流群
领取专属 10元无门槛券
AI混元助手 在线答疑
关注 腾讯云开发者公众号
洞察 腾讯核心技术
剖析业界实践案例
腾讯云开发者
