| gvSIG desktop 1

package org.gvsig.data.datastores.vectorial.driver.jdbc;

import java.io.File;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

import org.gvsig.data.DataSourceManager;

import org.gvsig.data.IDataStoreParameters;

import org.gvsig.data.datastores.vectorial.driver.DriverStore;

import org.gvsig.data.datastores.vectorial.driver.IDriverParameters;

import org.gvsig.data.datastores.vectorial.driver.IDriverStoreParameters;

import org.gvsig.data.datastores.vectorial.driver.shp.ShpDriverParameters;

import org.gvsig.data.datastores.vectorial.driver.shp.fileshp.SHP;

import org.gvsig.data.exception.CloseException;

import org.gvsig.data.exception.InitializeException;

import org.gvsig.data.exception.OpenException;

import org.gvsig.data.exception.ReadException;

import org.gvsig.data.exception.WriteException;

import org.gvsig.data.vectorial.IFeature;

import org.gvsig.data.vectorial.IFeatureAttributeDescriptor;

import org.gvsig.data.vectorial.IFeatureCollection;

import org.gvsig.data.vectorial.IFeatureStore;

import org.gvsig.data.vectorial.IFeatureType;

import org.gvsig.exceptions.BaseException;

public class Kiko {

        public static void main(String args[]){

                Kiko kiko= new Kiko();

                kiko.shp2H2();

        }

        public void shp2H2() {

                System.out.println("======= SHP ==============");

                org.gvsig.data.datastores.vectorial.driver.shp.Register.selfRegister();

                org.gvsig.data.datastores.vectorial.driver.dbf.Register.selfRegister();

                org.gvsig.data.datastores.vectorial.driver.Register.selfRegister();

                DataSourceManager dsm=DataSourceManager.getManager();

                File shpfile= new File(DataStoreTest.class.getResource("data/prueba.dbf").getFile());

                IDriverParameters dp=dsm.createDriverParameters("shp");

                ((ShpDriverParameters)dp).setSHPFile(shpfile);

                ((ShpDriverParameters)dp).setSHXFile(SHP.getShxFile(shpfile));

                ((ShpDriverParameters)dp).setDBFFile(SHP.getDbfFile(shpfile));

                driverTest(dp,null,null,false);

        }

        private void driverTest(IDriverParameters dp,String filter, String order,boolean testEdit){

                DataSourceManager dsm=DataSourceManager.getManager();

                IDataStoreParameters dsp=dsm.createDataStoreParameters(DriverStore.DATASTORE_NAME);

                ((IDriverStoreParameters)dsp).setDriverParameters(dp);

                IFeatureStore fs=createFeatureStore(dp);

                try {

                        fs.open();

                } catch (OpenException e2) {

                        e2.printStackTrace();

                        throw new RuntimeException(e2);

                }

                if (fs.isEditable() && testEdit) {

                        fs.startEditing();

                        IFeature feature1 = fs.createDefaultFeature(false);

                        IFeature feature2 = fs.createDefaultFeature(false);

                        IFeature feature3 = fs.createDefaultFeature(false);

                        fs.insert(feature1);

                        fs.insert(feature2);

                        fs.update(feature3,feature1);

                        fs.delete(feature3);

                        fs.delete(feature2);

                }

                //Mostrar por consola todos los registros.

                IFeatureType ft= fs.getDefaultFeatureType();

                IFeatureCollection featureCollection;

//                featureCollection = (IFeatureCollection)fs.getDataCollection();

//                featureCollection = (IFeatureCollection)fs.getDataCollection(ft,"NOMBRE = 'CALPE'",null);

//                featureCollection = (IFeatureCollection)fs.getDataCollection(ft,"AREA > 3.2213163729E7 and AREA < 3.2213163749E7",null);

                featureCollection = (IFeatureCollection)fs.getDataCollection(ft,filter,order);

                String tableName=createStructure(ft);

                SHP2H2FeaturesVisitor visitor=new SHP2H2FeaturesVisitor(ft);

                visitor.setTableName(tableName);

                try {

                        featureCollection.accept(visitor);

                } catch (BaseException e1) {

                        e1.printStackTrace();

                }

                if (fs.isEditable() && testEdit){

                        try {

                                fs.finishEditing();

                        } catch (WriteException e) {

                                e.printStackTrace();

                        } catch (ReadException e) {

                                e.printStackTrace();

                        }

                }

                try {

                        fs.close();

                } catch (CloseException e) {

                        e.printStackTrace();

                }

                fs.dispose();

        }

