python将TXT数据导入数据库的方法代码如下:
#!/usr/bin/python #coding=utf-8 import_mysql,sys,time #读入数据函数 defadd_data(id,name,created_time): try: conn=_mysql.connect('127.0.0.1','root','') conn.query("setnamesutf8") conn.query("insertintomysql.test3(%s,%s,%s)values('%s','%s','%s')"%('object_id','object_name','created',id,name,created_time)) result=conn.use_result() conn.close() except_mysql.Error,e: print("error%d:%s"%(e.args[0],e.args[1])) sys.exit(1) if__name__=="__main__": f=open("/opt/testdata/aaa.txt","r") time1=time.time() printtime.ctime() #读出第一行数据,作为数据表的段名 line=f.readline() content=line.strip().split(",") conn0=_mysql.connect('127.0.0.1','root','') print'connectionisbuildedsuccesfully' conn0.query("droptableifexistsmysql.test3") conn0.query("createtablemysql.test3(%svarchar(90),%svarchar(90),%svarchar(90))"%(content[0][1:-1],content[1][1:-1],content[2][1:-1])) conn0.close() #运用next函数,让for循环从第二行开始读数据 next(f) forlineinf: #做一些处理,让每一段分开,放置在一个列表中 content=line.strip().split(",") add_data(id=content[0][1:-1],name=content[1][1:-1],created_time=content[2][1:-1]) f.close() time2=time.time() printtime.ctime() #计算导入数据的时间 print'importingtimeis%f'%(time2-time1)原文来自:https://www.py.cn
© 版权声明
文章版权归作者所有,未经允许请勿转载。
THE END
暂无评论内容