首页 / PYTHON / Python开发MySQL数据库(表)克隆工具

Python开发MySQL数据库(表)克隆工具

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Python开发MySQL数据库(表)克隆工具，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含16151字，纯文字阅读大概需要24分钟。

内容图文

前段时间因为某些需求，需要频繁的克隆MySQL的某些数据库或者某几个表。手动导出导入操作了几次，感觉甚是繁琐，而且效率不高，出错几率过大。索性抽时间用Python开发了一个MySQL的clone工具，用了一段时间，将数据库或者表克隆到同一台服务器的话(即源数据库与目标数据库在同一主机上)，百万条数据也就是几十秒的时间搞定。该工具也支持将本地数据库或者表克隆到远程主机上。

程序比较简单，就一个Python文件,原理就是主要使用了MySQL的LOAD DATA INFILE命令。先来看下工具帮助信息：

[root@iZ2876x9bezZ ~]# python mysqlclone.py --help
usage: mysqlclone.py [-h] [--sourceHost SOURCEHOST] [--sourcePort SOURCEPORT]
                     [--sourcePasswd SOURCEPASSWD] [--sourceUser SOURCEUSER]
                     [--sourceDb SOURCEDB] [--dstDb DSTDB]
                     [--sourceTable SOURCETABLE] [--dstHost DSTHOST]
                     [--dstPort DSTPORT] [--dstPasswd DSTPASSWD]
                     [--dstUser DSTUSER] [--no-data] [--lock-all-tables]
                     [--events] [--routines] [--triggers]

optional arguments:
  -h, --help            show this help message and exit
  --sourceHost SOURCEHOST
                        The source database host,default[localhost]
  --sourcePort SOURCEPORT
                        The source database port,defalut[3306]
  --sourcePasswd SOURCEPASSWD
                        The source databas passwd,default[NULL]
  --sourceUser SOURCEUSER
                        The source databas username,default[root]
  --sourceDb SOURCEDB   The source databas name
  --dstDb DSTDB         The dst databas name
  --sourceTable SOURCETABLE
                        The source table,default[None]
  --dstHost DSTHOST     The dst database host,default[localhost]
  --dstPort DSTPORT     The dst database port,defalut[3306]
  --dstPasswd DSTPASSWD
                        The dst databas passwd,default[NULL]
  --dstUser DSTUSER     The dst databas username,default[root]
  --no-data, -d         No row information;False is default
  --lock-all-tables, -X
                        Locks all tables,default[False:Lock the table to be
                        read]
  --events, -E          Clone events,default[False]
  --routines, -R        Clone stored routines (functions and
                        procedures),default[False]
  --triggers            Clone triggers for each dumped
                        table,default[False]

简单介绍下几个选项参数：

--sourceHost   指定源数据库主机的IP或者主机名
--sourcePasswd 源数据库主机的密码
--sourceUser 源数据库主机的用户名
--sourceDb   指定要克隆的源数据库
--sourceTable 指定要克隆的源数据表，该值可以不指定，若不指定的话则为克隆上边指定数据库里的所有表
--dstHost 目标数据库主机IP或者主机名
--dstPasswd 目标数据库密码
--dstUser  目标数据库用户名
--no-data|-d 指定该参数时，只克隆表结构信息，不克隆数据。
--lock-all-tables|-X 指定该参数时，表示将整个数据库的所有表都加上读所。默认情况下只是给单个表加读所。
--events|-E 克隆events
--routines|-R 克隆function和procedure
--triggers 克隆triggers

示例，将test数据库整个clone到test3库中，test3库为提前创建好的一个空库。

[root@iZ2876x9bezZ ~]# python mysqlclone.py --sourceHost 127.0.0.1 --sourceUser root --sourcePasswd xxx --dstHost 127.0.0.1 --dstUser root --dstPasswd xxx --sourceDb test --dstDb test3 --no-data -E -R -X

  [2015-07-10 11:44:44] INFO: - Start clone database [127.0.0.1:test] To [127.0.0.1:test3]
