/branches/v2_0_0_prep/libraries/org.gvsig.fmap.dal.db.h2spatial/src/main/java/org/gvsig/fmap/dal/db/h2spatial/impl/H2SpatialServerExplorer.java - Diff - | gvSIG desktop 1 - gvSIG

Revision 32684 branches/v2_0_0_prep/libraries/org.gvsig.fmap.dal.db.h2spatial/src/main/java/org/gvsig/fmap/dal/db/h2spatial/impl/H2SpatialServerExplorer.java

     import org.slf4j.Logger;
     import org.slf4j.LoggerFactory;
     /**
+     *
      * @author Vicente Caballero Navarro
      */
     public class H2SpatialServerExplorer extends JDBCServerExplorer {
     	final static private Logger logger = LoggerFactory
-...
     		"net.sourceforge.hatbox.jts.Proc.spatialize"
     	};
     	private static boolean initialized=false;
     	public H2SpatialServerExplorer(JDBCServerExplorerParameters parameters,
     			DataServerExplorerProviderServices services)
     			throws InitializeException {
-...
+    	}
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#createHelper()
     	 */
     	protected JDBCHelper createHelper() throws InitializeException {
     		return new H2SpatialHelper(this, getH2Spatialparameters());
+    	}
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#getStoreName()
     	 */
     	protected String getStoreName() {
     		return H2SpatialStoreProvider.NAME;
+    	}
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#getName()
     	 */
     	public String getName() {
     		return NAME;
+    	}
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#createStoreParams()
     	 */
     	protected JDBCStoreParameters createStoreParams()
     			throws InitializeException, ProviderNotRegisteredException {
     		H2SpatialStoreParameters orgParams = (H2SpatialStoreParameters) super
-...
     		return orgParams;
+    	}
     	// ****************************
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#canAdd()
     	 */
     	public boolean canAdd() {
     		return true;
+    	}
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#checkIsMine(org.gvsig.fmap.dal.DataStoreParameters)
     	 */
     	protected void checkIsMine(DataStoreParameters dsp) {
     		if (!(dsp instanceof H2SpatialStoreParameters)) {
     			// FIXME Excpetion ???
-...
+    		}
+    	}
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#remove(org.gvsig.fmap.dal.DataStoreParameters)
     	 */
     	public void remove(DataStoreParameters dsp) throws RemoveException {
     		final H2SpatialStoreParameters slParams =(H2SpatialStoreParameters) dsp;
-...
+    			}
     			public Object action(Connection conn) throws DataException {
     				Statement st;
     				try{
     					Proc.deSpatialize(conn, slParams.getSchema().toUpperCase(), slParams.getTable().toUpperCase());
     					st = conn.createStatement();
     				} catch (SQLException e) {
     					throw new JDBCSQLException(e);
+    				}
     				String sqlDrop = "Drop table "
     					+ slParams.tableID();
     				StringBuilder strb = new StringBuilder();
     				strb.append("Delete from geometry_columns where f_table_name = ");
     				strb.append('\'');
     				strb.append(slParams.getTable());
     				strb.append('\'');
     				StringBuilder strb2 = new StringBuilder();
     				strb2.append("Delete from geom_cols_ref_sys where f_table_name = ");
     				strb2.append('\'');
     				strb2.append(slParams.getTable());
     				strb2.append('\'');
     				StringBuilder strb3 = new StringBuilder();
     				strb3.append("DROP TABLE IF EXISTS");
     				strb3.append('\'');
     				strb3.append("idx_");
     				strb3.append(slParams.getTable());
     				strb3.append("_the_geom");
     				strb3.append('\'');
     				strb3.append("DROP TABLE IF EXISTS ");
     				strb3.append(slParams.getTable().toUpperCase());
     				StringBuilder strb4 = new StringBuilder();
     				strb4.append("DROP TABLE IF EXISTS");
     				strb4.append('\'');
     				strb4.append("idx_");
     				strb4.append(slParams.getTable());
     				strb4.append("_the_geom_node");
     				strb4.append('\'');
     				strb4.append("DROP TABLE IF EXISTS ");
     				strb4.append(slParams.getTable().toUpperCase());
     				strb4.append("_HATBOX");
     				String sqlDeleteTable = strb3.toString();
     				String sqlDeleteTable_HATBOX = strb4.toString();
     				StringBuilder strb5 = new StringBuilder();
     				strb5.append("DROP TABLE IF EXISTS");
     				strb5.append('\'');
     				strb5.append("idx_");
     				strb5.append(slParams.getTable());
     				strb5.append("_the_geom_parent");
     				strb5.append('\'');
     				StringBuilder strb6 = new StringBuilder();
     				strb6.append("DROP TABLE IF EXISTS");
     				strb6.append('\'');
     				strb6.append("idx_");
     				strb6.append(slParams.getTable());
     				strb6.append("_the_geom_rowid");
     				strb6.append('\'');
     				StringBuilder strb7 = new StringBuilder();
     				strb6.append("DROP TABLE IF EXISTS");
     				strb6.append('\'');
     				strb6.append("cache_");
     				strb6.append(slParams.getTable());
     				strb6.append("_the_geom");
     				strb6.append('\'');
     				String sqlDeleteFromGeometry_column = strb.toString();
     				String sqlDeleteFromGeom_cols_ref = strb2.toString();
     				String sqlDeleteIdx = strb3.toString();
     				String sqlDeleteIdx_node = strb4.toString();
     				String sqlDeleteIdx_parent = strb5.toString();
     				String sqlDeleteIdx_rowid = strb6.toString();
     				String sqlDeleteCache = strb7.toString();
     				try{
     					try{
     						st.execute(sqlDrop);
     						st.execute(sqlDeleteTable);
     					} catch (SQLException e) {
     						throw new JDBCExecuteSQLException(sqlDrop, e);
     						throw new JDBCExecuteSQLException(sqlDeleteTable, e);
+    					}
     					try {
     						st.execute(sqlDeleteFromGeometry_column);
     						st.execute(sqlDeleteTable_HATBOX);
     					} catch (SQLException e) {
     						throw new JDBCExecuteSQLException(
     								sqlDeleteFromGeometry_column, e);
     						throw new JDBCExecuteSQLException(sqlDeleteTable_HATBOX, e);
+    					}
     					try {
     						st.execute(sqlDeleteFromGeom_cols_ref);
     					} catch (SQLException e) {
     						throw new JDBCExecuteSQLException(
     								sqlDeleteFromGeom_cols_ref, e);
+    					}
     					try {
     						st.execute(sqlDeleteIdx);
     					} catch (SQLException e) {
     						throw new JDBCExecuteSQLException(
     								sqlDeleteIdx, e);
+    					}
     					try {
     						st.execute(sqlDeleteIdx_node);
     					} catch (SQLException e) {
     						throw new JDBCExecuteSQLException(
     								sqlDeleteIdx_node, e);
+    					}
     					try {
     						st.execute(sqlDeleteIdx_parent);
     					} catch (SQLException e) {
     						throw new JDBCExecuteSQLException(
     								sqlDeleteIdx_parent, e);
+    					}
     					try {
     						st.execute(sqlDeleteIdx_rowid);
     					} catch (SQLException e) {
     						throw new JDBCExecuteSQLException(
     								sqlDeleteIdx_rowid, e);
+    					}
     					try {
     						st.execute(sqlDeleteCache);
     					} catch (SQLException e) {
     						throw new JDBCExecuteSQLException(
     								sqlDeleteCache, e);
+    					}
     				} finally{
     					try{ st.close(); } catch (SQLException e) {};
+    				}
-...
+    		}
+    	}
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#getAddParameters()
     	 */
     	public NewDataStoreParameters getAddParameters() throws DataException {
     		H2SpatialServerExplorerParameters parameters = getH2Spatialparameters();
     		H2SpatialNewStoreParameters params = new H2SpatialNewStoreParameters();
-...
     		return params;
+    	}
     	// ***********************
     	// ***********************
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#getSQLForList(int, boolean)
     	 */
     	protected List getSQLForList(int mode, boolean showInformationDBTables) {
     		List list = new ArrayList(1);
     		String sql="SELECT TABLE_CATALOG, TABLE_SCHEMA, TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA<>'INFORMATION_SCHEMA' AND TABLE_NAME NOT LIKE '%_HATBOX' AND EXISTS (SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME LIKE '%_HATBOX')";
-...
     		return list;
+    	}
     	/* (non-Javadoc)
     	 * @see org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer#add(org.gvsig.fmap.dal.NewDataStoreParameters, boolean)
     	 */
     	public boolean add(NewDataStoreParameters ndsp, boolean overwrite)
     	throws DataException {
     		//crea el fichero de la bbdd y la hace espacial
     		this.initializedb();
     		if (!initialized){
     			this.initializedb();
     			initialized=true;
+    		}
     		/**
     		 * CREATE [ [ GLOBAL | LOCAL ] { TEMPORARY | TEMP } ] TABLE table_name (
     		 * { column_name data_type [ DEFAULT default_expr ] [ column_constraint
     		 * [ ... ] ] | table_constraint | LIKE parent_table [ { INCLUDING |
     		 * EXCLUDING } DEFAULTS ] } [, ... ] ) [ INHERITS ( parent_table [, ...
     		 * ] ) ] [ WITH OIDS | WITHOUT OIDS ] [ ON COMMIT { PRESERVE ROWS |
     		 * DELETE ROWS | DROP } ]
+    		 *
     		 * where column_constraint is:
+    		 *
     		 * [ CONSTRAINT constraint_name ] { NOT NULL | NULL | UNIQUE | PRIMARY
     		 * KEY | CHECK (expression) | REFERENCES reftable [ ( refcolumn ) ] [
     		 * MATCH FULL | MATCH PARTIAL | MATCH SIMPLE ] [ ON DELETE action ] [ ON
     		 * UPDATE action ] } [ DEFERRABLE | NOT DEFERRABLE ] [ INITIALLY
     		 * DEFERRED | INITIALLY IMMEDIATE ]
+    		 *
     		 * and table_constraint is:
+    		 *
     		 * [ CONSTRAINT constraint_name ] { UNIQUE ( column_name [, ... ] ) |
     		 * PRIMARY KEY ( column_name [, ... ] ) | CHECK ( expression ) | FOREIGN
     		 * KEY ( column_name [, ... ] ) REFERENCES reftable [ ( refcolumn [, ...
     		 * ] ) ] [ MATCH FULL | MATCH PARTIAL | MATCH SIMPLE ] [ ON DELETE
     		 * action ] [ ON UPDATE action ] } [ DEFERRABLE | NOT DEFERRABLE ] [
     		 * INITIALLY DEFERRED | INITIALLY IMMEDIATE ]
     		 */
     		if (!(ndsp instanceof NewFeatureStoreParameters)) {
     			// FIXME exception
     			throw new IllegalArgumentException();
+    		}
     		checkIsMine(ndsp);
-...
     		StringBuilder sql = new StringBuilder();
     		if (!nfdsp.isValid()) {
     			// TODO Exception
     			throw new InitializeException(this.getName(), new Exception(
     			"Parameters not valid"));
+    		}
-...
     		TransactionalAction action = new TransactionalAction() {
     			public boolean continueTransactionAllowed() {
     				// TODO Auto-generated method stub
     				return false;
+    			}
-...
     						logger.error("Exception clossing statement", e);
+    					}
+    				}
     				return Boolean.TRUE;
