for row in sqlserver_result: user_doc = {'i_ui_identifier': row[0], 'nvc_user_name': row[1],'nvc_company': row[2], 'nvc_phone': row[3]} user_collection.insert_one(user_doc) mongo_cursor = user_collection.aggregate([ { "$lookup": { "from": "payCondition", "localField": "i_ui_identifier", "foreignField": "i_ui_identifier", "as": "pay_info" } } ]) mysql_cursor = mysql_conn.cursor() for row in mongo_cursor: wuliu_doc = { 'i_ui_identifier': row['i_ui_identifier'], 'nvc_user_name': row['nvc_user_name'], 'nvc_company': row['nvc_company'], 'nvc_phone': row['nvc_phone'], 'pay_info': row['pay_info'] } mysql_cursor.execute("INSERT INTO wuliu VALUES (%s, %s, %s, %s, %s)", (wuliu_doc['i_ui_identifier'], wuliu_doc['nvc_user_name'], wuliu_doc['nvc_company'], wuliu_doc['nvc_phone'],wuliu_doc['pay_info'])) mysql_conn.commit()这样的python代码正确吗?如果不正确,如何修改
时间: 2024-03-23 20:36:42 浏览: 90
这段 Python 代码的目的是将 SQL Server 数据库中的用户信息和 MongoDB 数据库中的支付信息合并,然后将结果插入到 MySQL 数据库的物流信息表中。
但是,这段代码有一个问题:在从 MongoDB 中查询结果时,返回的是一个游标对象,而不是一个字典对象,因此在 for 循环中需要使用字典的键值来访问结果。
以下是修改过的代码:
```python
for row in sqlserver_result:
user_doc = {'i_ui_identifier': row[0], 'nvc_user_name': row[1],'nvc_company': row[2], 'nvc_phone': row[3]}
user_collection.insert_one(user_doc)
mongo_cursor = user_collection.aggregate([{"$lookup": {"from": "payCondition", "localField": "i_ui_identifier", "foreignField": "i_ui_identifier", "as": "pay_info"}}])
mysql_cursor = mysql_conn.cursor()
for row in mongo_cursor:
i_ui_identifier = row['i_ui_identifier']
nvc_user_name = row['nvc_user_name']
nvc_company = row['nvc_company']
nvc_phone = row['nvc_phone']
pay_info = row['pay_info'][0]
wuliu_doc = {
'i_ui_identifier': i_ui_identifier,
'nvc_user_name': nvc_user_name,
'nvc_company': nvc_company,
'nvc_phone': nvc_phone,
'pay_info': pay_info
}
mysql_cursor.execute("INSERT INTO wuliu VALUES (%s, %s, %s, %s, %s)",
(wuliu_doc['i_ui_identifier'], wuliu_doc['nvc_user_name'], wuliu_doc['nvc_company'], wuliu_doc['nvc_phone'], wuliu_doc['pay_info']))
mysql_conn.commit()
```
在这个修改后的代码中,我们使用 `row['pay_info'][0]` 来访问 MongoDB 中的支付信息。另外,我们还将 MongoDB 中的每个字段都存储到了相应的变量中,以便更好地理解代码。
阅读全文