脚本功能
1 利用python 读取csv文件数据 输出 并写入到mysql数据库
2 利用python 从mysql数据库读取数据并写入到csv文件中
3 用到的三方库
pandas 安装
pip install pandas
sqlalchemy 安装
pip install sqlalchemy
pymysql 安装
pip install pymysql
4 python 脚本源码
import pandas as pd
from sqlalchemy import create_engine
def imtomysql():
engine = create_engine('mysql+pymysql://username:password@127.0.0.1:3306/dbname')
df = pd.read_csv("./web.csv", sep=',')
df.to_sql('webmpg', engine,if_exists='append', index=False)
print("Write to MySQL successfully!")
def readfrommysql():
engine = create_engine('mysql+pymysql://username:password@127.0.0.1:3306/dbname')
sql = '''
select * from sys_log;
'''
df = pd.read_sql_query(sql, engine)
df['id'] = df['id'].map(deal_str)
df.to_csv('export.csv', index=False, header=True)
print('Read from and write to Mysql table successfully!')
def deal_str(data):
data = str(data) + '\t'
return data
if __name__ == "__main__":
imtomysql()