forked from geodmms/xdgnjobs

?? ?
2008-06-13 78792a3cca250c5d4f91f782c1697d4d9d180936
xdgnjobs/ximple-spatialjob/src/main/java/com/ximple/eofms/jobs/OracleConvertDgn2PostGISJob.java
@@ -287,6 +287,7 @@
        Statement stmt = connection.createStatement();
        stmt.execute(AbstractOracleJobContext.TRUNCATE_CONNECTIVITY_WEBCHECK);
        stmt.execute(AbstractOracleJobContext.COPY_CONNECTIVITY_TO_WEBCHECK);
        stmt.close();
    }
    private void exetcuteConvert(OracleConvertPostGISJobContext jobContext,
@@ -411,9 +412,9 @@
        Statement stmt = connection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
        stmt.setFetchSize(FETCHSIZE);
        ResultSet rs = stmt.executeQuery(fetchStmt);
        try
        {
        while (rs.next())
        {
            int size = rs.getMetaData().getColumnCount();
@@ -433,10 +434,11 @@
            else
                pair.second = name;
        }
        } finally
        {
        rs.close();
        stmt.close();
        }
        return orderedMap;
    }
@@ -450,7 +452,6 @@
        Statement stmtSrc = connection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
        stmtSrc.setFetchSize(FETCHSIZE);
        ResultSet rsSrc = stmtSrc.executeQuery(fetchSrcStmt);
        while (rsSrc.next())
@@ -492,9 +493,10 @@
        Statement stmtDest = connection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
        stmtDest.setFetchSize(FETCHSIZE);
        ResultSet rsDest = stmtDest.executeQuery(fetchDestStmt);
        try
        {
        while (rsDest.next())
        {
            ARRAY rawsValue = ((OracleResultSet) rsDest).getARRAY(1);
@@ -524,9 +526,11 @@
                logger.warn("Dgn7Exception:" + e.getMessage(), e);
            }
        }
        } finally
        {
        rsDest.close();
        stmtDest.close();
        }
    }
    // Binary to Element