Application: gvSIG desktop » gvSIG data provider for PostgreSQL

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

    <file>

      <source>src/main/resources-plugin/config.xml</source>

    </file>

  </files>

  <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>org.postgresql:postgresql</include>

		<include>org.apache.commons:commons-dbcp2</include>

		<include>org.apache.commons:commons-pool2</include>

      </includes>

    </dependencySet>

  </dependencySets>

</assembly>

_PostgreSQL_loading_parameters=PostgreSQL loading parameters

_PostgreSQL_loading_parameters=Par\u00e1metros de carga de PostgreSQL

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

<plugin-config>

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

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

  <resourceBundle name="text"/>

  <extensions>

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

  </extensions>    

</plugin-config>

<?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>${project.artifactId}</name>

  <description>PostgreSQL file format support</description>

  <parent>

      <groupId>org.gvsig</groupId>

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

      <version>2.0.182</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>org.postgresql</groupId>

      <artifactId>postgresql</artifactId>

      <scope>runtime</scope>

    </dependency>

    <dependency>

      <groupId>org.apache.commons</groupId>

      <artifactId>commons-dbcp2</artifactId>

      <scope>runtime</scope>

    </dependency>    

    <dependency>

      <groupId>org.apache.commons</groupId>

      <artifactId>commons-pool2</artifactId>

      <scope>runtime</scope>

    </dependency>

  </dependencies>

    <properties>

        <!-- Package info property values -->

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

        <gvsig.package.info.name>Formats: PostgreSQL support</gvsig.package.info.name>

        <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>https://devel.gvsig.org/download/projects/gvsig-postgresql/pool/</gvsig.package.info.poolURL>

    </properties>

</project>

#Fri Nov 26 00:53:29 CET 2021

buildNumber=2239

