建站
咨詢
售后
建站咨詢
新聞中心
成都創(chuàng)新互聯(lián)公司專注于企業(yè)全網(wǎng)整合營(yíng)銷推廣、網(wǎng)站重做改版、余慶網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、H5頁(yè)面制作、購(gòu)物商城網(wǎng)站建設(shè)、集團(tuán)公司官網(wǎng)建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)公司、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁(yè)設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性價(jià)比高，為余慶等各大城市提供網(wǎng)站開(kāi)發(fā)制作服務(wù)。
數(shù)據(jù)庫(kù)連接池
DBUtils是Python的一個(gè)用于實(shí)現(xiàn)數(shù)據(jù)庫(kù)連接池的模塊。
安裝
進(jìn)官網(wǎng)下載https://pypi.org/project/DBUtils/1.2/，然后安裝：
連接池有兩種方式
（1）模式一
為每個(gè)線程創(chuàng)建連接，線程即使調(diào)用了close方法，也不會(huì)關(guān)閉，只是把連接重新放到連接池，供自己線程再次使用。當(dāng)線程終止時(shí)，連接自動(dòng)關(guān)閉。
POOL = PersistentDB(
creator=pymysql, # 使用鏈接數(shù)據(jù)庫(kù)的模塊
maxusage=None, # 一個(gè)鏈接最多被重復(fù)使用的次數(shù)，None表示制
setsession=[], # 開(kāi)始會(huì)話前執(zhí)行的命令列表。如：["set datestyle to ...", "set time zone ..."]
ping=0,
# ping MySQL服務(wù)端，檢查是否服務(wù)可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
closeable=False,
# 如果為False時(shí)， conn.close() 實(shí)際上被忽略，供下次使用，再線程關(guān)閉時(shí)，才會(huì)自動(dòng)關(guān)閉鏈接。如果為True時(shí)， conn.close()則關(guān)閉鏈接，那么再次調(diào)用pool.connection時(shí)就會(huì)報(bào)錯(cuò)，因?yàn)橐呀?jīng)真的關(guān)閉了連接（pool.steady_connection()可以獲取一個(gè)新的鏈接）
threadlocal=None, # 本線程獨(dú)享值得對(duì)象，用于保存鏈接對(duì)象，如果鏈接對(duì)象被重置
host='127.0.0.1',
port=3306,
user='root',
password='123',
database='pooldb',
charset='utf8'
)
def func():
conn = POOL.connection(shareable=False)
cursor = conn.cursor()
cursor.execute('select * from tb1')
result = cursor.fetchall()
cursor.close()
conn.close()
func()
相關(guān)推薦：《Python視頻教程》
（2）模式二，推薦使用的方式
創(chuàng)建多個(gè)連接，多線程來(lái)時(shí)，去獲取，
import time
import pymysql
import threading
from DBUtils.PooledDB import PooledDB, SharedDBConnection
POOL = PooledDB(
creator=pymysql, # 使用鏈接數(shù)據(jù)庫(kù)的模塊
maxconnections=6, # 連接池允許的連接數(shù)，0和None表示不限制連接數(shù)
mincached=2, # 初始化時(shí)，鏈接池中至少創(chuàng)建的空閑的鏈接，0表示不創(chuàng)建
maxcached=5, # 鏈接池中最多閑置的鏈接，0和None不限制
maxshared=3, # 鏈接池中最多共享的鏈接數(shù)量，0和None表示全部共享。PS: 無(wú)用，因?yàn)閜ymysql和MySQLdb等模塊的 threadsafety都為1，所有值無(wú)論設(shè)置為多少，_maxcached永遠(yuǎn)為0，所以永遠(yuǎn)是所有鏈接都共享。
blocking=True, # 連接池中如果沒(méi)有可用連接后，是否阻塞等待。True，等待；False，不等待然后報(bào)錯(cuò)
maxusage=None, # 一個(gè)鏈接最多被重復(fù)使用的次數(shù)，None表示制
setsession=[], # 開(kāi)始會(huì)話前執(zhí)行的命令列表。如：["set datestyle to ...", "set time zone ..."]
ping=0,
# ping MySQL服務(wù)端，檢查是否服務(wù)可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
host='127.0.0.1',
port=3306,
user='root',
password='123',
database='pooldb',
charset='utf8'
)
def func():
# 檢測(cè)當(dāng)前正在運(yùn)行連接數(shù)的是否小于鏈接數(shù)，如果不小于則：等待或報(bào)raise TooManyConnections異常
# 否則
# 則優(yōu)先去初始化時(shí)創(chuàng)建的鏈接中獲取鏈接 SteadyDBConnection。
# 然后將SteadyDBConnection對(duì)象封裝到PooledDedicatedDBConnection中并返回。
# 如果最開(kāi)始創(chuàng)建的鏈接沒(méi)有鏈接，則去創(chuàng)建一個(gè)SteadyDBConnection對(duì)象，再封裝到PooledDedicatedDBConnection中并返回。
# 一旦關(guān)閉鏈接后，連接就返回到連接池讓后續(xù)線程繼續(xù)使用。
conn = POOL.connection()
# print(th, '鏈接被拿走了', conn1._con)
# print(th, '池子里目前有', pool._idle_cache, '\r\n')
cursor = conn.cursor()
cursor.execute('select * from tb1')
result = cursor.fetchall()
conn.close()
func()
如果沒(méi)有連接池，使用pymysql來(lái)連接數(shù)據(jù)庫(kù)時(shí)，單線程應(yīng)用完全沒(méi)有問(wèn)題，但如果涉及到多線程應(yīng)用那么就需要加鎖，一旦加鎖那么連接勢(shì)必就會(huì)排隊(duì)等待，當(dāng)請(qǐng)求比較多時(shí)，性能就會(huì)降低了。
import pymysql
import threading
from threading import RLock
LOCK = RLock()
CONN = pymysql.connect(host='127.0.0.1',
port=3306,
user='root',
password='123',
database='pooldb',
charset='utf8')
def task(arg):
with LOCK:
cursor = CONN.cursor()
cursor.execute('select * from tb1')
result = cursor.fetchall()
cursor.close()
print(result)
for i in range(10):
t = threading.Thread(target=task, args=(i,))
t.start()
網(wǎng)頁(yè)題目：創(chuàng)新互聯(lián)Python教程：Flask如何實(shí)現(xiàn)數(shù)據(jù)庫(kù)連接池
本文路徑：http://m.5511xx.com/article/dpcdgph.html
