建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
創(chuàng)新互聯(lián)Python教程：Flask如何實(shí)現(xiàn)數(shù)據(jù)庫連接池
成都創(chuàng)新互聯(lián)公司專注于企業(yè)全網(wǎng)整合營銷推廣、網(wǎng)站重做改版、余慶網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、H5頁面制作、購物商城網(wǎng)站建設(shè)、集團(tuán)公司官網(wǎng)建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)公司、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性價(jià)比高，為余慶等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。
數(shù)據(jù)庫連接池
DBUtils是Python的一個用于實(shí)現(xiàn)數(shù)據(jù)庫連接池的模塊。
安裝
進(jìn)官網(wǎng)下載https://pypi.org/project/DBUtils/1.2/，然后安裝：
連接池有兩種方式
（1）模式一
為每個線程創(chuàng)建連接，線程即使調(diào)用了close方法，也不會關(guān)閉，只是把連接重新放到連接池，供自己線程再次使用。當(dāng)線程終止時，連接自動關(guān)閉。
POOL = PersistentDB(
creator=pymysql, # 使用鏈接數(shù)據(jù)庫的模塊
maxusage=None, # 一個鏈接最多被重復(fù)使用的次數(shù)，None表示制
setsession=[], # 開始會話前執(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時， conn.close() 實(shí)際上被忽略，供下次使用，再線程關(guān)閉時，才會自動關(guān)閉鏈接。如果為True時， conn.close()則關(guān)閉鏈接，那么再次調(diào)用pool.connection時就會報(bào)錯，因?yàn)橐呀?jīng)真的關(guān)閉了連接（pool.steady_connection()可以獲取一個新的鏈接）
threadlocal=None, # 本線程獨(dú)享值得對象，用于保存鏈接對象，如果鏈接對象被重置
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)建多個連接，多線程來時，去獲取，
import time
import pymysql
import threading
from DBUtils.PooledDB import PooledDB, SharedDBConnection
POOL = PooledDB(
creator=pymysql, # 使用鏈接數(shù)據(jù)庫的模塊
maxconnections=6, # 連接池允許的連接數(shù)，0和None表示不限制連接數(shù)
mincached=2, # 初始化時，鏈接池中至少創(chuàng)建的空閑的鏈接，0表示不創(chuàng)建
maxcached=5, # 鏈接池中最多閑置的鏈接，0和None不限制
maxshared=3, # 鏈接池中最多共享的鏈接數(shù)量，0和None表示全部共享。PS: 無用，因?yàn)閜ymysql和MySQLdb等模塊的 threadsafety都為1，所有值無論設(shè)置為多少，_maxcached永遠(yuǎn)為0，所以永遠(yuǎn)是所有鏈接都共享。
blocking=True, # 連接池中如果沒有可用連接后，是否阻塞等待。True，等待；False，不等待然后報(bào)錯
maxusage=None, # 一個鏈接最多被重復(fù)使用的次數(shù)，None表示制
setsession=[], # 開始會話前執(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():
# 檢測當(dāng)前正在運(yùn)行連接數(shù)的是否小于鏈接數(shù)，如果不小于則：等待或報(bào)raise TooManyConnections異常
# 否則
# 則優(yōu)先去初始化時創(chuàng)建的鏈接中獲取鏈接 SteadyDBConnection。
# 然后將SteadyDBConnection對象封裝到PooledDedicatedDBConnection中并返回。
# 如果最開始創(chuàng)建的鏈接沒有鏈接，則去創(chuàng)建一個SteadyDBConnection對象，再封裝到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()
如果沒有連接池，使用pymysql來連接數(shù)據(jù)庫時，單線程應(yīng)用完全沒有問題，但如果涉及到多線程應(yīng)用那么就需要加鎖，一旦加鎖那么連接勢必就會排隊(duì)等待，當(dāng)請求比較多時，性能就會降低了。
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()
當(dāng)前題目：創(chuàng)新互聯(lián)Python教程：Flask如何實(shí)現(xiàn)數(shù)據(jù)庫連接池
標(biāo)題路徑：http://m.fisionsoft.com.cn/article/dpcdgph.html