<?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.182</version>

  </parent>

  <modules>

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

    <!--

    <module>org.gvsig.postgresql.app.export</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.182</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.343</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.182</connection>

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

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

  </scm>

    <repositories>

        <repository>

            <id>gvsig-public-http-repository</id>

            <name>gvSIG maven public HTTP repository</name>

            <url>http://devel.gvsig.org/m2repo/j2se</url>

            <releases>

                <enabled>true</enabled>

                <updatePolicy>daily</updatePolicy>

                <checksumPolicy>warn</checksumPolicy>

            </releases>

            <snapshots>

                <enabled>true</enabled>

                <updatePolicy>daily</updatePolicy>

                <checksumPolicy>warn</checksumPolicy>

            </snapshots>

        </repository>

    </repositories>

	<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.182</version>

          </dependency>

          <dependency>

            <groupId>org.gvsig</groupId>

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

            <version>2.0.182</version>

          </dependency>

        <dependency>

            <groupId>org.postgresql</groupId>

            <artifactId>postgresql</artifactId>

            <version>42.3.1</version>

        </dependency>

        <dependency>

          <groupId>org.apache.commons</groupId>

          <artifactId>commons-dbcp2</artifactId>

          <version>2.7.0</version>

        </dependency>   

        <dependency>

            <groupId>org.apache.commons</groupId>

            <artifactId>commons-pool2</artifactId>

            <version>2.7.0</version>

        </dependency>

      </dependencies>

  </dependencyManagement>

  <modules>

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

    <module>org.gvsig.postgresql.provider</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.provider</artifactId>

  <packaging>jar</packaging>

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

  <description>DAL provider for PostgeSQL files</description>

  <parent>

    <groupId>org.gvsig</groupId>

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

    <version>2.0.182</version>

  </parent>

  <dependencies>

    <dependency>

      <groupId>com.googlecode.log4jdbc</groupId>

      <artifactId>log4jdbc</artifactId>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

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

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.projection.api</artifactId>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.fmap.dal.api</artifactId>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.fmap.dal.db.jdbc</artifactId>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.fmap.dal.db.lib</artifactId>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.fmap.dal.spi</artifactId>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.metadata.lib.basic.api</artifactId>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.fmap.geometry.api</artifactId>

      <scope>compile</scope>

    </dependency>

    <!--

    <dependency>

        <groupId>org.gvsig</groupId>

        <artifactId>org.gvsig.fmap.geometry.operation</artifactId>

        <scope>compile</scope>

    </dependency>

    -->

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.timesupport.lib.api</artifactId>

      <scope>compile</scope>

    </dependency>  

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.utils</artifactId>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.postgresql</groupId>

      <artifactId>postgresql</artifactId>

      <scope>compile</scope>

    </dependency>

    <dependency>

        <groupId>org.apache.commons</groupId>

        <artifactId>commons-dbcp2</artifactId>

    </dependency>

    <dependency>

        <groupId>org.apache.commons</groupId>

        <artifactId>commons-pool2</artifactId>

    </dependency>

    <dependency>

      <groupId>commons-collections</groupId>

      <artifactId>commons-collections</artifactId>

      <scope>compile</scope>

    </dependency>

    <!-- TESTS -->

    <dependency>

      <groupId>org.gvsig</groupId>

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

      <type>test-jar</type>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.compat.se</artifactId>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.fmap.dal.impl</artifactId>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.fmap.dal.file.csv</artifactId>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.tools.util.impl</artifactId>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.tools.swing.impl</artifactId>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>${org.gvsig.fmap.geometry.impl}</artifactId>

      <scope>test</scope>

    </dependency>    

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.expressionevaluator.geometry.lib.impl</artifactId>

      <scope>test</scope>

    </dependency>    

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>${org.gvsig.proj.lib.impl}</artifactId>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.projection.cresques.impl</artifactId>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.timesupport.lib.impl</artifactId>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.metadata.lib.basic.impl</artifactId>

      <scope>test</scope>

    </dependency>      

    <dependency>

      <artifactId>junit</artifactId>

      <groupId>junit</groupId>

      <scope>test</scope>

    </dependency>

  </dependencies>

  <build>

    <plugins>

      <!-- Skip test execution ? -->

      <plugin>

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

        <artifactId>maven-surefire-plugin</artifactId>

        <configuration>

          <skipTests>false</skipTests>

        </configuration>

      </plugin>

      <!-- Skip test compilation ? -->

      <plugin>

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

        <artifactId>maven-compiler-plugin</artifactId>

        <executions>

          <execution>

            <id>default-testCompile</id>

            <phase>process-test-sources</phase>

            <goals>

              <goal>testCompile</goal>

            </goals>

            <configuration>

              <skip>false</skip>

            </configuration>

          </execution>

        </executions>

      </plugin>

      <!-- Ignore test execution failure ? -->

      <plugin>

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

        <artifactId>maven-surefire-plugin</artifactId>

        <configuration>

          <testFailureIgnore>false</testFailureIgnore>

        </configuration>

      </plugin>

    </plugins>

  </build>

</project>

package org.gvsig.postgresql.dal;

import junit.framework.TestCase;

import org.apache.commons.lang3.ArrayUtils;

import org.cresques.cts.IProjection;

import org.gvsig.expressionevaluator.ExpressionBuilder;

import org.gvsig.expressionevaluator.GeometryExpressionBuilder;

import org.gvsig.fmap.crs.CRSFactory;

import org.gvsig.fmap.dal.SQLBuilder;

import org.gvsig.fmap.dal.SQLBuilder.Privilege;

import org.gvsig.fmap.dal.feature.spi.SQLBuilderBase;

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory.TableReference;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.OperationsFactoryBase;

import org.gvsig.fmap.geom.DataTypes;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.fmap.geom.GeometryLocator;

import org.gvsig.fmap.geom.GeometryManager;

import org.gvsig.fmap.geom.primitive.Polygon;

import org.gvsig.tools.library.impl.DefaultLibrariesInitializer;

public class PostgreSQLBuilderTest extends TestCase {

    public PostgreSQLBuilderTest(String testName) {

        super(testName);

    }

    @Override

