在使用Flask-SQLAlchemy時(shí)，經(jīng)常需要直接用sql語句，或有時(shí)需要Join聯(lián)合多表查詢，此時(shí)返回的結(jié)果SQLAlchemy不會(huì)自動(dòng)轉(zhuǎn)換為dict類型，而是內(nèi)部使用的Row或RowProxy類型，在對(duì)這些數(shù)據(jù)進(jìn)行Json轉(zhuǎn)換，或返回給前端處理時(shí)系統(tǒng)會(huì)報(bào)錯(cuò)：
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多個(gè)表時(shí)，系統(tǒng)無法使用model定義的表對(duì)象表結(jié)果自動(dòng)進(jìn)行轉(zhuǎn)換，而是直接返回Row對(duì)象的List，這個(gè)象的數(shù)據(jù)如下圖所示：
Row對(duì)象數(shù)據(jù)后臺(tái)調(diào)度數(shù)據(jù)結(jié)構(gòu)圖
我在網(wǎng)上找了很長時(shí)間，沒有找到直接可用的函數(shù)或解決方，只能對(duì)數(shù)據(jù)結(jié)構(gòu)進(jìn)行研究，自己寫了一個(gè)把Row List轉(zhuǎn)換為Dict List的方法，具體如 代碼：
# 進(jìn)接讀取數(shù)據(jù)庫，或者多表讀取時(shí)，返回的是RowList,需要把row list轉(zhuǎn)換為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多表查詢實(shí)現(xiàn)
下面是多表而查詢實(shí)現(xiàn)代碼：
if stock_code: # 多表查詢不能用標(biāo)準(zhǔn)的query，返回的結(jié)果因?yàn)椴皇莔odel中的對(duì)像，不能自己處理為標(biāo)準(zhǔn)的dct，需要將Row對(duì)象轉(zhuǎn)為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)}聯(lián)系客服
