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

107 阅读 0 评论 71 点赞

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

查询数据库判断是否存在

测试代码： 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)

以上就是真实白开水最近收集整理的关于mysql 高并发重复写入_高并发场景下数据重复插入的问题的全部内容，更多相关mysql内容请搜索靠谱客的其他文章。

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