import pymysql
import pandas as pd
def run_sql(path):
    connection = pymysql.connect(
        host=‘localhost‘,
        user=‘root‘,
        password=‘zhangziyi1670‘,
        db=‘payiqing‘,
        charset=‘utf8‘
    )

    cursor = connection.cursor()
    file=open(path,encoding=‘utf-8‘)  #文件路径有中文，所以，先使用open打开一下
    df=pd.read_csv(file,encoding=‘utf-8‘)
    print(df)

    for i in range(df.shape[0]):
        data=df.iloc[i]
        data=(data[‘title‘],data[‘article‘])
        sql = "insert into news(title,context) values " + str(data) + ";"  #要与表的机构对其。第一个是主键，自增长的。
        print(sql)
        try:
            cursor.execute(sql)  #执行sql语句
            connection.commit() #连接提交
        except:
            connection.rollback()

    cursor.close()
    connection.close()
    return

if __name__ == ‘__main__‘:
    path=r‘C:\Users\admin\PycharmProjects\untitled1\pachong\ruanjianbei.csv‘
    run_sql(path)