<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

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


    網站導航:
     
    主站蜘蛛池模板: 亚洲精品日韩中文字幕久久久| 亚洲精品一级无码鲁丝片| 亚洲五月激情综合图片区| 三年在线观看免费观看完整版中文| 亚洲一区精品伊人久久伊人| 视频一区在线免费观看| www.亚洲精品| 一个人看的www免费在线视频| 亚洲午夜福利精品久久| 国产精品hd免费观看| 亚洲AV无码成人专区片在线观看| 日韩av无码免费播放| 久久国产亚洲观看| 青青青国产在线观看免费网站| 精品亚洲成在人线AV无码| 女人毛片a级大学毛片免费| 日韩亚洲综合精品国产| 国产成人精品亚洲精品| 日韩视频在线观看免费| 中文字幕 亚洲 有码 在线| 暖暖日本免费在线视频| 一个人看的www视频免费在线观看 一个人看的免费观看日本视频www | CAOPORM国产精品视频免费| 国产亚洲人成无码网在线观看 | 一个人晚上在线观看的免费视频 | 亚洲欧美熟妇综合久久久久| 免费a级毛片网站| 国产福利在线观看永久免费| 亚洲国语精品自产拍在线观看 | 亚洲女久久久噜噜噜熟女| 182tv免费观看在线视频| 亚洲综合激情五月丁香六月| 亚洲五月午夜免费在线视频| 免费无遮挡无码永久视频| 亚洲中文无码mv| 国产亚洲精品激情都市| 国产精品久久免费| 国产高清视频免费在线观看| 亚洲一区中文字幕在线观看| 亚洲精品成人片在线观看| 16女性下面扒开无遮挡免费|