[2015-07-10 11:44:44] INFO: - table [pcore_information_information] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_information_reply] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_item_item] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_member_consignee_address] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_member_member] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_member_region] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_member_region_district] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_member_region_district_exist] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_member_session] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_member_usergroup] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_passport_adminsession] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_passport_member] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_passport_memberfield] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_passport_seccode] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_passport_session] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_passport_usergroup] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_system_data] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_system_field] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_system_file] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_system_global] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_system_module] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_system_schedule] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_trade_cart] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_trade_order] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_trade_order_detail] was transferred.
[2015-07-10 11:44:44] INFO: - table [pcore_trade_order_return_goods] was transferred.

脚本代码：

#!/bin/env python
#coding=utf-8

import MySQLdb,datetime,sys,time,os,argparse
from abc import ABCMeta, abstractmethod
__author__ = "liuzhenwei"
__version__ = "1.2"

class Clone():
	__metaclass__ = ABCMeta

	def __init__(self,**kwargs):
		self.pid = os.getpid()
		self.sourceCur = kwargs[‘sourceCur‘]
		self.dstCur =  kwargs[‘dstCur‘]
		self.noData =  kwargs[‘noData‘]
		self.sourceTable =  kwargs[‘sourceTable‘]
		self.lockAllTables =  kwargs[‘lockAllTables‘]
		self.sourceDb = kwargs[‘sourceDb‘]
		#print kwargs
	@abstractmethod
	def clone(self):
		pass

class MySQLClone(object):

	def __init__(self,**kwargs):
		self.sourceTable = kwargs[‘sourceTable‘]
		self.noData = kwargs[‘noData‘]
		self.lockAllTables = kwargs[‘lockAllTables‘]
		self.triggers = kwargs[‘triggers‘]
		self.routines = kwargs[‘routines‘]
		self.events = kwargs[‘events‘]
		self.sourceDb = kwargs[‘sourceDb‘]
		try:
			self.sourceConn=MySQLdb.connect(host=kwargs[‘sourceHost‘],user=kwargs[‘sourceUser‘],passwd=kwargs[‘sourcePasswd‘],port=kwargs[‘sourcePort‘])
			self.sourceCur=self.sourceConn.cursor()
			self.sourceConn.select_db(kwargs[‘sourceDb‘])
			self.sourceCur.execute("SET NAMES utf8;")
			#self.sourceCur.execute("SET AUTOCOMMIT=0;")
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])

		try:
			self.dstConn=MySQLdb.connect(host=kwargs[‘dstHost‘],user=kwargs[‘dstUser‘],passwd=kwargs[‘dstPasswd‘],port=kwargs[‘dstPort‘],local_infile=1)
			self.dstCur=self.dstConn.cursor()
			self.dstConn.select_db(kwargs[‘dstDb‘])
			self.dstCur.execute("SET NAMES utf8;")
			self.dstCur.execute("SET AUTOCOMMIT=0;")
			#stop bin log
			self.dstCur.execute("SET sql_log_bin=0;")
			#
			#self.dstCur.execute("SET GLOBAL innodb_flush_log_at_trx_commit=2;")
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])

	def __dstCommit(self):
	 	 self.dstConn.commit()
    
	def __sourceColse(self):
		self.sourceCur.close()
		self.sourceConn.close()

	def __dstColse(self):
		self.dstCur.close()
		self.dstConn.close()

	def clone(self):
		kwargs = {}
		kwargs[‘sourceCur‘] = self.sourceCur
		kwargs[‘dstCur‘] = self.dstCur
		kwargs[‘noData‘] = self.noData
		kwargs[‘sourceTable‘] = self.sourceTable
		kwargs[‘lockAllTables‘] = self.lockAllTables
		kwargs[‘sourceDb‘] = self.sourceDb
		c = DatabaseClone(**kwargs)
		c.clone()

		if self.triggers:
			t = TriggersClone(**kwargs)
			t.clone()

		if self.routines:
			#print kwargs
			r = RoutinesClone(**kwargs)
			r.clone()

		if self.events:
			e = EventsClone(**kwargs)
			e.clone()

	def __del__(self):
		self.__dstCommit()
		self.__sourceColse()
		self.__dstColse()


