Linux中将txt导入到mysql的方法教程
18 浏览量
2020-09-09
06:54:19
上传
评论
收藏 48KB PDF 举报
Linux中将中将txt导入到导入到mysql的方法教程的方法教程
主要给大家介绍了关于在Linux中将txt导入到mysql的方法教程，文中通过示例代码介绍的非常详细，对大家的
学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
前言前言
昨天写小项目的时候遇到了一个需求：把txt文档的数据导入到mysql数据库中，开始本来想直接用Mysql Workbench导入TXT
文件，但是最后发现不支持TXT导入，结果我吧嗒吧嗒的去把TXT转了Excel，拿到Linux上导入的时候又发现了各种乱码问
题。
抱着没有什么是程序员干不了的原则，我手写了一个Python代码直接操作文件进行导入了。结果大概一万多条的文件，导入
时间大概两分钟。
下面是具体的代码：下面是具体的代码：
mysqlpython.py文件： 自定义的连接mysql数据库的类
importtxt.py文件： 读TXT文件并进行插入操作
dict.txt文件： 要操作的TXT文件
mysqlpython.py文件文件
from pymysql import *
class Mysqlpython:
def __init__(self,database,host="localhost",
user="root",password="123456",
charset="utf8",port=3306):
self.database = database
self.host = host
self.user = user
self.password = password
self.charset = charset
self.port = port
# 创建数据连接和游标对象
def open(self):
self.db = connect(host=self.host,
user=self.user,
password=self.password,
port=self.port,
database=self.database,
charset=self.charset)
self.cur = self.db.cursor()
# 关闭游标对象和数据库连接对象
def close(self):
self.cur.close()
self.db.close()
# 执行sql命令
def zhixing(self,sql,L=[]):
self.open()
self.cur.execute(sql,L)
self.db.commit()
self.close()
# 查询功能
def all(self,sql,L=[]):
self.open()
self.cur.execute(sql,L)
result = self.cur.fetchall()
return result
if __name__ == "__main__":
sqlh = Mysqlpython("dictionary")
sel = "select * from user"
r = sqlh.all(sel)
print(r)
importtxt.py文件
import re
资源评论
