学步园

最近在弄个短信平台的东西，需要不断请求数据库，本以为一个数据库连接一直保持，用起来无压力，结果由于程序为多线程，可能许多查询，是并发的，这就导致了大量的查询报，lost connect during query,报这种错误的原因，我想和mysql的数据通信协议，你在发送一个包，还没发完，就来一个新包了，导致协议错乱，mysql肯定要断开你的连接了，所以，既然mysql支持，并发，何必浪费只单连一个连接呢，好吧，多并发，请求一次，就连接一次数据库，太耗资源，而且，一不小心就会超过最大并发，

    这时候就需要数据库连接池了，连接池要满足如下几点要求：

    1.池子里有已经连接好的链接，可以随时取用

    2.如果已经用光了，而且没有超过最大连接数，新建立个链接，放在池子里，若超过，程序阻塞

    3.链接用完，需要放回池子，假设现在的链接已经超过最小连接数，销毁这个数据库连

经过一天的思考，和两个小时的编写，代码如下，耦合性有点太大，不过用起来，很给力啊，，哇哈哈哈哈哈啊

class dbPool:
    '''数据库连接池'''
    def __init__(self):
        
        self.minLength = 10
        self.maxLength = 30
        self.lNum = 0
        self.dbList = Queue.Queue(maxsize = self.maxLength)
        self.createL(self.minLength)
            
    def createL(self,num=1):
        G_var = Global_var()
        for i in range(0,num):
            self.lNum = self.lNum+1
            self.dbList.put(MySql(G_var,self.lNum))
    def getLink(self):
        
        if self.lNum<self.maxLength and self.dbList.empty():
            self.createL(1)
        return self.dbList.get()

    def pushBack(self,db):
        
        if self.lNum>self.minLength:
            self.destroyDb(db)
            self.lNum = self.lNum-1
        else:
            self.dbList.put(db)

    def destroyDb(self,db):
        try:
            db.cur.close()    #关闭指针
            db.db.close()
        except Exception,e:
            pass

说明：Mysql是我封装的一个mysql链接类，G_var是我的全局变量列表

使用的时候只需要

dp = dbPool() #新建个连接池

db = dp.getLink()#从连接池返回一个数据库链接对象

 db.query(sql)#执行查询

 dp.pushBack(db)#将链接对象放回连接池