从文本文件中提取 SQL 查询

Question

如何从这个文本文件中提取两个使用 JAVA 的 SQL 查询？

--------------------------------------------------------
--  File created - 01-25-2009   
--------------------------------------------------------
--------------------------------------------------------
--  Table PRODUCT
--------------------------------------------------------

  CREATE TABLE "PRODUCT" 
   (    "PRODUCTID" INTEGER, 
    "TYPE" VARCHAR(255), 
    "NAME" VARCHAR(10), 
    "CODE" VARCHAR(255), 
    "CLIENTS" VARCHAR(255), 
    "LOCATION" VARCHAR(255), 
    "REMAININGARTICLES" VARCHAR(255), 
    "STAFF" VARCHAR(511), 
    "WAREHOUSES" VARCHAR(511), 
    "DOWN" VARCHAR(64), 
    "UP" VARCHAR(56), 
    "EXPIRY" DATE
   ) ;
--------------------------------------------------------
--  Constraints for Table PRODUCT
--------------------------------------------------------

  ALTER TABLE "PRODUCT" MODIFY ("PRODUCTID" NOT NULL ENABLE);

这是我迄今为止尝试使用spark：

Dataset<String> sqlQuery=spark.read().textFile("C:/product.sql");

那我试试：

sqlQuery.toString()

但后者没有返回一个字符串，如何以一种简洁的方式实现这一点？

Answer 1

sqlQuery 不是你必须首先收集的结果，我不确定是否使用 java，但在 scala 中你会这样使用它：

val arr = spark.read.textFile("C:/product.sql").collect()

然后像这样加入它：

val query = String.join("\n", arr: _*)

在java中会是这样的：

array[] arr = spark.read().textFile("C:/product.sql").collect()

然后像这样加入它：

String query = String.join("\n", arr)