class DatabaseClone(Clone):
	‘‘‘
	clone database
	‘‘‘
	def __init__(self,**kwargs):
		Clone.__init__(self,**kwargs)
	def __cloneSingleTable(self,table):
		#create table
		count = self.sourceCur.execute(‘SHOW CREATE TABLE %s;‘ % table)
		results=self.sourceCur.fetchone()
		try:
			self.dstCur.execute(results[1])
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])
			return False
		else:
			if self.noData:
				PrintInfo.say(‘table‘,table)
		#load data
		if not self.noData:
			tmpFile = ‘/tmp/‘+table+‘_‘+str(self.pid)
			try:
				outFileSQL = "SELECT * INTO OUTFILE ‘%s‘ FIELDS TERMINATED BY ‘,‘ OPTIONALLY ENCLOSED BY ‘\"‘ LINES TERMINATED BY ‘\n‘ FROM %s;" % (tmpFile,table)
				count = self.sourceCur.execute(outFileSQL)
			except MySQLdb.Error,e:
				print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])
			else:
				self.__loadData(tmpFile,table)
		if not self.lockAllTables:
			self.sourceCur.execute("COMMIT;")
			self.sourceCur.execute("UNLOCK TABLES;")
	
	def __loadData(self,dataFile,table):
		try:
			intoFileSQL = "LOAD DATA LOCAL INFILE ‘%s‘ INTO TABLE %s CHARACTER SET utf8 FIELDS TERMINATED BY ‘,‘ OPTIONALLY ENCLOSED BY ‘\"‘ LINES TERMINATED BY ‘\n‘;" % (dataFile,table)
			self.dstCur.execute(intoFileSQL)
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])
		else:
			os.remove(dataFile)
			PrintInfo.say(‘table‘,table)

	def clone(self):
		tableList = []
		if self.sourceTable:
			tableList.append(self.sourceTable)
		else:
			count = self.sourceCur.execute(‘SHOW TABLES;‘)
			results=self.sourceCur.fetchall()
			for table in results:
				tableList.append(table[0])
			#lock all tables
			if self.lockAllTables:
				lockSQL = "LOCK TABLES %s;" % ‘,‘.join([t+‘ READ‘ for t in tableList])
				self.sourceCur.execute(lockSQL)

		for t in tableList:
			#lock single table
			if not self.lockAllTables:
				self.sourceCur.execute("LOCK TABLES %s READ;"% t)
			self.__cloneSingleTable(t)
		
		if self.lockAllTables:
			self.sourceCur.execute("COMMIT;")
			self.sourceCur.execute("UNLOCK TABLES;")


class EventsClone(Clone):
	‘‘‘
	clone events
	‘‘‘
	def __init__(self,**kwargs):
		Clone.__init__(self,**kwargs)
	def clone(self):
		for event in self.__getEventList():
			self.__cloneEvent(event)

	def __getEventList(self):
		try:
			count = self.sourceCur.execute("SHOW EVENTS;")
			results=self.sourceCur.fetchall()
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])
		else:
			for event in results:
				yield event[1]

	def __cloneEvent(self,event):
		try:
			count = self.sourceCur.execute("SHOW CREATE EVENT %s;" % event)
			results=self.sourceCur.fetchone()
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])

		else:
			try:
				self.dstCur.execute(results[3])
			except MySQLdb.Error,e:
				print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])
			else:
				PrintInfo.say(‘event‘,event)

class TriggersClone(Clone):
	‘‘‘
	clone triggers
	‘‘‘
	def __init__(self,**kwargs):
		pass
	def clone(self):
		print "clone triggers"

class RoutinesClone(Clone):
	‘‘‘
	clone routines (functions and procedures).
	‘‘‘
	def __init__(self,**kwargs):
		Clone.__init__(self,**kwargs)

	def clone(self):
		for proc in self.__getProcList():
			self.__cloneProc(proc)

		for func in self.__getFunctionList():
			self.__cloneFunc(func)

	def __getProcList(self):
		try:
			count = self.sourceCur.execute("SHOW PROCEDURE STATUS WHERE db=‘%s‘;" % (self.sourceDb))
			results=self.sourceCur.fetchall()
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])
		else:
			for proc in results:
				yield proc[1]

	def __cloneProc(self,proc):
		try:
			count = self.sourceCur.execute("SHOW CREATE PROCEDURE %s;" % proc)
			results=self.sourceCur.fetchone()
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])

		else:
			try:
				self.dstCur.execute(results[2])
			except MySQLdb.Error,e:
				print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])
			else:
				PrintInfo.say(‘procedure‘,proc)
	def __getFunctionList(self):
		try:
			count = self.sourceCur.execute("SHOW FUNCTION STATUS WHERE db=‘%s‘;" % (self.sourceDb))
			results=self.sourceCur.fetchall()
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])
		else:
			for func in results:
				yield func[1]

	def __cloneFunc(self,func):
		try:
			count = self.sourceCur.execute("SHOW CREATE FUNCTION %s;" % func)
			results=self.sourceCur.fetchone()
		except MySQLdb.Error,e:
			print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])

		else:
			try:
				self.dstCur.execute(results[2])
			except MySQLdb.Error,e:
				print >> sys.stderr,"Mysql Error %d: %s" % (e.args[0], e.args[1])
			else:
				PrintInfo.say(‘function‘,func)

