Application: gvSIG desktop » gvSIG data provider for PostgreSQL

#Tue Oct 08 20:52:46 CEST 2013

buildNumber=2073

<?xml version="1.0" encoding="ISO-8859-1"?>

<plugin-config>

  <libraries library-dir="lib/"/>

  <depends plugin-name="org.gvsig.app"/>

  <resourceBundle name="text"/>

  <extensions>

     <extension class-name="org.gvsig.andami.LibraryExtension" active="false"/>

  </extensions>    

</plugin-config>

<assembly>

  <id>gvsig-plugin-package</id>

  <formats>

    <format>zip</format>

  </formats>

  <baseDirectory>${project.artifactId}</baseDirectory>

  <includeBaseDirectory>true</includeBaseDirectory>

  <files>

    <file>

      <source>target/${project.artifactId}-${project.version}.jar</source>

      <outputDirectory>lib</outputDirectory>

    </file>

    <file>

      <source>target/package.info</source>

    </file>

  </files>

  <fileSets>

    <fileSet>

      <directory>src/main/resources-plugin</directory>

      <outputDirectory>.</outputDirectory>

    </fileSet>

  </fileSets>

  <dependencySets>

    <dependencySet>

      <useProjectArtifact>false</useProjectArtifact>

      <useTransitiveDependencies>false</useTransitiveDependencies>

      <outputDirectory>lib</outputDirectory>

      <includes>

        <include>org.gvsig:org.gvsig.postgresql.provider</include>

      </includes>

    </dependencySet>

    <dependencySet>

      <useProjectArtifact>false</useProjectArtifact>

      <useTransitiveDependencies>false</useTransitiveDependencies>

      <outputDirectory>lib</outputDirectory>

      <includes>

		<include>postgresql:postgresql</include>

		<include>commons-dbcp:commons-dbcp</include>

		<include>commons-collections:commons-collections</include>

		<include>commons-pool:commons-pool</include>

      </includes>

    </dependencySet>

  </dependencySets>

</assembly>

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.0</modelVersion>

  <artifactId>org.gvsig.postgresql.app.mainplugin</artifactId>

  <packaging>jar</packaging>

  <name>Formats: PostgreSQL support</name>

  <description>PostgreSQL file format support</description>

  <parent>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.postgresql.app</artifactId>

      <version>2.0.17</version>

  </parent>

  <dependencies>

    <dependency>

        <groupId>org.gvsig</groupId>

        <artifactId>org.gvsig.tools.lib</artifactId>

        <scope>compile</scope>

    </dependency>

    <dependency>

        <groupId>org.gvsig</groupId>

        <artifactId>org.gvsig.andami</artifactId>

        <scope>compile</scope>

    </dependency>

    <dependency>

        <groupId>org.gvsig</groupId>

        <artifactId>org.gvsig.postgresql.provider</artifactId>

        <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>postgresql</groupId>

      <artifactId>postgresql</artifactId>

      <scope>runtime</scope>

    </dependency>

    <dependency>

      <groupId>commons-dbcp</groupId>

      <artifactId>commons-dbcp</artifactId>

      <scope>runtime</scope>

    </dependency>

    <dependency>

      <groupId>commons-collections</groupId>

      <artifactId>commons-collections</artifactId>

      <scope>runtime</scope>

    </dependency>

    <dependency>

      <groupId>commons-pool</groupId>

      <artifactId>commons-pool</artifactId>

      <scope>runtime</scope>

    </dependency>

  </dependencies>

    <properties>

        <!-- Package info property values -->

        <!-- Default values in org.gvsig.desktop -->

        <gvsig.package.info.state>testing</gvsig.package.info.state>

        <gvsig.package.info.official>true</gvsig.package.info.official>

        <gvsig.package.info.dependencies>required: org.gvsig.app.mainplugin -ge 2.0.1</gvsig.package.info.dependencies>

        <gvsig.package.info.categories>Formats,Vector,Database</gvsig.package.info.categories>

        <gvsig.package.info.poolURL>http://devel.gvsig.org/download/projects/gvsig-postgresql/pool/</gvsig.package.info.poolURL>

    </properties>

</project>

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.0</modelVersion>

  <artifactId>org.gvsig.postgresql.app</artifactId>

  <packaging>pom</packaging>

  <name>${project.artifactId}</name>

  <parent>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.postgresql</artifactId>

      <version>2.0.17</version>

  </parent>

  <modules>

    <module>org.gvsig.postgresql.app.mainplugin</module>

  </modules>

