Application: gvSIG desktop

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

* MA  02110-1301, USA.

*

*/

/*

* AUTHORS (In addition to CIT):

* 2009 IVER T.I   {{Task}}

*/

package org.gvsig.fmap.dal.store.mysql;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.feature.BaseTestEditableFeatureStore;

import org.gvsig.fmap.dal.feature.EditableFeatureType;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.FeatureType;

import org.gvsig.fmap.dal.feature.NewFeatureStoreParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCStoreParameters;

public class MySQLTestWrite extends BaseTestEditableFeatureStore {

	private MySQLNewStoreParameters newParams;

	private MySQLServerExplorer myExplorer;

	@Override

	protected void doSetUp() throws Exception {

		super.doSetUp();

	}

	public DataStoreParameters getDefaultDataStoreParameters()

			throws DataException {

		MySQLStoreParameters parameters = null;

		parameters = (MySQLStoreParameters) dataManager

				.createStoreParameters(MySQLStoreProvider.NAME);

		parameters.setHost("localhost");

		parameters.setPort(3306);

		parameters.setUser("test");

		parameters.setPassword("test");

		parameters.setDBName("gis");

		// parameters.setTable("alfanum_autoid");

		parameters.setTable("comunic_lin_300k");

		return parameters;

	}

	/*

	 * (non-Javadoc)

	 *

	 * @see org.gvsig.fmap.dal.feature.BaseTestFeatureStore#hasExplorer()

	 */

	@Override

	public boolean hasExplorer() {

		// TODO Auto-generated method stub

		return true;

	}

	/*

	 * (non-Javadoc)

	 *

	 * @see org.gvsig.fmap.dal.feature.BaseTestFeatureStore#usesResources()

	 */

	@Override

	public boolean usesResources() {

		// TODO Auto-generated method stub

		return true;

	}

	/*

	public void testImportDB() throws Exception {

		JDBCNewStoreParameters newParasm = (JDBCNewStoreParameters) getDefaultNewDataStoreParameters();

		JDBCServerExplorerParameters seParams = (JDBCServerExplorerParameters) dataManager

				.createServerExplorerParameters(JDBCServerExplorer.NAME);

		assertTrue(myExplorer.add(newParasm, true));

		FeatureStore store = (FeatureStore) dataManager

				.createStore(getDefaultDataStoreParameters());

		FeatureStore newstore = (FeatureStore) dataManager

				.createStore(newParasm);

		newstore.edit(FeatureStore.MODE_APPEND);

		FeatureSet set = store.getFeatureSet();

		DisposableIterator iter = set.iterator();

		Feature org;

		EditableFeature trg;

		Iterator attrIter;

		FeatureAttributeDescriptor attr;

		while (iter.hasNext()) {

			org = (Feature) iter.next();

			trg = newstore.createNewFeature(false);

			attrIter = trg.getType().iterator();

			while (attrIter.hasNext()) {

				attr = (FeatureAttributeDescriptor) attrIter.next();

				trg.set(attr.getName(), org.get(attr.getName()));

			}

			newstore.insert(trg);

		}

		newstore.finishEditing();

		iter.dispose();

		set.dispose();

		store.dispose();

		newstore.dispose();

	}

	*/

	@Override

	public NewFeatureStoreParameters getDefaultNewDataStoreParameters()

			throws Exception {

		JDBCStoreParameters params = (JDBCStoreParameters) getDefaultDataStoreParameters();

		if (this.myExplorer == null) {

			MySQLServerExplorerParameters seParameters = null;

			seParameters = (MySQLServerExplorerParameters) dataManager

					.createServerExplorerParameters(MySQLServerExplorer.NAME);

			seParameters.setHost("localhost");

			seParameters.setPort(3306);

			seParameters.setUser("test");

			seParameters.setPassword("test");

			seParameters.setDBName("gis");

			myExplorer = (MySQLServerExplorer) dataManager

					.createServerExplorer(seParameters);

		}

		if (this.newParams == null) {

			FeatureStore store = (FeatureStore) dataManager.createStore(params);

			newParams = (MySQLNewStoreParameters) myExplorer

					.getAddParameters();

			newParams.setTable(params.getTable() + "_test");

			FeatureType ftOrg = store.getDefaultFeatureType();

			EditableFeatureType ftTrg = ftOrg.getEditable();

//			EditableFeatureType ftTrg = (EditableFeatureType) newParams

//					.getDefaultFeatureType();

			newParams.setDefaultFeatureType(ftTrg);

//			FeatureAttributeDescriptor org;

//			EditableFeatureAttributeDescriptor trg;

//			Iterator iter = ftOrg.iterator();

//			while (iter.hasNext()) {

//				org = (FeatureAttributeDescriptor) iter.next();

//				trg = ftTrg.add(org.getName(), org.getDataType());

//				trg.setAllowNull(org.allowNull());

//				trg.setDefaultValue(org.getDefaultValue());

//				trg.setGeometrySubType(org.getGeometrySubType());

//				trg.setGeometryType(org.getGeometryType());

//				trg.setIsAutomatic(org.isAutomatic());

//				trg.setIsPrimaryKey(org.isPrimaryKey());

//				trg.setIsReadOnly(org.isReadOnly());

//				trg.setMaximumOccurrences(org.getMaximumOccurrences());

//				trg.setMinimumOccurrences(org.getMinimumOccurrences());

//				trg.setPrecision(org.getPrecision());

//				trg.setSize(org.getSize());

//				trg.setSRS(org.getSRS());

//				trg.setAdditionalInfo("SQLType", org

//						.getAdditionalInfo("SQLType"));

//				trg.setAdditionalInfo("SQLTypeName", org

//						.getAdditionalInfo("SQLTypeName"));

//

//			}

//			ftTrg.setDefaultGeometryAttributeName(ftOrg

//					.getDefaultGeometryAttributeName());

//			ftTrg.setHasOID(ftOrg.hasOID());

			store.dispose();

		}

		return this.newParams;

	}

