1

我有一个passenger_log有四列的表psngr_id（不一定是唯一的）arrival_dt_tm，departure_dt_tm和timediff（乘客上次出发日期和下次到达日期之间的差异）。

从此表中，我希望能够仅选择时差小于 24 小时的行，并选择下一行。

我使用的是 SQL 2008，所以不能真正使用最新版本LEAD和LAG功能。

现有表 -

local_passenger_id arrival_date_time departure_date_time timediff
-----------------------------------------------------------------

00F9P0L193  28/07/2013 23:30    28/07/2013 23:36    0.516666
00F9P0L193  29/07/2013 00:07    29/07/2013 03:16    NULL
01MLEMFDUK  12/10/2008 16:43    12/10/2008 20:28    21.116666
01MLEMFDUK  13/10/2008 17:35    13/10/2008 20:19    3889.9
01MLEMFDUK  24/03/2009 22:13    25/03/2009 01:23    32268
01MLEMFDUK  28/11/2012 13:23    28/11/2012 14:10    676.583333
01MLEMFDUK  26/12/2012 18:45    26/12/2012 19:27    20.433333
01MLEMFDUK  27/12/2012 15:53    27/12/2012 17:07    289.2
01MLEMFDUK  08/01/2013 18:19    08/01/2013 19:00    NULL
02CJHH6KAJ  27/02/2011 09:48    27/02/2011 11:56    10167.25
02CJHH6KAJ  26/04/2012 03:11    26/04/2012 06:42    44.566666
02CJHH6KAJ  28/04/2012 03:16    28/04/2012 07:06    23.233333
02CJHH6KAJ  29/04/2012 06:20    29/04/2012 09:45    NULL

所需的输出 -

local_passenger_id arrival_date_time departure_date_time timediff_mins
----------------------------------------------------------------------

00F9P0L193  28/07/2013 23:30    28/07/2013 23:36    0.516666
00F9P0L193  29/07/2013 00:07    29/07/2013 03:16    NULL
01MLEMFDUK  12/10/2008 16:43    12/10/2008 20:28    21.116666
01MLEMFDUK  13/10/2008 17:35    13/10/2008 20:19    3889.9
01MLEMFDUK  26/12/2012 18:45    26/12/2012 19:27    20.433333
01MLEMFDUK  27/12/2012 15:53    27/12/2012 17:07    289.2
02CJHH6KAJ  28/04/2012 03:16    28/04/2012 07:06    23.233333
02CJHH6KAJ  29/04/2012 06:20    29/04/2012 09:45    NULL
4

2 回答 2

1

尝试这个

WITH cte(id,pid,adt,ddt,tdif) AS
(SELECT ROW_NUMBER() OVER (ORDER BY pid,adt), pid,adt,ddt,tdif FROM pass),
 hit(id) AS
(SELECT id FROM cte c1 WHERE EXISTS 
  (SELECT 1 FROM cte c2 WHERE c2.id=c1.id+1 AND c2.pid=c1.pid AND c1.tdif<24) )

SELECT pid,adt,ddt,tdif FROM cte WHERE id IN 
  (SELECT id FROM hit UNION SELECT id+1 FROM hit)

基于表

INSERT INTO pass
    ([pid], [adt], [ddt], [tdif])
VALUES
    ('00F9P0L193', '28.07.2013 23:30', '28.07.2013 23:36', '0.516666'),
    ('00F9P0L193', '29.07.2013 00:07', '29.07.2013 03:16', NULL),
    ('01MLEMFDUK', '12.10.2008 16:43', '12.10.2008 20:28', '21.116666'),
    ('01MLEMFDUK', '13.10.2008 17:35', '13.10.2008 20:19', '3889.9'),
    ('01MLEMFDUK', '24.03.2009 22:13', '25.03.2009 01:23', '32268'),
    ('01MLEMFDUK', '28.11.2012 13:23', '28.11.2012 14:10', '676.583333'),
    ('01MLEMFDUK', '26.12.2012 18:45', '26.12.2012 19:27', '20.433333'),
    ('01MLEMFDUK', '27.12.2012 15:53', '27.12.2012 17:07', '289.2'),
    ('01MLEMFDUK', '08.01.2013 18:19', '08.01.2013 19:00', NULL),
    ('02CJHH6KAJ', '27.02.2011 09:48', '27.02.2011 11:56', '10167.25'),
    ('02CJHH6KAJ', '26.04.2012 03:11', '26.04.2012 06:42', '44.566666'),
    ('02CJHH6KAJ', '28.04.2012 03:16', '28.04.2012 07:06', '23.233333'),
    ('02CJHH6KAJ', '29.04.2012 06:20', '29.04.2012 09:45', NULL)
;

常用表表达式：

  • cte是一个编号列表（我只是row_number()在所有行上使用，不管乘客 ID）
  • hit是一个表，其中仅包含同一乘客的下一行时差 <24 小时的行。

在主要我通过使用 SUB- 将行和紧随其后的行select绑定在一起hitSELECTUNION

输出：

pid,    adt,    ddt,    tdif
00F9P0L193  28.07.2013 23:30    28.07.2013 23:36    0.516666
00F9P0L193  29.07.2013 00:07    29.07.2013 03:16    
01MLEMFDUK  12.10.2008 16:43    12.10.2008 20:28    21.116666
01MLEMFDUK  13.10.2008 17:35    13.10.2008 20:19    3889.9
01MLEMFDUK  26.12.2012 18:45    26.12.2012 19:27    20.433333
01MLEMFDUK  27.12.2012 15:53    27.12.2012 17:07    289.2
02CJHH6KAJ  28.04.2012 03:16    28.04.2012 07:06    23.233333
02CJHH6KAJ  29.04.2012 06:20    29.04.2012 09:45

只需一个 CTE 也可以做到这一点：

;WITH cte AS 
(SELECT ROW_NUMBER() OVER (ORDER BY pid,adt) id,pid,adt,ddt,tdif FROM pass)
SELECT pid,adt,ddt,tdif FROM cte c0 WHERE EXISTS (
 SELECT 1 FROM cte c1 WHERE c1.id IN(c0.id,c0.id-1) AND EXISTS 
   (SELECT 1 FROM cte c2 WHERE c2.id=c1.id+1 AND c2.pid=c1.pid AND c1.tdif<24) )

可能不是那么容易阅读，但工作方式相同......

于 2013-09-17T16:02:02.833 回答
0 
SELECT T.local_passenger_id, T.arrival_date_time, T.departure_date_time, T.timediff FROM passenger_log T
WHERE T.timediff < 24
UNION
SELECT T2.local_passenger_id, T2.arrival_date_time, T2.departure_date_time, T2.timediff FROM 
(SELECT *, RANK() OVER (PARTITION BY local_passenger_id ORDER BY arrival_date_time) AS Ranked FROM passenger_log) T1
LEFT JOIN 
(SELECT *, RANK() OVER (PARTITION BY local_passenger_id ORDER BY arrival_date_time) AS Ranked FROM passenger_log) T2
ON T1.local_passenger_id = T2.local_passenger_id AND T1.Ranked + 1 = T2.Ranked
WHERE T1.timediff < 24

ORDER BY local_passenger_id, arrival_date_time
于 2013-09-17T15:41:06.677 回答