class PrintInfo(object):
	‘‘‘
	print info
	‘‘‘
	@staticmethod
	def say(item,name):
		‘‘‘
		print info 
		‘‘‘
		curTime = time.strftime(‘%Y-%m-%d %H:%M:%S‘,time.localtime(time.time()))
		print >> sys.stdout,"[%s] INFO: - %s [%s] was transferred." % (curTime,item,name)



if __name__ == "__main__":

	parser = argparse.ArgumentParser()
	parser.add_argument(‘--sourceHost‘,action=‘store‘,dest=‘sourceHost‘,default=‘localhost‘,help=‘The source database host,default[localhost]‘)
	parser.add_argument(‘--sourcePort‘,action=‘store‘,dest=‘sourcePort‘,default=3306,help=‘The source database port,defalut[3306]‘)
	parser.add_argument(‘--sourcePasswd‘,action=‘store‘,dest=‘sourcePasswd‘,default="",help=‘The source databas passwd,default[NULL]‘)
	parser.add_argument(‘--sourceUser‘,action=‘store‘,dest=‘sourceUser‘,default=‘root‘,help=‘The source databas username,default[root]‘)
	parser.add_argument(‘--sourceDb‘,action=‘store‘,dest=‘sourceDb‘,default=None,help=‘The source databas name‘)
	parser.add_argument(‘--dstDb‘,action=‘store‘,dest=‘dstDb‘,default=None,help=‘The dst databas name‘)
	parser.add_argument(‘--sourceTable‘,action=‘store‘,dest=‘sourceTable‘,default=None,help=‘The source table,default[None]‘)
	parser.add_argument(‘--dstHost‘,action=‘store‘,dest=‘dstHost‘,default=‘localhost‘,help=‘The dst database host,default[localhost]‘)
	parser.add_argument(‘--dstPort‘,action=‘store‘,dest=‘dstPort‘,default=3306,help=‘The dst database port,defalut[3306]‘)
	parser.add_argument(‘--dstPasswd‘,action=‘store‘,dest=‘dstPasswd‘,default="",help=‘The dst databas passwd,default[NULL]‘)
	parser.add_argument(‘--dstUser‘,action=‘store‘,dest=‘dstUser‘,default=‘root‘,help=‘The dst databas username,default[root]‘)

	parser.add_argument(‘--no-data‘,‘-d‘,action=‘store_true‘,dest=‘noData‘,help=‘No row information;False is default‘)
	
	parser.add_argument(‘--lock-all-tables‘,‘-X‘,action=‘store_true‘,dest=‘lockAllTables‘,help=‘Locks all tables,default[False:Lock the table to be read]‘)

	parser.add_argument(‘--events‘,‘-E‘,action=‘store_true‘,dest=‘events‘,help=‘Clone events,default[False]‘)
	parser.add_argument(‘--routines‘,‘-R‘,action=‘store_true‘,dest=‘routines‘,help=‘Clone stored routines (functions and procedures),default[False]‘)
	parser.add_argument(‘--triggers‘,action=‘store_true‘,dest=‘triggers‘,help=‘Clone triggers for each dumped table,default[False]‘)

	args = parser.parse_args()

	if args.sourceDb is None:
		print >> sys.stderr,"ERROR: parameter --sourceDb cant not be NULL"
		sys.exit(1)

	if args.dstDb is None:
		print >> sys.stderr,"ERROR: parameter --dstDb cant not be NULL"
		sys.exit(1)

	conInfo = {
		"sourceHost":args.sourceHost,
		"sourceUser":args.sourceUser,
		"sourcePasswd":args.sourcePasswd,
		"sourceDb":args.sourceDb,
		"sourceTable":args.sourceTable,
		"noData":args.noData,
		"dstHost":args.dstHost,
		"dstUser":args.dstUser,
		"dstPasswd":args.dstPasswd,
		"dstDb":args.dstDb,
		"sourcePort":args.sourcePort,
		"dstPort":args.dstPort,
		"lockAllTables":args.lockAllTables,
		"events":args.events,
		"routines":args.routines,
		"triggers":args.triggers
		}
	print >> sys.stdout,"[%s] INFO: - Start clone database [%s:%s] To [%s:%s]" %(time.strftime(‘%Y-%m-%d %H:%M:%S‘,time.localtime(time.time())),conInfo[‘sourceHost‘],conInfo[‘sourceDb‘],conInfo[‘dstHost‘],conInfo[‘dstDb‘])
	
	m = MySQLClone(**conInfo)
	m.clone()

