Python基于多线程操作数据库相关问题分析
2018-07-11 08:41
1011 查看
python多线程并发操作数据库,会存在链接数据库超时、数据库连接丢失、数据库操作超时等问题。
解决方法:使用数据库连接池,并且每次操作都从数据库连接池获取数据库操作句柄,操作完关闭连接返回数据库连接池。
*连接数据库需要设置
charset = 'utf8', use_unicode = True,不然会报中文乱码问题*网上说解决python多线程并发操作数据库问题,连接时使用
self.conn.ping(True)(检查并保持长连接),但是我这边亲测无法解决,建议还是使用数据库连接池
python多线程代码:
import threading class MyThread(threading.Thread): def __init__(self, name, count, exec_object): threading.Thread.__init__(self) self.name = name self.count = count self.exec_object = exec_object def run(self): while self.count >= 0: count = count - 1 self.exec_object.execFunc(count) thread1 = MyThread('MyThread1', 3, ExecObject()) thread2 = MyThread('MyThread2', 5, ExecObject()) thread1.start() thread2.start() thread1.join() # join方法 执行完thread1的方法才继续主线程 thread2.join() # join方法 执行完thread2的方法才继续主线程 # 执行顺序 并发执行thread1 thread2,thread1和thread2执行完成才继续执行主线程 # ExecObject类是自定义数据库操作的业务逻辑类 # ########join方法详解######## thread1 = MyThread('MyThread1', 3, ExecObject()) thread2 = MyThread('MyThread2', 5, ExecObject()) thread1.start() thread1.join() # join方法 执行完thread1的方法才继续主线程 thread2.start() thread2.join() # join方法 执行完thread2的方法才继续主线程 # 执行顺序 先执行thread1,执行完thread1再执行thread2,执行完thread2才继续执行主线程
mysql数据库连接池代码:
import MySQLdb from DBUtils.PooledDB import PooledDB class MySQL: host = 'localhost' user = 'root' port = 3306 pasword = '' db = 'testDB' charset = 'utf8' pool = None limit_count = 3 # 最低预启动数据库连接数量 def __init__(self): self.pool = PooledDB(MySQLdb, self.limit_count, host = self.host, user = self.user, passwd = self.pasword, db = self.db, port = self.port, charset = self.charset, use_unicode = True) def select(self, sql): conn = self.pool.connection() cursor = conn.cursor() cursor.execute(sql) result = cursor.fetchall() cursor.close() conn.close() return result def insert(self, table, sql): conn = self.pool.connection() cursor = conn.cursor() try: cursor.execute(sql) conn.commit() return {'result':True, 'id':int(cursor.lastrowid)} except Exception as err: conn.rollback() return {'result':False, 'err':err} finally: cursor.close() conn.close()
更多关于Python相关内容感兴趣的读者可查看本站专题:《Python进程与线程操作技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》、《Python+MySQL数据库程序设计入门教程》及《Python常见数据库操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
您可能感兴趣的文章:
相关文章推荐
- 《网络爬虫-Python和数据分析》数据库建库建表问题
- python+mysql 操作数据库出现的中文编码问题
- iOS移动开发数据库相关操作,基于…
- Qt 多线程与数据库操作需要注意的几点问题
- 基于Python的数据分析:数据库索引效率探究
- 【问题】如何在Python中操作数据库
- Qt 多线程与数据库操作需要注意的几点问题
- python对json的相关操作以及json模块的简要分析
- 基于java+play的相关数据库的查询和多表查询问题
- 【Python数据分析】Python3操作Excel(二) 一些问题的解决与优化
- 关于打开数据库时提示"对象打开时,不允许操作",问题分析及解决办法
- Python 和 数据库相关的编码问题
- python中访问数据库并打印输出信息相关的问题
- Qt 多线程与数据库操作需要注意的几点问题(QSqlDatabase对象只能在当前线程里使用)
- Qt 多线程与数据库操作需要注意的几点问题
- python操作数据库相关的代码
- Qt 多线程与数据库操作需要注意的几点问题
- SQLite并发操作下的分析与处理,解决database is locked,以及多线程下执行事务等问题
- 困扰老子一下午的数据库操作问题(python+mysql)
- python对json的相关操作以及json模块的简要分析