    protected void setUp() throws Exception {

        super.setUp();

        new DefaultLibrariesInitializer().fullInitialize();

    }

    @Override

    protected void tearDown() throws Exception {

        super.tearDown();

    }

    private SQLBuilder createSQLBuilder() {

        return new PostgreSQLBuilder(new PostgreSQLHelper(new FakePostgreSQLConnectionParameters()));

    }

    public void testCalulateEnvelopeOfColumn() throws Exception {

        TableReference table = new OperationsFactoryBase.DefaultTableReference("master","dbo","test1", null);

        String columnName = "the_geom";

        SQLBuilder sqlbuilder = createSQLBuilder();

        GeometryExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.select().column().value(

            expbuilder.as_geometry(

                expbuilder.ST_ExtentAggregate(

                        expbuilder.column(columnName)

                )

            )

        );

        //sqlbuilder.select().group_by(expbuilder.column(columnName));

        sqlbuilder.select().from().table()

                .database(table.getDatabase())

                .schema(table.getSchema())

                .name(table.getTable());

        sqlbuilder.select().from().subquery(table.getSubquery());

        sqlbuilder.select().where().and(        

            expbuilder.not_is_null(expbuilder.column(columnName))

        );

        System.out.println("# Test:: testCalulateEnvelopeOfColumn");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "SELECT ST_AsBinary(ST_Extent(\"the_geom\")) FROM \"master\".\"dbo\".\"test1\" WHERE ( (\"the_geom\") IS NOT NULL )",

                sqlbuilder.toString()

        );

        assertEquals(

                "[the_geom]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testCalulateEnvelope() throws Exception {

        GeometryManager geometryManager = GeometryLocator.getGeometryManager();

        IProjection proj = CRSFactory.getCRS("EPSG:4326");

        Polygon limit = geometryManager.createPolygon(Geometry.SUBTYPES.GEOM2D);

        limit.addVertex(0, 0);

        limit.addVertex(0, 100);

        limit.addVertex(100, 100);

        limit.addVertex(100, 0);

        limit.addVertex(0, 0);

        SQLBuilder sqlbuilder = createSQLBuilder();

        GeometryExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.select().column().value(

            expbuilder.as_geometry(

              expbuilder.ST_ExtentAggregate(

                expbuilder.column("the_geom")

              )

            )

        ).as("envelope");

        sqlbuilder.select().from().table().database("master").schema("dbo").name("test1");

        sqlbuilder.select().where().set(

            expbuilder.ST_Intersects(

                expbuilder.ST_Envelope(

                    expbuilder.column("the_geom")

                ),

                expbuilder.geometry(limit, proj)

            )

        );

        sqlbuilder.select().where().and(

                expbuilder.custom("x = 27")

        );

        System.out.println("# Test:: testCalulateEnvelope");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "SELECT ST_AsBinary(ST_Extent(\"the_geom\")) AS \"envelope\" FROM \"master\".\"dbo\".\"test1\" WHERE (ST_Intersects((ST_Envelope(\"the_geom\")), (ST_GeomFromWKB(('\\x000000000300000001000000050000000000000000000000000000000000000000000000004059000000000000405900000000000040590000000000004059000000000000000000000000000000000000000000000000000000000000'::bytea), (4326)))) AND x = 27)",

                sqlbuilder.toString()

        );

