又谈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.
THE END
