jdbc - 有没有办法查看Calcite JDBC执行的物理SQL？

Question

最近在学习Apache Calcite，现在可以用explain plan for通过JDBC查看逻辑计划，我想知道如何查看计划执行中的物理sql？由于物理sql生成中可能存在错误，因此我需要确保正确性。

    val connection = DriverManager.getConnection("jdbc:calcite:")
    val calciteConnection = connection.asInstanceOf[CalciteConnection]
    val rootSchema = calciteConnection.getRootSchema()

    val dsInsightUser = JdbcSchema.dataSource("jdbc:mysql://localhost:13306/insight?useSSL=false&serverTimezone=UTC", "com.mysql.jdbc.Driver", "insight_admin","xxxxxx")
    val dsPerm = JdbcSchema.dataSource("jdbc:mysql://localhost:13307/permission?useSSL=false&serverTimezone=UTC", "com.mysql.jdbc.Driver", "perm_admin", "xxxxxx")

    rootSchema.add("insight_user", JdbcSchema.create(rootSchema, "insight_user", dsInsightUser, null, null))
    rootSchema.add("perm", JdbcSchema.create(rootSchema, "perm", dsPerm, null, null))

    val stmt = connection.createStatement()
    val rs = stmt.executeQuery("""explain plan for select "perm"."user_table".* from "perm"."user_table" join "insight_user"."user_tab" on "perm"."user_table"."id"="insight_user"."user_tab"."id" """)
    val metaData = rs.getMetaData()

    while(rs.next()) {
      for(i <- 1 to metaData.getColumnCount) printf("%s ", rs.getObject(i))
      println()
    }

结果是

EnumerableCalc(expr#0..3=[{inputs}], proj#0..2=[{exprs}])
  EnumerableHashJoin(condition=[=($0, $3)], joinType=[inner])
    JdbcToEnumerableConverter
      JdbcTableScan(table=[[perm, user_table]])
    JdbcToEnumerableConverter
      JdbcProject(id=[$0])
        JdbcTableScan(table=[[insight_user, user_tab]])

Answer 1

有一个方解石钩，Hook.QUERY_PLAN由 JDBC 查询字符串触发。来自 source :

/** Called with a query that has been generated to send to a back-end system.
* The query might be a SQL string (for the JDBC adapter), a list of Mongo
* pipeline expressions (for the MongoDB adapter), et cetera. */
QUERY_PLAN;

您可以注册一个监听器来记录任何查询字符串，就像在 Java 中这样:

Hook.QUERY_PLAN.add((Consumer<String>) s -> LOG.info("Query sent over JDBC:\n" + s));