Application: gvSIG desktop

package org.gvsig.fmap.data.feature.db.jdbc.postgresqlbin;

import java.util.Iterator;

import java.util.NoSuchElementException;

import org.gvsig.fmap.data.CloseException;

import org.gvsig.fmap.data.DataManager;

import org.gvsig.fmap.data.InitializeException;

import org.gvsig.fmap.data.ReadException;

import org.gvsig.fmap.data.feature.FeatureCollection;

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

import org.gvsig.fmap.data.feature.db.DBTest;

import org.gvsig.fmap.data.feature.db.jdbc.postgresqlbin.PostgresqlBinStore;

import org.gvsig.fmap.data.feature.db.jdbc.postgresqlbin.PostgresqlBinStoreParameters;

import org.gvsig.fmap.data.feature.db.jdbc.postgresqlbin.Register;

public class postgresqlBinTest extends DBTest {

        private static String SERVER_IP="192.168.0.66";

        private static String SERVER_PORT="5432";

        private static String SERVER_DBNAME="gis";

        private static String SERVER_SCHEMA="ds_test";

        private static String SERVER_USER="testCase";

        private static String SERVER_PASWD="testCase";

        private static String DS_NAME = PostgresqlBinStore.DATASTORE_NAME;

        public void test1(){

                Register.selfRegister();

                DataManager manager = DataManager.getManager();

                PostgresqlBinStoreParameters dparam=null;

                try {

                        dparam = (PostgresqlBinStoreParameters)manager.createDataStoreParameters(DS_NAME);

                } catch (InitializeException e) {

                        e.printStackTrace();

                        fail();

                }

                dparam.setHost(SERVER_IP);

                dparam.setPort(SERVER_PORT);

                dparam.setUser(SERVER_USER);

                dparam.setPassw(SERVER_PASWD);

                dparam.setSchema(SERVER_SCHEMA);

                dparam.setDb(SERVER_DBNAME);

                dparam.setTableName("prueba");

                dparam.setFieldId(new String[] {"gid"});

                dparam.setFields(new String[] {"*"});

                dparam.setDefaultGeometryField("the_geom");

                storeTest(dparam, null, null, false);

        }

        public void testSimpleIteration38K_regs(){

                Register.selfRegister();

                DataManager manager = DataManager.getManager();

                PostgresqlBinStoreParameters dparam=null;

                try {

                        dparam = (PostgresqlBinStoreParameters)manager.createDataStoreParameters(DS_NAME);

                } catch (InitializeException e1) {

                        e1.printStackTrace();

                        fail();

                }

                dparam.setHost(SERVER_IP);

                dparam.setPort(SERVER_PORT);

                dparam.setUser(SERVER_USER);

                dparam.setPassw(SERVER_PASWD);

                dparam.setSchema(null);

                dparam.setDb(SERVER_DBNAME);

                dparam.setTableName("hidropol");

//                dparam.setTableName("ejes");

                dparam.setFieldId(new String[] {"gid"});

                dparam.setFields(new String[] {"*"});

                dparam.setDefaultGeometryField("the_geom");

//                storeTest(dparam, null, null, false);

                FeatureStore fs=null;

                try {

                        fs = (FeatureStore) manager.createDataStore(dparam);

                } catch (InitializeException e) {

                        e.printStackTrace();

                        fail();

                }

                FeatureCollection fc=null;

                try {

                        fc = (FeatureCollection) fs.getDataCollection();

                } catch (ReadException e) {

                        e.printStackTrace();

                        fail();

                }

                int i=0;

                int count = fc.size();

                Iterator iter = fc.iterator();

                while (true){

                        try{

                                iter.next();

                                i++;

                        } catch (NoSuchElementException e) {

                                break;

                        }

                }

                assertEquals(count, i);

                fc.dispose();

//                try {

//                        fs.close();

//                } catch (CloseException e) {

//                        e.printStackTrace();

//                        fail("Exception: "+e);

//                }

                try {

                        fs.dispose();

                } catch (CloseException e) {

                        // TODO Auto-generated catch block

                        e.printStackTrace();

                }

        }

}