mysql 高并发重复写入_高并发场景下数据重复插入的问题

89 阅读 0 评论 59 点赞

我是靠谱客的博主真实白开水，最近开发中收集的这篇文章主要介绍mysql 高并发重复写入_高并发场景下数据重复插入的问题，觉得挺不错的，现在分享给大家，希望可以做个参考。

高并发场景下，数据库经常会发生数据重复插入的问题，这时候单单在插入前，查询数据库，判断是否存在，再进行插入，往往不能保证数据唯一性。

查询数据库判断是否存在

测试代码： th_insert_test.py 每次插入前，去数据库查询，要插入的 User0-9 是否存在，若不存在则插入，若存在，则返回已经有。

#-*- coding:utf8 -*-

def db_op_thread_func(i, num_of_op):

r = redis.Redis(host='127.0.0.1', port=6379, db=0)

# r = redis.Redis(connection_pool=pool)

conn = MySQLdb.connect(host="redisHost", port=3306, user="root", passwd="pass", db="blog")

cursor = conn.cursor()

for j in range(0, int(num_of_op)):

nickname = 'User' + str(int(i % 10))

lockkey = "lock"+nickname

getsql = ("select ID from User where Username = '%s'") % (nickname)

cursor.execute(getsql)

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。