sql之多查询结果合并

sql之多查询结果合并

根据需求查询,出现多个结果集,而且没有交集,但数据类型一样,进行合并;

语法:

UNION：去除重复记录，例如：SELECT * FROM t1 UNION SELECT * FROM t2；
UNION ALL：不去除重复记录，例如：SELECT * FROM t1 UNION ALL SELECT * FROM t2

代码:

val conf = new SparkConf().setAppName("").setMaster("local")
val spark = SparkSession.builder().config(conf).getOrCreate()
import spark.implicits._
val rdd = spark.read.textFile("f:/ab/input/c.txt").map(_.split("[ \t]+")).map(x => (x(0), x(1).toInt))
var df = rdd.toDF("a1", "a2")
df.createOrReplaceTempView("stu")
//  println("")spark.sql("select a1,count(a1) c1 from stu group by a1").show
println("统计出每个用户的粉丝数量,按照粉丝数量排序并输出")
spark.sql("select a2,count(a2) c2 from stu group by a2 order by c2 desc").show//  SELECT * FROM t1 UNION SELECT * FROM t2
println("请统计出一共有多少个不同的ID  ok")
spark.sql("select count(a1) from (select a1,count(a1) c1 from stu group by a1     union        select a2,count(a2) c2 from stu group by a2 order by c1 desc) zong").show
println("统计出每个ID出现的次数")
spark.sql("select a1,count(a1) c1 from stu group by a1     union        select a2,count(a2) c2 from stu group by a2 order by c1 desc").show

运行结果:

+--------+---+
|      a1| c1|
+--------+---+
|11111111|  9|
|11111113|  7|
|11111112|  7|
+--------+---+
统计出每个用户的粉丝数量,按照粉丝数量排序并输出
+--------+---+
|      a2| c2|
+--------+---+
|12743457|  3|
|13256236|  3|
|10000001|  3|
|12356363|  2|
|34232443|  2|
|10000032|  2|
|16386587|  2|
|13426275|  2|
|19764388|  1|
|12357365|  1|
|12364375|  1|
|32435546|  1|
+--------+---+
请统计出一共有多少个不同的ID  ok
+---------+
|count(a1)|
+---------+
|       15|
+---------+
统计出每个ID出现的次数
+--------+---+
|      a1| c1|
+--------+---+
|11111111|  9|
|11111113|  7|
|11111112|  7|
|10000001|  3|
|12743457|  3|
|13256236|  3|
|13426275|  2|
|10000032|  2|
|34232443|  2|
|12356363|  2|
|16386587|  2|
|32435546|  1|
|12364375|  1|
|19764388|  1|
|12357365|  1|
+--------+---+

sql之多查询结果合并相关推荐

sql多表查询之合并查询（union）
题1 https://www.nowcoder.com/practice/203d0aed8928429a8978185d9a03babc?tpId=240&tags=&title=& ...
一对多查询，合并成一条数据
一对多查询,合并成一条数据举例:一个产品对应多个型号,把多个型号查询出来显示在一个字段下面.显示出一条数据. 步骤: 1:创建产品表: 2:创建型号表: 思路: 先写出不含产品型号的查询语句, 然后 ...
ORACLE---Unit04： SQL（高级查询）
---(重点复习:子查询.分页查询.decode) --- SQL(高级查询) --- 子查询 --- 子查询是嵌套在其它SQL语句当中的,目的是为嵌套的SQL提供数据,以便其执行. ---查看谁的工 ...
mysql 两个查询结果合并去重_《MySQL 入门教程》第 21 篇集合操作符
文章来源:https://blog.csdn.net/horses/article/details/108174837 来源平台:CSDN 原文作者:不剪发的Tony老师数据表与集合理论中的集合非常 ...
sql 标量子查询_SQL Server 2017：标量子查询简化
sql 标量子查询 Nowadays a lot of developers use Object-Relational Mapping (ORM) frameworks. ORM is a prog ...
使用SQL Coalesce函数查询数据
We all know that a Null value is a field with no value. The statements that we are running daily wil ...
浅谈sql之连接查询
SQL之连接查询一.连接查询的分类 sql中将连接查询分成四类: 内链接外连接左外连接右外连接自然连接交叉连接二.连接查询的分类数据库表如下: 1.学生表 2.老师表 3.班级表表用 ...
SQL语言 --- 数据查询
数据查询一.单表查询(查询仅涉及一个表) 1.选择表中的若干列 2.选择表中的若干元组 3.ORDER BY子句 4.聚集函数 5.GROUP BY子句二.连接查询 1.等值与非等值连接查询 2. ...
oracle横向合并两张表,SQL中将两个表合并成一个新表 SQL如何合并两个表并生成一个新表？...
sql把两个表合并成一个新表的语句应该怎么写SQL SERVER: select * into 表3 from ( select 字段列表1 from 表1 union all select 字段列表 ...

sql之多查询结果合并

sql之多查询结果合并相关推荐

最新文章

热门文章