标签：__ return self pymysql cursor connection sql 工具

import pymysql

class MysqlConnection(object):
    def __init__(self, config):
        self.connection = pymysql.connect(**config)
        self.connection.autocommit(True)
        self.cursor = self.connection.cursor()
    
    def reConnect(self):
        """
        重连机制
        :return:
        """
        try:
            self.connection.ping()
        except:
            self.connection()
    
    def close(self):
        """
        断开连接
        :return:
        """
        self.cursor.close()
        self.connection.close()
    
    def __del__(self):
        self.close()
    
    def queryAll(self, sql):
        """
        查询所有数据
        :param sql: sql语句
        :return:
        """
        self.reConnect()
        try:
            self.cursor.execute(sql)
            return self.cursor.fetchall()
        except Exception as e:
            return e
    
    def queryMany(self, sql, n):
        """
        查询几条数据
        :param sql:
        :return:
        """
        self.reConnect()
        try:
            self.cursor.execute(sql)
            return self.cursor.fetchmany(n)
        except Exception as e:
            return e
    
    def queryOne(self, sql):
        """
        查询一条记录
        :param sql:
        :return:
        """
        self.reConnect()
        try:
            self.cursor.execute(sql)
            return self.cursor.fetchone()
        except Exception as e:
            return e
    
    def operate(self, sql, params=None, DML=True):
        """
        """
        self.reConnect()
        try:
            with self.connection.cursor() as cursor:
                cursor.execute(sql, params)
                self.connection.commit()
                return 0
        except Exception as e:
            if DML:
                self.connection.rollback()
                return e

if __name__ == "__main__":
	# 举个例子
    config = {
        'host':'192.168.153.32',
        'port':3306,
        'user':'root',
        'password':'123456',
        'db':'webapp'
    }
    msc = MysqlConnection(config)
    sql = "select * from students"
    print(msc.queryAll(sql))

标签：__,return,self,pymysql,cursor,connection,sql,工具
来源： https://www.cnblogs.com/bkhb/p/15384390.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。