| | |
|---|
| | | # 网络代理 |
|---|
| | | import logging |
|---|
| | | |
|---|
| | | import pymysql |
|---|
| | | |
|---|
| | | # 把连接参数定义成字典 |
|---|
| | | import constant |
|---|
| | | from log_module.log import logger_mysql_debug |
|---|
| | | from utils import middle_api_protocol |
|---|
| | | |
|---|
| | | config = constant.MYSQL_CONFIG |
|---|
| | |
|---|
| | | } |
|---|
| | | if args: |
|---|
| | | data["args"] = args |
|---|
| | | fdata = middle_api_protocol.load_redis_cmd(data) |
|---|
| | | result = middle_api_protocol.request(fdata) |
|---|
| | | return result |
|---|
| | | fdata = middle_api_protocol.load_mysql_cmd(data) |
|---|
| | | try: |
|---|
| | | result = middle_api_protocol.request(fdata) |
|---|
| | | return result |
|---|
| | | except Exception as e: |
|---|
| | | logger_mysql_debug.exception(e) |
|---|
| | | |
|---|
| | | # 查询sql语句返回的所有数据 |
|---|
| | | def select_all(self, sql): |
|---|
