From 8d92a72f542aa00604749f56da466ab09b9bb991 Mon Sep 17 00:00:00 2001 From: ?? ? <ulysseskao@ximple.com.tw> Date: Thu, 12 Jun 2008 19:36:04 +0800 Subject: [PATCH] update for EOFM-118 --- xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleConvertDgn2PostGISJob.java | 24 ++++++++++-------------- 1 files changed, 10 insertions(+), 14 deletions(-) diff --git a/xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleConvertDgn2PostGISJob.java b/xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleConvertDgn2PostGISJob.java index 8b679f9..e73e9f7 100644 --- a/xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleConvertDgn2PostGISJob.java +++ b/xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleConvertDgn2PostGISJob.java @@ -72,7 +72,7 @@ private static final String USEWKB = "USEWKB"; private static final int FETCHSIZE = 30; - private static final int COMMITSIZE = 20; + private static final int COMMITSIZE = 100; class Pair { @@ -214,25 +214,21 @@ { logger.info("-- step:clearOutputDatabase --"); clearOutputDatabase(); - boolean bFirst = isCopyConnectivityMode(); if (checkConvertDB()) { logger.info("-- step:convertOracleDB --"); + OracleConvertPostGISJobContext jobContext = + (OracleConvertPostGISJobContext) prepareJobContext(_filterPath); + jobContext.setSourceDataStore(getSourceDataStore()); + // jobContext.setConvertElementIn(_convertElementIn); + jobContext.setElementLogging(checkElementLogging()); + jobContext.setExecutionContext(context); + if (isCopyConnectivityMode()) + copyConnectivity(jobContext); + for (String orgSchema : _orgSchema) { - OracleConvertPostGISJobContext jobContext = - (OracleConvertPostGISJobContext) prepareJobContext(_filterPath); - jobContext.setSourceDataStore(getSourceDataStore()); - // jobContext.setConvertElementIn(_convertElementIn); - jobContext.setElementLogging(checkElementLogging()); - jobContext.setExecutionContext(context); - - if (bFirst) - copyConnectivity(jobContext); - else - bFirst = false; - logger.info("----- start schema:" + orgSchema + " -----"); exetcuteConvert(jobContext, orgSchema, _dataPath); -- Gitblit v0.0.0-SNAPSHOT