        private String createStructure(IFeatureType featureType) {

                        System.out.println("***************** New Feature ******************");

                        System.out.println("ATTRIBUTES = ");

                        StringBuffer sb=new StringBuffer();

                        sb.append("CREATE TABLE TablaPrueba");

                        String s=String.valueOf(System.currentTimeMillis());

                        String tableName="TablaPrueba"+s.substring(s.length()-5);

                        sb.append(s.substring(s.length()-5));

                        sb.append(" (");

                        sb.append("id int, ");

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

                                IFeatureAttributeDescriptor descriptor=(IFeatureAttributeDescriptor)featureType.get(i);

                                String type = descriptor.getDataType();

                                if (type.equals(IFeatureAttributeDescriptor.TYPE_BOOLEAN)){

                                        sb.append(descriptor.getName());

                                        sb.append(" bit, ");

                                }else if (type.equals(IFeatureAttributeDescriptor.TYPE_BYTE)){

                                        sb.append(descriptor.getName());

                                        sb.append(" byte, ");

                                }else if (type.equals(IFeatureAttributeDescriptor.TYPE_DATE)){

                                        sb.append(descriptor.getName());

                                        sb.append(" date, ");

                                }else if (type.equals(IFeatureAttributeDescriptor.TYPE_DOUBLE)){

                                        sb.append(descriptor.getName());

                                        sb.append(" double, ");

                                }else if (type.equals(IFeatureAttributeDescriptor.TYPE_FLOAT)){

                                        sb.append(descriptor.getName());

                                        sb.append(" float, ");

                                }else if (type.equals(IFeatureAttributeDescriptor.TYPE_INT)){

                                        sb.append(descriptor.getName());

                                        sb.append(" int, ");

                                }else if (type.equals(IFeatureAttributeDescriptor.TYPE_LONG)){

                                        sb.append(descriptor.getName());

                                        sb.append(" bigint, ");

                                }else if (type.equals(IFeatureAttributeDescriptor.TYPE_STRING)){

                                        sb.append(descriptor.getName());

                                        sb.append(" varchar, ");

                                }else if (type.equals(IFeatureAttributeDescriptor.TYPE_GEOMETRY)){

                                        sb.append(descriptor.getName());

                                        sb.append(" other, ");

                                }else {

                                        System.out.print(" ---- " + "TYPE UNKNOWN");

                                }

                                System.out.print("\n");

                        }

                        String createTable=sb.toString();

                        createTable=createTable.substring(0, createTable.length()-2);

                        createTable+=")";

                        try{

                                Class.forName("org.h2.Driver");

                                Connection con=DriverManager.getConnection("jdbc:h2:tcp://localhost/default", "SA", "");

                                Statement st=con.createStatement();

                                if(st.executeUpdate(createTable)>0){

                                        System.out.println("Tutto benne");

                                }

                                else{

                                        System.out.println("Sisoma el error");

                                }

                                st.close();

                                con.close();

                        }

                        catch(SQLException except){

                                except.printStackTrace();

                        } catch (ClassNotFoundException e) {

                                // TODO Auto-generated catch block

                                e.printStackTrace();

                        }

                        return tableName;

        }

        private IFeatureStore createFeatureStore(IDriverParameters dp){

                DataSourceManager dsm=DataSourceManager.getManager();

                IDataStoreParameters dsp=dsm.createDataStoreParameters(DriverStore.DATASTORE_NAME);

                ((IDriverStoreParameters)dsp).setDriverParameters(dp);

                IFeatureStore fs=null;

                try {

                        fs = (IFeatureStore)dsm.createDataStore(dsp);

                } catch (InitializeException e) {

                        e.printStackTrace();

                }

                return fs;

        }

}