建站
咨詢
售后
建站咨詢
新聞中心
成都創(chuàng)新互聯(lián)公司于2013年開始，先為和順等服務(wù)建站，和順等地企業(yè)，進(jìn)行企業(yè)商務(wù)咨詢服務(wù)。為和順企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問題。
python 數(shù)據(jù)庫連接池
python編程中可以使用pymysql進(jìn)行數(shù)據(jù)庫連接及增刪改查操作，但每次連接mysql請(qǐng)求時(shí)，都是獨(dú)立的去請(qǐng)求訪問，比較浪費(fèi)資源，而且訪問數(shù)量達(dá)到一定數(shù)量時(shí)，對(duì)mysql的性能會(huì)產(chǎn)生較大的影響。因此實(shí)際使用中，通常會(huì)使用數(shù)據(jù)庫的連接池技術(shù)，來訪問數(shù)據(jù)庫達(dá)到資源復(fù)用。
python的數(shù)據(jù)庫連接池包：DBUtils
DBUtils提供兩種外部接口：
PersistentDB：提供線程專用的數(shù)據(jù)庫連接，并自動(dòng)管理連接。
PooledDB：提供線程間可共享的數(shù)據(jù)庫連接，并自動(dòng)管理連接。
DBUtils包安裝： pip3 install DBUtils或者下載 DBUtils 安裝包，解壓后，使用python setup.py install 命令進(jìn)行安裝。
未使用連接池的數(shù)據(jù)庫方法：
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) #建立游標(biāo)并指定游標(biāo)類型
cur.execute(sql) #執(zhí)行sql
if sql.startswith('select'): #判斷sql是否是select
res = cur.fetchone()
else:
conn.commit() #insert\delete\update語句執(zhí)行完畢后需要進(jìn)行commit
res = 88
cur.close() #關(guān)閉游標(biāo)
conn.close() #關(guān)閉連接
return res用數(shù)據(jù)庫連接池后的方法：
import MySQLdb from DBUtils.PooledDB import PooledDB pool = PooledDB(MySQLdb,5,host='localhost',user='root',passwd='pwd',db='myDB',port=3306) #5為連接池里的最少連接數(shù) conn = pool.connection() #以后每次需要數(shù)據(jù)庫連接就是用connection（）函數(shù)獲取連接就好了 cur=conn.cursor() SQL="select * from table1" r=cur.execute(SQL) r=cur.fetchall() cur.close() conn.close()
相關(guān)推薦：《Python視頻教程》
下面利用pymysql 和 DBUtils 建立自己的mysql數(shù)據(jù)庫連接工具包。
class OPMysql(object):
__pool = None
def __init__(self):
# 構(gòu)造函數(shù)，創(chuàng)建數(shù)據(jù)庫連接、游標(biāo)
self.coon = OPMysql.getmysqlconn()
self.cur = self.coon.cursor(cursor=pymysql.cursors.DictCursor)
# 數(shù)據(jù)庫連接池連接
@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) # 執(zhí)行sql
select_res = self.cur.fetchone() # 返回結(jié)果為字典
print('op_select', select_res)
return select_res
#釋放資源
def dispose(self):
self.coon.close()
self.cur.close()配置文件mysqlinfo，包含數(shù)據(jù)庫的連接信息、用戶名密碼等：
mysqlInfo = {
"host": '192.168.1.112',
"user": 'root',
"passwd": '123456',
"db": 'apitest',
"port": 3306,
"charset": 'utf8'
}創(chuàng)建test，測(cè)試數(shù)據(jù)庫連接
if __name__ == '__main__': #申請(qǐng)資源 opm = OPMysql() sql = "select * from demo where name ='a' and pwd='e10adc3949ba59abbe56e057f20f883e' " res = opm.op_select(sql) #釋放資源 opm.dispose()
PooledDB參數(shù)解釋：
mincached，最少的空閑連接數(shù)，如果空閑連接數(shù)小于這個(gè)數(shù)，pool會(huì)創(chuàng)建一個(gè)新的連接。
maxcached，空閑連接數(shù)，如果空閑連接數(shù)大于這個(gè)數(shù)，pool會(huì)關(guān)閉空閑連接。
maxconnections，連接數(shù)，進(jìn)程中可創(chuàng)建的線程數(shù)。
blocking， 當(dāng)連接數(shù)達(dá)到連接數(shù)時(shí)，再次請(qǐng)求時(shí)，如果這個(gè)值是True，請(qǐng)求連接的程序會(huì)一直等待，直到當(dāng)前連接數(shù)小于連接數(shù)；如果這個(gè)值為False，會(huì)報(bào)錯(cuò)。
masxshared，當(dāng)連接數(shù)達(dá)到這個(gè)數(shù)時(shí)，新請(qǐng)求的連接會(huì)分享已經(jīng)分配出去的連接。
在uwsgi中，每個(gè)http請(qǐng)求都會(huì)有一個(gè)進(jìn)程，連接池中配置的連接數(shù)都是一個(gè)進(jìn)程為單位的（即上面的連接數(shù)，都是在一個(gè)進(jìn)程中創(chuàng)建的線程數(shù)），如果業(yè)務(wù)中，一個(gè)http請(qǐng)求中需要的sql連接數(shù)不是很多的話（其實(shí)大多數(shù)都只需要?jiǎng)?chuàng)建一個(gè)連接），配置的連接數(shù)配置都不需要太大。
連接池對(duì)性能的提升：
在程序創(chuàng)建連接的時(shí)候，可以從一個(gè)空閑的連接中獲取，不需要重新初始化連接，提升獲取連接的速度。
關(guān)閉連接的時(shí)候，把連接放回連接池，而不是真正的關(guān)閉，所以可以減少頻繁的打開和關(guān)閉連接。
當(dāng)前題目：創(chuàng)新互聯(lián)Python教程：Python如何使用數(shù)據(jù)庫的連接池
文章來源：http://m.5511xx.com/article/cdpospd.html
