是否有方法验证原始spark sql查询的语法？

Question

是否有方法验证原始spark SQL查询的语法？

例如，我想知道spark是否提供了任何isvalidAPI调用？

val query = "select * from table"
if(isValid(query)) {
    sparkSession.sql(query) 
} else {
    log.error("Invalid Syntax")
}

val query = "select * morf table" // Invalid query
val parser = spark.sessionState.sqlParser
try{
    parser.parseExpression(query)
} catch (ParseException ex) {
    throw new Exception(ex); //Exception not getting thrown
}
Dataset<>Row df = sparkSession.sql(query) // Exception gets thrown here
df.writeStream.format("console").start()

Answer 1

使用Spark SQL解析器：

val parser = spark.sessionState.sqlParser
parser.parseExpression("select * from table")