从多个 pyodbc 数据库查询结果构造一个大 json 响应

Question

我正在使用 pyodbc 从数据库中的数据构建 json 响应。有些字段是从 table 列直接映射的，而有些字段必须是列表、字典格式。

Table 结构和数据如下所示

甜心 |客户 |发票期 |欠款|截止日期 |收费 |余额 |col8|col9|col10
美国广播公司 | 101 | 20190801 | 12 |某天 | 2 | 10 |col8|col9|col10
美国广播公司 | 101 | 20190701 | 13 |某天 | 3 | 13 |col8|col9|col10
美国广播公司 | 101 | 20190601 | 10 |某天 | 5 | 11 |col8|col9|col10

custid='abc'
conn = pyodbc.connect(connection_string)
cursor = conn.cursor()

#get all invoiceperiod for custid
l = []
cursor.execute("select invoiceperiod from table where custid=? order by invoiceperiod desc", custid)
rows = cursor.fetchall()
for row in rows:
    l.append(row.invoiceperiod)
print("billingperiod:", l)  

#get other direct mapping fields from DB  
cursor.execute("SELECT col8,col9,col10 FROM table where custid=? and invoiceperiod=(select max(invoiceperiod) from table where custid=?)", custid, custid)

results = []
columns = [column[0] for column in cursor.description]

for row in cursor:
    results.append(dict(zip(columns, row)))
#    results.append("billingperid", l)
print(results)

对于给定的监护人 ('abc')，预期 json 响应应如下 -

{
    "accounts": [{
        "custacct": 101,
        "invoiceperiods": ["20190801", "20190701","20190601"],
        "currentinvoicePeriod": "20190801", 
        "custacctsummary":{
            "amtdue":12,
            "duedate":"somedate",
            "charges":2,
            "balance":10
            },
        "col8":value1,
        "col9":value2,
        "col10":value3
        }]
}

1] 如何构造 "custacctsummary" json 对象并附加到 json 响应
2] 为给定 custid/custacct 准备所有发票周期的列表并附加到主要 json 响应 3] 获取 current/latest invoiceperiod.

其他属性的值

Answer 1

您的代码已经生成了 str

的列表

print("billingperiod:", l)
# billingperiod: ['20190801', '20190701', '20190601']

和包含单个 dict

的列表

print(results)
# [{'col8': 'value1', 'col9': 'value2', 'col10': 'value3'}]

如果你改变

results = []
columns = [column[0] for column in cursor.description]

for row in cursor:
    results.append(dict(zip(columns, row)))
#    results.append("billingperid", l)
print(results)

到...

columns = [column[0] for column in cursor.description]

row = cursor.fetchone()
results = dict(zip(columns, row))
print(results)
# {'col8': 'value1', 'col9': 'value2', 'col10': 'value3'}

... 将 l 列表插入 results 字典，然后转储到 JSON 字符串，您将得到

results['invoiceperiods'] = l
j = json.dumps(results, indent=4);
print(j)
# {
#     "col8": "value1",
#     "col9": "value2",
#     "col10": "value3",
#     "invoiceperiods": [
#         "20190801",
#         "20190701",
#         "20190601"
#     ]
# }

您可以使用类似的逻辑来构建其余的 JSON 要求。

从多个 pyodbc 数据库查询结果构造一个大 json 响应

Construct a big json response from multiple pyodbc database query result

python

json

pyodbc