Оператор INTERSECT
возвращает только те строки, которые являются результатом как первого, так и второго запросов. Запросы должны совпадать по количеству колонок, порядку и типу. Результат INTERSECT
может содержать дублирующие строки.
Несколько операторов INTERSECT
выполняются слева направо, если скобки не указаны. Оператор INTERSECT
имеет более высокий приоритет, чем операторы UNION
и EXCEPT
.
SELECT column1 [, column2 ]
FROM table1
[WHERE condition]
INTERSECT
SELECT column1 [, column2 ]
FROM table2
[WHERE condition]
Условие может быть любым выражением в зависимости от ваших требований.
Примеры
Вот простой пример, который пересекает числа от 1 до 10 с числами от 3 до 8:
SELECT number FROM numbers(1,10) INTERSECT SELECT number FROM numbers(3,8);
Результат:
┌─number─┐
│ 3 │
│ 4 │
│ 5 │
│ 6 │
│ 7 │
│ 8 │
└────────┘
INTERSECT
полезен, если у вас есть две таблицы, которые имеют общую колонку (или колонки). Вы можете пересечь результаты двух запросов, при условии что результаты содержат одинаковые колонки. Например, предположим, что у нас есть несколько миллионов строк исторических данных по криптовалютам, которые содержат цены торгов и объем:
CREATE TABLE crypto_prices
(
trade_date Date,
crypto_name String,
volume Float32,
price Float32,
market_cap Float32,
change_1_day Float32
)
ENGINE = MergeTree
PRIMARY KEY (crypto_name, trade_date);
INSERT INTO crypto_prices
SELECT *
FROM s3(
'https://learn-clickhouse.s3.us-east-2.amazonaws.com/crypto_prices.csv',
'CSVWithNames'
);
SELECT * FROM crypto_prices
WHERE crypto_name = 'Bitcoin'
ORDER BY trade_date DESC
LIMIT 10;
┌─trade_date─┬─crypto_name─┬──────volume─┬────price─┬───market_cap─┬──change_1_day─┐
│ 2020-11-02 │ Bitcoin │ 30771456000 │ 13550.49 │ 251119860000 │ -0.013585099 │
│ 2020-11-01 │ Bitcoin │ 24453857000 │ 13737.11 │ 254569760000 │ -0.0031840964 │
│ 2020-10-31 │ Bitcoin │ 30306464000 │ 13780.99 │ 255372070000 │ 0.017308505 │
│ 2020-10-30 │ Bitcoin │ 30581486000 │ 13546.52 │ 251018150000 │ 0.008084608 │
│ 2020-10-29 │ Bitcoin │ 56499500000 │ 13437.88 │ 248995320000 │ 0.012552661 │
│ 2020-10-28 │ Bitcoin │ 35867320000 │ 13271.29 │ 245899820000 │ -0.02804481 │
│ 2020-10-27 │ Bitcoin │ 33749879000 │ 13654.22 │ 252985950000 │ 0.04427984 │
│ 2020-10-26 │ Bitcoin │ 29461459000 │ 13075.25 │ 242251000000 │ 0.0033826586 │
│ 2020-10-25 │ Bitcoin │ 24406921000 │ 13031.17 │ 241425220000 │ -0.0058658565 │
│ 2020-10-24 │ Bitcoin │ 24542319000 │ 13108.06 │ 242839880000 │ 0.013650347 │
└────────────┴─────────────┴─────────────┴──────────┴──────────────┴───────────────┘
Теперь предположим, что у нас есть таблица под названием holdings
, которая содержит список криптовалют, которыми мы владеем, а также количество монет:
CREATE TABLE holdings
(
crypto_name String,
quantity UInt64
)
ENGINE = MergeTree
PRIMARY KEY (crypto_name);
INSERT INTO holdings VALUES
('Bitcoin', 1000),
('Bitcoin', 200),
('Ethereum', 250),
('Ethereum', 5000),
('DOGEFI', 10);
('Bitcoin Diamond', 5000);
Мы можем использовать INTERSECT
, чтобы ответить на вопросы, такие как "Какие монеты мы владеем и которые торговались по цене выше $100?":
SELECT crypto_name FROM holdings
INTERSECT
SELECT crypto_name FROM crypto_prices
WHERE price > 100
Результат:
┌─crypto_name─┐
│ Bitcoin │
│ Bitcoin │
│ Ethereum │
│ Ethereum │
└─────────────┘
Это означает, что в какой-то момент времени Bitcoin и Ethereum торговались выше 100,аDOGEFIиBitcoinDiamondникогданеторговалисьвыше100 (по крайней мере, на основе данных, которые у нас есть в этом примере).
INTERSECT DISTINCT
Обратите внимание, что в предыдущем запросе у нас было множество резервов Bitcoin и Ethereum, которые торговались выше $100. Было бы неплохо убрать дублирующиеся строки (поскольку они только повторяют то, что мы уже знаем). Вы можете добавить DISTINCT
к INTERSECT
, чтобы исключить дублирующие строки из результата:
SELECT crypto_name FROM holdings
INTERSECT DISTINCT
SELECT crypto_name FROM crypto_prices
WHERE price > 100;
Результат:
┌─crypto_name─┐
│ Bitcoin │
│ Ethereum │
└─────────────┘
См. также