Application: gvSIG desktop

package org.gvsig.remoteservices.conf.geonetwork.test;

import java.io.BufferedReader;

import java.io.DataInputStream;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileWriter;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.util.Vector;

public class DDF2postgres{

        File f=null;

        File sql=null;

        File f2=null;

        FileWriter write = null;

        File aux[]=null;

        String path=null;

        String squema="public";

        BufferedReader read= null;

        //squema --> squema of the ddf files (must belong same squema)

        //path   -->path to the ddf files

        DDF2postgres(String squema,String path){

                if(squema!=null){

                        this.squema=squema;

                }

                this.path=path;

                f=new File(path);

                sql=null;

                f2=null;

                aux=f.listFiles();

                int i;

                //created sql dir

                sql=new File(path+"/sql");

                sql.mkdir();

                File aux2[]=sql.listFiles();

                //force delete of existing .sql

                for(i=0;i<aux2.length;i++){

                        f2=new File(path+"/sql/"+aux2[i].getName());

                        f2.delete();

                }

        }

        //conver all ddf files in path to .sql format

        //all .sql files are created into path/sql subdir (if exist will be deleted, be carefull my friend)

        public void convert(){

                int i;

                for(i=0;i<aux.length;i++){

                        Vector data=new Vector();

                        String s3=null;

                        String s6=null;

                        int contd=0;

                        int contf=0;

                        sql=new File(path+"/"+"sql/"+aux[i].getName().split(".ddf")[0]+".sql");

                        String table=sql.getName().split(".sql")[0];

                        //System.out.println(table);

                        //System.out.println(sql.getName());

                        try{

                                read = new BufferedReader(new InputStreamReader(new DataInputStream(new FileInputStream(aux[i]))));

                                write = new FileWriter(sql);

                                String s=read.readLine();

                                String s2[]=null;

                                if(squema.compareTo("public")==0){

                                        s3="INSERT INTO public."+table.toLowerCase()+"(";

                                }

                                else{

                                        s3="INSERT INTO "+squema+"."+table.toLowerCase()+"(";

                                }

                                String s4="";

                                String s5=null;

                                if(s!=null){

                                        while(s.compareTo("[FIELDS]")!=0){

                                                s=read.readLine();

                                        }

                                }

                                s=read.readLine();

                                while(s.compareTo("")!=0){

                                        s2=s.split(",");

                                        contd++;

                                        data.addElement(s2[0]);

                                        //System.out.println(s2[0]);

                                        s=read.readLine();

                                }

                                s4=s3;

                                int j;

                                for(j=0;j<data.size()-1;j++){

                                        s4=s4+data.elementAt(j)+",";

                                }

                                s4=s4+data.elementAt(data.size()-1)+") VALUES(";

                                while(s.compareTo("[DATA]")!=0){

                                        s=read.readLine();

                                }

                                s=read.readLine();

                                s6=s.replaceAll("\'"," ");

                                s5=s4;

                                while(s!=null){

                                        s2=s6.split("\t");

                                        contf=s2.length;

                                        int k;

                                        write.write(s5);

                                        for(k=0;k<s2.length-1;k++){

                                                if(s2[k].compareTo("")==0){

                                                        write.write("null,");

                                                        //System.out.print(s2[k]);

                                                }

                                                else{

                                                        write.write("\'"+s2[k]+"\',");

                                                        //System.out.print(s2[k]);

                                                }

                                        }

                                        write.write("\'"+s2[s2.length-1]+"\'");

                                        if(contd-contf>0){

                                                int l;

                                                write.write(",");

                                                for(l=0;l<(contd-contf)-1;l++){

                                                        write.write("null,");

                                                }

                                                write.write("null");

                                        }

                                        write.write(");\n");

                                        //System.out.println();

                                        s=read.readLine();

                                        if(s!=null){

                                                s6=s.replaceAll("\'"," ");

                                                if(s.compareTo("")==0){

                                                        s=read.readLine();

                                                        s6=s.replaceAll("\'"," ");

                                                }

                                        }

                                }

                                write.close();

                        }

                        catch(FileNotFoundException e1){

                                System.out.println("File not found.");

                        }

                        catch(IOException e){

                                System.out.println("I/O error.");

                        }

                }

        }

}