Python 接口自动化核心模块 - 数据库操作和日志

# 创建数据库连接对象
connect =
  pymysql.Connect(
      host='xxxxx',
      port=3306,
      user='root',
      password='XXXX',
      charset='utf8mb4',
      cursorclass=pymysql.cursors.DictCursor
)


connect：接收Pymysql.connect方法返回的对象,建立连接对象
pymysql.Connect 建立连接方法
host=XXXX 连接数据库服务器
port=3306 连接数据库端口号

password="xxxxx"：密码
charset="utf8mb4"：建立连接的编码
cursorclass=pymysql.cursors.DictCursor:设置返回数据类型    返回字典


# 建立游标
cursor = conn.cursor()
# 执行核心SQL语句

# 关闭游标
cursor.close()
# 关闭连接
conn.close()


查询订单库
得到一个游标对象
cursor = connect.cursor()
查询库名加表名 
mtxshop_trade.es_order
cursor.execute("SELECT order_id,trade_sn FROM mtxshop_trade.es_order WHERE order_id=47050 OR order_id=47049")
data = cursor.fetchall() #得到查询的所有结果
cursor.close()#关闭游标对象

图片%(levelno)s: 打印日志级别的数值
图片%(levelname)s: 打印日志级别名称
图片%(pathname)s: 打印当前执行程序的路径，其实就是sys.argv[0]
图片%(filename)s: 打印当前执行程序名
图片%(funcName)s: 打印日志的当前函数
图片%(lineno)d: 打印日志的当前行号
图片%(asctime)s: 打印日志的时间
图片%(thread)d: 打印线程ID
图片%(threadName)s: 打印线程名称
图片%(process)d: 打印进程ID
图片%(message)s: 打印日志信息

def logging_init():
# 初始化日志器


logger = logging.getLogger()
# 设置日志等级
logger.setLevel(logging.INFO)
# 添加控制器
stream_handler = logging.StreamHandler()
file_handler = logging.handlers.TimedRotatingFileHandler(config.BASE_DIR + "/logs/lagou_log.log", when='h',
interval=1,backupCount=3, encoding="utf-8")
# 设置日志格式
fmt = "%(asctime)s %(levelname)s [%(name)s] [ %(filename)s %(funcName)s % (lineno)d ] %(message)s "
formatter = logging.Formatter(fmt)
# 将日志格式添加到控制器
stream_handler.setFormatter(formatter)
file_handler.setFormatter(formatter)
# 将控制器添加到日志器
logger.addHandler(stream_handler)
logger.addHandler(file_handler)


return logger

from utils import logging_init


# 初始化日志配置函数
logging_init()


# 测试打印日志
import logging

logging.debug("测试debug级别的日志打印") #不会打印