为了导入数据,可以先对数据做些处理,让其更容易导入数据库
# !/usr/bin/python
#=utf - 8编码
import _mysql sys、时间
#读入数据函数
def add_data (id、名称、created_time):
,,,试一试:
,,,,,,,康涅狄格州=_mysql.connect(127.0.0.1,‘根’,”)
,,,,,,,conn.query (set names utf8)
,,,,,,,conn.query (“insert into mysql.test3 (% s, % s % s),值(' % s ', ' % s ', ' % s ')“% (‘object_id’,‘object_name’,‘创造’,id、名称、created_time))
,,,,,,,结果=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=,开放(“/opt/testdata/aaa.txt”、“r”)
,,,time1=time.time ()
,,,print time.ctime ()
#读出第一行数据,作为数据表的段名
,,,行=f.readline ()
,,,内容=line.strip () .split (", ")
,,,conn0=_mysql.connect(127.0.0.1,‘根’,”)
,,,print “connection is builded 成功的
,,,conn0.query (“drop table if exists mysql.test3”)
,,,conn0.query (“create table mysql.test3 (% s varchar (90), % s varchar (90), % s varchar(90))“%(内容[0][1:1],内容[1][1:1],[2]的内容(1):1)))
,,,conn0.close ()
,,,#运用下函数,让对循环从第二行开始读数据
,,,下一个(f)
,,,for line f:拷贝
,,#做一些处理,让每一段分开,放置在一个列表中
,,,,,,内容=line.strip () .split (", ")
,,,,,,add_data (id=内容[0][1:1)name=内容[1][1:1],[2]created_time=内容(1):1))
,,,,,,
,,,f.close ()
,,,time2=time.time ()
,,,print time.ctime ()
#计算导入数据的时间
,,,print “importing time is % f ' % (time2-time1)
