Python使用数据库连接池的方法
这篇文章主要介绍了Python使用数据库连接池的方法,具有一定借鉴价值,需要的朋友可以参考下。希望大家阅读完这篇文章后大有收获。下面让小编带着大家一起了解一下。
为企业提供成都做网站、成都网站设计、网站优化、营销型网站、竞价托管、品牌运营等营销获客服务。成都创新互联拥有网络营销运营团队,以丰富的互联网营销经验助力企业精准获客,真正落地解决中小企业营销获客难题,做到“让获客更简单”。自创立至今,成功用技术实力解决了企业“网站建设、网络品牌塑造、网络营销”三大难题,同时降低了营销成本,提高了有效客户转化率,获得了众多企业客户的高度认可!
Python 数据库连接池
python编程中可以使用pyMySQL进行数据库连接及增删改查操作,但每次连接mysql请求时,都是独立的去请求访问,比较浪费资源,而且访问数量达到一定数量时,对mysql的性能会产生较大的影响。因此实际使用中,通常会使用数据库的连接池技术,来访问数据库达到资源复用。
python的数据库连接池包:DBUtils
DBUtils提供两种外部接口:
PersistentDB:提供线程专用的数据库连接,并自动管理连接。
PooledDB:提供线程间可共享的数据库连接,并自动管理连接。
DBUtils包安装: pip3 install DBUtils或者下载 DBUtils 安装包,解压后,使用python setup.py install 命令进行安装。
未使用连接池的数据库方法:
def getconn(host, user, passwd, db, sql, port=3306,charset='utf8'): conn = pymysql.connect(host=host, user=user, passwd=passwd, port=port, db=db, charset=charset) #建立连接 cur = conn.cursor(cursor=pymysql.cursors.DictCursor) #建立游标并指定游标类型 cur.execute(sql) #执行sql if sql.startswith('select'): #判断sql是否是select res = cur.fetchone() else: conn.commit() #insert\delete\update语句执行完毕后需要进行commit res = 88 cur.close() #关闭游标 conn.close() #关闭连接 return res
用数据库连接池后的方法:
import MySQLdb from DBUtils.PooledDB import PooledDB pool = PooledDB(MySQLdb,5,host='localhost',user='root',passwd='pwd',db='myDB',port=3306) #5为连接池里的最少连接数 conn = pool.connection() #以后每次需要数据库连接就是用connection()函数获取连接就好了 cur=conn.cursor() SQL="select * from table1" r=cur.execute(SQL) r=cur.fetchall() cur.close() conn.close()
下面利用pymysql 和 DBUtils 建立自己的mysql数据库连接工具包。
class OPMysql(object): __pool = None def __init__(self): # 构造函数,创建数据库连接、游标 self.coon = OPMysql.getmysqlconn() self.cur = self.coon.cursor(cursor=pymysql.cursors.DictCursor) # 数据库连接池连接 @staticmethod def getmysqlconn(): if OPMysql.__pool is None: __pool = PooledDB(creator=pymysql, mincached=1, maxcached=20, host=mysqlInfo['host'], user=mysqlInfo['user'], passwd=mysqlInfo['passwd'], db=mysqlInfo['db'], port=mysqlInfo['port'], charset=mysqlInfo['charset']) print(__pool) return __pool.connection() # 插入\更新\删除sql def op_insert(self, sql): print('op_insert', sql) insert_num = self.cur.execute(sql) print('mysql sucess ', insert_num) self.coon.commit() return insert_num # 查询 def op_select(self, sql): print('op_select', sql) self.cur.execute(sql) # 执行sql select_res = self.cur.fetchone() # 返回结果为字典 print('op_select', select_res) return select_res #释放资源 def dispose(self): self.coon.close() self.cur.close()
配置文件mysqlinfo,包含数据库的连接信息、用户名密码等:
mysqlInfo = { "host": '192.168.1.112', "user": 'root', "passwd": '123456', "db": 'apitest', "port": 3306, "charset": 'utf8' }
创建test,测试数据库连接
if __name__ == '__main__': #申请资源 opm = OPMysql() sql = "select * from demo where name ='a' and pwd='e10adc3949ba59abbe56e057f20f883e' " res = opm.op_select(sql) #释放资源 opm.dispose()
PooledDB参数解释:
mincached,最少的空闲连接数,如果空闲连接数小于这个数,pool会创建一个新的连接。
maxcached,最大的空闲连接数,如果空闲连接数大于这个数,pool会关闭空闲连接。
maxconnections,最大的连接数,进程中最大可创建的线程数。
blocking, 当连接数达到最大连接数时,再次请求时,如果这个值是True,请求连接的程序会一直等待,直到当前连接数小于最大连接数;如果这个值为False,会报错。
masxshared,当连接数达到这个数时,新请求的连接会分享已经分配出去的连接。
在uwsgi中,每个http请求都会有一个进程,连接池中配置的连接数都是一个进程为单位的(即上面的最大连接数,都是在一个进程中创建的线程数),如果业务中,一个http请求中需要的sql连接数不是很多的话(其实大多数都只需要创建一个连接),配置的连接数配置都不需要太大。
连接池对性能的提升:
在程序创建连接的时候,可以从一个空闲的连接中获取,不需要重新初始化连接,提升获取连接的速度。
关闭连接的时候,把连接放回连接池,而不是真正的关闭,所以可以减少频繁的打开和关闭连接。
感谢你能够认真阅读完这篇文章,希望小编分享Python使用数据库连接池的方法内容对大家有帮助,同时也希望大家多多支持创新互联,关注创新互联行业资讯频道,遇到问题就找创新互联,详细的解决方法等着你来学习!
分享文章:Python使用数据库连接池的方法
新闻来源:http://scyanting.com/article/pceicj.html