public static String pretreatStatement(Executor executor, String statement) {
        statement = SqlUtil.removeNote(statement);
        if (executor.isUseSqlFragment()) {
            statement = executor.getVariableManager().parseVariable(statement);
        }
        return statement.trim();
    }
@Test
    public void replaceFragmentTest() {
        String statement = "nullif1:=NULLIF(1, 0) as val;\n"
                + "nullif2:=NULLIF(0, 0) as val$null;\n"
                + "select ${nullif1},${nullif2}";
        String pretreatStatement = FlinkInterceptor.pretreatStatement(ExecutorFactory.getDefaultExecutor(), statement);
        Assert.assertEquals("select NULLIF(1, 0) as val,NULLIF(0, 0) as val$null", pretreatStatement);
    }