SQL Сбор заявок на основе интервала 30 минут

Question

Название, вероятно, оставляет некоторые вопросы, поэтому я подробно объясню.

У меня есть таблица (MySQL), содержащая сообщения чата, Эти сообщения содержат все столбцы datetime даты, когда они добавлены.

Теперь, когда я хочу достичь, я получаю количество сеансов, которые были у вас.

Теперь, что такое сеанс? Новый сеанс начинается с 30 минут или более с момента предыдущего сообщения.

Так, например, с данными:

2014-01-01 00:00:01 
2014-01-01 00:20:01 
2014-01-01 00:40:01 
2014-01-01 00:60:01 

будет один сеанс

2014-01-01 00:00:01 <-- 
2014-01-01 00:32:01 <-- 
2014-01-01 00:35:01 
2014-01-01 01:00:01 
2014-01-01 02:00:01 <-- 
2014-01-01 02:20:01 

Было бы три сессии, начиная заново, когда я положил стрелку на старте.

Мне не обязательно нужен пример DQL. MySQL будет в порядке, я надеюсь, что кто-то может мне помочь.

Редактировать: Ответ, приведенный ниже, кажется, работает на скрипке, но не на наших серверах MySQL, работающих под управлением 5.5.4. Удовлетворение, если это определенная настройка, или что sqlFiddle просто не работает должным образом.

Answer 1

Для моего конкретного случая я решил его с помощью запроса, как это:

SELECT * 
FROM chat c 
WHERE NOT EXISTS 
     (
     SELECT * 
     FROM chat c2 
     WHERE c2.date_add <= (c.date_add + INTERVAL 30 MINUTE) 
     AND  c2.date_add > c.date_add 
     ) 

Единственная проблема здесь в том, что я не могу видеть, когда сессия началась, но это достаточно функциональность для моего конкретного случая. Я с радостью согласимся на лучший ответ!

Answer 2

MySQL, к сожалению, не имеет так называемых оконных функций (что делает большинство других основных РСУБД), поэтому нам нужно приманить один из наших собственных. На самом деле это не так сложно, но было бы неплохо иметь поддержку ...

В любом случае, я сказал, что нам нужно было приманить функцию LAG(), но это действительно так, что мы можем сравнить с увеличением группирования счетчика, так что мы можем на самом деле вырезать шаг, Сорт:

SELECT sentAt, 
     @Session := IF(sentAt < @SessionBoundary, @Session, @Session + 1) AS session, 
     @SessionBoundary := ADDTIME(sentAt, '00:30:00') AS sessionBoundary 
FROM Message 
JOIN (SELECT @Session := 0) n 
ORDER BY sentAt 

SQL Fiddle Example

Критически, обратите внимание, что, как это хорошая практика, чтобы использовать эксклюзивны верхнюю границу "(<) для положительные типы непрерывного диапазона (например, date/time/timestamps), это 30th минута, что на самом деле начинается ваша новая сессия. То есть, начальное сообщение в 13:00 означает, что следующий сеанс начинается в 13:30 (без дополнительных сообщений). У этого есть приятное свойство сделать все, что выстраивается красиво, и что мне не нужно беспокоиться о странном поведении с дробными секундами, которые я, возможно, не указал.
В любом случае, это возвращает результаты так:

sentAt    session sessionBoundary 
2014-01-01 00:00:01 1  2014-01-01 00:30:01 
2014-01-01 00:32:01 2  2014-01-01 01:02:01 
2014-01-01 00:35:01 2  2014-01-01 01:05:01 
2014-01-01 01:00:01 2  2014-01-01 01:30:01 
2014-01-01 02:00:01 3  2014-01-01 02:30:01 
2014-01-01 02:20:01 3  2014-01-01 02:50:01 

Теперь, так как все, что вам нужен был простой подсчет, сколько session s были, вы можете обернуть его в качестве подзапроса:

SELECT MAX(session) 
FROM (SELECT sentAt, 
      @Session := IF(sentAt < @SessionBoundary, @Session, @Session + 1) AS session, 
      @SessionBoundary := ADDTIME(sentAt, '00:30:00') AS sessionBoundary 
     FROM Message 
     JOIN (SELECT @Session := 0) n 
     ORDER BY sentAt) MessageSession 

(Примечание:. по какой-то причине я не понимаю, используя первоначальную работу в качестве подзапроса является причиной скрипку, чтобы начать на 0 вместо 1, что и до Пожалуйста, проверьте это на вашем сервере,s вам может понадобиться инициализировать с помощью @Session = 1 вместо 0 или использовать что-то вроде COUNT(DISTINCT session)).

... И все готово.

---

Хотя вы только перечисленные желая граф, как только вы сеанс группировки вы можете иметь все виды весело с вашими данными. Теперь тривиально получить MAX(sentAt)/MIN(sentAt) для каждой группы, количество сообщений в группе или что-то еще. Например, вы могли бы сказать, «найти все давно запущенные сеансы» через что-то вроде этого:

SELECT session, 
     MIN(sentAt) AS firstMessageAt, MAX(sentAt) AS lastMessageAt, COUNT(*) AS messages 
FROM (SELECT sentAt, 
      @Session := IF(sentAt < @SessionBoundary, @Session, @Session + 1) AS session, 
      @SessionBoundary := ADDTIME(sentAt, '00:30:00') AS sessionBoundary 
     FROM Message 
     JOIN (SELECT @Session := 0) n 
     ORDER BY sentAt) MessageSession 
GROUP BY session 
HAVING ADDTIME(MIN(sentAt), '24:00:00') < MAX(sentAt) 

(найти всю сессию, которая уже в течение не менее 24 часов)

Answer 3

Твердая частью является то, что SQL является не процедурный язык, когда проблема является процедурной.

Ваше предложение - разумный запрос, который может быть выполнен в чистом SQL. Если вы хотите, чтобы идти дальше, я бы посоветовал вам использовать процедурный сценарий, который может быть записан на многих языках, Python, Perl, Ruby, ...

В языке псевдо, это может быть:

long last=-1800 // time of previous line 
long beg = -1 // begin time for current session 
CREATE_QUERY_FOR : SELECT UNIX_TIMESTAMP(dat) FROM chat ORDER BY dat 
LOOP_PER_LINE_FETCHED getting dat 

if (dat - last > 30 * 60) 
then 
    if last != -1 // we had a session 
    then NOTE SESSION begin at beg and ending at last 
    endif 

    beg = dat // start a new session 
endif 

last = dat 

END_LOOP 

ИМХО это единственный способ (или, по крайней мере, самый простой и эффективный), чтобы получить все сеансы с начала и конца - но я должен признать, это не может быть то, что вы просите ...

Answer 4

SELECT distinct * 
FROM chat c 
WHERE NOT EXISTS 
     (
     SELECT * 
     FROM chat c2 
     WHERE c2.date_add > (c.date_add - INTERVAL 30 MINUTE) 
     AND  c2.date_add < c.date_add 
     )