Python DBUtils数据连接池与mysql配合用法

首页

数据库

mysql教程

Python DBUtils数据连接池与mysql配合用法_MySQL

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jun 01, 2016 pm 01:11 PM

python

# -*- coding: UTF-8 -*-"""desc:数据库操作类@note:1、执行带参数的ＳＱＬ时，请先用sql语句指定需要输入的条件列表，然后再用tuple/list进行条件批配２、在格式ＳＱＬ中不需要使用引号指定数据类型，系统会根据输入参数自动识别３、在输入的值中不需要使用转意函数，系统会自动处理"""import MySQLdbfrom MySQLdb.cursors import DictCursorfrom DBUtils.PooledDB import PooledDBimport Config"""Config是一些数据库的配置文件"""class Mysql(object):    """        MYSQL数据库对象，负责产生数据库连接 , 此类中的连接采用连接池实现        获取连接对象：conn = Mysql.getConn()        释放连接对象;conn.close()或del conn    """    #连接池对象    __pool = None    def __init__(self):        """        数据库构造函数，从连接池中取出连接，并生成操作游标        """#        self._conn = MySQLdb.connect(host=Config.DBHOST , port=Config.DBPORT , user=Config.DBUSER , passwd=Config.DBPWD ,#                              db=Config.DBNAME,use_unicode=False,charset=Config.DBCHAR,cursorclass=DictCursor)        self._conn = Mysql.__getConn()        self._cursor = self._conn.cursor()    @staticmethod    def __getConn():        """        @summary: 静态方法，从连接池中取出连接        @return MySQLdb.connection        """        if Mysql.__pool is None:            __pool = PooledDB(creator=MySQLdb, mincached=1 , maxcached=20 ,                              host=Config.DBHOST , port=Config.DBPORT , user=Config.DBUSER , passwd=Config.DBPWD ,                              db=Config.DBNAME,use_unicode=False,charset=Config.DBCHAR,cursorclass=DictCursor)        return __pool.connection()    def getAll(self,sql,param=None):        """        @summary: 执行查询，并取出所有结果集        @param sql:查询ＳＱＬ，如果有查询条件，请只指定条件列表，并将条件值使用参数[param]传递进来        @param param: 可选参数，条件列表值（元组/列表）        @return: result list/boolean 查询到的结果集        """        if param is None:            count = self._cursor.execute(sql)        else:            count = self._cursor.execute(sql,param)        if count>0:            result = self._cursor.fetchall()        else:            result = False        return result    def getOne(self,sql,param=None):        """        @summary: 执行查询，并取出第一条        @param sql:查询ＳＱＬ，如果有查询条件，请只指定条件列表，并将条件值使用参数[param]传递进来        @param param: 可选参数，条件列表值（元组/列表）        @return: result list/boolean 查询到的结果集        """        if param is None:            count = self._cursor.execute(sql)        else:            count = self._cursor.execute(sql,param)        if count>0:            result = self._cursor.fetchone()        else:            result = False        return result    def getMany(self,sql,num,param=None):        """        @summary: 执行查询，并取出num条结果        @param sql:查询ＳＱＬ，如果有查询条件，请只指定条件列表，并将条件值使用参数[param]传递进来        @param num:取得的结果条数        @param param: 可选参数，条件列表值（元组/列表）        @return: result list/boolean 查询到的结果集        """        if param is None:            count = self._cursor.execute(sql)        else:            count = self._cursor.execute(sql,param)        if count>0:            result = self._cursor.fetchmany(num)        else:            result = False        return result    def insertOne(self,sql,value):        """        @summary: 向数据表插入一条记录        @param sql:要插入的ＳＱＬ格式        @param value:要插入的记录数据tuple/list        @return: insertId 受影响的行数        """        self._cursor.execute(sql,value)        return self.__getInsertId()    def insertMany(self,sql,values):        """        @summary: 向数据表插入多条记录        @param sql:要插入的ＳＱＬ格式        @param values:要插入的记录数据tuple(tuple)/list[list]        @return: count 受影响的行数        """        count = self._cursor.executemany(sql,values)        return count    def __getInsertId(self):        """        获取当前连接最后一次插入操作生成的id,如果没有则为０        """        self._cursor.execute("SELECT @@IDENTITY AS id")        result = self._cursor.fetchall()        return result[0]['id']    def __query(self,sql,param=None):        if param is None:            count = self._cursor.execute(sql)        else:            count = self._cursor.execute(sql,param)        return count    def update(self,sql,param=None):        """        @summary: 更新数据表记录        @param sql: ＳＱＬ格式及条件，使用(%s,%s)        @param param: 要更新的  值 tuple/list        @return: count 受影响的行数        """        return self.__query(sql,param)    def delete(self,sql,param=None):        """        @summary: 删除数据表记录        @param sql: ＳＱＬ格式及条件，使用(%s,%s)        @param param: 要删除的条件 值 tuple/list        @return: count 受影响的行数        """        return self.__query(sql,param)    def begin(self):        """        @summary: 开启事务        """        self._conn.autocommit(0)    def end(self,option='commit'):        """        @summary: 结束事务        """        if option=='commit':            self._conn.commit()        else:            self._conn.rollback()    def dispose(self,isEnd=1):        """        @summary: 释放连接池资源        """        if isEnd==1:            self.end('commit')        else:            self.end('rollback');        self._cursor.close()        self._conn.close()

