在使用Flask-SQLAlchemy时,经常需要直接用sql语句,或有时需要Join联合多表查询,此时返回的结果SQLAlchemy不会自动转换为dict类型,而是内部使用的Row或RowProxy类型,在对这些数据进行Json转换,或返回给前端处理时系统会报错:
File 'C:\Python\lib\json\encoder.py', line 179, in default
raise TypeError(f'Object of type {o.__class__.__name__} '
TypeError: Object of type Row is not JSON serializable
由于直接使用sql特别是join多个表时,系统无法使用model定义的表对象表结果自动进行转换,而是直接返回Row对象的List,这个象的数据如下图所示:
Row对象数据后台调度数据结构图
我在网上找了很长时间,没有找到直接可用的函数或解决方,只能对数据结构进行研究,自己写了一个把Row List转换为Dict List的方法,具体如 代码:
# 进接读取数据库,或者多表读取时,返回的是RowList,需要把row list转换为dict listdef row_to_dict(row_list): result = [] for row in row_list: row_value = {} for field in row.keys(): data = row[field] if isinstance(data, datetime.datetime): data = data.strftime('%Y-%m-%d %H:%M:%S') elif isinstance(data, datetime.date): data = data.strftime('%Y-%m-%d') elif isinstance(data, datetime.time): data = data.isoformat() elif isinstance(data, decimal.Decimal): data = float(data) row_value.update({field: data}) result.append(row_value) return result
三、SQLAlchemy多表查询实现
下面是多表而查询实现代码:
if stock_code: # 多表查询不能用标准的query,返回的结果因为不是model中的对像,不能自己处理为标准的dct,需要将Row对象转为dictstocks_score = StocksScoreGr.query.with_entities(StocksScoreGr.security_code, StocksScoreGr.scores, StockBasic.security_name_abbr, StocksScoreGr.fx_date). \filter(StocksScoreGr.security_code == stock_code).join(StockBasic,StocksScoreGr.security_code == StockBasic.security_code) \ .order_by(StocksScoreGr.scores.desc()).paginate(page, pagesize)result = row_to_dict(stocks_score.items)res = {'page': stocks_score.page, 'pages': stocks_score.pages, 'data': json.dumps(result)}
联系客服