由于时间问题，克隆triggers的功能还没有完成，而且当数据量过大的时候，最好是将数据分批操作，如每10万load一次，这样会得到更好的性能，该程序会持续更新下。

也可以直接从github下载程序源码:https://github.com/diannaowa/mysqlclone

本文出自 “diannaowa” 博客，请务必保留此出处http://diannaowa.blog.51cto.com/3219919/1677651

Python开发MySQL数据库(表)克隆工具

标签：mysql 克隆 python mysql克隆

本文系统来源：http://diannaowa.blog.51cto.com/3219919/1677651

内容总结

以上是互联网集市为您收集整理的Python开发MySQL数据库(表)克隆工具全部内容，希望文章能够帮你解决Python开发MySQL数据库(表)克隆工具所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/453007.html

来源：【匿名】

【上一篇】mac 上面安装mysql－python 【下一篇】浅谈PHP运行Python脚本的方法

更多 ►

【Python开发MySQL数据库(表)克隆工具】教程文章相关的互联网学习教程文章

Python/MySQL（四、MySQL数据库操作）【代码】

Python/MySQL（四、MySQL数据库操作）一、数据库条件语句：1 case when id>9 then ture else false二、三元运算：1if（isnull（xx）0,1）三、上下连表：select id，name from ta1 union 天然去重（检测上边的表和下边的表行内完全一样就只显示一行内容） select num,sname from tb2 ========================================== select id，name from ta1 union all 不去重 select num,sname from tb2 --------------------...

用python操作mysql数据库（之批量插入数据）【代码】

#!/usr/bin/env python # -*- coding: utf-8 -*- import MySQLdb#建立连接 conn = MySQLdb.connect(host=‘127.0.0.1‘,user=‘root‘,passwd=‘1qaz#EDC‘,db=‘test_db‘) cur = conn.cursor()#对数据进行操作 li = [(‘tanzhenx‘,‘shaoguan‘),(‘huangmengdie‘,‘shaoguan‘)] #定义一个列表，列表中含多个元组，等会批量插入每个元组中的数据 cur.executemany(‘insert into user (name,address) values(%s,%s)‘,li) #批量...

Python使用MySQL数据库(新)【代码】

一，安装mysql 如果是windows 用户，mysql 的安装非常简单，直接下载安装文件，双击安装文件一步一步进行操作即可。Linux 下的安装可能会更加简单，除了下载安装包进行安装外，一般的linux 仓库中都会有mysql ，我们只需要通过一个命令就可以下载安装：Ubuntu\deepin>>sudo apt-get install mysql-server >>Sudo apt-get install mysql-clientcentOS/redhat>>yum install mysql 二，安装MySQL-python要想使python可以操作mysql 就...

python2.7连接mysql数据库，并从插入数据【代码】

