前言
因为最近业务问题，面临大批量的条件查询、排序、分页、字段筛选，所以用原生sql写了这么一个封装。
适用范围
前端查询：包括分页、排序、条件、字段筛选。
后端查询：单表查询直接使用。
数据库查询：自动生成SQL语句，可直接使用。
功能以及接口使用
参数介绍
‘condition’:[]
解释：参数由列表输入：[‘name@like:小明’,year@>:16] '@‘和’：‘为固定格式，后台代码用其进行通配符，@前为字段名，’:'后为内容。包含 !=,=,>,>=,<,<=,in,notin,like。
‘orderby’:[]
解释：参数由列表输入：['date@desc,‘name@asc’] @为固定格式。
‘exclude’:[]
解释：参数由列表输入：[‘remark’,‘name’] 数据为不包含的字段名。
‘page’:int
解释：参数为页数，类型为整型。
‘pagesize’:int
解释：参数为每页的大小，类型为整型。
注意：不需要的字段可以不给
源码及使用说明
sqlcomment.py:封装的SQL代码
import re def querycomment(param:dict,tablename:str,cursor,cursorclass): ''' :param param: :param tablename: :param cursor: :param cursorclass: :return: sql,sql_count ''' sql = f'select * from {tablename}' if v := param.get('exclude'): if isinstance(v,list) and len(v) != 0: tup = tuple(v) if len(tup) == 1: tup = str(tup).replace(',','') str_ = f"CONCAT(' select ',GROUP_CONCAT(COLUMN_NAME),' from ', '{tablename}',' ;')" include_col = f"SELECT {str_} FROM information_schema.COLUMNS WHERE table_name = '{tablename}' and COLUMN_NAME != {tup}" cursor.execute(include_col) if cursorclass == 'DictCursor': sql = cursor.fetchone()[str_].replace(';', '') elif cursorclass == 'Cursor': sql = cursor.fetchone()[0].replace(';','') if condition:=param.get('condition'): print(condition) if isinstance(condition,list) and len(condition) != 0: condi_sql = '' for c in condition: re_content = re.findall("(.*?)@(.*?):(.*?)$", c.replace(' ', ''))[0] try: tuple_ = tuple(eval(re_content[2])) except: tuple_ = re_content[2] if re_content[1] == 'notin': if 'where' in condi_sql: condi_sql += f' and {re_content[0]} not in {tuple_}' else: condi_sql += f' where {re_content[0]} not in {tuple_}' elif re_content[1] == 'like': if 'where' in condi_sql: condi_sql += f' and {re_content[0]} like "%{re_content[2]}%"' else: condi_sql += f' where {re_content[0]} like "%{re_content[2]}%"' elif re_content[1] == 'in': if 'where' in condi_sql: condi_sql += f' and {re_content[0]} in {tuple_}' else: condi_sql += f' where {re_content[0]} in {tuple_}' else: if 'where' in condi_sql: condi_sql += f" and {re_content[0]} {re_content[1]} '{re_content[2]}'" else: condi_sql += f" where {re_content[0]} {re_content[1]} '{re_content[2]}'" sql += condi_sql find_col = re.findall(r'select (.*?) from', sql)[0] sql_count = sql.replace(find_col, 'count(*)') if orderby := param.get('orderby',[]): if orderby != []: order_sql = ' order by ' flag = False for order in orderby: re_content = re.findall("(.*?)@(.*?)$", order.replace(' ', ''))[0] if flag: order_sql += f',{re_content[0]} {re_content[1]}' continue order_sql += f'{re_content[0]} {re_content[1]}' flag = True sql += order_sql page, pagesize = param.get('page', 1), param.get('pagesize', 20) start = (page-1)*pagesize sql += f' limit {pagesize} offset {start}' return sql,sql_count
test:案例使用
解析：querycomment函数中，cursor为游标；cursorclass为游标类别：用于获取字典或者数组，pymysql可以通过db.cursorclass.__name__获取，但其他并不一定，故在querycomment的第四个参数cursorclass枚举两个值分别为Cursor、DictCursor。若使用其他连接工具，记得更改哦
from sqlcomment.sql import querycomment def db_connect(): db = pymysql.connect( host=host, port=port, user=user, passwd=passwd, db=database, charset='utf8', cursorclass = pymysql.cursors.DictCursor ) cursor = db.cursor() return db,cursor param = {'exclude':['url'], 'condition':['area@notin:("绵竹市","德阳市")','date@>:2023-01-01'], 'orderby':['date@desc','title@desc'], 'page':2, 'pagesize':10 } dbname = 'dy' db,cursor = db_connect() cursorclass = db.cursorclass.__name__ sql,sql_count = querycomment(param,dbname,cursor,cursorclass) _,data = cursor.execute(sql),cursor.fetchall() _,count = cursor.execute(sql_count),cursor.fetchone()
sql,sql_count 返回的是sql语句，需要在返回之后手动执行一次获取数据，这样设计的原因是可能有时候在业务需求上我们还需要对sql语句进一步编写，如联表查询等。其中data是查询回来的数据，count是符合条件的总数据 这样的话有助于前端进行分页操作
whl文件获取
此模块属于抽象部分，故将其打包成whl文件。可直接pip install后使用，安装后也可在lib中查看源码
链接：https://pan.baidu.com/s/1b1rp993bHPyp-J81HUBsxQ
提取码：3u8t
