Python中怎么實現數據庫連接池

這篇文章將為大家詳細講解有關Python中怎么實現數據庫連接池，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。

示例：

#-*-coding:utf-8-*-  
import threading,time,datetime  
import MySQLdb  
from DBUtils import PooledDB  
pool = PooledDB.PooledDB(MySQLdb,100,50,100,490,False,
host='localhost',user='root',passwd='321',db='test',
charset='utf8')   

默認打開的時候就創建了100個數據庫連接。檢查發現果然數據庫中有100個

class MyThread(threading.Thread):  def __init__(self,threadName):  self.conn = pool.connection()

直接從數據庫連接池中提取

threading.Thread.__init__(self,name=threadName)  def run(self):  cursor=self.conn.cursor()  print "hello--->",self.getName()  file_objct = open('8.txt','a+')  file_objct.write(self.getName()+'\n')  file_objct.close()  #cursor.execute("call loaddate();")  #self.conn.commit()  time.sleep(10)  def __del__(self):  self.conn.close()  self.conn = None   for i in range(5):  obj = MyThread(str(i))  obj.start()

如果我開480個線程的話 數據庫顯示的正是480個連接！maxconnections: ***允許連接數量(缺省值 0 代表不限制)如果我現在將代碼調整如下：

#-*-coding:utf-8-*-  
import threading,time,datetime  
import MySQLdb  
from DBUtils import PooledDB  
pool = PooledDB.PooledDB(MySQLdb,100,50,100,400,False,
host='localhost',user='root',passwd='321',db='test',
charset='utf8')  
class MyThread(threading.Thread):  
def __init__(self,threadName):  
self.conn = pool.connection()   
threading.Thread.__init__(self,name=threadName)  
def run(self):  
cursor=self.conn.cursor()  
print "hello--->",self.getName()  
file_objct = open('8.txt','a+')  
file_objct.write(self.getName()+'\n')  
file_objct.close()  
#cursor.execute("call loaddate();")  
#self.conn.commit()  
time.sleep(10)  
def __del__(self):  
self.conn.close()  
self.conn = None   
for i in range(402):  
obj = MyThread(str(i))  
obj.start()   

關于Python中怎么實現數據庫連接池就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。