Unverified Commit c841efa4 authored by Licho's avatar Licho Committed by GitHub

fix: fixPackageError (#1152)

parent 52d04aa7
...@@ -34,6 +34,8 @@ import org.apache.flink.table.api.TableResult; ...@@ -34,6 +34,8 @@ import org.apache.flink.table.api.TableResult;
* @since 2021/6/11 22:17 * @since 2021/6/11 22:17
*/ */
public class FlinkInterceptor { public class FlinkInterceptor {
private FlinkInterceptor() {
}
public static String pretreatStatement(Executor executor, String statement) { public static String pretreatStatement(Executor executor, String statement) {
statement = SqlUtil.removeNote(statement); statement = SqlUtil.removeNote(statement);
......
...@@ -17,10 +17,9 @@ ...@@ -17,10 +17,9 @@
* *
*/ */
package com.dlink.core; package com.dlink.interceptor;
import com.dlink.executor.Executor; import com.dlink.executor.Executor;
import com.dlink.interceptor.FlinkInterceptor;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
...@@ -39,6 +38,6 @@ public class FlinkInterceptorTest { ...@@ -39,6 +38,6 @@ public class FlinkInterceptorTest {
+ "nullif2:=NULLIF(0, 0) as val$null;" + "nullif2:=NULLIF(0, 0) as val$null;"
+ "select ${nullif1},${nullif2}"; + "select ${nullif1},${nullif2}";
String pretreatStatement = FlinkInterceptor.pretreatStatement(Executor.build(), statement); String pretreatStatement = FlinkInterceptor.pretreatStatement(Executor.build(), statement);
Assert.assertEquals("select NULLIF(1, 0) as val,NULLIF(0, 0) as val$null",pretreatStatement); Assert.assertEquals("select NULLIF(1, 0) as val,NULLIF(0, 0) as val$null", pretreatStatement);
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment