python远程获取数据库中的相关数据并存储至json文件

1. conn中的5个变量的寄义：
① Driver：数据库驱动程序，我利用的是SQL Server数据库。
② Server：数据库所在的服务器地址。
③ Database：要毗连的数据库的名称。
④ UID：登录 SQL Server 数据库的用户名。
⑤ PWD：密码。
2. prefixAll：数据模板前缀。
    handles：自定义名称。

1. # -*- coding:utf-8 -*-
2. """
3. 作者:青鸟飞啊555
4. 日期:2025年01月22日
5. """
6. import pyodbc
7. import json
8. from datetime import datetime
10. def fetch_data_from_db():
11.     conn = None
12.     try:
13.         # 连接到 SQL Server 数据库，根据实际情况修改连接信息
14.         conn = pyodbc.connect(
15.             "Driver={SQL Server};"
16.             "Server=xxx.xxx.x.xxx;"
17.             "Database=xxxx;"
18.             "UID=xx;"
19.             "PWD=xxxxxx;"
20.         )
21.         cursor = conn.cursor()
22.         # 执行 SQL 查询
23.         cursor.execute('''
24.             SELECT
25.                 DISTINCT(BPERNAME),
26.                 C.POSTNAME,
27.                 ORGANNAME,
28.                 (CASE WHEN B.SEX= '00' THEN '男' ELSE '女' END) AS SEX
29.             FROM
30.                 ISM_TAG AS A
31.                 LEFT JOIN PF_EMPLOYEE AS B ON A.BPERID= B.ID
32.                 LEFT JOIN PF_POST C ON B.POSTID = C.ID
33.                 LEFT JOIN PF_ORGAN D ON C.ORGANID= D.ID
34.             WHERE
35.                 BPERNAME != ''
36.                 AND C.POSTNAME!= ''
37.                 AND ORGANNAME != ''
38.                 AND SEX != ''
39.         ''')
40.         rows = cursor.fetchall()
41.         data = {
42.             "prefixAll": "8x.5xx.7xxxx",
43.             "handles": []
44.         }
45.         handle_counter = 1  # 用于生成 handle 编号
46.         today = datetime.now().strftime("%Y%m%d")
47.         for row in rows:
48.             bpername, postname, organname, sex = row
49.             handle = f"test{today}{str(handle_counter).zfill(3)}"
50.             data["handles"].append({
51.                 "handle": handle,
52.                 "templateVersion": "人员测试",
53.                 "data": [
54.                     {"key": "personName", "value": bpername},
55.                     {"key": "organName", "value": organname},
56.                     {"key": "bperName", "value": bpername},
57.                     {"key": "sex", "value": sex}
58.                 ]
59.             })
60.             handle_counter += 1
61.         return data
62.     except pyodbc.Error as e:
63.         print("数据库操作错误:", e)
64.     finally:
65.         if conn:
66.             conn.close()
69. def save_data_to_json(data):
70.     try:
71.         with open('data.json', 'w+', encoding='utf-8') as file:
72.             json.dump(data, file, ensure_ascii=False, indent=4)
73.         print("数据已成功保存到 data.json 文件中。")
74.     except IOError as e:
75.         print("保存文件时出错:", e)
78. def main():
79.     data = fetch_data_from_db()
80.     if data:
81.         save_data_to_json(data)
84. if __name__ == "__main__":
85.     main()

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。