REDSHIFT:根据另一列中的特定值将列中的值分配给所有行
REDSHIFT: Assign value in column to all rows based on a certain value in another column
CREATE TABLE customers (
id SERIAL PRIMARY KEY,
order_date DATE,
country VARCHAR(255),
customer VARCHAR(255)
);
INSERT INTO customers
(order_date, country, customer)
VALUES
('2020-04-10', 'DE', 'user_01'),
('2020-04-11', 'DE', 'user_01'),
('2020-04-13', 'AT', 'user_01'),
('2020-04-20', 'AT', 'user_02'),
('2020-04-22', 'AT', 'user_02'),
('2020-05-19', 'DE', 'user_03'),
('2020-06-17', 'AT', 'user_04'),
('2020-06-23', 'AT', 'user_04'),
('2020-07-04', 'DE', 'user_04'),
('2020-08-19', 'NL', 'user_05'),
('2020-10-23', 'FR', 'user_05');
预期结果:
order_date | customer | first_country | second_country |
-------------|-------------|------------------|-------------------|-----------
2020-04-10 | user_01 | DE | DE |
2020-04-11 | user_01 | DE | DE |
2020-04-13 | user_01 | AT | DE |
-------------|-------------|------------------|-------------------|-----------
2020-04-20 | user_02 | AT | NULL |
2020-04-22 | user_02 | AT | NULL |
-------------|-------------|------------------|-------------------|-----------
2020-05-19 | user_03 | DE | NULL |
-------------|-------------|------------------|-------------------|-----------
2020-06-17 | user_04 | AT | DE |
2020-06-23 | user_04 | AT | DE |
2020-07-04 | user_04 | DE | DE |
-------------|-------------|------------------|-------------------|-----------
2020-08-19 | user_05 | NL | NULL |
2020-10-23 | user_05 | FR | NULL |
在上面的例子中,可能有一位顾客在 DE
和 AT
都下了订单。
对于这些客户,我想将 second_country
列中的国家 DE
分配给他们的每个 order_dates
.
参考 的回答,我尝试这样做:
SELECT
c.order_date AS order_date,
c.customer AS customer,
c.country AS first_country,
(CASE WHEN COUNT(*) FILTER (WHERE c.country = 'DE') OVER (PARTITION BY c.customer) > 0 AND
COUNT(*) FILTER (WHERE c.country = 'AT') OVER (PARTITION BY c.customer) > 0
THEN 'DE'
END) AS second_country
FROM customers c
GROUP BY 1,2,3
ORDER BY 1,2,3;
但是,在 redshift
中 FILTER
功能不可用。
我必须如何修改查询才能使其在 redshift
中也能正常工作?
只需使用 case
表达式:
SELECT c.order_date AS order_date,
c.customer AS customer,
c.country AS first_country,
(CASE WHEN SUM(CASE WHEN c.country = 'DE' THEN 1 ELSE 0 END) OVER (PARTITION BY c.customer) > 0 AND
SUM(CASE WHEN c.country = 'AT' THEN 1 ELSE 0 END) OVER (PARTITION BY c.customer) > 0
THEN 'DE'
END) AS second_country
FROM customers c
GROUP BY 1,2,3
ORDER BY 1,2,3;
实际上,您可以将其简化为:
(CASE WHEN SUM( (c.country = 'DE')::int ) OVER (PARTITION BY c.customer) > 0 AND
SUM( (c.country = 'DE')::int ) OVER (PARTITION BY c.customer) > 0
THEN 'DE'
END) AS second_country
CREATE TABLE customers (
id SERIAL PRIMARY KEY,
order_date DATE,
country VARCHAR(255),
customer VARCHAR(255)
);
INSERT INTO customers
(order_date, country, customer)
VALUES
('2020-04-10', 'DE', 'user_01'),
('2020-04-11', 'DE', 'user_01'),
('2020-04-13', 'AT', 'user_01'),
('2020-04-20', 'AT', 'user_02'),
('2020-04-22', 'AT', 'user_02'),
('2020-05-19', 'DE', 'user_03'),
('2020-06-17', 'AT', 'user_04'),
('2020-06-23', 'AT', 'user_04'),
('2020-07-04', 'DE', 'user_04'),
('2020-08-19', 'NL', 'user_05'),
('2020-10-23', 'FR', 'user_05');
预期结果:
order_date | customer | first_country | second_country |
-------------|-------------|------------------|-------------------|-----------
2020-04-10 | user_01 | DE | DE |
2020-04-11 | user_01 | DE | DE |
2020-04-13 | user_01 | AT | DE |
-------------|-------------|------------------|-------------------|-----------
2020-04-20 | user_02 | AT | NULL |
2020-04-22 | user_02 | AT | NULL |
-------------|-------------|------------------|-------------------|-----------
2020-05-19 | user_03 | DE | NULL |
-------------|-------------|------------------|-------------------|-----------
2020-06-17 | user_04 | AT | DE |
2020-06-23 | user_04 | AT | DE |
2020-07-04 | user_04 | DE | DE |
-------------|-------------|------------------|-------------------|-----------
2020-08-19 | user_05 | NL | NULL |
2020-10-23 | user_05 | FR | NULL |
在上面的例子中,可能有一位顾客在 DE
和 AT
都下了订单。
对于这些客户,我想将 second_country
列中的国家 DE
分配给他们的每个 order_dates
.
参考
SELECT
c.order_date AS order_date,
c.customer AS customer,
c.country AS first_country,
(CASE WHEN COUNT(*) FILTER (WHERE c.country = 'DE') OVER (PARTITION BY c.customer) > 0 AND
COUNT(*) FILTER (WHERE c.country = 'AT') OVER (PARTITION BY c.customer) > 0
THEN 'DE'
END) AS second_country
FROM customers c
GROUP BY 1,2,3
ORDER BY 1,2,3;
但是,在 redshift
中 FILTER
功能不可用。
我必须如何修改查询才能使其在 redshift
中也能正常工作?
只需使用 case
表达式:
SELECT c.order_date AS order_date,
c.customer AS customer,
c.country AS first_country,
(CASE WHEN SUM(CASE WHEN c.country = 'DE' THEN 1 ELSE 0 END) OVER (PARTITION BY c.customer) > 0 AND
SUM(CASE WHEN c.country = 'AT' THEN 1 ELSE 0 END) OVER (PARTITION BY c.customer) > 0
THEN 'DE'
END) AS second_country
FROM customers c
GROUP BY 1,2,3
ORDER BY 1,2,3;
实际上,您可以将其简化为:
(CASE WHEN SUM( (c.country = 'DE')::int ) OVER (PARTITION BY c.customer) > 0 AND
SUM( (c.country = 'DE')::int ) OVER (PARTITION BY c.customer) > 0
THEN 'DE'
END) AS second_country