</project>

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.0</modelVersion>

  <artifactId>org.gvsig.postgresql</artifactId>

  <version>2.0.17</version>

  <packaging>pom</packaging>

  <name>${project.artifactId}</name>

  <description>PostgreSQL support fort DAL and gvSIG</description>

  <parent>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.desktop</artifactId>

      <version>2.0.21</version>

  </parent>

  <url>https://devel.gvsig.org/redmine/projects/gvsig-postgresql</url>

  <scm>

      <connection>scm:svn:https://devel.gvsig.org/svn/gvsig-postgresql/tags/org.gvsig.postgresql-2.0.17</connection>

      <developerConnection>scm:svn:https://devel.gvsig.org/svn/gvsig-postgresql/tags/org.gvsig.postgresql-2.0.17</developerConnection>

      <url>https://devel.gvsig.org/redmine/projects/gvsig-postgresql/repository/show/tags/org.gvsig.postgresql-2.0.17</url>

  </scm>

	<build>

		<plugins>

			<plugin>

				<groupId>org.apache.maven.plugins</groupId>

				<artifactId>maven-release-plugin</artifactId>

				<configuration>

					<tagBase>https://devel.gvsig.org/svn/gvsig-postgresql/tags/</tagBase>

					<goals>deploy</goals>

				</configuration>

			</plugin>

		</plugins>

	</build>

  <dependencyManagement>

      <dependencies>

          <dependency>

            <groupId>org.gvsig</groupId>

            <artifactId>org.gvsig.postgresql.provider</artifactId>

            <version>2.0.17</version>

          </dependency>

          <dependency>

            <groupId>org.gvsig</groupId>

            <artifactId>org.gvsig.postgresql.app.mainplugin</artifactId>

            <version>2.0.17</version>

          </dependency>

      </dependencies>

  </dependencyManagement>

  <dependencies>

        <dependency>

            <groupId>org.slf4j</groupId>

            <artifactId>slf4j-api</artifactId>

            <scope>compile</scope>

        </dependency>

  </dependencies>

  <modules>

    <module>org.gvsig.postgresql.app</module>

    <module>org.gvsig.postgresql.provider</module>

  </modules>

</project>

/**

 * 

 */

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

	}

}

