设为首页 收藏本站
查看: 530|回复: 0

[经验分享] mysql数据库表字段替换问题之python解决办法(后来直接用了sql解决,其中py程序有个小问题暂时还没解决)

[复制链接]

尚未签到

发表于 2016-10-24 04:46:38 | 显示全部楼层 |阅读模式
  本篇会提供两种解决方案,当然py部分,可能比较麻烦。不过,我想这个部分今后也会使用到,所以还是贴出来留个纪念,以鼓励后人。对于长期性能监控来说,使用shell进行自动话性能监控,只是我对游戏自动化构想的第一步。而既然现在,可以产生如此多的数据,如何更为高效的管理和分析这些数据应该下个阶段需要着重讨论的问题。本篇后,本人也会花更多经历在这个方面进行研究,欢迎高手指证,嘿嘿!
  以下提供Py部分解决方案:
DSC0000.gif #-*-coding:cp936-*-
#
需求:批量替换Mysql两表的数据,如:A、B两表分别都包含a、b、c三个字段,我们需要替换A表中的B字段
#为B表中的C字段。由此,写了以下这个麻烦的替换程序,生成新表C
importMySQLdb

globalconn,cursor0,cursor1,cursor2,cursor3,id_values,name_values

#数据连接
defMysql_conn():

globalconn,cursor0,cursor1,cursor2,cursor3
host
="localhost"
user
="root"
passwd
="123456"
dbname
="test"
try:
conn
=MySQLdb.connect(host,
user,
passwd,
dbname)
cursor0
=conn.cursor()
cursor1
=conn.cursor()
cursor2
=conn.cursor()
cursor3
=conn.cursor()

#Mysql_conn_test()

returncursor0,cursor1,cursor2,cursor3,conn

exceptMySQLdb.Error,e:
print"Error%d:%s"%(e.args[0],e.args[1])

#数据库连接测试,得到当前数据版本
defMysql_conn_test():

Mysql_conn()
cursor0.execute(
"selectversion()")
print"数据版本%s"%cursor.fetchone()[0]

#测试数据库插入方法
defMysql_insert_test():
Print_params(
"测试")
Mysql_conn()
Print_params(
"测试")
#cursor0.execute("insertintotest000(name)values('123')")
cursor0.execute("insertintotest000(id,name)values('','123');")
print"数据版本%s"%cursor.fetchone()[0]
Print_params(
"数据插入成功!")
cursor0.close()

#数据库替换方法
defMysql_task():

globalconn,cursor0,cursor1,cursor2,cursor3,id_values,name_values
#初始化列表
instead_list_000=[]
instead_list_001
=[]
num
=0

#从两张表中得到数据
Mysql_conn()

cursor0.execute(
"select*fromtest000")
cursor1.execute(
"select*fromtest001")

row000
=cursor0.fetchall()
row001
=cursor1.fetchall()

#读出两张表的数据,替换其类型tuple->list
row000=list(row000)
row001
=list(row001)

#测试
#Print_params(row001[0][0])

#使用第一张表的数据行数进行循环,控制替换数据的行数
foriinrange(len(row001)):

try:
#取出第一张表的每一行数据,生成一个完整的数组
instead_list_000.append(row000)
#取出第二张表的每一行数据,生成一个完整的数组
instead_list_001.append(row001)

exceptKeyError:
num
+=1
print'noelem%d'%num

#测试数据,打印生成的完整数组
Print_params(instead_list_000)
Print_params(instead_list_001)

#重新定义一张新表
cursor2.execute("""
DROPTABLEIFEXISTS`test002`;
CREATETABLE`test002`(
`id`int(11)NOTNULLauto_increment,
`name`int(11)defaultNULL,
PRIMARYKEY(`id`)
)ENGINE=InnoDBDEFAULTCHARSET=gbk;
""")

#从生成新数组,instead_list_000,instead_list_001中读取元素,插入新数据库

foriinrange(len(instead_list_000)):

#测试数据,循环读取第一个字段id,values
#Print_params(instead_list_000[0])

#插入数据库前,进行字符转换list->str
id_values=str(instead_list_000[0])
name_values
=str(instead_list_001[1])

#测试插入数据
Print_params(id_values)
Print_params(name_values)

#替换两表数值,插入新数据库
#cursor2.execute("insertintotest.test002values(%s,%s)"%(id_values,name_values))
#cursor2.nextset()
cursor0.execute("insertintotest.test000(id,name)values('9','9')")

#关闭数据库
Mysql_close(cursor0,cursor1)


#测试方法,打印变量的值
defPrint_params(data):

print"Params'svalue=",data


#测试方法,输出到*.txt的值
defOutPrint_txt(data):

path
="D:CodeSourcesDev_Pydata.txt"
out_list
=open(path,'w')
out_list.writelines(data)
returnout_list

#测试方法,检查数据返回类型
defType(type_params):

print"type:",type(type_params)

#关闭数据库
defMysql_close(a,b):

a.close()
b.close()
conn.close()
print"数据库更新成功,连接已关闭"

if__name__=="__main__":
#Mysql_task()
Mysql_insert_test

  另一个办法,使用sql:

  • 建议一张新表:(这里,数据库的方式选的InnoDB,详细可以查看MysalAdministrator)
DROPTABLEIFEXISTS`test_robot_data`;
CREATETABLE`test_robot_data`(
`tt
char(32)NOTNULL,
`tt1
char(32)NOTNULL,
`tt2`
char(32)NOTNULL,
PRIMARYKEY(`tt`)
)ENGINE
=InnoDBDEFAULTCHARSET=gbk;


  • 筛选前15000条数据,导入新的表,当然也可以用between
insertintotemp_dianxinyi.test_robot_dataSELECT*FROMtemp_dianxinyi.roledatalimit15000;


  • 替换某字段的数据,这里使用了concat
updatetest_robot_datasetAccountName=concat('robot',right(concat('0000',id),4))


  • 在Linux下使用mysqldump备份,某库某表
/mysql/bin/mysqldump--hex-blob--single-transaction--quick-uroot-p123456SchemaTableNmae(可以为多个)>倒出的Linux路径$FILEPATH/DX1/1_$i/$DATE.sql

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-290321-1-1.html 上篇帖子: 转:mysql索引类型normal,unique,full text 及btree和hash索引方式的区别 下篇帖子: 30多条mysql数据库优化方法,千万级数据库记录查询轻松解决
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表