forked from geodmms/xdgnjobs

Dennis Kao
2013-11-25 2450ce5ee53fbb20751daf77acf7c481e526f144
xdgnjobs/pom.xml
@@ -19,7 +19,7 @@
    <src.output>${basedir}/target</src.output>
    <java5>1.6</java5>
    <xdgnio.version>2.1.0</xdgnio.version>
    <gt.version>10.1.x</gt.version>
    <gt.version>10.2.x</gt.version>
    <failIfNoTests>false</failIfNoTests>
    <stress.skip.pattern></stress.skip.pattern>
    <online.skip.pattern></online.skip.pattern>
xdgnjobs/ximple-jobcarrier/src/main/resources/quartz_jobs.xml
@@ -26,7 +26,8 @@
      <description>A job that convert dgn to postgis</description>
      <!--job-class>com.ximple.eofms.jobs.OracleConvertDgn2PostGISJob</job-class-->
      <!--job-class>com.ximple.eofms.jobs.GeoserverIntegrateConfigJob</job-class-->
      <job-class>com.ximple.eofms.jobs.OracleTransformColorOwnerJob</job-class>
      <!--job-class>com.ximple.eofms.jobs.OracleTransformColorOwnerJob</job-class-->
      <job-class>com.ximple.eofms.jobs.OracleTransformColorOwner2CSVJob</job-class>
      <!--volatility>false</volatility-->
      <durability>false</durability>
      <recover>false</recover>
xdgnjobs/ximple-spatialjob/pom.xml
@@ -161,6 +161,12 @@
      <artifactId>mysql-connector-java</artifactId>
    </dependency-->
    <dependency>
       <groupId>net.sf.opencsv</groupId>
       <artifactId>opencsv</artifactId>
       <version>2.3</version>
    </dependency>
    <!-- Ximple Library -->
    <dependency>
      <groupId>com.ximple.eofms</groupId>
xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleTransformColorOwner2CSVJob.java
@@ -13,8 +13,11 @@
import java.util.TreeMap;
import au.com.bytecode.opencsv.CSVWriter;
import au.com.bytecode.opencsv.ResultSetHelper;
import au.com.bytecode.opencsv.ResultSetHelperService;
import com.ximple.eofms.jobs.context.AbstractOracleJobContext;
import com.ximple.eofms.jobs.context.postgis.OracleConvertPostGISJobContext;
import com.ximple.eofms.util.DefaultColorTable;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.geotools.data.DataStore;
@@ -45,7 +48,7 @@
    private static final boolean useTpclidText = false;
    private static final int FETCHSIZE = 30;
    private static final int FETCHSIZE = 100;
    private static final int COMMITSIZE = 100;
    protected static class Pair {
@@ -240,9 +243,15 @@
            logger.info("target schema:" + targetSchemaName);
            stmt = connection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
            rs = stmt.executeQuery(FETCH_CONNFDR);
            rs.setFetchSize(50);
            rs.setFetchSize(FETCHSIZE);
            ResultSetHelper resultService = new ResultSetHelperService();
            final String[] header = new String[] { "tid", "oid", "owner" };
            CSVWriter writer = new CSVWriter(new FileWriter("featureowner.csv"), ',');
            writer.writeAll(rs, true);
            writer.writeNext(header);
            while (rs.next()) {
                writer.writeNext(resultService.getColumnValues(rs));
            }
            writer.flush();
            writer.close();
        } finally {
@@ -262,9 +271,22 @@
            logger.info("target schema:" + targetSchemaName);
            stmt = connection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
            rs = stmt.executeQuery(FETCH_COLORTAB);
            rs.setFetchSize(50);
            rs.setFetchSize(FETCHSIZE);
            ResultSetHelper resultService = new ResultSetHelperService();
            DefaultColorTable colorTable = (DefaultColorTable) DefaultColorTable.getInstance();
            final String[] header = new String[] { "tid", "oid", "dyncolor" };
            CSVWriter writer = new CSVWriter(new FileWriter("featurecolor.csv"), ',');
            writer.writeAll(rs, true);
            // writer.writeAll(rs, true);
            writer.writeNext(header);
            while (rs.next()) {
                int colorId = rs.getInt(3);
                String[] values = resultService.getColumnValues(rs);
                String colorText = colorTable.getColorCode(colorId);
                values[2] = colorText;
                writer.writeNext(values);
            }
            writer.flush();
            writer.close();
        } finally {