From 848e4c119f9ffea9d436eb3a8a7551debddb689f Mon Sep 17 00:00:00 2001
From: yuanhung <yuanhung@ximple.com.tw>
Date: Fri, 04 Mar 2016 10:58:19 +0800
Subject: [PATCH] fix some bug
---
xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleIncrementDgn2PostGISJob.java | 40 +++++++++++++++-------------------------
1 files changed, 15 insertions(+), 25 deletions(-)
diff --git a/xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleIncrementDgn2PostGISJob.java b/xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleIncrementDgn2PostGISJob.java
index 2a904f2..e0e260f 100644
--- a/xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleIncrementDgn2PostGISJob.java
+++ b/xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleIncrementDgn2PostGISJob.java
@@ -1,29 +1,8 @@
package com.ximple.eofms.jobs;
-import java.io.IOException;
-import java.nio.BufferOverflowException;
-import java.nio.ByteBuffer;
-import java.nio.ByteOrder;
-import java.sql.Connection;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-import java.sql.Types;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.Map;
-import java.util.TreeMap;
-import java.util.logging.Logger;
-
import com.ximple.eofms.jobs.context.AbstractOracleJobContext;
import com.ximple.eofms.jobs.context.postgis.OracleIncrementPostGISJobContext;
-import com.ximple.io.dgn7.ComplexElement;
-import com.ximple.io.dgn7.Dgn7fileException;
-import com.ximple.io.dgn7.Element;
-import com.ximple.io.dgn7.ElementType;
-import com.ximple.io.dgn7.FrammeAttributeData;
-import com.ximple.io.dgn7.IElementHandler;
+import com.ximple.io.dgn7.*;
import com.ximple.util.PrintfFormat;
import oracle.sql.BLOB;
import org.apache.commons.logging.Log;
@@ -38,7 +17,17 @@
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
-import static com.ximple.eofms.jobs.context.postgis.OracleIncrementPostGISJobContext.*;
+import java.io.IOException;
+import java.nio.BufferOverflowException;
+import java.nio.ByteBuffer;
+import java.nio.ByteOrder;
+import java.sql.*;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.Map;
+import java.util.TreeMap;
+
+import static com.ximple.eofms.jobs.context.postgis.OracleIncrementPostGISJobContext.ElementTransactionContext;
public class OracleIncrementDgn2PostGISJob extends AbstractOracleDatabaseJob {
final static Log logger = LogFactory.getLog(OracleIncrementDgn2PostGISJob.class);
@@ -394,21 +383,22 @@
*/
private void exetcuteIncrementConvert(OracleIncrementPostGISJobContext jobContext, String targetSchemaName) throws SQLException {
+
Connection connection = jobContext.getOracleConnection();
if (connection == null) {
logger.warn("Cannot Get Oracle Connection for DMMS.");
return;
}
-
+ try {
// SELECT COUNT(*) FROM CMMS_POSTDB.GEO_EXCHANGE WHERE ISEXCHANGE = 0
int exchangeCount = fetchExchangeCount(connection);
logger.info("exchangeCount=" + exchangeCount);
- try {
processIncrementElement(jobContext, exchangeCount);
// jobContext.setCurrentSchema(querySchema);
} finally {
+ JDBCUtils.close(connection, Transaction.AUTO_COMMIT, null);
}
}
--
Gitblit v0.0.0-SNAPSHOT