/* 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.SQLException;

import java.text.MessageFormat;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSource;

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

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

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

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

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

import org.gvsig.fmap.dal.store.jdbc.exception.JDBCDriverClassNotFoundException;

import org.gvsig.fmap.dal.store.jdbc.exception.JDBCSQLException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class PostgreSQLResource extends JDBCResource {

	final static private Logger logger = LoggerFactory

			.getLogger(PostgreSQLResource.class);

	public final static String NAME = "PostgreSQLResource";

	public static final String DESCRIPTION = "PostgreSQL Connection";

	public PostgreSQLResource(PostgreSQLResourceParameters parameters)

			throws InitializeException {

		super(parameters);

	}

	public String getName() throws AccessResourceException {

		PostgreSQLResourceParameters params = (PostgreSQLResourceParameters) this.getParameters();

		return MessageFormat.format("PostgreSQLResource({0},{1})",

				new Object[] { params.getUrl(),params.getUser() });

	}

	protected void connectToDB() throws DataException {

		if (this.dataSource != null) {

			return;

		}

		JDBCResourceParameters jdbcParams = (JDBCResourceParameters) this

				.getParameters();

		BasicDataSource dataSource = new BasicDataSource();

		dataSource.setDriverClassName(jdbcParams.getJDBCDriverClassName());

		dataSource.setUsername(jdbcParams.getUser());

		dataSource.setPassword(jdbcParams.getPassword());

		dataSource.setUrl(jdbcParams.getUrl());

		dataSource.setMaxWait(60L * 1000); // FIXME

		// FIXME Set Pool parameters:

		/*

		dataSource.setMaxActive(maxActive);

		dataSource.setMaxIdle(maxActive);

		dataSource.setMaxOpenPreparedStatements(maxActive);

		dataSource.setMaxWait(maxActive);

		dataSource.setInitialSize(initialSize);

		dataSource.setDefaultReadOnly(defaultReadOnly);

		dataSource.setDefaultTransactionIsolation(defaultTransactionIsolation);

		dataSource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);

		dataSource.setMinIdle(minIdle);

		dataSource.setTestOnBorrow(testOnBorrow);

		dataSource.setTestOnReturn(testOnReturn);

		dataSource.setTestWhileIdle(testOnReturn);

		dataSource

				.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);

		dataSource.setAccessToUnderlyingConnectionAllowed(allow);

		dataSource.setLoginTimeout(seconds);

		dataSource.setLogWriter(out);

		*/

		this.dataSource = dataSource;

	}	

	protected void registerJDBCDriver() throws InitializeException {

		String className = ((JDBCResourceParameters) getParameters())

				.getJDBCDriverClassName();

		if (className == null) {

			return;

		}

		Class theClass = null;

		try {

			theClass = Class.forName(className);

		} catch (Exception e){

			throw new InitializeException(e);

		}

		if (theClass == null) {

			try {

				throw new JDBCDriverClassNotFoundException(this.getName(),

						className);

			} catch (AccessResourceException e) {

				throw new InitializeException(e);

			}

		}

	}

	protected DataSource createDataSource() {

		PostgreSQLResourceParameters jdbcParams = (PostgreSQLResourceParameters) this

				.getParameters();

		BasicDataSource dataSource = new BasicDataSource();

		dataSource.setDriverClassName(jdbcParams.getJDBCDriverClassName());

		dataSource.setUsername(jdbcParams.getUser());

		dataSource.setPassword(jdbcParams.getPassword());

		dataSource.setUrl(jdbcParams.getUrl());

		dataSource.setMaxWait(60L * 1000); // FIXME

		// FIXME Set Pool parameters:

		/*

		dataSource.setMaxActive(maxActive);

		dataSource.setMaxIdle(maxActive);

		dataSource.setMaxOpenPreparedStatements(maxActive);

		dataSource.setMaxWait(maxActive);

		dataSource.setInitialSize(initialSize);

		dataSource.setDefaultReadOnly(defaultReadOnly);

		dataSource.setDefaultTransactionIsolation(defaultTransactionIsolation);

		dataSource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);

		dataSource.setMinIdle(minIdle);

		dataSource.setTestOnBorrow(testOnBorrow);

		dataSource.setTestOnReturn(testOnReturn);

		dataSource.setTestWhileIdle(testOnReturn);

		dataSource

			.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);

		dataSource.setAccessToUnderlyingConnectionAllowed(allow);

		dataSource.setLoginTimeout(seconds);

		dataSource.setLogWriter(out);

		 */

		return dataSource;

	}

	public boolean isConnected() {

		if (dataSource == null) {

			return false;

		}

		if (dataSource instanceof BasicDataSource) {

			return ((BasicDataSource) dataSource).getNumActive() > 0

					|| ((BasicDataSource) dataSource).getNumIdle() > 0;

		}

		return true;

	}	

	private void logPoolStatus(String src) {

		if (logger.isDebugEnabled() && dataSource instanceof BasicDataSource) {

			BasicDataSource ds = (BasicDataSource) dataSource;

			logger.debug(src + "  actives:" + ds.getNumActive() + "("

					+ ds.getMaxActive() + ") idle:" + ds.getNumIdle() + "("

					+ ds.getMaxIdle() + ")");

		}

	}

	protected synchronized Object getTheConnection() throws DataException {

		try {

			Object conn = this.dataSource.getConnection();

			logPoolStatus("getTheConnection");

			return conn;

		} catch (SQLException e) {

			throw new JDBCSQLException(e);

		}

	}	

}

/* 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.SQLException;

import java.sql.Statement;

import java.util.ArrayList;

import java.util.List;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.NewDataStoreParameters;

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

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

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

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

import org.gvsig.fmap.dal.spi.DataServerExplorerProviderServices;

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

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

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

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

import org.gvsig.fmap.dal.store.jdbc.exception.JDBCExecuteSQLException;

import org.gvsig.fmap.dal.store.jdbc.exception.JDBCSQLException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * @author jmvivo

 *

 */

public class PostgreSQLServerExplorer extends JDBCServerExplorer {

	final static private Logger logger = LoggerFactory

			.getLogger(PostgreSQLServerExplorer.class);

	public static final String NAME = "PostgreSQLExplorer";

