MySQL - 将 CSV 文件导入数据库

要通过 PHP 程序将 CSV 文件导入数据库，我们需要使用 mysqli 函数 query() 执行"LOAD DATA INFILE"语句，如下所示 -

$sql = "LOAD DATA INFILE 'C:/ProgramData/mysql8/MySQL Server 8.0/Uploads/EMPLOYEES_BACKUP.csv' INTO TABLE CUSTOMERS FIELDS TERMINATED BY ';' OPTIONALLY ENCLOSED BY '' LINES TERMINATED BY '
'";
$mysqli->query($sql);

$dbhost = 'localhost';
$dbuser = 'root';
$dbpass = 'password';
$db = 'TUTORIALS';
$mysqli = new mysqli($dbhost, $dbuser, $dbpass, $db);
if ($mysqli->connect_errno) {
    printf("Connect failed: %s
", $mysqli->connect_error);
    exit();
}
//printf('Connected successfully.
');
$sql = "CREATE TABLE EMPLOYEES( ID INT NOT NULL, NAME VARCHAR(20) NOT NULL, AGE INT NOT NULL, ADDRESS CHAR(25) NOT NULL, SALARY DECIMAL(18, 2), PRIMARY KEY(ID) )";
if($mysqli->query($sql)){
    printf("Employees table created successfully...!
");
}
//现在让我们向其中插入一些数据..
$sql = "INSERT INTO EMPLOYEES (ID,NAME,AGE,ADDRESS,SALARY) VALUES (1, 'Ramesh', 
32, 'Ahmedabad', 2000.00 )";
if($mysqli->query($sql)){
    printf("First record inserted successfully...!
");
}
$sql = "INSERT INTO EMPLOYEES (ID,NAME,AGE,ADDRESS,SALARY) VALUES (2, 'Khilan', 
25, 'Delhi', 1500.00 )";
 if($mysqli->query($sql)){
    printf("Second record inserted successfully...!
");
}
$sql = "INSERT INTO EMPLOYEES (ID,NAME,AGE,ADDRESS,SALARY) VALUES (3, 'kaushik', 
23, 'Kota', 2000.00 )";
if($mysqli->query($sql)){
    printf("Third record inserted successfully...!
");
}
//显示表记录
$sql = "SELECT * FROM EMPLOYEES";
if($result = $mysqli->query($sql)){
    printf("Table records: 
");
    while($row = mysqli_fetch_array($result)){
        printf("ID: %d, NAME: %s, AGE: %d, ADDRESS: %s, SALARY: %f", 
            $row['ID'],
            $row['NAME'],
            $row['AGE'],
            $row['ADDRESS'],
            $row['SALARY']);
            printf("
");
    }
}
//现在让我们将表格数据导出到 csv 文件
$sql = "SELECT ID, NAME, AGE, ADDRESS, SALARY FROM EMPLOYEES INTO OUTFILE 'C:/ProgramData/mysql8/MySQL Server 8.0/Uploads/EMPLOYEES_BACKUP.csv' FIELDS ENCLOSED BY '' TERMINATED BY ';' ESCAPED BY '' LINES TERMINATED BY '
'";
if($result = $mysqli->query($sql)){
   printf("Table data exported successfully....!
");
   print_r($result , "
");
}
//现在让我们创建一个客户表
$sql = "CREATE TABLE CUSTOMERS( ID INT NOT NULL, NAME VARCHAR(20) NOT NULL, AGE INT NOT NULL, ADDRESS CHAR(25) NOT NULL, SALARY DECIMAL(18, 2), PRIMARY KEY(ID) )";
if($mysqli->query($sql)){
    printf("Customers table created successfully...!
");
}
//现在让我们将员工表数据 csv 文件导入到客户表中
$sql = "LOAD DATA INFILE 'C:/ProgramData/mysql8/MySQL Server 8.0/Uploads/EMPLOYEES_BACKUP.csv' INTO TABLE CUSTOMERS FIELDS TERMINATED BY ';' OPTIONALLY ENCLOSED BY '' LINES TERMINATED BY '
'";
if($mysqli->query($sql)){
    printf("CSV file data imported successfully into Customers table....!
");
}
//打印customers表记录
$sql = "SELECT * FROM CUSTOMERS";
if($result = $mysqli->query($sql)){
    printf("Customers table records after importing csv file data into it: 
");
    while($row = mysqli_fetch_array($result)){
        printf("ID: %d, NAME: %s, AGE: %d, ADDRESS: %s, SALARY: %f", 
            $row['ID'],
            $row['NAME'],
            $row['AGE'],
            $row['ADDRESS'],
            $row['SALARY']);
            printf("
");
    }
}
if($mysqli->error){
    printf("Error message: ", $mysqli->error);
}
$mysqli->close();

输出

获得的输出如下所示 -

Employees table created successfully...!
First record inserted successfully...!
Second record inserted successfully...!
Third record inserted successfully...!
Table records:
ID: 1, NAME: Ramesh, AGE: 32, ADDRESS: Ahmedabad, SALARY: 2000.000000
ID: 2, NAME: Khilan, AGE: 25, ADDRESS: Delhi, SALARY: 1500.000000
ID: 3, NAME: kaushik, AGE: 23, ADDRESS: Kota, SALARY: 2000.000000
Table data exported successfully....!
Customers table created successfully...!
CSV file data imported successfully into Customers table....!
Customers table records after importing csv file data into it:
ID: 1, NAME: Ramesh, AGE: 32, ADDRESS: Ahmedabad, SALARY: 2000.000000
ID: 2, NAME: Khilan, AGE: 25, ADDRESS: Delhi, SALARY: 1500.000000
ID: 3, NAME: kaushik, AGE: 23, ADDRESS: Kota, SALARY: 2000.000000