簡単なテーブル名の変更を使用JSqlParser
していますが、ステートメントでいくつかの udf 関数を使用すると例外がスローされます。機能チェックを無視する方法は?
def replaceTableName(sql: String) = {
val select = CCJSqlParserUtil.parse(sql).asInstanceOf[Select]
val buffer = new java.lang.StringBuilder()
val expressionDeParser = new ExpressionDeParser() {
override def visit(tableColumn: Column) = {
if (tableColumn.getTable.getName != null && tmpTables.contains(resolveName(tableColumn.getTable.getName))) {
tableColumn.getTable().setName(resolveName(tableColumn.getTable().getName()))
}
super.visit(tableColumn)
}
}
val deparser = new SelectDeParser(expressionDeParser, buffer) {
override def visit(tableName: Table) {
if(tmpTables.contains(resolveName(tableName.getName)))
tableName.setName(resolveName(tableName.getName()))
super.visit(tableName)
}
}
expressionDeParser.setSelectVisitor(deparser)
expressionDeParser.setBuffer(buffer)
select.getSelectBody().accept(deparser)
buffer.toString
}
このコードはスローします
原因: net.sf.jsqlparser.parser.ParseException: 予期しないトークンが発生しました:
<K_TIME_KEY_EXPR>
行 1、列 xx で「current_date」
私の入力が昨日の日付を取得するための私の udfsselect * from table where date = sub_date(current_date('yyyyMMdd'),'1','yyyyMMdd');
sub_date
である場合。current_date