程序员开发实例大全宝库

网站首页 > 编程文章 正文

Flask-SQLAlchemy直接用sql或Join查询出Row对象处理

zazugpt 2025-04-02 00:18:06 编程文章 19 ℃ 0 评论

在使用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 List转换为Dict List的方法,具体如 代码:

# 进接读取数据库,或者多表读取时,返回的是RowList,需要把row list转换为dict list
def 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对象转为dict
stocks_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)}

Tags:

本文暂时没有评论,来添加一个吧(●'◡'●)

欢迎 发表评论:

最近发表
标签列表