Application: gvSIG desktop » gvSIG data provider for PostgreSQL

<?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.258</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.jdbc</artifactId>

      <scope>test</scope>

      <type>test-jar</type>

    </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.operations.usecases.arena2;

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

import org.gvsig.fmap.dal.store.jdbc2.operations.usecases.arena2.AbstractTestMultipleExpansionOfCalculatedField;

import org.gvsig.postgresql.dal.TestUtilsPostgreSQL;

@SuppressWarnings("UseSpecificCatch")

public class TestMultipleExpansionOfCalculatedField extends AbstractTestMultipleExpansionOfCalculatedField {

    public TestMultipleExpansionOfCalculatedField(String testName) {

        super(testName);

    }

    @Override

    protected AbstractTestUtils createUtils() {

        return new TestUtilsPostgreSQL();

    }

    @Override

    public void testMultipleExpansionOfCalculatedField() throws Exception {

       super.testMultipleExpansionOfCalculatedField();

    }

}

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

import org.gvsig.postgresql.dal.TestUtils;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestUpdateTableStatistics extends TestCase {

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

  public TestUpdateTableStatistics(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 testUpdateTableStatistics() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

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

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    UpdateTableStatisticsOperation updateTableStatistics = operations.createUpdateTableStatistics(

            table

    );

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

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

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

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

    }

  }

}

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

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

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

import org.gvsig.postgresql.dal.TestUtilsPostgreSQL;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestJsonValue extends AbstractTestJsonValue {

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

    public TestJsonValue(String testName) {

        super(testName);

    }

    @Override

    protected void setUp() throws Exception {

        super.setUp();

        new DefaultLibrariesInitializer().fullInitialize();

    }

    @Override

    protected void tearDown() throws Exception {

        super.tearDown();

    }

    @Override

    protected AbstractTestUtils createUtils() {

        return new TestUtilsPostgreSQL();

    }

    public void testJsonValue() throws Exception {

        super.testJsonValue();

    }

}

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

import java.util.ArrayList;

import java.util.List;

import junit.framework.TestCase;

import org.gvsig.fmap.dal.DataTypes;

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

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

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

import org.gvsig.postgresql.dal.TestUtils;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestAppend extends TestCase {

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

  public TestAppend(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 testAppend() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

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

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    AppendOperation append = operations.createAppend(

            table,

            featureType

    );

    append.begin();

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

    SQLs.addAll(append.getPreviousSQLs());

    SQLs.add( append.getSQL());

    SQLs.addAll(append.getPostSQLs());

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

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

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

    }

    for (Feature sourceFeature : sourceStore.getFeatureSet()) {

      List<Object> parametersSQL = append.getSQLParameters(TestUtils.getFeatureProvider(sourceFeature));

      List<Object> expectedParameters = this.getExpectedparameters(sourceFeature);

      assertEquals("Append num. parameters", parametersSQL.size(), expectedParameters.size());

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

        assertEquals("Append parameter "+i, expectedParameters.get(i), parametersSQL.get(i));

      }

    }

    append.end();

  }

  private List<Object> getExpectedparameters(Feature sourceFeature) {

    FeatureType ft = sourceFeature.getType();

    List<Object> values = new ArrayList<>();

    for (FeatureAttributeDescriptor attr : ft) {

      Object v = sourceFeature.get(attr.getIndex());

      values.add(v);

      if( attr.getType()==DataTypes.GEOMETRY ) {

        String srs = attr.getSRS().getAbrev();

        values.add(Integer.parseInt(srs.split(":")[1]));

      }

    }

    return values;

  }

}

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

import java.util.Collections;

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

import org.gvsig.postgresql.dal.TestUtils;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestFetchFeatureType extends TestCase {

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

  public TestFetchFeatureType(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 testFetchFeatureType() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

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

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    FetchFeatureTypeOperation fetchFeatureType = operations.createFetchFeatureType(

            featureType.getEditable(),

            table,

            Collections.EMPTY_LIST,

            null, // "Geometry" 

            featureType.getDefaultSRS()

    );

    String retrieveFirstRowOfTableSQL = fetchFeatureType.getSQLToRetrieveMetadataOfTable();

    String retrievePrimaryKeysFromInformationSchemaSQL = fetchFeatureType.getSQLToRetrievePrimaryKeysFromInformationSchema();

    assertEquals("FetchFeatureType first row SQL", expectedSQLs.get(0), retrieveFirstRowOfTableSQL);

    assertEquals("FetchFeatureType get primery keys SQL", expectedSQLs.get(1), retrievePrimaryKeysFromInformationSchemaSQL);

  }

}

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

