如何使用 JDBC 在 Spark 中的其他数据库中获取表的创建语句

Question

问题陈述：

1. 我有一个 Impala 数据库，其中存在多个表

2. 我正在创建到 Impala 的 Spark JDBC 连接，并将这些表加载到 spark 数据框中，以进行这样的验证，效果很好：

    val df = spark.read.format("jdbc")
                 .option("url","url")
                 .option("dbtable","tablename")
                 .load()
   

3. 现在下一步，我的实际问题是我需要找到用于在 Impala 本身中创建表的 create 语句

4. 由于我无法运行如下所示的命令，因为它给出了错误，所以无论如何我可以获取 Impala 中存在的表的 show create 语句。

   val df = spark.read.format("jdbc")
                 .option("url","url")
                 .option("dbtable","show create table tablename")
                 .load()
   

Answer 1

也许您可以“本机”使用 Spark SQL 来执行类似的操作

val createstmt = spark.sql("show create table <tablename>")

生成的数据框将有一个列（类型字符串），其中包含完整的CREATE TABLE 语句。

但是，如果您仍然选择使用 JDBC 路线，则始终可以选择使用良好的旧 JDBC 接口。毕竟，Scala 理解所有用 Java 编写的东西......

import java.sql.*
Connection conn = DriverManager.getConnection("url")
Statement stmt = conn.createStatement()
ResultSet rs = stmt.executeQuery("show create table <tablename>")
...etc...