代码如下:
# -*- coding: utf-8 -*-”’created on 2013年12月9日
@author: hhdys”’
import osimport mysql.connector
config = { ‘user’: ‘root’, ‘password’: ‘******’, ‘host’: ‘127.0.0.1’, ‘database’: ‘test’, ‘raise_on_warnings’: true,}cnx = mysql.connector.connect(**config)
class readfile: def readlines(self): f = open(“e:/data/2013-11-5.txt”, “r”, 1, “utf-8”) i=0 list=[] for line in f: strs = line.split(“\t”) if len(strs) != 5: continue data=(strs[0], strs[1], strs[2], strs[3], strs[4].replace(“\n”,””)) list.append(data) cursor=cnx.cursor() sql = “insert into data_test(uid,log_date,fr,is_login,url)values(%s,%s,%s,%s,%s)” if i>5000: cursor.executemany(sql,list) cnx.commit() print(“插入”) i=0 list.clear() i=i+1 if i>0: cursor.executemany(sql,list) cnx.commit() cnx.close() f.close() print(“ok”) def listfiles(self): d = os.listdir(“e:/data/”) return d if __name__ == “__main__”: readfile = readfile() readfile.readlines()