        assertEquals(

                "[the_geom]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testCount() throws Exception {

        SQLBuilder sqlbuilder = createSQLBuilder();

        ExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.select().column().value(sqlbuilder.count().all());

        sqlbuilder.select().from().table().database("master").schema("dbo").name("test1");

        sqlbuilder.select().from().subquery(null);

        sqlbuilder.select().where().set( expbuilder.custom("pp = 200"));

        System.out.println("# Test:: testCount");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        //# Test:: testCount

        //# SQL:: SELECT COUNT(*) FROM "test1" WHERE pp = 200

        //# Variables:: []

        //# Parametros:: []

        assertEquals(

                "SELECT COUNT(*) FROM \"master\".\"dbo\".\"test1\" WHERE pp = 200",

                sqlbuilder.toString()

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testCreateTable() throws Exception {

        SQLBuilder sqlbuilder = createSQLBuilder();

        ExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.create_table().table().database("master").schema("dbo").name("test1");

        sqlbuilder.create_table().add_column(

                "name",

                DataTypes.STRING,

                45,

                0,

                0,

                false,

                false,

                true,

                false,

                null

        );

        sqlbuilder.create_table().add_column(

                "id",

                DataTypes.INT,

                0,

                0,

                0,

                true,

                false,

                false,

                true,

                0

        );

        sqlbuilder.create_table().add_column(

                "geom",

                DataTypes.GEOMETRY,

                0,

                0,

                0,

                false,

                false,

                true,

                false,

                null

        );

        // CREATE TABLE "test1" ("name" VARCHAR(45) DEFAULT NULL, "id" INTEGER PRIMARY KEY AUTO_INCREMENT DEFAULT '0' NOT NULL, "geom" GEOMETRY ); ALTER TABLE "test1" ADD CONSTRAINT IF NOT EXISTS "constraint_test1_geom_dim" CHECK ST_CoordDim("geom") = 2

        System.out.println("# Test:: testCreateTable");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "CREATE TABLE \"master\".\"dbo\".\"test1\" (\"name\" VARCHAR(45) DEFAULT NULL NULL, \"id\"  SERIAL PRIMARY KEY ); SELECT AddGeometryColumn('dbo' , 'test1' , 'geom', null , 'GEOMETRY' , 2, TRUE)",

                sqlbuilder.toString()

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testDropTable() throws Exception {

        SQLBuilder sqlbuilder = createSQLBuilder();

        ExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.drop_table().table().database("master").schema("dbo").name("test1");

        // DROP TABLE "test1"

        System.out.println("# Test:: testDropTable");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "DROP TABLE \"master\".\"dbo\".\"test1\"",

                sqlbuilder.toString()

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testFetchFeatureProviderByReference() throws Exception {

        SQLBuilder sqlbuilder = new SQLBuilderBase();

        ExpressionBuilder expbuilder = sqlbuilder.expression();

        String value = "yoyo";

        sqlbuilder.select().column().name("name");

        sqlbuilder.select().column().name("id");

        sqlbuilder.select().column().name("geom").as_geometry();

        sqlbuilder.select().from().table().database("master").schema("dbo").name("test1");

        sqlbuilder.select().where().set(

            expbuilder.eq(

                expbuilder.column("name"),

                expbuilder.parameter(value).as_constant()

            )

        );

        sqlbuilder.select().limit(1);

        // SELECT "name", "id", ST_AsBinary("geom") FROM "master"."dbo"."test1" WHERE ( ("name") = (?) ) LIMIT 1

        System.out.println("# Test:: testFetchFeatureProviderByReference");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "SELECT \"name\", \"id\", ST_AsBinary(\"geom\") FROM \"master\".\"dbo\".\"test1\" WHERE ( (\"name\") = (?) ) LIMIT 1",

                sqlbuilder.toString()

        );

        assertEquals(

                "[geom, id, name]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "['yoyo']",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testFetchFeatureType() throws Exception {

        SQLBuilder sqlbuilder = createSQLBuilder();

        ExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.select().column().all();

        sqlbuilder.select().from().table().database("master").schema("dbo").name("test1");

        sqlbuilder.select().limit(1);

        System.out.println("# Test:: testFetchFeatureType");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        //# Test:: testFetchFeatureType

        //# SQL:: SELECT * FROM "test1" LIMIT 1

        //# Variables:: []

        //# Parametros:: []        

        assertEquals(

                "SELECT * FROM \"master\".\"dbo\".\"test1\" LIMIT 1",

                sqlbuilder.toString()

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testPerformDeletes() throws Exception {

        SQLBuilder sqlbuilder = createSQLBuilder();

        ExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.delete().table().database("master").schema("dbo").name("test1");

        sqlbuilder.delete().where().and(

            expbuilder.eq( 

                expbuilder.column("id1"),

                expbuilder.parameter("id1").as_variable()

            )

        );

        sqlbuilder.delete().where().and(

            expbuilder.eq( 

                expbuilder.column("id2"),

                expbuilder.parameter("id2").as_variable()

            )

        );

        // DELETE FROM "test1" WHERE ( ("id1") = (?) ) AND ( ("id2") = (?) )

        System.out.println("# Test:: testPerformDeletes");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "DELETE FROM \"master\".\"dbo\".\"test1\" WHERE (( (\"id1\") = (?) ) AND ( (\"id2\") = (?) ))",

                sqlbuilder.toString()

        );

        assertEquals(

                "[id1, id2]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[\"id1\", \"id2\"]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testPerformInserts1() throws Exception {

        IProjection proj = CRSFactory.getCRS("EPSG:4326");

        SQLBuilder sqlbuilder = createSQLBuilder();

        GeometryExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.insert().table().database("master").schema("dbo").name("test1");

        sqlbuilder.insert().column().name("id").with_value(expbuilder.parameter("id"));

        sqlbuilder.insert().column().name("name").with_value(expbuilder.parameter("name"));

        sqlbuilder.insert().column().name("geom").with_value(expbuilder.parameter("geom").as_geometry_variable().srs(proj));

        System.out.println("# Test:: testPerformInserts1");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "INSERT INTO \"master\".\"dbo\".\"test1\" ( \"id\", \"name\", \"geom\" ) VALUES ( ?, ?, ST_GeomFromWKB((?), (4326)) )",

                sqlbuilder.toString()

        );

        assertEquals(

                "[geom, id, name]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[\"id\", \"name\", \"geom\"]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testPerformInserts2() throws Exception {

        IProjection proj = CRSFactory.getCRS("EPSG:4326");

        SQLBuilder sqlbuilder = createSQLBuilder();

        GeometryExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.insert().table().database("master").schema("dbo").name("test1");

        sqlbuilder.insert().column().name("id").with_value(expbuilder.parameter("id"));

        sqlbuilder.insert().column().name("name").with_value(expbuilder.parameter("name"));

        sqlbuilder.insert().column().name("geom").with_value(expbuilder.parameter("geom").as_geometry_variable().srs(proj));

        System.out.println("# Test:: testPerformInserts2");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "INSERT INTO \"master\".\"dbo\".\"test1\" ( \"id\", \"name\", \"geom\" ) VALUES ( ?, ?, ST_GeomFromWKB((?), (4326)) )",

                sqlbuilder.toString()

        );

        assertEquals(

                "[geom, id, name]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[\"id\", \"name\", \"geom\"]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testPerformUpdates1() throws Exception {

        IProjection proj = CRSFactory.getCRS("EPSG:4326");

        SQLBuilder sqlbuilder = createSQLBuilder();

        GeometryExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.update().table().database("master").schema("dbo").name("test1");

        sqlbuilder.update().where().and(

            expbuilder.eq(

                expbuilder.column("id"), 

                expbuilder.parameter("id").as_variable()

            )

        );

        sqlbuilder.update().column().name("name").with_value(expbuilder.parameter("name"));

        sqlbuilder.update().column().name("geom").with_value(

                expbuilder.parameter("geom").as_geometry_variable().srs(proj) 

        );

        System.out.println("# Test:: testPerformUpdates");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "UPDATE \"master\".\"dbo\".\"test1\" SET \"name\" = ?, \"geom\" = ST_GeomFromWKB((?), (4326)) WHERE ( (\"id\") = (?) )",

                sqlbuilder.toString()

        );

        assertEquals(

                "[geom, id, name]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[\"name\", \"geom\", \"id\"]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testPerformUpdates2() throws Exception {

        IProjection proj = CRSFactory.getCRS("EPSG:4326");

        SQLBuilder sqlbuilder = createSQLBuilder();

        GeometryExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.update().table().database("master").schema("dbo").name("test1");

        sqlbuilder.update().where().and(

            expbuilder.eq(

                expbuilder.column("id"), 

                expbuilder.parameter("id").as_variable()

            )

        );

        sqlbuilder.update().column().name("name").with_value(expbuilder.parameter("name"));

        sqlbuilder.update().column().name("geom").with_value(

                expbuilder.parameter("geom").as_geometry_variable()

                        .srs(expbuilder.parameter().value(proj)) 

        );

        System.out.println("# Test:: testPerformUpdates");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "UPDATE \"master\".\"dbo\".\"test1\" SET \"name\" = ?, \"geom\" = ST_GeomFromWKB((?), (?)) WHERE ( (\"id\") = (?) )",

                sqlbuilder.toString()

        );

        assertEquals(

                "[geom, id, name]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[\"name\", \"geom\", 4326, \"id\"]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testGrant1() throws Exception {

        SQLBuilder sqlbuilder = createSQLBuilder();

        ExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.grant().table().database("master").schema("dbo").name("test1");

        sqlbuilder.grant().role("prueba").select().insert().update();

        sqlbuilder.grant().role("gis").all();

        System.out.println("# Test:: testGrant1");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "",

                sqlbuilder.toString()

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

    public void testGrant2() throws Exception {

        SQLBuilder sqlbuilder = new SQLBuilderBase();

        ExpressionBuilder expbuilder = sqlbuilder.expression();

        sqlbuilder.grant().table().database("master").schema("dbo").name("test1");

        sqlbuilder.grant().role("prueba").privilege(Privilege.SELECT)

                .privilege(Privilege.INSERT)

                .privilege(Privilege.UPDATE);

        sqlbuilder.grant().role("gis").privilege(Privilege.ALL);

        System.out.println("# Test:: testGrant2");

        System.out.println("# SQL:: " + sqlbuilder.toString());

        System.out.println("# Variables:: " + ArrayUtils.toString(sqlbuilder.variables_names()));

        System.out.println("# Parametros:: " + ArrayUtils.toString(sqlbuilder.parameters_names()));

        assertEquals(

                "",

                sqlbuilder.toString()

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.variables_names())

        );

        assertEquals(

                "[]",

                ArrayUtils.toString(sqlbuilder.parameters_names())

        );

    }

}

package org.gvsig.postgresql.dal;

import java.io.File;

import java.net.URL;

import java.util.ArrayList;

import java.util.List;

import org.apache.commons.io.FileUtils;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataStore;

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

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

import org.gvsig.fmap.dal.feature.impl.DefaultFeature;

import org.gvsig.fmap.dal.feature.spi.FeatureProvider;

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

import org.gvsig.fmap.dal.store.jdbc2.spi.FakeConnectionParameters;

import org.gvsig.fmap.dal.store.jdbc2.spi.FakeConnectionProvider;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestUtils  {

    public static final Logger LOGGER = LoggerFactory.getLogger(TestUtils.class);

    public static final String PROVIDER_NAME = PostgreSQLLibrary.NAME;

    public static File getTargetFolder() throws Exception {

        URL url = TestUtils.class.getResource("/");

        File x = new File(url.toURI());

        File target = x.getParentFile();

        return target;

    }

    public static File getResource(String name) throws Exception {

        File x = new File(getTargetFolder(), name);

        return x;

    }

    public static File getResourceAsFile(String pathname) throws Exception {

        URL url = TestUtils.class.getResource(pathname);

        File x = new File(url.toURI());

        return x;

    }

    public static FeatureStore openSourceStore1() throws Exception {

        DataManager dataManager = DALLocator.getDataManager();

        File f = getResourceAsFile("/org/gvsig/postgresql/dal/testCreateSource1.csv");

        FeatureStore store = (FeatureStore) dataManager.openStore(

                DataStore.CSV_PROVIDER_NAME, 

                "file=",f,

                "automaticTypesDetection=", false,

                "locale=","en"

        );

        return store;

    }

    public static List<String> getSQLs(String name) throws Exception {

      File f = getResourceAsFile("/org/gvsig/postgresql/dal/"+name);

      List<String> SQLs = new ArrayList<>();

      List<String> lines = FileUtils.readLines(f);

      StringBuilder sb = new StringBuilder();

      for (String line : lines) {

        line = StringUtils.stripStart(line, null);

        if( line.startsWith("--") ) {

          continue;

        }

        if( line.endsWith(";") ) {

          sb.append(line.substring(0, line.length()-1));

          SQLs.add(sb.toString());

          sb.setLength(0);

        } else {

          sb.append(line);

        }

      }

      return SQLs;

    }

    public static JDBCHelper getJDBCHelper() {

      JDBCHelper helper = new PostgreSQLHelper(new FakePostgreSQLConnectionParameters(), new FakeConnectionProvider());

      return helper;

    }

    public static FeatureProvider getFeatureProvider(Feature feature) {

      return ((DefaultFeature)feature).getData();

    }

}

package org.gvsig.postgresql.dal.operations.sql;

import java.util.List;

import junit.framework.TestCase;

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

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

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

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

import org.gvsig.fmap.dal.feature.impl.featurereference.FeatureReferenceFactory;

import org.gvsig.fmap.dal.feature.spi.FeatureReferenceProviderServices;

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

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory;

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory.TableReference;

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCSQLBuilderBase;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.FetchFeatureProviderByReferenceOperation;

import org.gvsig.postgresql.dal.TestUtils;

import org.gvsig.tools.library.impl.DefaultLibrariesInitializer;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestFetchFeatureProviderByReference extends TestCase {

  private static final Logger LOGGER = LoggerFactory.getLogger(TestFetchFeatureProviderByReference.class);

  public TestFetchFeatureProviderByReference(String testName) {

    super(testName);

  }

  @Override

  protected void setUp() throws Exception {

    super.setUp();

    new DefaultLibrariesInitializer().fullInitialize();

  }

  @Override

  protected void tearDown() throws Exception {

    super.tearDown();

  }

  // TODO add test methods here. The name must begin with 'test'. For example:

  // public void testHello() {}

  public void testFetchFeatureProviderByReference() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

    List<String> expectedSQLs = TestUtils.getSQLs("fetchFeatureProviderByReference.sql");

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    Feature feature = sourceStore.getFeatures().get(1);    

    FeatureReference reference = FeatureReferenceFactory.createReferencePKFromFeature(feature);

    FetchFeatureProviderByReferenceOperation fetchFeatureProviderByReference = operations.createFetchFeatureProviderByReference(

            (FeatureReferenceProviderServices) reference,

            featureType, 

            table

    );

    String sql = fetchFeatureProviderByReference.getSQL();

    assertEquals("FetchFeatureProviderByReference SQL", expectedSQLs.get(0), sql);

  }

}

package org.gvsig.postgresql.dal.operations.sql;

import java.util.List;

import junit.framework.TestCase;

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

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

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

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory;

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory.TableReference;

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCSQLBuilderBase;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.CalculateEnvelopeOfColumnOperation;

import org.gvsig.postgresql.dal.TestUtils;

import org.gvsig.tools.library.impl.DefaultLibrariesInitializer;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestCalculateEnvelope extends TestCase {

  private static final Logger LOGGER = LoggerFactory.getLogger(TestCalculateEnvelope.class);

  public TestCalculateEnvelope(String testName) {

    super(testName);

  }

  @Override

  protected void setUp() throws Exception {

    super.setUp();

    new DefaultLibrariesInitializer().fullInitialize();

  }

  @Override

  protected void tearDown() throws Exception {

    super.tearDown();

  }

  // TODO add test methods here. The name must begin with 'test'. For example:

  // public void testHello() {}

  public void testCalculateEnvelope() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

    List<String> expectedSQLs = TestUtils.getSQLs("calculateEnvelope.sql");

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    CalculateEnvelopeOfColumnOperation calculateEnvelope = operations.createCalculateEnvelopeOfColumn(

            featureType,

            table, 

            "Geometry",

            null,

            null, 

            featureType.getDefaultSRS()

    );

    String sql = calculateEnvelope.getSQL();

    assertEquals("CalculateEnvelope SQL", expectedSQLs.get(0), sql);

  }

}

package org.gvsig.postgresql.dal.operations.sql;

import java.util.List;

import junit.framework.TestCase;

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

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

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

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory;

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory.TableReference;

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCSQLBuilderBase;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.CreateTableOperation;

import org.gvsig.postgresql.dal.TestUtils;

import org.gvsig.tools.library.impl.DefaultLibrariesInitializer;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestCreateTable extends TestCase {

  private static final Logger LOGGER = LoggerFactory.getLogger(TestCreateTable.class);

  public TestCreateTable(String testName) {

    super(testName);

  }

  @Override

  protected void setUp() throws Exception {

    super.setUp();

    new DefaultLibrariesInitializer().fullInitialize();

  }

  @Override

  protected void tearDown() throws Exception {

    super.tearDown();

  }

  // TODO add test methods here. The name must begin with 'test'. For example:

  // public void testHello() {}

  public void testCreateTable() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

    List<String> expectedSQLs = TestUtils.getSQLs("createTable.sql");

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    CreateTableOperation createTable = operations.createTable(

            table,

            featureType,

            null,

            null

    );

    List<String> SQLs = createTable.getSQLs();

    assertEquals("CreateTable num. SQLs", expectedSQLs.size(), SQLs.size());

    for (int i = 0; i < expectedSQLs.size(); i++) {

      assertEquals("CreateTable SQL "+i, expectedSQLs.get(i), SQLs.get(i));

    }

  }

}

package org.gvsig.postgresql.dal.operations.sql;

import java.util.List;

import junit.framework.TestCase;

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

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

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory;

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory.TableReference;

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCSQLBuilderBase;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.DropTableOperation;

import org.gvsig.postgresql.dal.TestUtils;

import org.gvsig.tools.library.impl.DefaultLibrariesInitializer;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestDropTable extends TestCase {

  private static final Logger LOGGER = LoggerFactory.getLogger(TestDropTable.class);

  public TestDropTable(String testName) {

    super(testName);

  }

  @Override

  protected void setUp() throws Exception {

    super.setUp();

    new DefaultLibrariesInitializer().fullInitialize();

  }

  @Override

  protected void tearDown() throws Exception {

    super.tearDown();

  }

  // TODO add test methods here. The name must begin with 'test'. For example:

  // public void testHello() {}

  public void testDropTable() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

    List<String> expectedSQLs = TestUtils.getSQLs("dropTable.sql");

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    DropTableOperation dropTable = operations.createDropTable(

            table

    );

    List<String> SQLs = dropTable.getSQLs();

    assertEquals("DropTable num. SQLs", expectedSQLs.size(), SQLs.size());

    for (int i = 0; i < expectedSQLs.size(); i++) {

      assertEquals("DropTable SQL "+i, expectedSQLs.get(i), SQLs.get(i));

    }

  }

}

package org.gvsig.postgresql.dal.operations.sql;

import java.util.List;

import junit.framework.TestCase;

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

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

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

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory;

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory.TableReference;

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCSQLBuilderBase;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.TableIsEmptyOperation;

import org.gvsig.postgresql.dal.TestUtils;

import org.gvsig.tools.library.impl.DefaultLibrariesInitializer;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestTableIsEmpty extends TestCase {

  private static final Logger LOGGER = LoggerFactory.getLogger(TestTableIsEmpty.class);

  public TestTableIsEmpty(String testName) {

    super(testName);

  }

  @Override

  protected void setUp() throws Exception {

    super.setUp();

    new DefaultLibrariesInitializer().fullInitialize();

  }

  @Override

  protected void tearDown() throws Exception {

    super.tearDown();

  }

  // TODO add test methods here. The name must begin with 'test'. For example:

  // public void testHello() {}

  public void testTableIsEmpty() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();