版本環(huán)境
成都創(chuàng)新互聯(lián)公司2013年開(kāi)創(chuàng)至今,是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司,擁有項(xiàng)目成都網(wǎng)站制作、成都做網(wǎng)站網(wǎng)站策劃,項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個(gè)夢(mèng)想脫穎而出為使命,1280元淶水做網(wǎng)站,已為上家服務(wù),為淶水各地企業(yè)和個(gè)人服務(wù),聯(lián)系電話:18982081108
- python 3.7
- DBUtils 1.3
- MySQLclient 1.4.6
連接池初始化
pool = PooledDB(creator=MySQLdb, mincached=0, maxcached=0,
maxshared=0, maxconnections=0, blocking=False,
maxusage=None, setsession=None, reset=True,
failures=None, ping=1,
*args, **kwargs)
參數(shù)說(shuō)明
#creator => 任何符合DB-API 2.0規(guī)范的函數(shù)或者兼容的數(shù)據(jù)庫(kù)模塊
#mincached => 初始化時(shí),鏈接池中至少創(chuàng)建的空閑的鏈接,0表示不創(chuàng)建
#maxcached => 鏈接池中最大閑置的鏈接數(shù)(0和None不限制)
#maxshared => maximum number of shared connections
(0 or None means all connections are dedicated)
When this maximum number is reached, connections are
shared if they have been requested as shareable
#maxconnections => 允許的最大鏈接數(shù)(0或None表示不限制)
#blocking => 鏈接池沒(méi)有可用鏈接后,是否阻塞等待。
True表示阻塞等待,直到獲取到鏈接;
False不等待,拋異常退出
#maxusage => 同一個(gè)鏈接最多被重復(fù)使用的次數(shù)(0和None表示無(wú)限制)
#setsession => 可選的會(huì)話命令:開(kāi)始會(huì)話前執(zhí)行的命令列表。
例如["set datestyle to…","set time zone…"]
#reset => 當(dāng)連接放回池中時(shí),重置連接的方式,默認(rèn)為T(mén)rue。
False或者None表示使用begin()開(kāi)啟了事務(wù)的鏈接,會(huì)執(zhí)行回滾;
安全起見(jiàn),建議使用True,當(dāng)為T(mén)rue時(shí)表示所有鏈接都執(zhí)行回滾操作
#failures => 當(dāng)默認(rèn)的(OperationalError,InternalError)異常不能滿足要求時(shí),
可以自定義拋出異常:默認(rèn)為None;
自定義為傳入的為tuple或者issubclass(failures, Exception)
#ping => 檢查連接是否仍然處于活動(dòng)狀態(tài)的方式
0 = None = never,
1 = default = whenever fetched from the pool,
2 = when a cursor is created,
4 = when a query is executed,
7 = always, and all other bit combinations of these values
#args, kwargs => 傳遞給creator的參數(shù)
使用
# -*- coding: utf-8 -*-
# @Time : 2020/1/26 0026 20:28
# @Email : lofish@foxmail.com(擼小魚(yú))
import MySQLdb
import MySQLdb.cursors
from DBUtils.PooledDB import PooledDB
import datetime
class DbManager(object):
def __init__(self, host, port, db_name, user_name, password):
cmds = ["set names utf8mb4;"]
conn_args = {'host': host,
'port': port,
'db': db_name,
'user': user_name,
'passwd': password,
'charset': 'utf8',
'cursorclass': MySQLdb.cursors.DictCursor
}
# 初始化時(shí),鏈接池中至少創(chuàng)建的空閑的鏈接,0表示不創(chuàng)建,mincached: 5
# 鏈接池中最大閑置的鏈接數(shù)(0和None不限制): 20
self._pool = PooledDB(MySQLdb, mincached=5, maxcached=20, setsession=cmds, **conn_args)
def connection(self):
return self._pool.connection()
_db_manager = None
def create_db_manager(host, port, dbname, username, password):
global _db_manager
if _db_manager is None:
_db_manager = DbManager(host, port, dbname, username, password)
return _db_manager
網(wǎng)站欄目:python數(shù)據(jù)庫(kù)mysqlclient的初始化和使用
網(wǎng)頁(yè)路徑:http://www.rwnh.cn/article18/jiecdp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供App設(shè)計(jì)、虛擬主機(jī)、網(wǎng)站策劃、、品牌網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)