1

我在 PostgreSQL 中有一个 CASE 查询的情况。

我的表（“statut_existenta_pf”）看起来像这里的图片http://cl.ly/0L1Q2f3v3L0s3V1p3P3X

我编写了以下查询，它应该与该表的结果相匹配：

SELECT p.*, se.se_id_statut, ne.ne_denumire
  FROM persoane_fizice p,
       statut_existenta_pf se,
       nom_statut_existenta ne
  WHERE p.pf_id = :id_pf
    AND se.se_id_pf = p.pf_id
    AND se.se_id_statut IN 
        (CASE 
           WHEN se_data_inceput IS NULL THEN
             (SELECT se_id_statut FROM statut_existenta_pf
                WHERE se_id_pf = :id_pf
                ORDER BY se_id DESC LIMIT 1)
           WHEN se_data_inceput IS NOT NULL AND se_data_sfarsit IS NULL THEN
             (SELECT se_id_statut FROM statut_existenta_pf
                WHERE se_id_pf = :id_pf
                ORDER BY se_id DESC LIMIT 1)
           ELSE
             (SELECT se_id_statut FROM statut_existenta_pf
                WHERE se_id_pf = :id_pf
                  AND CURRENT_DATE BETWEEN se_data_inceput AND se_data_sfarsit)
        END) 
    AND se.se_id_statut = ne.ne_id

问题是我得到 0 个结果，我应该返回一个结果，即“se_data_inceput”为“2010-03-31”且“se_data_sfarsit”为空的结果。

有任何想法吗？

谢谢你。

4

2 回答 2

1

看起来您在statut_existenta_pf表中保留了基于时间的对象实例。

我使用了以下测试平台：

CREATE TABLE statut_existenta_pf (
    se_id                   int4,
    se_id_pf                int4,
    se_id_statut            int2,
    se_data_inceput         date,
    se_data_sfarsit         date
); -- the rest fields are irrelevant for this example
CREATE TABLE nom_statut_existenta (
    id           int2,
    ne_denumire  varchar(30)
); -- my wild guess bout this table
CREATE TABLE persoane_fizice (
    pf_id           int4,
    pf_name         varchar(60)
); --- same here, irrelevant for the example

使用以下测试数据：

INSERT INTO nom_statut_existenta VALUES
    (1, 'Status: Vive'), (2, 'Status: Morto');
INSERT INTO persoane_fizice VALUES (3489, 'Giuseppe Garibaldi');
INSERT INTO statut_existenta_pf VALUES
    (4275, 3489, 2, '2012-04-18', '2012-05-18'),
    (3669, 3489, 1, '2010-03-31', NULL);

现在，您正在此基于时间的系列中搜索当前对象。您的逻辑似乎如下：

  1. 如果se_data_inceput是NULL（我将此列视为instance_start_date），则获取给定的最新修订的值persoane_fizice；
  2. 如果se_data_sfarsit是NULL（instance_end_date我相信）那么再次获取最新修订的值；
  3. 如果两列都是NOT NULL，则获取这些日期之间的修订值。

您没有提到设置中的约束，但我认为拥有多个日期范围重叠的条目是非法的。

以下是我如何重写您的初始查询，产生正确的结果：

WITH max_se_id AS (
SELECT se_id_pf, max(se_id) se_id_max FROM statut_existenta_pf
 GROUP BY se_id_pf
)
SELECT p.*, se.se_id_statut, ne.ne_denumire
  FROM persoane_fizice p
  JOIN statut_existenta_pf se ON se.se_id_pf = p.pf_id
  JOIN nom_statut_existenta ne ON ne.id = se.se_id_statut
  JOIN max_se_id mse ON se.se_id_pf = mse.se_id_pf
 WHERE p.pf_id = :id_pf
   AND se.se_id_statut IN 
    (CASE 
       WHEN se_data_inceput IS NULL THEN mse.se_id_max
       WHEN se_data_inceput IS NOT NULL AND se_data_sfarsit IS NULL THEN mse.se_id_max
       ELSE se_id_statut
    END) ;

但是这个查询会产生不正确的结果，对于给定的测试平台，它会返回最高的修订版本se_id，尽管它的开始时间在未来。

我正在使用相同的方法来保留数据库中对象的历史记录，我建议改用这样的查询：

SELECT p.*, se.se_id_statut, ne.ne_denumire
  FROM persoane_fizice p
  JOIN statut_existenta_pf se ON se.se_id_pf = p.pf_id
  JOIN nom_statut_existenta ne ON ne.id = se.se_id_statut
 WHERE p.pf_id = :id_pf
   AND statement_timestamp() BETWEEN coalesce(se.se_data_inceput, now())
       AND coalesce(se.se_data_sfarsit, clock_timestamp());

如果se_data_inceput+se_data_sfarsit列中有不重叠的日期，则此查询将产生当前活动的行。

我在用着：

  • now()作为 的默认值se_data_inceput，这会产生当前事务的开始时间；
  • statement_timestamp()作为当前时间点和
  • clock_timestamp()作为se_data_sfarsit.

使用这种组合，您总是可以期望您的查询从历史表中返回当前对象实例。

我希望我的假设是正确的。

于 2012-04-17T20:03:56.213 回答
0

我不确定是否CASE可以返回一个列表，您正在获得该列表，ELSE也许其他人可以启发我们。同时，我认为您可以将se.se_id_statut IN部分放入CASE：

AND 
    (CASE 
       WHEN se_data_inceput IS NULL THEN
         se.se_id_statut IN (SELECT se_id_statut FROM statut_existenta_pf
            WHERE se_id_pf = :id_pf
            ORDER BY se_id DESC LIMIT 1)
       WHEN se_data_inceput IS NOT NULL AND se_data_sfarsit IS NULL THEN
         se.se_id_statut IN (SELECT se_id_statut FROM statut_existenta_pf
            WHERE se_id_pf = :id_pf
            ORDER BY se_id DESC LIMIT 1)
       ELSE
         se.se_id_statut IN  (SELECT se_id_statut FROM statut_existenta_pf
            WHERE se_id_pf = :id_pf
              AND CURRENT_DATE BETWEEN se_data_inceput AND se_data_sfarsit)
    END)
于 2012-04-17T16:59:43.107 回答