<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    GalaxyPilot —— D.S


            生命不熄,戰斗不止
    數據加載中……

    java調用kettle4.2數據庫型資料庫中的作業

    import org.pentaho.di.core.KettleEnvironment;
    import org.pentaho.di.core.database.DatabaseMeta;
    import org.pentaho.di.job.JobMeta;
    import org.pentaho.di.job.Job;
    import org.pentaho.di.repository.Repository;
    import org.pentaho.di.repository.RepositoryDirectoryInterface;
    import org.pentaho.di.repository.kdr.KettleDatabaseRepository;
    import org.pentaho.di.repository.kdr.KettleDatabaseRepositoryMeta;

    public class execRepositoryJobs {

        private static String jobName = "Job";

        public static void main(String[] args) {
            try {
                KettleEnvironment.init();

                KettleDatabaseRepository repository = new KettleDatabaseRepository();

                DatabaseMeta databaseMeta = new DatabaseMeta("repository", "MSSQL","Native", "192.169.0.146", "repository", "1433", "sa","sa");

                KettleDatabaseRepositoryMeta kettleDatabaseMeta = new KettleDatabaseRepositoryMeta("repository", "ERP", "Transformation description",databaseMeta);

                repository.init(kettleDatabaseMeta);

                repository.connect("admin", "admin");

                RepositoryDirectoryInterface directory = repository.loadRepositoryDirectoryTree();
                
                JobMeta jobMeta = ((Repository) repository).loadJob(jobName, directory, null, null ) ;

    //            RepositoryDirectoryInterface fooBar = directory.findDirectory("/");
    //
    //            JobMeta jobMeta = repository.loadJob(repository.getJobId(jobName, fooBar), null);

                Job job = new Job(repository,jobMeta);
                
                job.start();
                
                job.waitUntilFinished();
                
                if (job.getErrors() > 0) {
                    throw new RuntimeException(
                            "There were errors during transformation execution.");
                }

            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    posted on 2012-07-30 14:33 舵手 閱讀(1521) 評論(1)  編輯  收藏

    評論

    # re: java調用kettle4.2數據庫型資料庫中的作業  回復  更多評論   

    這陣子跟kettle較勁了?
    2012-10-25 11:19 | klzz

    只有注冊用戶登錄后才能發表評論。


    網站導航:
     
    主站蜘蛛池模板: 国产无遮挡吃胸膜奶免费看视频| 精品亚洲永久免费精品| 歪歪漫画在线观看官网免费阅读 | 9420免费高清在线视频| 亚洲av色福利天堂| 无码人妻一区二区三区免费看 | 免费无码又爽又刺激网站直播 | 亚洲第一区精品观看| 精品久久久久亚洲| 亚洲精品国产高清嫩草影院| 一级毛片正片免费视频手机看| 亚洲日韩中文在线精品第一| 亚洲国产免费综合| 亚洲av无码专区国产乱码在线观看| 免费日本一区二区| 亚洲成aⅴ人在线观看| 成人免费在线视频| 国产99久久亚洲综合精品| 亚洲天堂中文字幕在线| 国产成人精品无码免费看| 亚洲精品国产啊女成拍色拍| 黄在线观看www免费看| 亚洲风情亚Aⅴ在线发布| 亚洲午夜精品一级在线播放放| 两个人看的www免费视频| 久久亚洲精品无码aⅴ大香| 全免费a级毛片免费看不卡| 日韩毛片在线免费观看| 亚洲欧洲日产国码久在线观看| 最近最新MV在线观看免费高清| 色窝窝亚洲AV网在线观看| 亚洲国产精品无码久久SM| 18禁成年无码免费网站无遮挡| 高清免费久久午夜精品| 亚洲福利一区二区| 一区二区三区亚洲视频| 外国成人网在线观看免费视频| 亚洲AV无码资源在线观看| 日本亚洲欧洲免费天堂午夜看片女人员 | 99视频免费播放| 亚洲AV无码一区二区三区久久精品|