import org.gvsig.postgresql.dal.TestUtils;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestCount extends TestCase {

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

  public TestCount(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 testCount() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

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

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    CountOperation count = operations.createCount(

            featureType,

            table, 

            null, null

    );

    String sql = count.getSQL();

    assertEquals("Count 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.ResultSetForSetProviderOperation;

import org.gvsig.postgresql.dal.TestUtils;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestResultSetForSetProvider extends TestCase {

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

  public TestResultSetForSetProvider(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 testResultSetForSetProvider() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

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

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    ResultSetForSetProviderOperation resultSetForSetProvider = operations.createResultSetForSetProvider(

            table,

            null,

            null,

            null,

            featureType,

            featureType,

            0,

            0, 

            0

    );

    String sql = resultSetForSetProvider.getSQL();

    System.out.println("###### testResultSetForSetProvider");

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

    System.out.println("###### EXP:" + expectedSQLs.get(0) + ";");

    assertEquals("ResultSetForSetProvider 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.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();

    System.out.println("###### testCalculateEnvelope");

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

    System.out.println("###### EXP:" + expectedSQLs.get(0) + ";");

    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();

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

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    TableIsEmptyOperation tableIsEmpty = operations.createTableIsEmpty(

            featureType,

            table,

            null, 

            null

    );

    String sql = tableIsEmpty.getSQL();

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

    System.out.println("###### EXP:" + expectedSQLs.get(0) + ";");

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

  }

}

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

import java.util.Collections;

import java.util.List;

import junit.framework.TestCase;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataTypes;

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

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

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

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

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

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

import org.gvsig.postgresql.dal.TestUtils;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestPerformChanges extends TestCase {

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

  public TestPerformChanges(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 testPerformChanges() throws Exception {

    JDBCHelper helper = TestUtils.getJDBCHelper();

    JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

    OperationsFactory operations = helper.getOperations();

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

    FeatureStore sourceStore = TestUtils.openSourceStore1();

    TableReference table = operations.createTableReference(

            "dbtest", 

            sqlbuilder.default_schema(), 

            "test", 

            null

    );

    FeatureType featureType = sourceStore.getDefaultFeatureType();

    FeatureTypeChanged featureTypeChanged = new FeatureTypeChanged() {

      @Override

      public FeatureType getSource() {

        EditableFeatureType ft = DALLocator.getDataManager().createFeatureType();

        EditableFeatureAttributeDescriptor id = ft.add("ID", DataTypes.INT);

        id.copyFrom(featureType.getAttributeDescriptor("ID"));

        return ft;

      }

      @Override

      public FeatureType getTarget() {

        return featureType;

      }

    };

    List<FeatureTypeChanged> featureTypesChangeds = Collections.singletonList(featureTypeChanged);

    PerformChangesOperation performChanges = operations.createPerformChanges(

            table, 

            sourceStore.getDefaultFeatureType(),

            null, 

            null, 

            null, 

            featureTypesChangeds.iterator()

    );

    String insertSQL = performChanges.getInsertSQL();

    String deleteSQL = performChanges.getDeleteSQL();

    String updateSQL = performChanges.getUpdateSQL();

    List<String> updateTableSQLs = performChanges.getUpdateTableSQLs();

    assertEquals("Insert SQL", expectedSQLs.get(0), insertSQL);

    assertEquals("Delete SQL", expectedSQLs.get(1), deleteSQL);

    assertEquals("Update SQL", expectedSQLs.get(2), updateSQL);

    assertEquals("UpdateTable num. SQLs", expectedSQLs.size()-3, updateTableSQLs.size());

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

      assertEquals("UpdateTable SQL "+i, expectedSQLs.get(i+3), updateTableSQLs.get(i));

    }

    // FIXME: El ALTER TABLE de una columna geometria no funciona

  }

}

package org.gvsig.postgresql.dal;

import java.net.URL;

import java.util.Properties;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

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

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

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

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

/**

 *

 * @author jjdelcerro

 */

@SuppressWarnings("UseSpecificCatch")

public class TestUtilsPostgreSQL extends AbstractTestUtils {

    @Override

    public String getProviderName() {

        return PostgreSQLLibrary.NAME;

    }

    @Override

    public String getExpectedsPath() {

        return "/org/gvsig/postgresql/dal";

    }

    @Override

    protected Properties getProperties() {

        if (this.properties == null) {

            try {

                URL url = this.getClass().getResource("postgresql.properties");

                Properties props = new Properties();

                props.load(url.openStream());

                String[] keys = new String[]{

                    "PostgreSQLEnabled",

                    "PostgreSQLHost",

                    "PostgreSQLPort",

                    "PostgreSQLDbname",

                    "PostgreSQLSchema",

                    "PostgreSQLUser",

                    "PostgreSQLPassword"

                };

                for (String key : keys) {

                    if (System.getenv().containsKey(key)) {

                        props.setProperty(key, System.getenv(key));

                    }

                }

                this.properties = props;

            } catch (Exception ex) {

                throw new RuntimeException(ex);

            } 

        }

        return this.properties;

    }

    @Override

    public boolean isTheDatabaseAvailable() {

        return this.getPropertyBoolean("PostgreSQLEnabled");

    }

    @Override

    public JDBCHelper createJDBCHelper() throws Exception {

        PostgreSQLServerExplorerParameters params = this.getServerExplorerParameters("fake");

        PostgreSQLHelper helper = new PostgreSQLHelper(params, new FakeConnectionProvider());

      return helper;

    }

    @Override

    public PostgreSQLServerExplorerParameters getServerExplorerParameters(String dbname) throws Exception {

        DataManager dataManager = DALLocator.getDataManager();

        PostgreSQLServerExplorerParameters conn = (PostgreSQLServerExplorerParameters) dataManager.createServerExplorerParameters(this.getProviderName());

        conn.setHost(getProperty("PostgreSQLHost"));

        conn.setPort(getPropertyInt("PostgreSQLPort", 5432));

        conn.setDBName(getProperty("PostgreSQLDbname"));

        conn.setSchema(getProperty("PostgreSQLSchema"));

        conn.setUser(getProperty("PostgreSQLUser"));

        conn.setPassword(getProperty("PostgreSQLPassword"));

        conn.setShowInformationDBTables(false);

        return conn;

    }

    @Override

    public void runSQLToCheckSyntax(String testName, FeatureStore datacsv, String testTableName, String sql) throws Exception {

        // Do nothing

    }

}

package org.gvsig.postgresql.dal;

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

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

public class TestComputedAttributes extends AbstractTestComputedAttributes {

    public TestComputedAttributes(String testName) {

        super(testName);

    }

    @Override

    protected AbstractTestUtils createUtils() {

        return new TestUtilsPostgreSQL();

    }

    @Override

    public void testComputed1() throws Exception {

        super.testComputed1(); 

    }

    @Override

    public void testComputed2() throws Exception {

        super.testComputed2(); 

    }

}

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,