如下所示:
import pymysqlimport timeimport redef get_raw_label(rece): re1 = r'"([/s/S]*?)": "' #-------------正則表達式 reg1 = re.compile(re1) # ------------編譯一下 str1 = reg1.findall(rece) return str1def get_detail(rece): re2 = r'": "([/s/S]*?)",' #-------------正則表達式 reg1 = re.compile(re2) # ------------編譯一下 str2 = reg1.findall(rece) return str2def a_file(file,cur): model1= 29 f = open(file, 'r', encoding='UTF-8') lines = f.readlines() #readlines() 方法用于讀取所有行(直到結束符 EOF)并返回列表,該列表可以由 Python 的 for... in ... 結構進行處理.保存給lines for line in lines: #循環執行每一行的內容 model1+=1 raw_label1 = get_raw_label(line) detail1 = get_detail(line) # 插入數據 sql = """insert into models(create_time,model_id,raw_label,detail) values (now(),%s,%s,%s)""" cur.execute(sql,[model1,raw_label1,detail1]) db.commit()db = pymysql.connect("localhost","root","subaobao666","newdatabase" ) #直接連入newdatabase庫cur = db.cursor() #獲取游標a_file("e:/Desktop/json1.txt",cur)db.close()
以上這篇python將txt文檔每行內容循環插入數據庫的方法就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持VEVB武林網。
新聞熱點
疑難解答