Python DB连接类

lys2021年09月29日 0条评论

Python DB连接类

import MySQLdb as mdb
import configparser
class DB:
    db = None
    cursor = None
    def __init__(self):
       config = configparser.ConfigParser()
       config.read("./config.ini", encoding="utf-8")
       # r = config.options("db")
       # print(r)
       # 打开数据库连接
       # print(config.get('db','db_host'))
       self.db = mdb.connect(config.get('db','db_host'), config.get('db','db_user'),config.get('db','db_pass'), config.get('db','db_name'), charset='utf8mb4',port=int(config.get('db','db_port')))
       # 使用cursor()方法获取操作游标
       self.cursor = self.db.cursor()
    #快速查找
    def quikFind(self,id):
       list = {}
       self.cursor.execute("SELECT id,name from `order` where id = %d" % (id,))
       list['order'] = self.cursor.fetchall()
       self.db.commit()  #解决客户信息缓存的问题 MySQLdb 的一个坑
       return list

config.ini

[db]
db_host = 127.0.0.1
db_user = test
db_pass = test_password
db_name = test_databasename
db_port = 3308