<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

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


    網站導航:
     
    主站蜘蛛池模板: 日本高清高色视频免费| 黄页视频在线观看免费| 99爱免费观看视频在线| 亚洲av永久无码精品秋霞电影影院| yellow视频免费看| 亚洲乱码中文字幕久久孕妇黑人| 丰满少妇作爱视频免费观看| 亚洲男人第一无码aⅴ网站| 免费无码AV一区二区| www亚洲精品少妇裸乳一区二区| 免费精品国自产拍在线播放| xvideos亚洲永久网址| 中国人免费观看高清在线观看二区| 国产国拍亚洲精品福利| 国产真人无码作爱视频免费| 亚洲精品无码不卡| 国产人在线成免费视频| 亚洲国产精品精华液| 亚洲精品国产高清不卡在线| 黄色网站软件app在线观看免费| 亚洲影院在线观看| 免费看国产精品3a黄的视频| 看全免费的一级毛片| 亚洲精品乱码久久久久久按摩| 中文字幕在线免费| 亚洲综合小说另类图片动图| 免费在线看片网站| 一个人看的www免费视频在线观看 一个人免费视频观看在线www | 国拍在线精品视频免费观看| 美国毛片亚洲社区在线观看| 国产综合精品久久亚洲| 一级毛片免费不卡在线| 亚洲色大成WWW亚洲女子| 亚洲日本一区二区三区在线不卡| 国产永久免费高清在线| 亚洲精品国产日韩| 国产亚洲成av片在线观看| 桃子视频在线观看高清免费完整| 免费一级全黄少妇性色生活片| 亚洲乱码中文字幕久久孕妇黑人| 久久不见久久见免费影院|