使用参考：https://www.yuque.com/u1046159/erg6ec/bbqe4q#RFrM9
    DB.py

    1. import pymysql
    2. from config import host, user, password, db, charset, port
    4. class DB():
    5.     def __init__(self):
    6.         self.host = host
    7.         self.user = user
    8.         self.password = password
    9.         self.dbName = db
    10.         self.charset = charset
    11.         self.port = port
    13.     # 连接数据库
    14.     def connet(self):
    15.         try:
    16.             # 连接数据库
    17.             self.conn = pymysql.connect(
    18.                 host=self.host,
    19.                 user=self.user,
    20.                 password=self.password,
    21.                 db=self.dbName,
    22.                 port=self.port,
    23.                 charset=self.charset,
    25.             )
    26.             # 获得游标
    27.             # pymysql.cursors.DictCursor 以字典的形式返回查询出来的数据
    28.             self.cursor = self.conn.cursor(pymysql.cursors.DictCursor)
    29.         except Exception as e:
    30.             print(str(e))    # 实际中可以写在日志中
    32.     # 关闭游标、数据库
    33.     def close(self):
    34.         try:
    35.             # 关闭游标
    36.             self.cursor.close()
    37.             # 关闭数据库
    38.             self.conn.close()
    39.         except Exception as e:
    40.             print(str(e))
    42.     # 查询多条数据
    43.     def get_all(self, sql):
    44.         try:
    45.             self.connet()
    46.             self.cursor.execute(sql)
    47.             res = self.cursor.fetchall()
    48.             self.close()
    49.         except Exception as e:
    50.             print(str(e))
    51.         return res
    53.     # 插入、更新、删除操作公共方法
    54.     def edit(self, sql):
    55.         try:
    56.             self.connet()
    57.             self.cursor.execute(sql)
    58.             # 插入、更新、删除操作必须进行commit
    59.             self.conn.commit()
    60.             self.close()
    61.         except Exception as e:
    62.             print(str(e))
    64.     # 数据库插入、更新、删除操作
    65.     def insert(self, sql):
    66.         return self.edit(sql)
    68.     def update(self, sql):
    69.         return self.edit(sql)
    71.     def delete(self, sql):
    72.         return self.edit(sql)
    • 其中数据库连接信息写在根目录下面的config.py 中
      1. host = 'localhost'
      2. user = 'root'
      3. password = ''
      4. db = 'ehsy_data'
      5. charset = 'utf8'
      6. port = 3306
      调用： ```python from pymysqlStudy.connect_mysql_impro import DB

    if name == ‘main‘: db = DB()

    1. # sql = " insert into st_info(id,name,password) values (%s,%s,%s)"
    2. # data = (11,'lisi','123456')
    3. # db.insert(sql,data)
    5. # 更新操作
    6. sql = " update st_info set name=%s where id=%s"
    7. data = ('lisi',11)
    8. db.update(sql,data)

    ```