您的位置:首页 > 数据库 > MySQL

代码干货 | MySQL上云同步脚本-Python3

2017-09-19 13:52 579 查看
本文来源于阿里云-云栖社区,原文点击这里

最近在做本地同步至云的脚本

使用kettle的话,几百个表的同步要一一设置,实在是蛋疼的紧

还好python可以解决一部分问题,所以写了个转换

由于5.6版本的mysql对null的处理不是很好,因此全部转为varchar型

blob和longblob,text都单独处理
#-*- coding: UTF-8 -*-
#获取对比列表
#表结构同步到云上mysql
#实现功能:oracle-mysql列转换/写入脚本/传输脚本
#待实现功能:执行脚本
#james.peng 20170905

import os
os.environ['NLS_LANG'] = 'SIMPLIFIED CHINESE_CHINA.UTF8'
import cx_Oracle
import pymysql
import datetime
import time

Start_time = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
date_nyr = time.strftime('%Y%m%d', time.localtime(time.time()))
#存放结果的txt
os_dir=os.chdir('/a/e/p/y')
remote_loc='/a/e/p/y/'+date_nyr+'/'
try:
os.mkdir(date_nyr)
linux_shell='chmod 777 '+date_nyr
os.popen(linux_shell)
except:
print('folder_existed!')
os_dir='/a/e/p/y/'+date_nyr
os.chdir(os_dir)

try:
f=open(os_dir+'/create_y_script.txt','w')
f.truncate()
f.write("use "+Mysql_schema+";\n")
except:
print('exception!')
print(os.getcwd())

#存放结果的list
create_yrs_table_list=[]

#parameters--参数设置
jump_server_host=
jump_server_destination=

Mysql_yrs_ip_port=
Mysql_yrs_username=
Mysql_yrs_passwd=
Mysql_yrs_db=
Mysql_yrs_port=
Mysql_yrs_schema=
展开全文
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息