python之TXT数据导入数据库-创新互联

为了导入数据，可以先对数据做些处理，让其更容易导入数据库 #!/usr/bin/python #coding=utf-8 import _mysql,sys,time #读入数据函数 def add_data(id,name,created_time):     try:         conn=_mysql.connect('127.0.0.1','root','')         conn.query("set names utf8")         conn.query("insert into mysql.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()     print time.ctime() #读出第一行数据，作为数据表的段名     line=f.readline()     content=line.strip().split(",")     conn0=_mysql.connect('127.0.0.1','root','')     print 'connection is builded succesfully'     conn0.query("drop table if exists mysql.test3")     conn0.query("create table mysql.test3(%s varchar(90),%s varchar(90),%s varchar(90))"%(content[0][1:-1],content[1][1:-1],content[2][1:-1]))     conn0.close()     #运用next函数，让for循环从第二行开始读数据     next(f)     for line in f:    #做一些处理，让每一段分开，放置在一个列表中        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()     print time.ctime() #计算导入数据的时间     print 'importing time is %f'%(time2-time1)

你所需要的网站建设服务，我们均能行业靠前的水平为你提供.标准是产品质量的保证，主要从事网站制作、成都网站设计、企业网站建设、手机网站制作、网页设计、品牌网站制作、网页制作、做网站、建网站。创新互联公司拥有实力坚强的技术研发团队及素养的视觉设计专才。

另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

标题名称：python之TXT数据导入数据库-创新互联
转载来源：http://cxhlcq.com/article/ipsdo.html