forked from geodmms/xdgnjobs
blame | history | patch | commit | commitdiff | ignore whitespace
unknown
2014-08-04 be3f6f9762dd15177477a7bcf6e11a2e27c70e57 
 xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleConvertDgn2PostGISJob.java


@@ -1,37 +1,21 @@


package com.ximple.eofms.jobs;




import java.io.File;


import java.io.FileFilter;


import java.io.FileInputStream;


import java.io.FileNotFoundException;


import java.io.FilenameFilter;


import java.io.IOException;


import java.io.PushbackReader;


import java.io.StringReader;


import java.math.BigDecimal;


import java.nio.BufferOverflowException;


import java.nio.ByteBuffer;


import java.nio.ByteOrder;


import java.nio.channels.FileChannel;


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.List;


import java.util.Map;


import java.util.TreeMap;




import com.ximple.eofms.jobs.context.AbstractOracleJobContext;


import com.ximple.eofms.jobs.context.postgis.FeatureDgnConvertPostGISJobContext;


import com.ximple.eofms.jobs.context.postgis.GeneralDgnConvertPostGISJobContext;


import com.ximple.eofms.jobs.context.postgis.IndexDgnConvertPostGISJobContext;


import com.ximple.eofms.jobs.context.postgis.OracleConvertPostGISJobContext;


import com.ximple.eofms.util.*;


import com.ximple.io.dgn7.*;


import com.ximple.util.PrintfFormat;


import oracle.jdbc.OracleConnection;


import oracle.jdbc.OracleResultSet;


import oracle.sql.ARRAY;


import oracle.sql.BLOB;


import org.apache.commons.collections.OrderedMap;


import org.apache.commons.collections.OrderedMapIterator;


import org.apache.commons.collections.map.LinkedMap;


import org.apache.commons.dbcp.DelegatingConnection;


import org.apache.commons.dbcp.PoolingConnection;


import org.apache.commons.dbcp.PoolingDataSource;


import org.apache.commons.logging.Log;


import org.apache.commons.logging.LogFactory;


import org.geotools.data.DataStore;


@@ -48,24 +32,15 @@


import org.quartz.JobExecutionContext;


import org.quartz.JobExecutionException;




import oracle.jdbc.OracleConnection;


import oracle.jdbc.OracleResultSet;


import oracle.sql.ARRAY;


import oracle.sql.BLOB;




import com.ximple.eofms.jobs.context.AbstractOracleJobContext;


import com.ximple.eofms.jobs.context.postgis.FeatureDgnConvertPostGISJobContext;


import com.ximple.eofms.jobs.context.postgis.GeneralDgnConvertPostGISJobContext;


import com.ximple.eofms.jobs.context.postgis.IndexDgnConvertPostGISJobContext;


import com.ximple.eofms.jobs.context.postgis.OracleConvertPostGISJobContext;


import com.ximple.io.dgn7.ComplexElement;


import com.ximple.io.dgn7.Dgn7fileException;


import com.ximple.io.dgn7.Dgn7fileReader;


import com.ximple.io.dgn7.Element;


import com.ximple.io.dgn7.ElementType;


import com.ximple.io.dgn7.IElementHandler;


import com.ximple.io.dgn7.Lock;


import com.ximple.util.PrintfFormat;


import java.io.*;


import java.math.BigDecimal;


import java.nio.BufferOverflowException;


import java.nio.ByteBuffer;


import java.nio.ByteOrder;


import java.nio.channels.FileChannel;


import java.sql.*;


import java.util.*;


import java.util.Date;




public class OracleConvertDgn2PostGISJob extends AbstractOracleDatabaseJob {


    final static Log logger = LogFactory.getLog(OracleConvertDgn2PostGISJob.class);


@@ -379,7 +354,12 @@


            logger.warn(ex.getMessage(), ex);


            throw new JobExecutionException("IO error. " + ex.getMessage(), ex);


        } finally {


            try{


            disconnect();


            }catch(Exception doubleEx)


            {




            }


        }


        logger.warn(jobName + " end at " + new Date());


    }


@@ -1238,10 +1218,15 @@


    }




    protected void disconnect() {


        try{


        super.disconnect();


        if (targetDataStore != null) {


            targetDataStore.dispose();


            targetDataStore = null;


        }


        }catch (Exception ex)


        {


            logger.warn(ex.getMessage());


        }


    }




@@ -1308,7 +1293,13 @@


        } finally {


            JDBCUtils.close(rs);


            JDBCUtils.close(stmt);


            try{


            JDBCUtils.close(connection, Transaction.AUTO_COMMIT, null);




            }catch(Exception doubleException)


            {




            }


        }


        return targetSchema;


    }