PHP从MySQL两字段获取唯一记录及私信表最近5个对话查询

首先得明确你的场景——大多时候这种需求出现在处理双向关联的数据，比如私信、好友关系表，两个字段（比如sender_id和receiver_id）会形成重复配对，比如(1,2)和(2,1)其实是同一个对话，咱们需要把这些重复项去掉，拿到唯一的关联记录。

核心解法：用MySQL函数统一双向字段顺序 #

MySQL自带的*LEAST()和GREATEST()*函数可以帮你把两个字段按数值大小排序，这样不管是(1,2)还是(2,1)都会被转换成(1,2)，之后再分组就能得到唯一的对话对了。

举个实际例子，假设你的表叫private_messages，字段是sender_id（发件人ID）和receiver_id（收件人ID），要获取当前登录用户（ID=1）参与的所有唯一对话：

SELECT 
  LEAST(sender_id, receiver_id) AS user_a,
  GREATEST(sender_id, receiver_id) AS user_b
FROM private_messages
WHERE sender_id = 1 OR receiver_id = 1
GROUP BY user_a, user_b;

结合PHP的处理逻辑 #

拿到数据库返回的结果后，你可以用PHP循环处理，这里推荐用PDO（比mysqli更安全灵活）：

// 假设你已经建立了PDO连接，存在变量$pdo中
$currentUserId = 1;
$sql = "SELECT 
          LEAST(sender_id, receiver_id) AS user_a,
          GREATEST(sender_id, receiver_id) AS user_b
        FROM private_messages
        WHERE sender_id = ? OR receiver_id = ?
        GROUP BY user_a, user_b";

// 预处理SQL，防止SQL注入
$stmt = $pdo->prepare($sql);
$stmt->execute([$currentUserId, $currentUserId]);
$uniqueConversations = $stmt->fetchAll(PDO::FETCH_ASSOC);

// 遍历结果，拿到每个对话的另一方ID
foreach ($uniqueConversations as $conv) {
    $otherUserId = $conv['user_a'] == $currentUserId ? $conv['user_b'] : $conv['user_a'];
    echo "对话对象：用户ID {$otherUserId}\n";
}

如果你的需求不是双向关联去重，而是单纯把两个字段的所有值合并后去重（比如把field1和field2的内容全部取出来，去掉重复值），那可以用UNION关键字：

SELECT field1 AS unique_value FROM your_table
UNION
SELECT field2 AS unique_value FROM your_table;

注意UNION会自动去重，如果你不想去重就用UNION ALL，按需选择就行。

虽然你提到表结构如图，但我先假设常见的私信表结构（如果实际字段名不同，你对应调整就行）：
messages表包含这些字段：

• id：消息主键（自增）
• sender_id：发件人ID
• receiver_id：收件人ID
• content：消息内容
• sent_at：发送时间（datetime类型）

实现思路 #

要搞定这个需求，咱们分三步走：

• 找出用户ID=1参与的所有唯一对话
• 对每个对话，找到最新的那条消息
• 按消息的发送时间倒序排列，取前5个对话

具体SQL代码 #

这里用子查询+关联表的方式，先找到每个对话的最新消息时间，再关联原表拿到对应的消息内容：

SELECT 
  m.*,
  -- 快速拿到对话的另一方ID
  CASE WHEN m.sender_id = 1 THEN m.receiver_id ELSE m.sender_id END AS other_user_id
FROM messages m
INNER JOIN (
  -- 子查询：找出每个唯一对话的最新消息时间
  SELECT 
    LEAST(sender_id, receiver_id) AS user_a,
    GREATEST(sender_id, receiver_id) AS user_b,
    MAX(sent_at) AS last_sent_at
  FROM messages
  WHERE sender_id = 1 OR receiver_id = 1
  GROUP BY user_a, user_b
  ORDER BY last_sent_at DESC
  LIMIT 5
) AS latest_convs ON 
  (LEAST(m.sender_id, m.receiver_id) = latest_convs.user_a 
   AND GREATEST(m.sender_id, m.receiver_id) = latest_convs.user_b)
  AND m.sent_at = latest_convs.last_sent_at
ORDER BY m.sent_at DESC;

PHP中的处理示例 #

还是用PDO来执行这段SQL，处理结果：

$currentUserId = 1;
$sql = "SELECT 
          m.*,
          CASE WHEN m.sender_id = ? THEN m.receiver_id ELSE m.sender_id END AS other_user_id
        FROM messages m
        INNER JOIN (
          SELECT 
            LEAST(sender_id, receiver_id) AS user_a,
            GREATEST(sender_id, receiver_id) AS user_b,
            MAX(sent_at) AS last_sent_at
          FROM messages
          WHERE sender_id = ? OR receiver_id = ?
          GROUP BY user_a, user_b
          ORDER BY last_sent_at DESC
          LIMIT 5
        ) AS latest_convs ON 
          (LEAST(m.sender_id, m.receiver_id) = latest_convs.user_a 
           AND GREATEST(m.sender_id, m.receiver_id) = latest_convs.user_b)
          AND m.sent_at = latest_convs.last_sent_at
        ORDER BY m.sent_at DESC";

$stmt = $pdo->prepare($sql);
$stmt->execute([$currentUserId, $currentUserId, $currentUserId]);
$recentConversations = $stmt->fetchAll(PDO::FETCH_ASSOC);

// 遍历输出每个对话的最后一条消息
foreach ($recentConversations as $conv) {
    echo "对话对象：用户ID {$conv['other_user_id']}\n";
    echo "最后一条消息：{$conv['content']}\n";
    echo "发送时间：{$conv['sent_at']}\n\n";
}

小补充 #

• 如果你的sent_at字段可能存在多条消息同一时间发送的情况，建议用MAX(id)代替MAX(sent_at)，因为自增ID更大的消息肯定是更晚创建的（前提是ID按时间递增）。
• 如果需要显示对话对象的昵称、头像等信息，只需要再关联用户表即可，比如在SELECT语句中加入u.nickname，然后INNER JOIN users u ON u.id = conv.other_user_id。

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