sql server数据转存mongodb

Friday, Sep 3, 2021 | 1 minute read | Updated at Friday, Sep 3, 2021

@
sql server数据转存mongodb

写得比较简单,直接查询插入了

#!/usr/bin/env python
# -*- coding:utf-8 -*-


import pymssql
import pymongo

sql = '''SELECT [Name]
      ,[CardNo]
      ,[Descriot]
      ,[CtfTp]
      ,[CtfId]
      ,[Gender]
      ,[Birthday]
      ,[Address]
      ,[Zip]
      ,[Dirty]
      ,[District1]
      ,[District2]
      ,[District3]
      ,[District4]
      ,[District5]
      ,[District6]
      ,[FirstNm]
      ,[LastNm]
      ,[Duty]
      ,[Mobile]
      ,[Tel]
      ,[Fax]
      ,[EMail]
      ,[Nation]
      ,[Taste]
      ,[Education]
      ,[Company]
      ,[CTel]
      ,[CAddress]
      ,[CZip]
      ,[Family]
      ,[Version]
  FROM cdsgus'''

ms_conn = pymssql.connect(host="127.0.0.1", user="sa",
                          password="root", database="database", charset="utf8")
ms_cur = ms_conn.cursor(as_dict=True)
ms_cur.execute(sql)

row = ms_cur.fetchone()

mongo_conn = pymongo.MongoClient('127.0.0.1', 27017)
mongo_db = mongo_conn['test']

while row:
    mongo_db.kf_data.insert_one(row)
    row = ms_cur.fetchone()

ms_conn.commit()
ms_conn.close()

© 2016 - 2025 Caisong's Blog

🌱 Powered by Hugo with theme Dream.

About Me

大龄程序员,喜欢折腾各种环境部署、软件应用。

博客记录日常。