3

我有 2 个表需要加入，以根据第一个表中的有效行获取第二个表中的最后/最新更新。

下面的代码是示例。

表 1：注册用户
此表包含在系统中注册的用户列表。当用户注册时，它会被添加到此表中。用户注册有姓名和注册时间。用户可以从系统中注销。完成此操作后，取消注册列将更新为删除用户的时间。如果该值为 NULL，则表示该用户仍处于注册状态。

CREATE TABLE users (
    entry_idx   SERIAL PRIMARY KEY,
    name        TEXT NOT NULL,
    reg_time    TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
    dereg_time  TIMESTAMP WITH TIME ZONE DEFAULT NULL  
);

表 2：用户更新
此表包含有关用户的更新。每次用户更改属性（示例位置）时，更改都会存储在此表中。由于需要在表中保留历史记录，因此必须删除任何更新。

CREATE TABLE user_updates (
    entry_idx   SERIAL PRIMARY KEY,
    name        TEXT NOT NULL,
    position    INTEGER NOT NULL,
    time        TIMESTAMP WITH TIME ZONE DEFAULT NOW()
);

所需输出
因此，鉴于上述信息，我需要获取一个仅包含当前注册用户的最后更新的新表。

测试数据
以下数据可作为上表的测试数据：

-- Register 3 users
INSERT INTO users(name) VALUES ('Person1');
INSERT INTO users(name) VALUES ('Person2');
INSERT INTO users(name) VALUES ('Person3');
-- Add some updates for all users
INSERT INTO user_updates(name, position) VALUES ('Person1', 0);
INSERT INTO user_updates(name, position) VALUES ('Person1', 1);
INSERT INTO user_updates(name, position) VALUES ('Person1', 2);
INSERT INTO user_updates(name, position) VALUES ('Person2', 1);
INSERT INTO user_updates(name, position) VALUES ('Person3', 1);
-- Unregister the 2nd user
UPDATE users SET dereg_time = NOW() WHERE name = 'Person2';

从上面，我想要第 1 个人和第 3 个人的最新更新。

尝试失败
我曾尝试使用连接和其他方法，但结果不是我想要的。这个问题与这里提出的问题几乎相同。我在答案 1 中使用了该解决方案，它确实给出了正确的答案，但是在我的系统中获得答案需要太长时间。

基于上面的链接，我创建了以下“有效”的查询：

SELECT
  t1.*
  , t2.*
FROM
  users t1
JOIN (
  SELECT
      t.*,
      row_number()
  OVER (
      PARTITION BY
        t.name
      ORDER BY t.entry_idx DESC
      ) rn
  FROM user_updates t
  ) t2
ON
  t1.name = t2.name
AND
  t2.rn = 1
WHERE
  t1.dereg_time IS NULL;

问题 上述查询的问题是需要很长时间才能完成。表 1 包含一小部分用户，而表 2 包含大量更新。我认为查询在处理 2 个表的方式上可能效率低下（基于我对查询的有限理解）。从 pgAdmin 的解释来看，在加入注册表之前，它会在第一次更新时进行大量排序和聚合。

问题
如何制定查询以高效、快速地为注册用户获取最新更新？

4

2 回答 2

1

distinct on对于这种类型的查询，PostgreSQL 有一个特殊的语法：

select distinct on(t1.name)
--it's better to specify columns explicitly, * just for example
    t1.*, t2.*           
from users as t1
    left outer join user_updates as t2 on t2.name = t1.name
where t1.dereg_time is null
order by t1.name, t2.entry_idx desc

sql fiddle demo

您可以尝试一下，但对我来说，您的查询也应该可以正常工作。

于 2013-09-17T11:26:06.957 回答
0

我正在使用 q1 来获取每个用户的最后更新。然后与用户一起删除已注销的条目。然后加入 q2 以获取其余的 user_update 字段。

select users.*,q2.* from users
join
(select name,max(time) t from user_updates group by name) q1
on users.name=q1.name 
join user_updates q2 on q1.t=q2.time and q1.name=q2.name
where
users.dereg_time is null

（我没有测试过。已经编辑了一些东西）

于 2013-09-17T10:31:32.527 回答