73. 美客生鲜项目实战 - 注册用户- mysql配置

pip install pymysql

project > config > settings.ini
project > utils > mysql_util.py

# project > config > settings.ini
[mysql]
HOST=47.110.151.136
PORT=3306
USER=vue_shop
PASSWD=5istudy_shop
DB=vue_shop

# project > utils > mysql_util.py
import pymysql

from utils.log_util import logger
from utils.read import read_ini

data = read_ini()['mysql']

DB_CONF = {
    "host": data["HOST"],
    "port": int(data["PORT"]),
    "user": data["USER"],
    "password": data["PASSWD"],
    "db": data["DB"]
}


class MysqlDb:
    def __init__(self):
        # mysql链接
        self.conn = pymysql.connect(**DB_CONF, autocommit=True)
        self.cur = self.conn.cursor(cursor=pymysql.cursors.DictCursor)

    # 查询一条数据
    def select_db_one(self, sql):
        logger.info(f"执行sql：{sql}")
        self.cur.execute(query=sql)
        # 获取数据
        result = self.cur.fetchone()
        logger.info(f"sql执行结果{result}")
        return result

    # 查询所有数据
    def select_db_all(self, sql):
        logger.info(f"执行sql：{sql}")
        self.cur.execute(query=sql)
        # 获取数据
        result = self.cur.fetchall()
        logger.info(f"sql执行结果{result}")
        return result

    # 执行sql
    def execute_sql(self, sql):
        try:
            logger.info(f"执行sql：{sql}")
            self.cur.execute(sql)
            self.conn.commit()
        except Exception as e:
            logger.info(f"执行sql出错：{sql}")

    # 释放资源
    def __del__(self):
        self.cur.close()
        self.conn.close()


db = MysqlDb()

if __name__ == '__main__':
    db = MysqlDb()
    sql = "select code from users_verifycode where mobile = '13900000003' order by id limit 1;"
    print(db.select_db_one(sql)['code'])