Python數據庫連接池DButils

　　DButils是python的一個實現數據庫連接池的模塊

　　兩種模式：

　　1.為每一個線程創建一個鏈接，即使線程即使調用了close()方法，也不會關閉，只是把線程放到連接池，供自己再次使用，當連接關閉時，線程連接自動關閉。

from DBUtils.PersistentDB import PersistentDB
import pymysql
PooL = PersistentDB(
    creator = pymysql,  #使用鏈接數據庫的模塊
    maxusage = None, #一個鏈接最多被使用的次數，None表示無限制
    setsession = [], #開始會話前執行的命令
    ping = 0, #ping MySQL服務端,檢查服務是否可用
    closeable = False, #conn.close()實際上被忽略，供下次使用，直到線程關閉，自動關閉鏈接，而等於True時，conn.close()真的被關閉
    threadlocal = None, # 本線程獨享值的對象，用於保存鏈接對象
    host = '127.0.0.1',
    port = 3306,
    user = 'root',
    password = '123',
    database = 'ok1',
    charset = 'utf8'
)
def func():
    conn = PooL.connection()
    cursor = conn.cursor()
    cursor.execute('select * from book')
    result = cursor.fetchall()
    print(result)
    cursor.close()
    conn.close()
import threading
for i in range(5):
    t = threading.Thread(target=func)
    t.start()

　　2.創建一批連接到連接池，供所有線程共享使用

　　注意：由於pymysql,mysqlDB中的threadsafety值為1，所有線程共享連接

import time
import pymysql
import threading
from DBUtils.PooledDB import PooledDB,SharedDBConnection

POOL = PooledDB(
    creator = pymysql, #使用鏈接數據庫的模塊
    maxconnections = 6,  #連接池允許的最大連接數，0和None表示沒有限制
    mincached = 2, #初始化時，連接池至少創建的空閑的連接，0表示不創建
    maxcached = 5, #連接池空閑的最多連接數，0和None表示沒有限制
    maxshared = 3, #連接池中最多共享的連接數量，0和None表示全部共享，ps:其實並沒有什么用，因為pymsql和MySQLDB等模塊中的threadsafety都為1，所有值無論設置多少，_maxcahed永遠為0，所以永遠是所有鏈接共享
    blocking = True, #鏈接池中如果沒有可用共享連接后，是否阻塞等待，True表示等待，False表示不等待然后報錯
    setsession = [],#開始會話前執行的命令列表
    ping = 0,#ping Mysql 服務端，檢查服務是否可用
    host = '127.0.0.1',
    port = 3306,
    user = 'root',
    password = '123',
    database = 'ok1',
    charset = 'utf8'
)
def func():
    #檢測當前正在運行的連接數是否小於最大的連接數，如果不小於則等待連接或者拋出raise TooManyConnections異常
    #否則優先去初始化時創建的連接中獲取連接SteadyDBConnection
    #然后將SteadyDBConnection對象封裝到PooledDedicatedDBConnection中並返回
    #如果最開始創建的連接沒有鏈接，則去創建SteadyDBConnection對象，再封裝到PooledDedicatedDBConnection中並返回
    #一旦關閉鏈接后，連接就返回到連接池讓后續線程繼續使用
    conn = POOL.connection()
    cursor = conn.cursor()
    cursor.execute('select * from book')
    result = cursor.fetchall()
    print(result)
    conn.close()
func()

　　PS：關於pymysql模塊，如果沒有單線程的情況，連接MySQL數據庫沒有問題，但如果要是多線程，就需要加鎖，一旦加鎖，后面的線程就得等待，勢必會降低使用效率。

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 = 'ok1',
                       charset = 'utf8'
                       )
def task(arg):
    with LOCK:
        cursor = CONN.cursor()
        cursor.execute('select * from book')
        result = cursor.fetchall()
        cursor.close()
        print(result)
for i in range(10):
    t = threading.Thread(target=task,args=(i,))
    t.start()

import pymysql
import threading
CONN = pymysql.connect(host='127.0.0.1',
                       port=3306,
                       user='root',
                       password='123',
                       database='ok1',
                       charset='utf8')

def task(arg):
    cursor = CONN.cursor()
    cursor.execute('select * from book')
    result = cursor.fetchall()
    cursor.close()
    print(result)
for i in range(10):  #1時不會報錯
    t = threading.Thread(target=task, args=(i,))
    t.start()