主要是通过python的DBUtils库、MySQLdb库来实现连接池操作数据库
import MySQLdbfrom DBUtils.PooledDB import PooledDBclass DBHelper(object): __pool = None def __init__(self): self._conn = DBHelper.__getConnection() self._cursor = self._conn.cursor() @staticmethod def __getConnection(): if DBHelper.__pool is None : __pool = PooledDB(creator = MySQLdb, mincached=1, maxcached=20, host = '127.0.0.1', port = 3306, user = 'root', passwd = '123456', db = 'test') return __pool.connection() def execute(self, sql, parameter=None): if parameter is None: self._cursor.execute(sql) else : self._cursor.execute(sql, parameter) <mark style="color:transparent">来4源gaodaimacom搞#代%码*网</mark> def readOne(self, sql, parameter=None): if parameter is None : count = self._cursor.execute(sql) else : count = self._cursor.execute(sql, parameter) if count > 0: return self._cursor.fetchone() else : return None def readList(self, sql, parameter=None): if parameter is None : count = self._cursor.execute(sql) else : count = self._cursor.execute(sql, parameter) if count > 0: return self._cursor.fetchall() else : return None def commint(self): self._conn.commit() def close(self): if self._cursor : self._cursor.close() if self._conn : self._conn.close()
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：Python 数据库相关操作
转载请注明原文链接：Python 数据库相关操作
