| | |
| | | import org.apache.commons.logging.LogFactory; |
| | | import org.geotools.data.DataStore; |
| | | import org.geotools.data.jdbc.JDBCUtils; |
| | | import org.geotools.data.oracle.OracleDataStore; |
| | | import org.geotools.data.oracle.OracleDataStoreFactory; |
| | | import org.geotools.data.oracle.OracleNGDataStoreFactory; |
| | | import org.geotools.feature.SchemaException; |
| | | import org.geotools.jdbc.JDBCDataStore; |
| | | import org.opengis.feature.IllegalAttributeException; |
| | | import org.quartz.JobDataMap; |
| | | import org.quartz.JobDetail; |
| | |
| | | } |
| | | } |
| | | |
| | | protected static OracleDataStoreFactory dataStoreFactory = new OracleDataStoreFactory(); |
| | | protected static OracleNGDataStoreFactory dataStoreFactory = new OracleNGDataStoreFactory(); |
| | | |
| | | protected String _sdoHost; |
| | | protected String _sdoDatabase; |
| | |
| | | protected String _sdoUseWKB; |
| | | |
| | | protected Map<String, String> sdoProperties; |
| | | protected OracleDataStore targetDataStore; |
| | | protected JDBCDataStore targetDataStore; |
| | | |
| | | public Log getLogger() { |
| | | return logger; |
| | |
| | | } |
| | | |
| | | Map<String, String> remote = new TreeMap<String, String>(); |
| | | remote.put("dbtype", "OraSDO"); |
| | | remote.put("charset", "UTF-8"); |
| | | remote.put("host", _sdoHost); |
| | | remote.put("port", _sdoPort); |
| | | remote.put("database", _sdoDatabase); |
| | | remote.put("user", _sdoUsername); |
| | | remote.put("passwd", _sdoPassword); |
| | | remote.put("namespace", null); |
| | | remote.put(OracleNGDataStoreFactory.DBTYPE.key, "oracle"); |
| | | // remote.put("charset", "UTF-8"); |
| | | remote.put(OracleNGDataStoreFactory.HOST.key, _sdoHost); |
| | | remote.put(OracleNGDataStoreFactory.PORT.key, _sdoPort); |
| | | remote.put(OracleNGDataStoreFactory.DATABASE.key, _sdoDatabase); |
| | | remote.put(OracleNGDataStoreFactory.USER.key, _sdoUsername); |
| | | remote.put(OracleNGDataStoreFactory.PASSWD.key, _sdoPassword); |
| | | // remote.put("namespace", null); |
| | | sdoProperties = remote; |
| | | } |
| | | |
| | |
| | | } |
| | | */ |
| | | |
| | | if (!sdoProperties.containsKey(OracleDataStoreFactory.MAXCONN.key)) { |
| | | sdoProperties.put(OracleDataStoreFactory.MAXCONN.key, "2"); |
| | | if (!sdoProperties.containsKey(OracleNGDataStoreFactory.MAXCONN.key)) { |
| | | sdoProperties.put(OracleNGDataStoreFactory.MAXCONN.key, "2"); |
| | | } |
| | | |
| | | if (!sdoProperties.containsKey(OracleDataStoreFactory.MINCONN.key)) { |
| | | sdoProperties.put(OracleDataStoreFactory.MINCONN.key, "1"); |
| | | if (!sdoProperties.containsKey(OracleNGDataStoreFactory.MINCONN.key)) { |
| | | sdoProperties.put(OracleNGDataStoreFactory.MINCONN.key, "1"); |
| | | } |
| | | |
| | | /* |
| | |
| | | throw new JobExecutionException("cannot process properties-"); |
| | | } |
| | | try { |
| | | targetDataStore = (OracleDataStore) dataStoreFactory.createDataStore(sdoProperties); |
| | | targetDataStore = dataStoreFactory.createDataStore(sdoProperties); |
| | | } catch (IOException e) { |
| | | getLogger().warn(e.getMessage(), e); |
| | | throw new JobExecutionException(e.getMessage(), e); |