又谈SQL-to-SQL翻译器

    public static 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();


TransformPepline tp = new TransformPepline();    //添加输入输出
tp.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());
    }