加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程开发 > Python > 正文

python文件读写并使用mysql批量插入示例分享(python操作mysql)

发布时间:2020-12-16 19:40:20 所属栏目:Python 来源:网络整理
导读:复制代码 代码如下: # -*- coding: utf-8 -*- ''' Created on 2013年12月9日 @author: hhdys ''' import os import mysql.connector config = { 'user': 'root', 'password': '******', 'host': '127.0.0.1', 'database': 'test', 'raise_on_warnings': True

复制代码 代码如下:

# -*- coding: utf-8 -*-
'''
Created on 2013年12月9日

@author: hhdys
'''

import os
import 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)"
            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()

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读