声明

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

mysql：blob和其他无-SQL存储，有什么区别？May 13, 2025 am 12:14 AM

mysql'sblobissuitableForStoringBinaryDataWithInareLationalDatabase，而alenosqloptionslikemongodb，redis和calablesolutionsoluntionsoluntionsoluntionsolundortionsolunsolunsstructureddata.blobobobsimplobissimplobisslowderperformandperformanceperformancewithlararengelitiate;

mySQL添加用户：语法，选项和安全性最佳实践May 13, 2025 am 12:12 AM

toaddauserinmysql，使用：createUser'username'@'host'Indessify'password'; there'showtodoitsecurely：1）choosethehostcarecarefullytocon trolaccess.2）setResourcelimitswithoptionslikemax_queries_per_hour.3）usestrong，iniquepasswords.4）Enforcessl/tlsconnectionswith

MySQL：如何避免字符串数据类型常见错误？May 13, 2025 am 12:09 AM

toAvoidCommonMistakeswithStringDatatatPesInMysQl，CloseStringTypenuances，chosethirtightType，andManageEngencodingAndCollationsEttingsefectery.1）usecharforfixed lengengters lengengtings，varchar forbariaible lengength，varchariable length，andtext/blobforlabforlargerdata.2 seterters seterters seterters seterters

mySQL：字符串数据类型和枚举？May 13, 2025 am 12:05 AM

mysqloffersechar，varchar，text，and denumforstringdata.usecharforfixed Lengttrings，varcharerforvariable长度，文本forlarger文本，andenumforenforcingDataAntegrityWithaEtofValues。

mysql blob：如何优化斑点请求May 13, 2025 am 12:03 AM

优化MySQLBLOB请求可以通过以下策略：1.减少BLOB查询频率，使用独立请求或延迟加载；2.选择合适的BLOB类型（如TINYBLOB）；3.将BLOB数据分离到单独表中；4.在应用层压缩BLOB数据；5.对BLOB元数据建立索引。这些方法结合实际应用中的监控、缓存和数据分片，可以有效提升性能。

将用户添加到MySQL：完整的教程May 12, 2025 am 12:14 AM

掌握添加MySQL用户的方法对于数据库管理员和开发者至关重要，因为它确保数据库的安全性和访问控制。1)使用CREATEUSER命令创建新用户，2)通过GRANT命令分配权限，3)使用FLUSHPRIVILEGES确保权限生效，4)定期审计和清理用户账户以维护性能和安全。

掌握mySQL字符串数据类型：varchar vs.文本与charMay 12, 2025 am 12:12 AM

chosecharforfixed-lengthdata，varcharforvariable-lengthdata，andtextforlargetextfield.1）chariseffity forconsistent-lengthdatalikecodes.2）varcharsuitsvariable-lengthdatalikenames，ballancingflexibilitibility andperformance.3）

MySQL：字符串数据类型和索引：最佳实践May 12, 2025 am 12:11 AM

在MySQL中处理字符串数据类型和索引的最佳实践包括：1)选择合适的字符串类型，如CHAR用于固定长度，VARCHAR用于可变长度，TEXT用于大文本；2)谨慎索引，避免过度索引，针对常用查询创建索引；3)使用前缀索引和全文索引优化长字符串搜索；4)定期监控和优化索引，保持索引小巧高效。通过这些方法，可以在读取和写入性能之间取得平衡，提升数据库效率。

See all articles