php中二维数组怎么写入到数据库

PHP中二维数组高效写入数据库的完整指南

在PHP开发中，经常需要将二维数组数据批量写入数据库，例如处理表单提交、导入Excel数据或API接口数据等场景，本文将详细介绍如何高效、安全地将二维数组数据写入数据库,包括多种实现方法和最佳实践。

准备工作

在开始之前,确保你已经：

建立了数据库连接（可以使用MySQLi或PDO）
准备好了目标数据表结构
确保PHP有足够的权限执行数据库操作

基础实现方法

使用循环逐条插入（简单但效率较低）

// 假设我们有一个二维数组
$data = [
    ['name' => '张三', 'age' => 25, 'email' => 'zhangsan@example.com'],
    ['name' => '李四', 'age' => 30, 'email' => 'lisi@example.com'],
    // 更多数据...
];
// 数据库连接
$conn = new mysqli('localhost', 'username', 'password', 'database');
if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}
// 循环插入数据
foreach ($data as $item) {
    $stmt = $conn->prepare("INSERT INTO users (name, age, email) VALUES (?, ?, ?)");
    $stmt->bind_param("sis", $item['name'], $item['age'], $item['email']);
    $stmt->execute();
    $stmt->close();
}
$conn->close();
echo "数据插入成功";

缺点：每次插入都会执行一次SQL语句,当数据量大时效率低下。

使用批量插入（推荐方法）

// 数据库连接
$conn = new mysqli('localhost', 'username', 'password', 'database');
// 准备SQL语句
$sql = "INSERT INTO users (name, age, email) VALUES ";
$values = [];
$params = [];
$types = [];
// 构建批量插入语句
foreach ($data as $item) {
    $values[] = "(?, ?, ?)";
    $params[] = &$item['name'];
    $params[] = &$item['age'];
    $params[] = &$item['email'];
    $types[] = 's'; // name是字符串
    $types[] = 'i'; // age是整数
    $types[] = 's'; // email是字符串
}
$sql .= implode(',', $values);
// 绑定参数
$stmt = $conn->prepare($sql);
if (!empty($params)) {
    $stmt->bind_param(implode('', $types), ...$params);
}
// 执行
$stmt->execute();
$stmt->close();
$conn->close();
echo "批量插入成功";

优点：只需执行一次SQL语句,大大提高插入效率。

使用PDO实现批量插入

PDO（PHP Data Objects）提供了更灵活的数据库操作方式：

// 数据库连接
try {
    $pdo = new PDO('mysql:host=localhost;dbname=database', 'username', 'password');
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch (PDOException $e) {
    die("连接失败: " . $e->getMessage());
}
// 准备SQL语句
$sql = "INSERT INTO users (name, age, email) VALUES (:name, :age, :email)";
$stmt = $pdo->prepare($sql);
// 开始事务
$pdo->beginTransaction();
try {
    // 批量插入
    foreach ($data as $item) {
        $stmt->execute([
            ':name' => $item['name'],
            ':age' => $item['age'],
            ':email' => $item['email']
        ]);
    }
    // 提交事务
    $pdo->commit();
    echo "批量插入成功";
} catch (Exception $e) {
    // 回滚事务
    $pdo->rollBack();
    echo "插入失败: " . $e->getMessage();
}

优点：事务支持确保数据一致性,代码更简洁。

使用LOAD DATA INFILE（超大数据量时）

对于超大数据量（数万条以上），可以使用MySQL的LOAD DATA INFILE命令：

// 将二维数组转换为CSV格式
$csv = "name,age,email\n";
foreach ($data as $item) {
    $csv .= "{$item['name']},{$item['age']},{$item['email']}\n";
}
// 保存到临时文件
$tmpFile = tmpfile();
fwrite($tmpFile, $csv);
fseek($tmpFile, 0);
// 获取文件路径
$meta = stream_get_meta_data($tmpFile);
$tmpFilePath = $meta['uri'];
// 数据库连接
$conn = new mysqli('localhost', 'username', 'password', 'database');
// 执行LOAD DATA INFILE
$sql = "LOAD DATA LOCAL INFILE '$tmpFilePath' 
        INTO TABLE users 
        FIELDS TERMINATED BY ',' 
        LINES TERMINATED BY '\n' 
        IGNORE 1 LINES";
if ($conn->query($sql) === TRUE) {
    echo "数据导入成功";
} else {
    echo "导入失败: " . $conn->error;
}
// 关闭文件和连接
fclose($tmpFile);
$conn->close();

注意：需要确保MySQL配置中允许LOAD DATA INFILE操作。

最佳实践和注意事项

使用预处理语句：防止SQL注入攻击
事务处理：确保数据一致性，特别是在批量插入时
错误处理：妥善处理数据库连接和执行过程中的错误
性能优化：
- 合理设置批量插入的大小（通常100-1000条一批）
- 对于超大数据量，考虑分批处理
内存管理：大数据量时注意内存消耗，可以分批处理
字段映射：确保数组键名与数据库字段名对应

完整示例代码

/**
 * 将二维数组批量插入数据库
 * @param array $data 二维数组数据
 * @param string $table 表名
 * @param PDO $pdo PDO数据库连接
 * @return bool
 */
function batchInsertArray($data, $table, $pdo) {
    if (empty($data) || !is_array($data)) {
        return false;
    }
    // 获取字段名
    $fields = array_keys($data[0]);
    $placeholders = array_fill(0, count($fields), '?');
    // 构建SQL
    $sql = "INSERT INTO {$table} (" . implode(',', $fields) . ") 
            VALUES (" . implode(',', $placeholders) . ")";
    try {
        $stmt = $pdo->prepare($sql);
        // 开始事务
        $pdo->beginTransaction();
        // 绑定参数并执行
        foreach ($data as $row) {
            $values = array_values($row);
            $stmt->execute($values);
        }
        // 提交事务
        $pdo->commit();
        return true;
    } catch (Exception $e) {
        // 回滚事务
        $pdo->rollBack();
        error_log("批量插入失败: " . $e->getMessage());
        return false;
    }
}
// 使用示例
try {
    $pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '');
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $data = [
        ['name' => '张三', 'age' => 25, 'email' => 'zhangsan@example.com'],
        ['name' => '李四', 'age' => 30, 'email' => 'lisi@example.com'],
        ['name' => '王五', 'age' => 28, 'email' => 'wangwu@example.com']
    ];
    if (batchInsertArray($data, 'users', $pdo)) {
        echo "数据插入成功";
    } else {
        echo "数据插入失败";
    }
} catch (PDOException $e) {
    echo "数据库错误: " . $e->getMessage();
}

将二维数组写入数据库是PHP开发中的常见任务,选择合适的方法取决于数据量大小和性能要求：