怎么創(chuàng)建python數(shù)據(jù)庫(kù)連接池

這篇文章主要介紹“怎么創(chuàng)建python數(shù)據(jù)庫(kù)連接池”，在日常操作中，相信很多人在怎么創(chuàng)建python數(shù)據(jù)庫(kù)連接池問(wèn)題上存在疑惑，小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”怎么創(chuàng)建python數(shù)據(jù)庫(kù)連接池”的疑惑有所幫助！接下來(lái)，請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧！

1、不使用數(shù)據(jù)庫(kù)連接池，每次操作都要鏈接數(shù)據(jù)庫(kù)，鏈接次數(shù)過(guò)多

 conn = pymysql.connect(host="127.0.0.1",port=3306,user='root',password='123', database='pooldb',charset='utf8')
    cursor = conn.cursor()
    cursor.execute("select * from td where id=%s", [5, ])
    result = cursor.fetchall()  # 獲取數(shù)據(jù)    cursor.close()
    conn.close()  # 關(guān)閉鏈接

這種方式每次請(qǐng)求，反復(fù)創(chuàng)建數(shù)據(jù)庫(kù)鏈接，多次鏈接數(shù)據(jù)庫(kù)會(huì)非常耗時(shí)

2、創(chuàng)建一個(gè)鏈接池，為所有線(xiàn)程提供連接，使用時(shí)來(lái)進(jìn)行獲取，使用完畢后在放回到連接池。

PS：假設(shè)最大鏈接數(shù)有10個(gè)，其實(shí)也就是一個(gè)列表，當(dāng)你pop一個(gè)，系統(tǒng)會(huì)再append一個(gè)，鏈接池的所有的鏈接都是按照排隊(duì)的這樣的方式來(lái)鏈接的。鏈接池里所有的鏈接都能重復(fù)使用，共享的， 即實(shí)現(xiàn)了并發(fā)，又防止了鏈接次數(shù)太多

import timeimport pymysqlimport threadingfrom 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表示無(wú)限制
    setsession=[],  # 開(kāi)始會(huì)話(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ù)線(xiàn)程繼續(xù)使用。
    # PooledDedicatedDBConnection
    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()

到此，關(guān)于“怎么創(chuàng)建python數(shù)據(jù)庫(kù)連接池”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章！