csv表导入mysql php函数

<?php
function import_csv_to_mysql($csv_file, $table_name, $db_host, $db_user, $db_pass, $db_name) {
    // 连接数据库
    $conn = mysqli_connect($db_host, $db_user, $db_pass, $db_name);
    if (!$conn) {
        die("连接失败: " . mysqli_connect_error());
    }

    // 打开CSV文件
    if (($handle = fopen($csv_file, "r")) !== FALSE) {
        $header = fgetcsv($handle); // 读取表头
        while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) {
            $values = array();
            foreach ($header as $key => $value) {
                $values[] = "'" . mysqli_real_escape_string($conn, $data[$key]) . "'";
            }
            $sql = "INSERT INTO $table_name (" . implode(", ", $header) . ") VALUES (" . implode(", ", $values) . ")";
            if (!mysqli_query($conn, $sql)) {
                echo "插入失败: " . mysqli_error($conn) . "\n";
            }
        }
        fclose($handle);
    }

    // 关闭数据库连接
    mysqli_close($conn);
}

// 使用示例
import_csv_to_mysql('data.csv', 'my_table', 'localhost', 'user', 'password', 'my_database');
?>