zoukankan      html  css  js  c++  java
  • 封装pymysql

    from pymysql import connect
    
    class MysqlHelp:
        def __init__(self,database,host = "localhost", user = "zengsf", 
                password = "密码", charset = "utf8", port = 3306):
            self.database = database
            self.host = host
            self.user = user
            self.password = password
            self.charset = charset
            self.port = port
    
        #创建对象
        def open(self):
            #创建conn
            self.conn = connect(host = self.host, user = self.user,
                                password = self.password, database = self.database,
                                charset = self.charset, port = self.port)
            #创建游标
            self.cur = self.conn.cursor()
    
        #关闭
        def close(self):
            self.cur.close()
            self.conn.close()
    
        #执行SQL语句
        def workOn(self, sql, L=[]):
            self.open()
            try:
                self.cur.execute(sql, L)
                self.conn.commit()
            except Exception as e:
                self.conn.rollback()
            self.close()
    
        #getAll查询方法
        def getAll(self, sql, L=[]):
            self.open()
            self.cur.execute(sql, L)
            result = self.cur.fetchall()
            self.close()
            return result
    
    if __name__ == "__main__":
        #测试 
        mysql = MysqlHelp("shengfen")
    #    sql_insert = "insert into sheng(s_name) values('美国');"
    #    mysql.workOn(sql_insert)
        sql_select = "select * from sheng;"
        result = mysql.getAll(sql_select)    
        print(result)
  • 相关阅读:
    rsyslog imfile 模块说明
    正确的健身是啥意思——北漂18年(79)
    CC++ 内存对齐
    异步请求和超时控制
    dubbo入门(1)
    Query Cache Configuration
    perl 批量生成分区表
    perl 通过生成mysql 批量sql
    next 跳过当前循环
    last 退出当前循环
  • 原文地址:https://www.cnblogs.com/zengsf/p/9589110.html
Copyright © 2011-2022 走看看