Pull to refresh

SELECT...WHERE запросы в Cassandra 2.0 на CQL3

NoSQLBig Data
Tutorial
Cassandra (далее C*) ограничивает WHERE запросы из-за своей внутренней структуры. Эта статья вам покажется сложной, запутанной, если вы не читали первую статью из цикла, где я рассказывал как устроена С*. Прочтите её, пожалуйста, прежде чем приступать к этой.

Цель этой статьи — выступать справочником для C* новичков.

Некоторые отличия CQL от SQL


В SELECT запросах Cassandra Query Language (CQL) отсутсвутют привычные нам SQL операции JOIN, GROUP BY. А операция WHERE сильно урезана. В SQL вы можете фильтровать по любой колонке, тогда как в CQL только по распределительным ключам (partition key), кластерным ключам (clustering columns) и вторичным индексам.
Заметка: В С* 2.0 можно создавать вторичные INDEX-ы у любой колонки наподобие SQL индексов. Фактически же, вторичные индексы Кассандры — это скрытая от вас дополнительная таблица, поэтому производительность WHERE запросов по ним хуже запросов по ключевым колонкам.


Disclaimer


  • CQL видоизменяется от релиза к релизу. Данная статья отображает состояние версии 3. Писалась когда последняя версия была 3.1.2.
  • Все примеры производятся над таблицей ad_click, созданной в предыдщуей, второй по счету, статье. Также там объяснена терминология используемая в этой статье. Тоже рекомендую хотя бы взглянуть.
CREATE TABLE ad_click (
  reseller_id text,
  day text, -- day in the format of 'YYYY-MM-DD'
  time timestamp,
  ad_id text,
  amount float,
  PRIMARY KEY ((reseller_id, day), time, ad_id) -- распределительный ключ (reseller_id,day) и кластерные ключи (time,ad_id)
)
WITH CLUSTERING ORDER BY (time DESC);


Фильтрация данных используя WHERE


Грубо говоря слово «фильтрация» тут неуместно. Правильнее сказать поиск. C* почти не даёт возможности фильтровать.

Каждый WHERE запрос говорит Кассандре найти ноду, в которой хранится строка и передать туда запрос.

Сравнение колонок друг с другом

Так как JOIN-ов нет, то и сравнивать колонки друг с другом нельзя.
SELECT * from ad_click WHERE 
maxTimeuuid(day) = maxTimeuuid(3141592653589); -- ОШИБКА;


AND, OR

Множественные условия WHERE запросов нельзя объединять оператором OR, работают только AND. И всего несколько операторов сравнения работает, да и то не всегда.

Равенство =

Использование операторов равенства (=) почти не ограничено. Оно ограничено колонками-ключами и колонками-индексами. А также нужно обязательно сравнить все предыдущие колонки-ключи, прежде чем сравнить следующий.

Правильно:
SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND -- OK
day = '2013-11-29' AND -- OK
time = 3141592653589 AND -- OK
ad_id = '890_567_234'; -- OK

Неправильно:
SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND 
day = '2013-11-29' AND 
amount = 0; -- ОШИБКА! Это не ключевая колонка.

SELECT * FROM ad_click WHERE 
day = '2013-11-29' AND -- ОШИБКА! Забыли сравнить колонку reseller_id.
time = 3141592653589 AND 
ad_id = '890_567_234';

SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND 
day = '2013-11-29' AND 
ad_id = '890_567_234'; -- ОШИБКА! Забыли сравнить колонку time.


Включение IN

Использование оператора включения (IN) ограничено последней колонкой в распрделительном ключе и последней колонкой в кластерном ключе.

Правильно:
SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND 
day IN ('2013-11-28', '2013-11-29') AND -- OK
time = 3141592653589 AND 
ad_id IN ('890_567_234', '890_567_010'); -- OK

Неправильно:
SELECT * FROM ad_click WHERE 
reseller_id IN ('supaboobs') AND -- ОШИБКА! Это не последняя колонка распределительного ключа.
day = '2013-11-28' AND 
time = 3141592653589 AND
ad_id = '890_567_234';

SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND
day = '2013-11-28' AND 
time IN (3141592653589) AND  -- ОШИБКА! Это не последняя колонка кластерного ключа.
ad_id = ('890_567_234');


Оперторы сравнения = > >= < <=


Синтаксис сравнений

Имя колонки должно быть слева от оператора сравнения, значение — справа.
Правильно:
SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND -- OK
day = '2013-11-29'; -- OK

Неправильно:
SELECT * FROM ad_click WHERE 
'supaboobs' = reseller_id AND  -- ОШИБКА! Нарушен порядок оператора сравнения.
'2013-11-29' = day AND -- ОШИБКА! Нарушен порядок оператора сравнения.
3141592653589 < time;  -- ОШИБКА! Нарушен порядок оператора сравнения.


Возможности сравнений

Их можно использовать в последней колонке вашего CQL запроса, причём колонка должна быть исключительно кластерной.

Правильно:
SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND
day = '2013-11-29' AND
time >= 3141592653589; -- OK

SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND
day = '2013-11-29' AND
time = 3141592653589 AND
ad_id > '890_567_234'; -- OK

Неправильно:
SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND
day = '2013-11-29' AND
time >= 3141592653589 AND  -- ОШИБКА! Это не последняя колонка запроса.
ad_id = '890_567_234';

SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND
day = '2013-11-29' AND
time >= 3141592653589 AND
ad_id < '890_567_234';  -- ОШИБКА! Предыдущий не фильтровался операцией равенство.

SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND
day = '2013-11-29' AND
ad_id < '890_567_234';  -- ОШИБКА! Пропущена фильтрация по колонке time.

SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND
day < '2013-11-29'; -- ОШИБКА! Это не кластерная колонка.


Обходной манёвр — ALLOW FILTERING

Можно не указывать распределительный ключ, а оставить только кластерный, поставив в конец запроса ALLOW FILTERING. Все остальные ограничения сохраняются.
ВАЖНО! Timeout в этом случае очень вероятен, потому что вы пробегаемся по всем нодам, по всем строкам.


Правильно:
SELECT * FROM ad_click WHERE 
time = 3141592653589 AND -- OK
ad_id > '890_567_234' -- OK
ALLOW FILTERING;

SELECT * FROM ad_click WHERE 
time >= 3141592653589 AND -- OK
time <= 3141592653589 -- OK
ALLOW FILTERING;

Неправильно:
SELECT * FROM ad_click WHERE 
time >= 3141592653589 AND
ad_id > '890_567_234' -- ОШИБКА! Нельзя больше двух сравнений.
ALLOW FILTERING;

SELECT * FROM ad_click WHERE 
time >= 3141592653589 AND
time <= 3241592653589 AND
ad_id = '890_567_234'  -- ОШИБКА! Предыдущий не фильтровался операцией равенство.
ALLOW FILTERING;


Вторичные индексы

Вторичные индексы поддерживают исключительно оператор равенства, и всё. Запросы по вторичным индексам можно делать как с указанием других ключей, так и без.

Чтобы создать вторичный индекс следует выполнить комманду:
CREATE INDEX on ad_click (amount);


Правильно:
SELECT * FROM ad_click WHERE 
amount = 0.0075; -- OK

SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND
day = '2013-11-29' AND
time = 3141592653589 AND
ad_id = '890_567_234' AND
amount = 0.0075; -- OK

Неправильно:
SELECT * FROM ad_click WHERE 
reseller_id = 'supaboobs' AND
day = '2013-11-29' AND
time = 3141592653589 AND
ad_id = '890_567_234' AND
amount > 0.0; -- ОШИБКА! Для вторичных индексов разрешен только оператор равенства.


Заключение


Надеюсь у вас больше не возникнет вопросов «почему мой SELECT не работает?»

Источники




Предыдущая статья цикла.
Tags:CQLCQL3CassandaraWHERE
Hubs: NoSQL Big Data
Total votes 17: ↑17 and ↓0+17
Views30K

Popular right now

Top of the last 24 hours