如何让CSV数组中未匹配数据库的记录以NULL形式返回？

我懂你的痛点——现在的查询是从数据库里捞匹配的记录，但CSV里那些没在数据库找到对应项的内容直接丢了，想要全部保留对吧？

问题出在你当前的查询逻辑：你是从members表出发做左连接，但实际上你需要把CSV里的所有记录作为“主表”，然后左连接到数据库的表，这样不管数据库有没有匹配，CSV的每一条都会留在结果里，没匹配的字段自动用NULL填充。

下面给你两种可行的方案，适配不同的数据库版本：

方案1：用CTE（公共表表达式）生成虚拟CSV表（推荐，适用于MySQL 8.0+、PostgreSQL、SQL Server等） #

这个方法不用创建物理表，直接用SQL的WITH子句把你的900条CSV数据转换成一个虚拟表，然后左连接到你的数据库表。

示例SQL #

WITH csv_records AS (
    VALUES
        (:addr0, :post0),
        (:addr1, :post1),
        -- ... 循环生成900条这样的占位符行
        (:addr899, :post899)
)
SELECT 
    -- 先把CSV里的原始字段返回，方便你对比
    cr.column1 AS csv_address,
    cr.column2 AS csv_postcode,
    -- 数据库里的字段，没匹配的就是NULL
    U.address AS db_address,
    U.postcode AS db_postcode,
    M.member_id
FROM csv_records cr
-- 关键：从虚拟CSV表出发，左连接到数据库的表
LEFT JOIN members M 
    -- 保留你原来的表关联逻辑
    LEFT JOIN users U ON M.user_id = U.id
    -- 匹配条件对应虚拟表的字段
    ON U.address LIKE CONCAT('%', cr.column1, '%')
    AND U.postcode = cr.column2

PDO实现思路 #

手动写900个占位符太麻烦，用PHP循环生成占位符和绑定值：

// 假设$csvData是你从CSV提取的数组，每个元素是['address' => 'xxx', 'postcode' => 'xxx']
$placeholders = [];
$bindParams = [];

foreach ($csvData as $idx => $row) {
    // 生成唯一的占位符名称
    $addrParam = ":addr{$idx}";
    $postParam = ":post{$idx}";
    $placeholders[] = "({$addrParam}, {$postParam})";
    // 绑定CSV里的实际值
    $bindParams[$addrParam] = $row['address'];
    $bindParams[$postParam] = $row['postcode'];
}

// 拼接VALUES子句
$valuesPart = implode(', ', $placeholders);

// 完整SQL
$sql = "
WITH csv_records AS (
    VALUES {$valuesPart}
)
SELECT 
    cr.column1 AS csv_address,
    cr.column2 AS csv_postcode,
    U.address AS db_address,
    U.postcode AS db_postcode,
    M.member_id
FROM csv_records cr
LEFT JOIN members M 
    LEFT JOIN users U ON M.user_id = U.id
    ON U.address LIKE CONCAT('%', cr.column1, '%')
    AND U.postcode = cr.column2
";

// 执行预处理查询
$stmt = $pdo->prepare($sql);
$stmt->execute($bindParams);
$allResults = $stmt->fetchAll(PDO::FETCH_ASSOC);

方案2：用临时表（适用于老版本MySQL < 8.0） #

如果你的数据库不支持CTE，就先创建一个临时表，把CSV数据批量插进去，再左连接：

步骤1：创建临时表 #

CREATE TEMPORARY TABLE csv_temp (
    address VARCHAR(255),
    postcode VARCHAR(50)
);

步骤2：批量插入CSV数据 #

用PDO的批量插入，或者预处理插入：

$insertStmt = $pdo->prepare("INSERT INTO csv_temp (address, postcode) VALUES (:addr, :post)");
foreach ($csvData as $row) {
    $insertStmt->execute([
        ':addr' => $row['address'],
        ':post' => $row['postcode']
    ]);
}

步骤3：左连接查询 #

SELECT 
    ct.address AS csv_address,
    ct.postcode AS csv_postcode,
    U.address AS db_address,
    U.postcode AS db_postcode,
    M.member_id
FROM csv_temp ct
LEFT JOIN members M 
    LEFT JOIN users U ON M.user_id = U.id
    ON U.address LIKE CONCAT('%', ct.address, '%')
    AND U.postcode = ct.postcode;

注意：临时表会在会话结束后自动删除，不用手动清理 #

几个关键细节提醒 #

• 如果你的原查询中LIKE是带通配符的（比如你之前绑定的是"%{$address}%"），记得调整关联条件里的通配符位置，避免重复加%导致匹配失败。
• 900条数据的量级不管用哪种方案，性能都不会有问题，放心用。
• 结果里的csv_address和csv_postcode是CSV里的原始值，方便你对比哪些记录没匹配到数据库。

内容的提问来源于stack exchange，提问作者cheesycoder