### 将CSV文件数据插入到MySQL数据库中的具体实现 以下是基于Python编写的代码示例，用于将CSV文件中的指定列数据批量插入到MySQL数据库的指定字段中。 #### 配置环境 在执行此操作之前，请确保已启用`local-infile`选项。可以通过修改MySQL配置文件`my.ini`来完成这一设置[^3]： ```ini [mysqld] # 服务端配置 local-infile=1 [mysql] # 客户端配置 local-infile=1 ``` 重启MySQL服务以使更改生效。 #### 创建数据库和表结构 假设已经创建了一个名为`db_csv`的数据库[^2]，并定义了一张目标表`example_table`，其结构如下： ```sql CREATE TABLE example_table ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT, email VARCHAR(255) ); ``` #### Python代码实现 以下是一个完整的Python脚本，它能够读取CSV文件并将其中的部分列数据插入到MySQL数据库中[^1]。 ```python import csv import mysql.connector def insert_data_from_csv_to_mysql(csv_file, db_config, table_name, columns): """ 插入CSV文件中的数据到MySQL数据库。 参数: csv_file (str): CSV文件路径。 db_config (dict): 数据库连接参数。 table_name (str): MySQL的目标表名。 columns (list): 要插入的列名列表。 """ try: # 连接到MySQL数据库 connection = mysql.connector.connect( host=db_config['host'], user=db_config['user'], password=db_config['password'], database=db_config['database'] ) cursor = connection.cursor() with open(csv_file, mode='r', encoding='utf-8') as file: reader = csv.DictReader(file) placeholders = ', '.join(['%s'] * len(columns)) column_names = ', '.join(columns) sql_query = f"INSERT INTO {table_name} ({column_names}) VALUES ({placeholders})" data_to_insert = [] for row in reader: record = tuple(row[col] for col in columns if col in row) data_to_insert.append(record) cursor.executemany(sql_query, data_to_insert) connection.commit() print(f"{cursor.rowcount} 条记录成功插入到 {table_name}") except Exception as e: print(f"发生错误: {e}") finally: if 'connection' in locals() and connection.is_connected(): cursor.close() connection.close() # 示例调用 if __name__ == "__main__": csv_path = "data.csv" db_credentials = { 'host': 'localhost', 'user': 'root', 'password': 'your_password', 'database': 'db_csv' } target_table = "example_table" selected_columns = ['name', 'age', 'email'] insert_data_from_csv_to_mysql(csv_path, db_credentials, target_table, selected_columns) ``` 上述代码实现了以下几个功能： 1. 使用`csv.DictReader`解析CSV文件，并提取所需的列数据。 2. 构建SQL查询语句动态适应不同的列数和列名。 3. 批量插入数据至MySQL数据库，提高效率。 #### 注意事项 - 确保CSV文件的第一行为列头，且与数据库表中的字段匹配。 - 如果某些列未被选中，则这些列不会参与插入过程。 - 替换`your_password`为实际的MySQL密码。 --- ###