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

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

不知道你这个问题是否已经解决, 如果还没有解决的话:

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