import pymysql

# 链接数据库
mydb = pymysql.connect(  
                     host="localhost",          # 数据库主机地址
                     user="root",               # 数据库用户名
                     passwd="1234"  ,           # 数据库密码
                     port = 3306                # 端口号
                                                # db=已经已经存在的数据库， 字符串

# 创建游标对象
mycursor = mydb.cursor()

# 创建数据库pandas_to_sql
mycursor.execute('create database pandas_to_sql')

# 读取数据
df = pd.read_csv(r"C:\Users\EDZ\Desktop\数据清洗\第三天\课堂\test3.txt", sep=',', header=0)
df

# 存入数据库
from sqlalchemy import create_engine

engine = create_engine("mysql+pymysql://root:1234@localhost:3306/pandas_to_sql?charset=utf8")

df.to_sql('test', con=engine)