又谈SQL-to-SQL翻译器

复制publicstatic void main(String[] args) throws IOException {        //输入        FileSourceFunction fileSourceFunction = new FileSourceFunction();        fileSourceFunction.init(new File("fff.txt"));        //输出        PrintlnSinkFunction<PrintStream> printSinkFunction = new PrintlnSinkFunction();        ListSinkFunction listSinkFunction = new ListSinkFunction();  ansformPepline tp = new TransformPepline();    //添加输入输出  .addSource(fileSourceFunction)                .addSink(printSinkFunction)                .addSink(listSinkFunction);    //定制转换动作        tp.addSourceMapFunction(new Function<String,又谈 String>() {            SqlTransExecManager sqlTransExecManager = new SqlTransExecManager().build();            @Override            public String apply(String s) {                return sqlTransExecManager.doParseAndTransform(s).getTargetSql();            }        });        //执行        tp.execute();        System.out.println(listSinkFunction.getLists());    }  1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.