使用Spark 的 hivecontext.sql查询，如何批量执行语句

前台会传来一条select语句，使用hivecontext.sql去执行。但用户写表的时候，可能不会指定数据库名，所以是想先执行一下 use dbName，再执行查询语句，保证能够找到这站表。那么在Scala程序中如何去实现呢？？

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除结题
收藏举报

1条回答

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
CSDN-Ada助手 CSDN-AI 官方账号 2022-10-27 15:50
关注
不知道你这个问题是否已经解决, 如果还没有解决的话:
这篇文章讲的很详细，请看：hive on spark 执行sql报错

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^
解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

Spark 读取 Hive 数据报错 NoSuchMethodError : org.apache.spark.sql.catalyst.catalog.SessionCatalog hive spark 大数据
2022-12-15 15:54

回答 1 已采纳 22/12/15 15:32:44 INFO SparkContext: Invoking stop() from shutdown hook集群资源不足，且动态资源分配申请的executors、内存
Error while instantiating 'org.apache.spark.sql.hive.HiveSessionState' eclipse intellij-idea java java-ee scala
2019-08-09 21:16

回答 3 已采纳这个问题我已经解决，我发现是仔细看了一下，后面的错误是Exception in thread "main"java.lang.UnsatisfiedLinkError，我本地的hadoop版本是2.7
求解答：如何使用sparksql进行模糊查询？ scala spark 大数据
2022-05-19 17:16

回答 1 已采纳 SELECT SUBSTR(NAME,1,INSTR(NAME,'(')-1),COUNT(1)FROM (SELECT '顶层(共20层)' NAME UNION ALLSELECT '顶层(共21
大数据之Spark（四）：Spark SQL
2021-08-16 21:21

Oak-Komorebi的博客 SparkSQL是Spark⽣态体系中的构建在SparkCore基础之上的⼀个基于SQL的计算模块。 SparkSQL的前身不叫SparkSQL，⽽叫Shark，最开始的时候底层代码优化，sql的解析、执⾏引擎等等完全基于 Hive，总是Shark的执⾏速度要...
在使用Spark连接数据库时发生Caused by: java.sql.SQLException: Out of range value for column 'age' : value age java spark sql
2022-02-09 14:38

回答 1 已采纳 http://cn.voidcc.com/question/p-ozcajljc-dh.html，看下这个
大数据，spark ，doris mysql spark 大数据
2023-01-17 22:05

回答 2 已采纳这是一个连接Doris服务器失败的错误，具体原因可能是Doris服务器无法连接或网络故障导致的。
spark sql数据如何求交集？ spark sql 大数据有问必答
2022-01-18 20:31

回答 3 已采纳 spark sql中可以使用except来获得两组数据的交集 SELECT * FROM student_1 EXCEPT SELECT * FROM student_2; 你如果是某一行中的某
大数据Hadoop之——Spark SQL+Spark Streaming
2021-12-25 18:16

大数据老司机的博客文章目录一、Spark SQL概述二、SparkSQL版本1）SparkSQL的演变之路2）shark与SparkSQL对比3）SparkSession三、RDD、DataFrames和DataSet1）三者关联关系1）RDD1、核心概念2、RDD简单操作3、RDD API1）Transformation...
spark通过jdbc读取hive的表报错，我是在zeppelin里运行的 hive spark
2017-06-06 08:21

回答 1 已采纳在目前Hive 1.2的JDBC版本里面，使用它会报错：`java.sql.SQLException: Method not supported at org.apache.hive.jdbc.Hiv
spark sql join 1个driver很慢，其他很快，怀疑数据倾斜，帮解决可有偿私 spark
2021-11-24 10:01

回答 1 已采纳你把它复制到记事本发给我
spark sql的执行顺序是什么样的 hadoop hive spark
2022-12-26 21:08

回答 2 已采纳 Spark SQL 的执行顺序通常分为以下几步：解析 SQL 语句：Spark SQL 会先将 SQL 语句解析成内部的表达式树，以便对其进行更好的优化。优化表达式树：在解析后，Spark SQL 会
Spark 【Spark SQL（一）DataFrame的创建、保存与基本操作】
2023-09-09 19:03

让线程再跑一会的博客 Spark SQL、DataFrame的创建与保存、DataFrame的两种操作：DSL语句和SQL语句。
为什么SparkSQL，dbeaver，hive命令行使用相同的语句操作hive表的结果不一样 hive spark sql 有问必答
2022-03-27 14:34

回答 2 已采纳把情景一改成这样试试spark.sql(""" INSERT INTO hive_test_one.djia_table(date, open, high, low, close, volume,
26.大数据学习之旅——Spark调优&源码解读&SparkSQL入门
2019-01-14 09:48

零零天的博客 Spark调优—上篇更好的序列化实现 Spark用到序列化的地方 1）Shuffle时需要将对象写入到外部的临时文件。 2）每个Partition中的数据要发送到worker上，spark先把RDD包装成task对象，将task通过网络发给worker。 3...
八、Spark SQL
2021-05-29 12:37

Robin_Liew的博客 Spark SQL提供了一种特殊的RDD，叫做SchemaRDD。 SchemaRDD是存放Row对象的RDD，每个Row对象代表一行记录。 SchemaRDD支持RDD上所没有的一些新操作，比如运行SQL查询。 SchemaRDD可以从外部数据源创建，也可以从查询...
没有解决我的问题, 去提问

悬赏问题

¥15 求daily translation（DT）偏差订正方法的代码
¥15 js调用html页面需要隐藏某个按钮
¥15 ads仿真结果在圆图上是怎么读数的
¥20 Cotex M3的调试和程序执行方式是什么样的？
¥20 java项目连接sqlserver时报ssl相关错误
¥15 一道python难题3
¥15 牛顿斯科特系数表表示
¥15 arduino 步进电机
¥20 程序进入HardFault_Handler
¥15 关于#python#的问题：自动化测试