	@Override

	public boolean resourcesNotifyChanges() {

		// TODO Auto-generated method stub

		return false;

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

* MA  02110-1301, USA.

*

*/

/*

* AUTHORS (In addition to CIT):

* 2009 IVER T.I   {{Task}}

*/

package org.gvsig.fmap.dal.store.jdbc;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.feature.BaseTestEditableFeatureStore;

import org.gvsig.fmap.dal.feature.EditableFeature;

import org.gvsig.fmap.dal.feature.EditableFeatureType;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.FeatureType;

import org.gvsig.fmap.dal.feature.NewFeatureStoreParameters;

import com.mysql.jdbc.Driver;

public class JDBCTestWrite extends BaseTestEditableFeatureStore {

	private JDBCNewStoreParameters newParams;

	private JDBCServerExplorer myExplorer;

	private int newId = 50000;

	public void fillPrimaryKeyInserFeature(EditableFeature feature) {

		feature.set("id", newId);

		newId++;

	}

	@Override

	protected void doSetUp() throws Exception {

		// Nothing to do	

	}

	public DataStoreParameters getDefaultDataStoreParameters()

			throws DataException {

		JDBCStoreParameters parameters = null;

		parameters = (JDBCStoreParameters) dataManager

				.createStoreParameters(JDBCStoreProvider.NAME);

		parameters.setHost("localhost");

		parameters.setPort(3306);

		parameters.setUser("test");

		parameters.setPassword("test");

		parameters.setDBName("gis");

		parameters.setTable("alfanum");

		parameters.setUrl("jdbc:mysql://" + parameters.getHost() + ":"

				+ parameters.getPort() + "/" + parameters.getDBName());

		parameters.setJDBCDriverClassName(Driver.class.getName());

		return parameters;

	}

	/*

	 * (non-Javadoc)

	 *

	 * @see org.gvsig.fmap.dal.feature.BaseTestFeatureStore#hasExplorer()

	 */

	@Override

	public boolean hasExplorer() {

		// TODO Auto-generated method stub

		return true;

	}

	/*

	 * (non-Javadoc)

	 *

	 * @see org.gvsig.fmap.dal.feature.BaseTestFeatureStore#usesResources()

	 */

	@Override

	public boolean usesResources() {

		// TODO Auto-generated method stub

		return true;

	}

	/*

	public void testImportDB() throws Exception {

		JDBCNewStoreParameters newParasm = (JDBCNewStoreParameters) getDefaultNewDataStoreParameters();

		JDBCServerExplorerParameters seParams = (JDBCServerExplorerParameters) dataManager

				.createServerExplorerParameters(JDBCServerExplorer.NAME);

		assertTrue(myExplorer.add(newParasm, true));

		FeatureStore store = (FeatureStore) dataManager

				.createStore(getDefaultDataStoreParameters());

		FeatureStore newstore = (FeatureStore) dataManager

				.createStore(newParasm);

		newstore.edit(FeatureStore.MODE_APPEND);

		FeatureSet set = store.getFeatureSet();

		DisposableIterator iter = set.iterator();

		Feature org;

		EditableFeature trg;

		Iterator attrIter;

		FeatureAttributeDescriptor attr;

		while (iter.hasNext()) {

			org = (Feature) iter.next();

			trg = newstore.createNewFeature(false);

			attrIter = trg.getType().iterator();

			while (attrIter.hasNext()) {

				attr = (FeatureAttributeDescriptor) attrIter.next();

				trg.set(attr.getName(), org.get(attr.getName()));

			}

			newstore.insert(trg);

		}

		newstore.finishEditing();

		iter.dispose();

		set.dispose();

		store.dispose();

		newstore.dispose();

	}

	*/

	@Override

	public NewFeatureStoreParameters getDefaultNewDataStoreParameters()

			throws Exception {

		JDBCStoreParameters params = (JDBCStoreParameters) getDefaultDataStoreParameters();

		if (this.myExplorer == null) {

			JDBCServerExplorerParameters seParameters = null;

			seParameters = (JDBCServerExplorerParameters) dataManager

					.createServerExplorerParameters(JDBCServerExplorer.NAME);

			seParameters.setHost("localhost");

			seParameters.setPort(3306);

			seParameters.setUser("test");

			seParameters.setPassword("test");

			seParameters.setDBName("gis");

			seParameters.setUrl("jdbc:mysql://" + seParameters.getHost() + ":"

					+ seParameters.getPort() + "/" + seParameters.getDBName());

			seParameters.setJDBCDriverClassName(Driver.class.getName());

			myExplorer = (JDBCServerExplorer) dataManager

					.createServerExplorer(seParameters);

		}

		if (this.newParams == null) {

			FeatureStore store = (FeatureStore) dataManager.createStore(params);

			newParams = (JDBCNewStoreParameters) myExplorer

					.getAddParameters();

			newParams.setTable(params.getTable() + "_test");

			FeatureType ftOrg = store.getDefaultFeatureType();

			EditableFeatureType ftTrg = ftOrg.getEditable();

//			EditableFeatureType ftTrg = (EditableFeatureType) newParams

//					.getDefaultFeatureType();

			newParams.setDefaultFeatureType(ftTrg);

//			FeatureAttributeDescriptor org;

//			EditableFeatureAttributeDescriptor trg;

//			Iterator iter = ftOrg.iterator();

//			while (iter.hasNext()) {

//				org = (FeatureAttributeDescriptor) iter.next();

//				trg = ftTrg.add(org.getName(), org.getDataType());

//				trg.setAllowNull(org.allowNull());

//				trg.setDefaultValue(org.getDefaultValue());

//				trg.setGeometrySubType(org.getGeometrySubType());

//				trg.setGeometryType(org.getGeometryType());

//				trg.setIsAutomatic(org.isAutomatic());

//				trg.setIsPrimaryKey(org.isPrimaryKey());

//				trg.setIsReadOnly(org.isReadOnly());

//				trg.setMaximumOccurrences(org.getMaximumOccurrences());

//				trg.setMinimumOccurrences(org.getMinimumOccurrences());

//				trg.setPrecision(org.getPrecision());

//				trg.setSize(org.getSize());

//				trg.setSRS(org.getSRS());

//				trg.setAdditionalInfo("SQLType", org

//						.getAdditionalInfo("SQLType"));

//				trg.setAdditionalInfo("SQLTypeName", org

//						.getAdditionalInfo("SQLTypeName"));

//

//			}

//			ftTrg.setDefaultGeometryAttributeName(ftOrg

//					.getDefaultGeometryAttributeName());

//			ftTrg.setHasOID(ftOrg.hasOID());

			store.dispose();

		}

		return this.newParams;

	}

	@Override

	public boolean resourcesNotifyChanges() {

		// TODO Auto-generated method stub

		return false;

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

* MA  02110-1301, USA.

*

*/

/*

* AUTHORS (In addition to CIT):

* 2009 IVER T.I   {{Task}}

*/

/**

 *

 */

package org.gvsig.fmap.dal.store.jdbc;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.feature.BaseTestFeatureStore;

import com.mysql.jdbc.Driver;

/**

 * @author jmvivo

 *

 */

public class JDBCTest extends BaseTestFeatureStore {

	@Override

	protected void doSetUp() throws Exception {

		// Nothing to do	

	}

	public DataStoreParameters getDefaultDataStoreParameters()

			throws DataException {

		JDBCStoreParameters parameters = null;

		parameters = (JDBCStoreParameters) dataManager

				.createStoreParameters(JDBCStoreProvider.NAME);

		parameters.setHost("localhost");

		parameters.setPort(3306);

		parameters.setUser("test");

		parameters.setPassword("test");

		parameters.setDBName("gis");

		parameters.setTable("alfanum");

		parameters.setUrl("jdbc:mysql://" + parameters.getHost() + ":"

				+ parameters.getPort() + "/" + parameters.getDBName());

		parameters.setJDBCDriverClassName(Driver.class.getName());

		return parameters;

	}

	/* (non-Javadoc)

	 * @see org.gvsig.fmap.dal.feature.BaseTestFeatureStore#hasExplorer()

	 */

	@Override

	public boolean hasExplorer() {

		// TODO Auto-generated method stub

		return true;

	}

	/* (non-Javadoc)

	 * @see org.gvsig.fmap.dal.feature.BaseTestFeatureStore#usesResources()

	 */

	@Override

	public boolean usesResources() {

		// TODO Auto-generated method stub

		return true;

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

* MA  02110-1301, USA.

*

*/

/*

* AUTHORS (In addition to CIT):

* 2009 IVER T.I   {{Task}}

*/

/**

 *

 */

package org.gvsig.fmap.dal.store.postgresql;

import java.util.Iterator;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.feature.BaseTestEditableFeatureStore;

import org.gvsig.fmap.dal.feature.EditableFeatureAttributeDescriptor;

import org.gvsig.fmap.dal.feature.EditableFeatureType;

import org.gvsig.fmap.dal.feature.FeatureAttributeDescriptor;

import org.gvsig.fmap.dal.feature.FeatureQuery;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.FeatureStoreTransform;

import org.gvsig.fmap.dal.feature.FeatureType;

import org.gvsig.fmap.dal.feature.NewFeatureStoreParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorer;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.fmap.geom.operation.towkt.ToWKT;

import org.gvsig.tools.evaluator.Evaluator;

import org.gvsig.tools.evaluator.EvaluatorData;

import org.gvsig.tools.evaluator.EvaluatorException;

import org.gvsig.tools.evaluator.EvaluatorFieldsInfo;

/**

 * @author jmvivo

 *

 */

// public class TestPostgreSQL extends BaseTestEditableFeatureStore {

public class TestPostgreSQLWrite extends BaseTestEditableFeatureStore {

	private JDBCServerExplorer myExplorer;

	private PostgreSQLNewStoreParameters newParams;

	@Override

	protected void doSetUp() throws Exception {

		// Initialize wkt geom operation

		int wktCode = ToWKT.CODE;

	}

	public DataStoreParameters getDefaultDataStoreParameters()

			throws DataException {

		PostgreSQLStoreParameters pgParameters = null;

		pgParameters = (PostgreSQLStoreParameters) dataManager

				.createStoreParameters(PostgreSQLStoreProvider.NAME);

		pgParameters.setHost("localhost");

		pgParameters.setUser("postgres");

		pgParameters.setPassword("postgres");

		pgParameters.setDBName("gis");

		pgParameters.setTable("muni10000_peq");

		return pgParameters;

	}

	public boolean hasExplorer() {

		return true;

	}

	public void testLoadMetadata() throws Exception {

		DataStoreParameters params = this.getDefaultDataStoreParameters();

		FeatureStore store = null;

		store = (FeatureStore) dataManager.createStore(params);

		FeatureType fType = store.getDefaultFeatureType();

		FeatureAttributeDescriptor geomAttr;

		if (fType.getDefaultGeometryAttributeIndex() >= 0) {

			assertNotNull(store.getEnvelope());

			geomAttr = fType.getAttributeDescriptor(fType

					.getDefaultGeometryAttributeIndex());

			assertTrue(geomAttr.getGeometryType() == Geometry.TYPES.MULTISURFACE);

			assertTrue(geomAttr.getGeometrySubType() == Geometry.SUBTYPES.GEOM2D);

			assertNotNull(store.getDynValue("CRS"));

		}

	}

	public void testCloserConnection() throws Exception {

		DataStoreParameters params = this.getDefaultDataStoreParameters();

		FeatureStore store = null;

		store = (FeatureStore) dataManager.createStore(params);

		FeatureQuery query = store.createFeatureQuery();

		query.getOrder().add("gid", true);

		query.setFilter(new Evaluator() {

			public Object evaluate(EvaluatorData data)

					throws EvaluatorException {

				// TODO Auto-generated method stub

				return Boolean.TRUE;

			}

			public String getSQL() {

				return "true = true";

			}

			public String getDescription() {

				// TODO Auto-generated method stub

				return null;

			}

			public String getName() {

				return "AlwaysTrue";

			}

			public EvaluatorFieldsInfo getFieldsInfo() {

				// TODO Auto-generated method stub

				return null;

			}

		});

		FeatureStoreTransform transform = new StringsToLowerTransform();

		transform.setFeatureStore(store);

		store.getTransforms().add(transform);

		transform = new StringsToLowerTransform();

		transform.setFeatureStore(store);

		store.getTransforms().add(transform);

		transform = new StringsToLowerTransform();

		transform.setFeatureStore(store);

		store.getTransforms().add(transform);

		for (int i = 0; i < 30; i++) {

			// this.fullStoreIteratorTest(store);

			this.testIterationFastAndStandart(store, query);

		}

		store.dispose();

	}

	public boolean usesResources() {

		return true;

	}

	public NewFeatureStoreParameters getDefaultNewDataStoreParameters()

			throws Exception {

		PostgreSQLStoreParameters parameters = (PostgreSQLStoreParameters) this

				.getDefaultDataStoreParameters();

		FeatureStore store = null;

		if (this.myExplorer == null) {

			store = (FeatureStore) dataManager.createStore(parameters);

			myExplorer = (JDBCServerExplorer) store.getExplorer();

		}

		if (this.newParams == null) {

			if (store == null){

				store = (FeatureStore) dataManager.createStore(parameters);

			}

			newParams = (PostgreSQLNewStoreParameters) myExplorer

					.getAddParameters();

			newParams.setTable(parameters.getTable() + "_test");

			FeatureType ftOrg = store.getDefaultFeatureType();

			EditableFeatureType ftTrg = (EditableFeatureType) newParams

					.getDefaultFeatureType();

			FeatureAttributeDescriptor org;

			EditableFeatureAttributeDescriptor trg;

			Iterator iter = ftOrg.iterator();

			while (iter.hasNext()) {

				org = (FeatureAttributeDescriptor) iter.next();

				trg = ftTrg.add(org.getName(), org.getType());

				trg.setAllowNull(org.allowNull());

				trg.setDefaultValue(org.getDefaultValue());

				trg.setGeometrySubType(org.getGeometrySubType());

				trg.setGeometryType(org.getGeometryType());

				trg.setIsAutomatic(org.isAutomatic());

				trg.setIsPrimaryKey(org.isPrimaryKey());

				trg.setIsReadOnly(org.isReadOnly());

				trg.setMaximumOccurrences(org.getMaximumOccurrences());

				trg.setMinimumOccurrences(org.getMinimumOccurrences());

				trg.setPrecision(org.getPrecision());

				trg.setSize(org.getSize());

				trg.setSRS(org.getSRS());

			}

			ftTrg.setDefaultGeometryAttributeName(ftOrg

					.getDefaultGeometryAttributeName());

			ftTrg.setHasOID(ftOrg.hasOID());

		}

		if (store != null){

			store.dispose();

		}

		return this.newParams;

	}

	public boolean resourcesNotifyChanges() {

		return false;

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

* MA  02110-1301, USA.

*

*/

/*

* AUTHORS (In addition to CIT):

* 2009 IVER T.I   {{Task}}

*/

package org.gvsig.fmap.dal.store.postgresql;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.text.MessageFormat;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.fmap.geom.GeometryLocator;

import org.gvsig.fmap.geom.GeometryManager;

import org.gvsig.fmap.geom.operation.fromwkb.FromWKB;

import org.gvsig.fmap.geom.operation.fromwkb.FromWKBGeometryOperationContext;

import org.gvsig.fmap.geom.operation.towkb.ToWKB;

import org.gvsig.fmap.geom.operation.towkt.ToWKT;

import org.gvsig.fmap.geom.primitive.impl.Point2D;

import org.gvsig.tools.junit.AbstractLibraryAutoInitTestCase;

public class TestReadAndWriteGeom extends AbstractLibraryAutoInitTestCase {

	private static final int FEATURES_TO_INSERT = 12000;

	private static final String TABLE_NAME_INSERT = "testReadadnwritegeom_testcase";

	private static final String FIELD_NAME_INSERT = "geom";

	private Connection conn;

	private GeometryManager geoManager;

	private static String SQL_FOR_READ_TEST = "Select {0} from medio_ejes";

	@Override

	protected void doSetUp() throws Exception {

		geoManager = GeometryLocator.getGeometryManager();

		Class klass = Class.forName(PostgreSQLLibrary.DEFAULT_JDCB_DRIVER_NAME);

		if (klass == null) {

			throw new Exception("Driver not found: "

					+ PostgreSQLLibrary.DEFAULT_JDCB_DRIVER_NAME);

		}

		// inicializamos operaciones de geometrias de las que dependemos

		int code = FromWKB.CODE;

		code = ToWKB.CODE;

		code = ToWKT.CODE;

		conn = DriverManager.getConnection(PostgreSQLLibrary.getJdbcUrl(

				"localhost", 5432, "gis"), "postgres", "postgres");

	}

	public void testInsertWKB() throws Exception {

		PreparedStatement pst = null;

		try {

			crearTablaTest();

			Point2D geom = (Point2D) geoManager.createPoint(0, 0,

					Geometry.SUBTYPES.GEOM2D);

			pst = conn.prepareStatement(

					"Insert into "

					+ TABLE_NAME_INSERT.toLowerCase() +

					"  ("

					+ FIELD_NAME_INSERT + ") Values (GeomFromWKB(?))");

			int i;

			for (i = 1; i <= FEATURES_TO_INSERT; i++) {

				pst.clearParameters();

				geom.setX(i);

				geom.setY(i);

				pst.setBytes(1,

					(byte[]) geom.invokeOperation(

							ToWKB.CODE,

							null)

					);

				pst.executeUpdate();

			}

			System.out

					.println("TestReadAndWriteGeom.testInsertPostgis() Inserteds= i");

		} finally {

			if (pst != null) {

				try {pst.close();} catch (SQLException e) {e.printStackTrace();}

			}

		}

	}

	private void crearTablaTest() throws SQLException {

		execute("DROP TABLE IF EXISTS " + TABLE_NAME_INSERT.toLowerCase());

		execute("Delete from geometry_columns  where  f_table_name = '"

				+ TABLE_NAME_INSERT.toLowerCase() + "'");

		execute("CREATE TABLE " + TABLE_NAME_INSERT.toLowerCase()

				+ " (id serial PRIMARY KEY)");

		execute("Select AddGeometryColumn('" + TABLE_NAME_INSERT.toLowerCase()

				+ "','"

				+ FIELD_NAME_INSERT + "',-1,'GEOMETRY',2)");

	}

	private void execute(String sql) throws SQLException {

		Statement st = null;

		try {

			st = conn.createStatement();

			st.execute(sql);

		} finally {

			if (st != null) {

				try {st.close();} catch (SQLException e) {e.printStackTrace();}

			}

		}

	}

	public String getSQLForRead(String geoColumn) {

		return MessageFormat.format(SQL_FOR_READ_TEST, geoColumn);

	}

	public void testReadBinary() throws Exception {

		// st.execute("declare " + getTableName() + myCursorId +

		// "_wkb_cursor binary scroll cursor with hold for " + sqlAux);

		// rs = st.executeQuery("fetch forward " + FETCH_SIZE+ " in " +

		// getTableName() + myCursorId + "_wkb_cursor");

		Statement st = null;

		ResultSet rs = null;

		long count = 0;

		Geometry geom;

		Geometry nullGeom = geoManager.createNullGeometry(Geometry.SUBTYPES.GEOM2D);

		try {

			st = conn.createStatement();

			String cursorName = "myCursor___xxx";

			st.execute("declare " + cursorName

					+ "_wkb_cursor binary scroll cursor with hold for "

					+ getSQLForRead("the_geom"));

			rs = st.executeQuery("fetch forward all in " + cursorName

					+ "_wkb_cursor");

			byte[] buff;

			FromWKBGeometryOperationContext opContext = new FromWKBGeometryOperationContext();

			while (rs.next()) {

				count++;

				buff = rs.getBytes(1);

//				if (buff != null) {

//					opContext.setData(buff);

//					geom = (Geometry) nullGeom.invokeOperation(FromWKB.CODE,

//							opContext);

//					assertNotNull(geom);

//				}

			}

			System.out

					.println("TestReadAndWriteGeom.testReadPostgis() Count = "

							+ count);

		} finally {

			if (st != null) {

				try {

					st.close();

				} catch (SQLException e) {

					e.printStackTrace();

				}

			}

			if (rs != null) {

				try {

					rs.close();

				} catch (SQLException e) {

					e.printStackTrace();

				}

			}

		}

	}

	public void testReadWKB() throws Exception {

		Statement st = null;

		ResultSet rs = null;

		long count = 0;

		Geometry geom;

		Geometry nullGeom = geoManager

				.createNullGeometry(Geometry.SUBTYPES.GEOM2D);

		byte[] buff;

		FromWKBGeometryOperationContext opContext = new FromWKBGeometryOperationContext();

		try {

			st = conn.createStatement();

			rs = st.executeQuery(getSQLForRead("asBinary(the_geom)"));

			while (rs.next()) {

				count++;

				buff = rs.getBytes(1);

//				if (buff != null) {

//					opContext.setData(buff);

//					geom = (Geometry) nullGeom.invokeOperation(FromWKB.CODE,

//							opContext);

//					assertNotNull(geom);

//				}

			}

			System.out

					.println("TestReadAndWriteGeom.testReadPostgis() Count = "

							+ count);

		} finally {

			if (st != null) {

				try {

					st.close();

				} catch (SQLException e) {

					e.printStackTrace();

				}

			}

			if (rs != null) {

				try {

					rs.close();

				} catch (SQLException e) {

					e.printStackTrace();

				}

			}

		}

	}

//	public void testReadPostgis() throws Exception {

//		Statement st = null;

//		ResultSet rs = null;

//		long count = 0;

//		Geometry geom;

//		PGgeometry pgGeom;

//		PostGIS2Geometry converter = new PostGIS2Geometry();

//		try {

//			st = conn.createStatement();

//			rs = st.executeQuery(getSQLForRead("the_geom"));

//			while (rs.next()) {

//				count++;

//				pgGeom = (PGgeometry) rs.getObject(1);

//				if (pgGeom != null) {

//					geom = converter.getGeometry(pgGeom);

//					assertNotNull(geom);

//				}

//			}

//

//

//			System.out

//					.println("TestReadAndWriteGeom.testReadPostgis() Count = "

//							+ count);

//

//

//		} finally {

//			if (st != null) {

//				try {

//					st.close();

//				} catch (SQLException e) {

//					e.printStackTrace();

//				}

//			}

//			if (rs != null) {

//				try {

//					rs.close();

//				} catch (SQLException e) {

//					e.printStackTrace();

//				}

//			}

//		}

//	}

	protected void tearDown() throws Exception {

		super.tearDown();

		conn.close();

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

* MA  02110-1301, USA.

*

*/

/*

* AUTHORS (In addition to CIT):

* 2009 IVER T.I   {{Task}}

*/

/**

 *

 */

package org.gvsig.fmap.dal.store.postgresql;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.feature.BaseTestFeatureStore;

import org.gvsig.fmap.dal.feature.FeatureAttributeDescriptor;

import org.gvsig.fmap.dal.feature.FeatureQuery;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.FeatureStoreTransform;

import org.gvsig.fmap.dal.feature.FeatureType;

import org.gvsig.fmap.dal.feature.NewFeatureStoreParameters;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.tools.evaluator.Evaluator;

import org.gvsig.tools.evaluator.EvaluatorData;

import org.gvsig.tools.evaluator.EvaluatorException;

import org.gvsig.tools.evaluator.EvaluatorFieldsInfo;

/**

 * @author jmvivo

 *

 */

// public class TestPostgreSQL extends BaseTestEditableFeatureStore {

public class TestPostgreSQL extends BaseTestFeatureStore {

	@Override

	protected void doSetUp() throws Exception {

		super.doSetUp();

	}

	public DataStoreParameters getDefaultDataStoreParameters()

			throws DataException {

		PostgreSQLStoreParameters pgParameters = null;

		pgParameters = (PostgreSQLStoreParameters) dataManager

				.createStoreParameters(PostgreSQLStoreProvider.NAME);

		pgParameters.setHost("localhost");

		pgParameters.setUser("postgres");

		pgParameters.setPassword("postgres");

		pgParameters.setDBName("gis");

		pgParameters.setTable("muni10000_peq");

		return pgParameters;

	}

	public boolean hasExplorer() {

		return true;

	}

	public void testLoadMetadata() throws Exception {

		DataStoreParameters params = this.getDefaultDataStoreParameters();

		FeatureStore store = null;

		store = (FeatureStore) dataManager.createStore(params);

		FeatureType fType = store.getDefaultFeatureType();

		FeatureAttributeDescriptor geomAttr;

		if (fType.getDefaultGeometryAttributeIndex() >= 0) {

			assertNotNull(store.getEnvelope());

			geomAttr = fType.getAttributeDescriptor(fType

					.getDefaultGeometryAttributeIndex());

			assertTrue(geomAttr.getGeometryType() == Geometry.TYPES.MULTISURFACE);

			assertTrue(geomAttr.getGeometrySubType() == Geometry.SUBTYPES.GEOM2D);

			assertNotNull(store.getDynValue("CRS"));

		}

	}

	public void testCloserConnection() throws Exception {

		DataStoreParameters params = this.getDefaultDataStoreParameters();

		FeatureStore store = null;

		store = (FeatureStore) dataManager.createStore(params);

		FeatureQuery query = store.createFeatureQuery();

		query.getOrder().add("gid", true);

		query.setFilter(new Evaluator() {

			public Object evaluate(EvaluatorData data)

					throws EvaluatorException {

				// TODO Auto-generated method stub

				return Boolean.TRUE;

			}

			public String getSQL() {

				return "true = true";

			}

			public String getDescription() {

				// TODO Auto-generated method stub

				return null;

			}

			public String getName() {

				return "AlwaysTrue";

			}

			public EvaluatorFieldsInfo getFieldsInfo() {

				// TODO Auto-generated method stub

				return null;

			}

		});

		FeatureStoreTransform transform = new StringsToLowerTransform();

		transform.setFeatureStore(store);

		store.getTransforms().add(transform);

		transform = new StringsToLowerTransform();

		transform.setFeatureStore(store);

		store.getTransforms().add(transform);

		transform = new StringsToLowerTransform();

		transform.setFeatureStore(store);

		store.getTransforms().add(transform);

		for (int i = 0; i < 30; i++) {

			// this.fullStoreIteratorTest(store);

			this.testIterationFastAndStandart(store, query);

		}

		store.dispose();

	}

	public boolean usesResources() {

		return true;

	}

	public NewFeatureStoreParameters getDefaultNewDataStoreParameters()

			throws Exception {

		// TODO Auto-generated method stub

		return null;

	}

}

/**

 * 

 */

package org.gvsig.fmap.dal.store.postgresql;

import java.sql.Connection;

import java.sql.DatabaseMetaData;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

/**

 * @author cordin

 * 

 */

public class DatabaseMetadataChecks {

	// Columns as specified by the DatabaseMetadata.getTables javadoc

	private static final String[] COLUMNS = new String[] {

	// Metadata resultset column names

			"TABLE_CAT", // String => table catalog (may be null)

			"TABLE_SCHEM", // String => table schema (may be null)

			"TABLE_NAME", // String => table name

			"TABLE_TYPE", // String => table type. Typical types are "TABLE",

						// "VIEW", "SYSTEM TABLE", "GLOBAL TEMPORARY",

						// "LOCAL TEMPORARY", "ALIAS", "SYNONYM".

			"REMARKS", // String => explanatory comment on the table

			"TYPE_CAT", // String => the types catalog (may be null)

			"TYPE_SCHEM", // String => the types schema (may be null)

			"TYPE_NAME", // String => type name (may be null)

			"SELF_REFERENCING_COL_NAME", // String => name of the designated

										// "identifier" column of a typed

										// table (may be null)

			"REF_GENERATION", // String => specifies how values in

							// SELF_REFERENCING_COL_NAME are created. Values

							// are "SYSTEM", "USER", "DERIVED". (may be

							// null)

	};

	public void showTables() throws Exception {

		Connection conn = DriverManager.getConnection(

				"jdbc:postgresql://localhost/gvsigDB", "gvsig", "gvsig");

		try {

			// Statement st = conn.createStatement();

			// String sql = "select tablename from pg_tables";

			// ResultSet result = st.executeQuery(sql);

			DatabaseMetaData metadata = conn.getMetaData();

			ResultSet result = metadata.getTables(null, null, null,

					new String[] { "TABLE", "VIEW" });

			ResultSetMetaData resultMD = result.getMetaData();

			String[] columns = new String[resultMD.getColumnCount()];

			for (int i = 0; i < columns.length; i++) {

				columns[i] = resultMD.getColumnName(i + 1);

			}

			for (int i = 0; i < columns.length; i++) {

				System.out.print(columns[i]);

				System.out.print(";");

			}

			System.out.println();

			while (result.next()) {

				for (int i = 0; i < columns.length; i++) {

					System.out.print(result.getString(columns[i]));

					System.out.print(";");

				}

				System.out.println();

			}

		} finally {

			try {

				conn.close();

			} catch (SQLException e) {

				e.printStackTrace();

			}

		}

	}

	/**

	 * @param args

	 */

	public static void main(String[] args) {

		try {

			new DatabaseMetadataChecks().showTables();

		} catch (Exception e) {

			e.printStackTrace();

			System.exit(-1);

		}

		System.exit(0);

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

* MA  02110-1301, USA.

*

*/

/*

* AUTHORS (In addition to CIT):

* 2009 IVER T.I   {{Task}}

*/

package org.gvsig.fmap.dal.resource.db;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.exception.InitializeException;

import org.gvsig.fmap.dal.resource.ResourceParameters;

import org.gvsig.fmap.dal.resource.exception.AccessResourceException;

import org.gvsig.fmap.dal.resource.exception.ResourceException;

import org.gvsig.fmap.dal.resource.spi.AbstractNonBlockingResource;

/**

 * <p>

 * Abstract Data Base Resource implementation that allow the concurrent access.

 * </p>

 * 

 * <p>

 * Useful for Pooled Data Base Access.

 * </p>

 * 

 * @author jmvivo

 *

 */

public abstract class AbstractDBResourceNoBlocker extends AbstractNonBlockingResource {

	/**

	 * Default constructor

	 *

	 * @param parameters

	 * @throws InitializeException

	 */

	protected AbstractDBResourceNoBlocker(DBResourceParameters parameters)

			throws InitializeException {

		super(parameters);

	}

	/**

	 * Return a connection to the data base.<br>

	 * Connect to the Data Base if is needed

	 *

	 * @return connection to the data base

	 */

	public Object get() throws AccessResourceException {

		if (!isConnected()) {

			try {

				this.connect();

			} catch (DataException e) {

				throw new AccessResourceException(this, e);

			}

		}

		try {

			return getTheConnection();

		} catch (DataException e) {

			throw new AccessResourceException(this, e);

		}

	}

	/**

	 * Return a connection to the data base.<br>

	 * Connect to the Data Base if is needed

	 *

	 *

	 * @return connection to the data base

	 * @see #get()

	 */

	public Object getConnection() throws AccessResourceException {

		return get();

	}