+    			}
-...
     			Proc.spatialize(helper.getConnection(), schema, table, geomCol, geomType, epsg, "false", "49");
     			Proc.buildIndex(helper.getConnection(), schema, table, 100, null);
     		} catch (Exception e) {
     			// FIXME Exception
     			throw new RuntimeException(e);
+    		}
-...
     		try {
         		Class.forName("org.h2.Driver");
     			conn = getHelper().getConnection();//DriverManager.getConnection("jdbc:h2:"+System.getProperty("user.home")+File.separator+"gvSIG"+File.separator+"cache"+File.separator+"cache", null, null);
     			StringBuilder strb = new StringBuilder();
     			strb.append("DROP ALL OBJECTS");
     			String sqlDeleteTable = strb.toString();
     			Statement st;
     			try{
     				st = conn.createStatement();
     				st.execute(sqlDeleteTable);
     			} catch (SQLException e) {
     				throw new JDBCExecuteSQLException(sqlDeleteTable, e);
+    			}
     		} catch (Exception e) {
     			e.printStackTrace();
+    		}
     		//si esta no esta la bd espacializada se espacializa
     		//si no est? la bd espacializada se espacializa
     		if(!determineDbStatus(conn)){
     			spatializedb(conn);
+    		}
-...
+    		}
     		return spatialized;
+    	}
+    }

Also available in: Unified diff