如何把csv导入mysql数据库

摘要

将 CSV (逗号分隔值) 数据导入 MySQL 数据库是一个常见的任务，涉及以下步骤：

1. 创建 MySQL 数据库和表
2. 使用 LOAD DATA 语句导入 CSV 文件
3. 映射 CSV 列与表字段
4. 指定导入选项（例如分隔符、字符集）
5. 处理错误和验证数据

详细说明

1. 创建 MySQL 数据库和表

创建一个 MySQL 数据库来存储 CSV 数据：

CREATE DATABASE csv_data;

然后创建一个表来表示 CSV 数据：

CREATE TABLE table_name (
    column1_name data_type,
    column2_name data_type,
    ...
);

2. 使用 LOAD DATA 语句导入 CSV 文件

使用 LOAD DATA 语句可以将 CSV 文件导入 MySQL 表：

LOAD DATA INFILE "path/to/csv_file.csv"
INTO TABLE table_name
FIELDS TERMINATED BY ","
ENCLOSED BY """
LINES TERMINATED BY "
"
IGNORE 1 ROWS;

• FIELDS TERMINATED BY ","：指定分隔 CSV 列的字符（此处为逗号）
• ENCLOSED BY """：指定包含文本值的字符（此处为双引号）
• LINES TERMINATED BY " "：指定分隔 CSV 行的字符（此处为换行符）
• IGNORE 1 ROWS：跳过 CSV 文件中的第一行（通常是标题行）

3. 映射 CSV 列与表字段

如果 CSV 文件的列顺序与 MySQL 表的字段顺序不同，可以使用 FIELDS 语句映射它们：

LOAD DATA INFILE "path/to/csv_file.csv"
INTO TABLE table_name
FIELDS TERMINATED BY ","
ENCLOSED BY """
LINES TERMINATED BY "
"
IGNORE 1 ROWS
(column1_name, column2_name, ...)

4. 指定导入选项

可以指定其他导入选项，例如：

• CHARACTER SET utf8mb4：指定字符集
• REPLACE：替换现有数据
• IGNORE：忽略错误行
• ERROR LOG：将错误日志记录到文件

5. 处理错误和验证数据

LOAD DATA 语句完成后，应检查是否有错误：

SELECT COUNT(*) FROM table_name;
SELECT * FROM table_name WHERE is_valid = 0;  -- 自定义标记无效行的列

可以编写验证脚本来检查数据完整性，例如：

import MySQLdb

db = MySQLdb.connect(host="localhost", user="root", passwd="password", db="csv_data")
cursor = db.cursor()

cursor.execute("SELECT COUNT(*) FROM table_name WHERE age < 0")
invalid_rows = cursor.fetchone()[0]

if invalid_rows > 0:
    print("Error: {} invalid rows found.".format(invalid_rows))
else:
    print("No invalid rows found.")

db.close()

通过遵循这些步骤，您可以将 CSV 数据成功导入 MySQL 数据库。

以上就是如何把csv导入mysql数据库的详细内容，更多请关注编程网其它相关文章！