mysql 自动导入

import mysql.connector

def import_data(file_path):
    try:
        # 连接数据库
        conn = mysql.connector.connect(
            host="localhost",
            user="username",
            password="password",
            database="database_name"
        )
        cursor = conn.cursor()

        # 使用 LOAD DATA INFILE 命令导入数据
        query = f"LOAD DATA INFILE '{file_path}' INTO TABLE table_name FIELDS TERMINATED BY ',' LINES TERMINATED BY '\n'"
        cursor.execute(query)

        # 提交事务
        conn.commit()
        print("数据导入成功！")

    except mysql.connector.Error as err:
        print(f"数据导入失败：{err}")

    finally:
        # 关闭连接
        if conn.is_connected():
            cursor.close()
            conn.close()

# 调用函数导入数据
import_data("path/to/data_file.csv")