每天一道大厂SQL题【Day22】华泰证券真题实战(四)

大家好，我是Maynor。相信大家和我一样，都有一个大厂梦，作为一名资深大数据选手，深知SQL重要性，接下来我准备用100天时间，基于大数据岗面试中的经典SQL题，以每日1题的形式，带你过一遍热门SQL题并给出恰如其分的解答。

一路走来，随着问题加深，发现不会的也愈来愈多。但底气着实足了不少，相信不少朋友和我一样，日积月累才是最有效的学习方式！

每日语录

有一天你会遇到一个妹子，她不要你的房也不要你的车，她也不要你。

第22题：

需求列表

2.有表结构及数据如下，请完成相应查询

基金产品交易流水表t_trade,描述如下：

create table t_trade(

init_date integer comment ’ 日期 ', client_id varchar(20) comment ‘客户号’,

fund_code varchar (6) comment ’ 基金产品代码 ', business_flag integer comment '1 卖出 2 买入 ', business_balance numeric(38,10)) comment ‘交易金额’

);

create or replace view

t_trade(init_date,client_id,fund_code,business_flag,business_balance) as values

(1,1,1,1,1000) ,

(1,88,1,1,2000) ,

(1,2,2,1,900) ,

(1,3,3,1,800) ,

(1,4,4,1,700) ,

(1,8,9,2,10000) ,

(1,7,8,2,9000) ,

(1,6,7,2,8000)

;

求每日买入成交金额前10名和卖出成交金额的前十名的基金产品。

思路分析

首先，子查询t1用来计算每个基金产品在每个日期和业务类型下的成交金额。然后，子查询t2使用窗口函数ROW_NUMBER()对每个日期和业务类型下的基金产品按照成交金额进行排名。最后，对排名前10名的基金产品进行筛选，输出结果。

需要注意的是，在查询每日买入成交金额前10名的基金产品时，应该筛选业务类型为2（即买入）的交易记录。如果要查询每日卖出成交金额前10名的基金产品，则应该筛选业务类型为1（即卖出）的交易记录。

答案获取

建议你先动脑思考，动手写一写再对照看下答案，如果实在不懂可以点击下方卡片，回复:大厂sql 即可。
参考答案适用HQL，SparkSQL，FlinkSQL，即大数据组件，其他SQL需自行修改。

加技术群讨论

点击下方卡片关注联系我进群

或者直接私信我进群

文末SQL小技巧

提高SQL功底的思路。
1、造数据。因为有数据支撑，会方便我们根据数据结果去不断调整SQL的写法。
造数据语法既可以create table再insert into，也可以用下面的create temporary view xx as values语句，更简单。
其中create temporary view xx as values语句，SparkSQL语法支持，hive不支持。
2、先将结果表画出来，包括结果字段名有哪些，数据量也画几条。这是分析他要什么。
从源表到结果表，一路可能要走多个步骤，其实就是可能需要多个子查询，过程多就用with as来重构提高可读性。
3、要由简单过度到复杂，不要一下子就写一个很复杂的。
先写简单的select from table…,每个中间步骤都执行打印结果，看是否符合预期，根据中间结果，进一步调整修饰SQL语句，再执行，直到接近结果表。
4、数据量要小，工具要快，如果用hive，就设置set hive.exec.mode.local.auto=true;如果是SparkSQL，就设置合适的shuffle并行度，set spark.sql.shuffle.partitions=4;