需求

將mysql中查詢到的資料匯入到另一個數據庫表中

程式碼

#!/usr/bin/env python3
# -*- coding:utf-8 -*-
#
import pymysql

# 原始資料的資料連線
db1 = pymysql.connect('127.0.0.1', 'root', '1234', 'test')
cursor1 = db1.cursor()
# 定義查詢語句
len1 = cursor1.execute('select id,CAST(createtime AS CHAR) AS createtime,paycount from admin_payinfo limit 100'
 
)

# 遷移庫的資料連線
db2 = pymysql.connect('192.168.0.110', 'root', '1234', 'test1')
cursor2 = db2.cursor()
# 批量插入語句
sql = 'insert into admin_payinfo(id,createtime,paycount) value(%s, %s, %s)'

# 每次迴圈匯入的資料量
num = 11

for i in range(int(len1/num)):
    print(i)
    data1 = cursor1.fetchmany(num)
    cursor2.executemany(sql, data1)

# 把剩下的資料一次性匯入
 

data2 = cursor1.fetchall()
cursor2.executemany(sql, data2)

# 這種可以全部匯入
# data2 = cursor1.fetchall()
# cursor2.executemany(sql, data2)

# 提交到資料庫
db2.commit()

# 關閉資料庫連線
db1.close()
db2.close()