from typing import List

import mysql
import mysql.connector
import csv
def hello():
    db_config = {
    'host': 'localhost',
    'user': 'root',
    'password': '12345678M',
    'database': 'pinglun',
    }
    cnx = mysql.connector.connect(**db_config)
    cursor = cnx.cursor()
    # 读取CSV
    with open('评论.csv', mode='r', encoding='utf-8') as file:
        reader = csv.reader(file)
        headers = next(reader, None)
        if headers is not None:  # 过表头
            for row in reader:
                sql = "INSERT IGNORE INTO pinglunxinxi(nicheng,pinglun,chanpingxinxi) VALUES (%s, %s, %s)"
                cursor.execute(sql, (row[0], row[1], row[2]))  #设csv与数据库对应
    try:
        cnx.commit()
        print("数据导入成功！")
    except mysql.connector.Error as err:
        print(f"数据导入失败: {err}")
    finally:
        cursor.close()
        cnx.close()
hello()