需要先导入mysqldb这个模块　　　　　　　　　　　　　　import MySQLdbconn= MySQLdb.connect( host=‘localhost‘, #主机，127.0.0.1 port = 3306,　　　　#端口 user=‘root‘,　　　　　#用户名 passwd=‘root‘,　　　　#密码 db =‘gupiao‘,　　　　　　#数据库名字 )cur = conn.cursor() cur.execute("insert into table_name(字段名字) values(后面要跟的值)")conn....

使用Python查询MySQL数据库生成Excel文件发送监控周报。【代码】【图】

业务方要求每周发一封周报出来，将过去一周的线上项目的详细信息发送出来，我们的监控用的是zabbix，过去一直是手动填写，非常耗时耗力，而且显得非常不专业，所以我花了几个月时间学习Python，编写如下脚本供大家参考，望大神勿笑。 #!/usr/bin/env python #-*- coding: utf8 -*- import MySQLdb import string import xlsxwriter import time,datetime import sys reload(sys) sys.setdefaultencoding(‘utf-8‘)zdbhost = ‘ ‘...

python操作MySQL数据库【代码】

坚持每天学一点，每天积累一点点，作为自己每天的业余收获，这个文章是我在吃饭的期间写的，利用自己零散的时间学了一下python操作MYSQL，所以整理一下。我采用的是MySQLdb操作的MYSQL数据库。先来一个简单的例子吧：import MySQLdbtry:conn=MySQLdb.connect(host=‘localhost‘,user=‘root‘,passwd=‘root‘,db=‘test‘,port=3306)cur=conn.cursor()cur.execute(‘select * from user‘)cur.close()conn.close() except MySQLd...

python对mysql数据库操作的三种不同方式【代码】【图】

首先要说一下，在这个暑期如果没有什么特殊情况，我打算用python尝试写一个考试系统，希望能在下学期的python课程实际使用，并且尽量在此之前把用到的相关技术都以分篇博客的方式分享出来，有想要交流的小伙伴可以持续关注我！话不多说，本博客是考试系统中要用到的一个技术 python对mysql的操作的三种实现方式。再此之前先引入三个知识点：1 ：__name__==‘__main__‘　　这是什么意思呢？　　1.python文件的后缀为.py　　2..py文...

Python---MySQL数据库之四大操作(增删改查)

一.对数据库,表,记录---四大操作(增删改查)1.操作数据库(1)对数据库(文件夹):进行增加操作Create database 库名;例: Create database db7 ; 查询库: show databases;结果:+-----------------------------+| Database |+----------------------------+| information_schema || db6 || db7 |+-----------------------------+ (2)对数据库(文件夹)...

mysql-mysql09使用python操作mysql数据库【代码】

一丶数据库的安装和连接1.1python连接数据库import pymysqlconn = pymysql.connect(host="127.0.0.1", # ip地址port=3306, # 端口位置user="root", # 用户名password="123", # 密码database="nash", # 数据库名charset="utf8", # 当前数据库编码格式autocommit=True # 是否设置自动commit确认 ) cursor = conn.cursor(pymysql.cursors.DictCursor)二丶创建表操作import pymysql# 打开数据库连接 db = pymysql...

Python连接MySQL数据库之pymysql模块使用【代码】

Python3连接MySQL本文介绍Python3连接MySQL的第三方库--PyMySQL的基本使用。PyMySQL介绍PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2中则使用mysqldb。Django中也可以使用PyMySQL连接MySQL数据库。PyMySQL安装pip install pymysql连接数据库注意事项在进行本文以下内容之前需要注意：你有一个MySQL数据库，并且已经启动。你有可以连接该数据库的用户名和密码你有一个有权限操作的database基本使用# 导入p...

python用Windows开发配置mysql数据库

Windows 版本：Windows10 64-bitPython 版本：Pyhton 3.6.1MySQL 版本：mysql-5.7.18-winx641. mysql-5.7.18-winx64 下载下载地址：https://www.mysql.com/downloads/ 对应Windows 系统版本选择下载，下面两个是测试版本，忽略。 2. 下载好的 zip 文件解压到想要安装的目录 3. 配置环境变量，就是添加 bin 文件的路径到系统变量 Path。 4. 用管理员权限进入 bin 目录，执行 mysqld --initialize-insecure 初始化目...

python操作mysql数据库

1:环境：MySQL for python模块　　　　安装好后用import MySQLdb检验2：DB API：统一的可操控多种数据库的接口　　　　1):连接对象[connection]：用MySQL.Connect（参数）创建　　　　　　参数：host：Mysql服务器地址　　　　　　　　　 port：Mysql服务器端口号　　　　　　　　 user：用户名　　　　　　　　 passwd　　　　　　　　　 db：所用数据库名　　　　　　　　　 charset：连接编码　　　　　　　　　【...

Python入门学习教程：数据库操作，连接MySql数据库

各位志同道合的同仁可以点击上方关注↑↑↑↑↑↑本教程致力于程序员快速掌握Python语言编程。本文章内容是基于上次课程Python教程：Python教程：连接数据库，对数据进行增删改查操作和python基础知识之上进行的。如想学习python基础请移步：Python开发实战系列教程-链接汇总，持续更新。数据库增删改查操作。我们打开Navicat 创建一个数据库Manager，并且创建一个数据表：Student并添加初始化数据：传统方式进行增删改查：传统...

Python学习之旅—Mysql数据库之数据类型和约束【代码】

前言　　　本篇博客我们主要专注于解决Mysql数据库中的数据类型和约束，将重点聚焦于字符类型，日期类型，集合类型和主键和unique等知识点，希望各位可以好好掌握今天的知识点。一.整数类型#整数类型：TINYINT SMALLINT MEDIUMINT INT BIGINT #作用：存储年龄，等级，id，各种号码等 #ps:默认都是有符号的关于整数类型，我们需要关注一点，即整形的宽度指的是显示宽度，而不是存储宽度我们来看看如下的例子：create table t1(id in...

Python Mysql 数据库操作

本文实例讲述了python中MySQLdb模块用法。分享给大家供大家参考。具体用法分析如下：MySQLdb其实有点像php或asp中连接数据库的一个模式了，只是MySQLdb是针对mysql连接了接口，我们可以在python中连接MySQLdb来实现数据的各种操作。python连接mysql的方案有oursql、PyMySQL、 myconnpy、MySQL Connector 等，不过本篇要说的确是另外一个类库MySQLdb，MySQLdb 是用于Python链接Mysql数据库的接口，它实现了 Python 数据库 API 规范 ...

PYTHON - 技术教程分类

Python3 教程 Python3 简介 Python3 环境搭建 Python3 基础语法 Python3 基本数据类型 Python3 解释器 Python3 注释 Python3 运算符 Python3 数字(Number) Python3 字符串 Python3 列表 Python3 元组 Python3 字典 Python3 集合 Python3 编程第一步 Python3 条件控制 Python3 循环语句 Python3 迭代器与生成器 Python3 函数 Python3 数据结构 Python3 模块 Python3 输入和输出 Python3 File Python3 OS Python3 错误和异常 Python3 面向对象 Python3 命名空间/作用域 Python3 标准库概览 Python3 实例 Python3 CGI编程 Python3 MySQL(PyMySQL) Python3 网络编程 Python3 SMTP发送邮件 Python3 多线程 Python3 日期和时间 Python3 内置函数 Python3 MongoDB Python3 urllib python 全部

PYTHON - 最热教程

python如何统计字符串中字母个数？使用Python进行微信公众号开发（三）回...Python+PyQT5的子线程更新UI界面的实例 python时间戳怎么获得？如何获得当前时...vscode调试python时提示无法将“conda”...python接口自动化全局变量access_token...python收取邮件(腾讯企业邮箱)python如何绘制降水图详解python并发获取snmp信息及性能测试...怎么卸载Python3.6？

首页 / PYTHON / Python开发MySQL数据库(表)克隆工具

Python开发MySQL数据库(表)克隆工具

内容导读

内容图文

内容总结

内容备注

内容手机端

【Python开发MySQL数据库(表)克隆工具】教程文章相关的互联网学习教程文章

Python/MySQL（四、MySQL数据库操作）【代码】

用python操作mysql数据库（之批量插入数据）【代码】

Python使用MySQL数据库(新)【代码】

python2.7连接mysql数据库，并从插入数据【代码】

使用Python查询MySQL数据库生成Excel文件发送监控周报。【代码】【图】

python操作MySQL数据库【代码】

python对mysql数据库操作的三种不同方式【代码】【图】

Python---MySQL数据库之四大操作(增删改查)

mysql-mysql09使用python操作mysql数据库【代码】

Python连接MySQL数据库之pymysql模块使用【代码】

python用Windows开发配置mysql数据库

python操作mysql数据库

Python入门学习教程：数据库操作，连接MySql数据库

Python学习之旅—Mysql数据库之数据类型和约束【代码】

Python Mysql 数据库操作

PYTHON - 相关标签

MYSQL - 相关标签

数据库 - 相关标签

PYTHON - 技术教程分类

PYTHON - 最新教程

PYTHON - 最热教程