添加插件如下代码,就能够注册一个Step的插件了
List<String> empty = Collections.emptyList();
// 这个map别复用了,下一个插件重新new一个,不然即使clear了,下一个插件也不能注册成功
Map<Class<?>,String> xxxxClassMap=new HashMap<Class<?>,String>();
// xxxxMeta 就是开发的插件的Meta类了
xxxxClassMap.put(StepMetaInterface.class,xxxxMeta.class.getName());
PluginInterface xxxxPlugin=new Plugin(
new String[]{"MergeField"},
StepPluginType.class,
StepMetaInterface.class,
"转换",
"插件的名字",
"插件的描述,不影响java执行",
"插件的图片,不影响java执行",
false,
false,
xxxxClassMap,
empty,
null,
null);
PluginRegistry.getInstance().registerPlugin(StepPluginType.class,xxxxPlugin);
Map<Class<?>,String> anotherClassMap=new HashMap<Class<?>,String>();
// anotherMeta 就是开发的插件的Meta类了
xxxxClassMap.put(StepMetaInterface.class,anotherMeta.class.getName());
PluginInterface anotherPlugin=new Plugin(
new String[]{"MergeField"},
StepPluginType.class,
StepMetaInterface.class,
"转换",
"插件的名字",
"插件的描述,不影响java执行",
"插件的图片,不影响java执行",
false,
false,
anotherClassMap,
empty,
null,
null);
PluginRegistry.getInstance().registerPlugin(StepPluginType.class,anotherPlugin);
KettleEnvironment.init();
List<String> empty = Collections.emptyList();
// 这个map别复用了,下一个插件重新new一个,不然即使clear了,下一个插件也不能注册成功
Map<Class<?>,String> xxxxClassMap=new HashMap<Class<?>,String>();
// xxxxMeta 就是开发的插件的Meta类了
xxxxClassMap.put(StepMetaInterface.class,xxxxMeta.class.getName());
PluginInterface xxxxPlugin=new Plugin(
new String[]{"MergeField"},
StepPluginType.class,
StepMetaInterface.class,
"转换",
"插件的名字",
"插件的描述,不影响java执行",
"插件的图片,不影响java执行",
false,
false,
xxxxClassMap,
empty,
null,
null);
PluginRegistry.getInstance().registerPlugin(StepPluginType.class,xxxxPlugin);
// 数据库连接元对象(连接名称,不必与kettle中配置的保持一致:数据库类型:连接方式(kettle支持的连接方式):资源库IP:资源库实例名:资源库端口:资源库用户名:资源库用户密码)
DatabaseMeta connection = new DatabaseMeta("资源库名称,不影响", "Oracle", DatabaseMeta.getAccessTypeDesc(0), "oracle的地址", "oracle的实例", "1521", "oracle用户名", "oracle密码");
// 资源库元对象
KettleDatabaseRepositoryMeta repinfo = new KettleDatabaseRepositoryMeta();
repinfo.setConnection(connection);
// 资源库
KettleDatabaseRepository repository = new KettleDatabaseRepository();
repository.init(repinfo);
// 连接资源库
repository.connect("admin","admin",true);
// 资源库目录对象
RepositoryDirectoryInterface directoryInterface=repository.loadRepositoryDirectoryTree();
// 转换元对象
TransMeta transMeta=repository.loadTransformation("tran的名称",directoryInterface,null,true,null);
// 转换
Trans trans = new Trans(transMeta);
// 执行转换
trans.execute(null);
// 等待转换执行结束
if(trans.getErrors()>0){
System.out.println("transformation error");
}else{
System.out.println("transformation successfully");
}