	public PostgreSQLServerExplorer(

			PostgreSQLServerExplorerParameters parameters,

			DataServerExplorerProviderServices services)

			throws InitializeException {

		super(parameters, services);

	}

	private PostgreSQLServerExplorerParameters getPostgreSQLParameters() {

		return (PostgreSQLServerExplorerParameters) getParameters();

	}

	protected JDBCHelper createHelper() throws InitializeException {

		return new PostgreSQLHelper(this, getPostgreSQLParameters());

	}

	protected String getStoreName() {

		return PostgreSQLStoreProvider.NAME;

	}

	public String getProviderName() {

		return NAME;

	}

	protected JDBCStoreParameters createStoreParams()

			throws InitializeException, ProviderNotRegisteredException {

		PostgreSQLStoreParameters orgParams = (PostgreSQLStoreParameters) super

				.createStoreParams();

		orgParams.setUseSSL(getPostgreSQLParameters().getUseSSL());

		return orgParams;

	}

	// ****************************

	public boolean canAdd() {

		return true;

	}

	protected void checkIsMine(DataStoreParameters dsp) {

		if (!(dsp instanceof PostgreSQLStoreParameters)) {

			// FIXME Excpetion ???

			throw new IllegalArgumentException(

					"not instance of PostgreSQLStoreParameters");

		}

		super.checkIsMine(dsp);

		PostgreSQLStoreParameters pgp = (PostgreSQLStoreParameters) dsp;

		if (pgp.getUseSSL().booleanValue() != getPostgreSQLParameters()

				.getUseSSL()) {

			throw new IllegalArgumentException("worng explorer: Host");

		}

	}

	public void remove(DataStoreParameters dsp) throws RemoveException {

		final PostgreSQLStoreParameters pgParams =(PostgreSQLStoreParameters) dsp;

		TransactionalAction action = new TransactionalAction() {

			public boolean continueTransactionAllowed() {

				return false;

			}

			public Object action(Connection conn) throws DataException {

				Statement st;

				try{

					st = conn.createStatement();

				} catch (SQLException e) {

					throw new JDBCSQLException(e);

				}

				String sqlDrop = "Drop table "

					+ pgParams.tableID();

				StringBuilder strb = new StringBuilder();

				strb.append("Delete from GEOMETRY_COLUMNS where f_table_schema = ");

				if (pgParams.getSchema() == null || pgParams.getSchema().length() ==  0) {

					strb.append("current_schema() ");

				} else {

					strb.append('\'');

					strb.append(pgParams.getSchema());

					strb.append("' ");

				}

				strb.append("and f_table_name = '");

				strb.append(pgParams.getTable());

				strb.append('\'');

				String sqlDeleteFromGeometry_column = strb.toString();

				try{

					try{

						st.execute(sqlDrop);

					} catch (SQLException e) {

						throw new JDBCExecuteSQLException(sqlDrop, e);

					}

					try {

						st.execute(sqlDeleteFromGeometry_column);

					} catch (SQLException e) {

						throw new JDBCExecuteSQLException(

								sqlDeleteFromGeometry_column, e);

					}

				} finally{

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

				}

				return null;

			}

		};

		try {

			this.helper.doConnectionAction(action);

		} catch (Exception e) {

			throw new RemoveException(this.getProviderName(), e);

		}

	}

	public NewDataStoreParameters getAddParameters() throws DataException {

		PostgreSQLServerExplorerParameters parameters = getPostgreSQLParameters();

		PostgreSQLNewStoreParameters params = new PostgreSQLNewStoreParameters();

		params.setHost(parameters.getHost());

		params.setPort(parameters.getPort());

		params.setDBName(parameters.getDBName());

		params.setUser(parameters.getUser());

		params.setPassword(parameters.getPassword());

		params.setCatalog(parameters.getCatalog());

		params.setSchema(parameters.getSchema());

		params.setJDBCDriverClassName(parameters.getJDBCDriverClassName());

		params.setUrl(parameters.getUrl());

		params.setUseSSL(parameters.getUseSSL());

		params.setDefaultFeatureType(this.getServerExplorerProviderServices()

				.createNewFeatureType());

		return params;

	}

	// ***********************

	// ***********************

	public boolean hasGeometrySupport() {

		return true;

	}

	protected PostgreSQLHelper getPgHelper() {