--- FM2SQL/Attic/Convert.java	2004/01/13 12:30:28	1.7
+++ FM2SQL/Attic/Convert.java	2004/01/19 08:25:52	1.15
@@ -36,7 +36,6 @@ class Convert
     //System.out.println(new String(b,"UTF-8"));
     } catch (UnsupportedEncodingException e)
     {
-      // TODO Auto-generated catch block
       e.printStackTrace();
     }*/
     FileOutputStream file = null;
@@ -51,7 +50,6 @@ class Convert
       file = new FileOutputStream("./log.txt");
     } catch (FileNotFoundException e1)
     {
-      // TODO Auto-generated catch block
       e1.printStackTrace();
     } 
    PrintStream stream= new PrintStream(file);
@@ -61,7 +59,7 @@ class Convert
    System.out.println("Finished!");
     //convert("jdbc:fmpro:http://141.14.237.74:8050","jdbc:postgresql://erebos/test",null,null);
   }
-  public static void  convertBatch(DBBean source,DBBean destination,Vector names,Vector layouts,Vector selects,Vector creates) throws Exception
+  public static void  convertBatch(DBBean source,DBBean destination,Vector names,Vector layouts,Vector selects,Vector creates,int mode) throws Exception
   {
    /*FM2SQL.ProgressDialog dialog = new  FM2SQL.ProgressDialog(FM2SQL.fmInstance);
    dialog.setTitle("Conversion running ...");
@@ -139,7 +137,7 @@ class Convert
         // System.out.println(beanDest.getTableNames(beanDest.getCatalogs().get(2).toString()));
         stm = beanDest.getConnection().createStatement();
         // System.exit(0);
-      if(true) 
+      if(mode==Convert.DataBase.CONVERT_MODE) 
       {
         if(tables.indexOf(names.get(tbIndex))>=0) 
         {
@@ -306,6 +304,175 @@ class Convert
   }
 
 
+  public static void update(String source, String destination, Vector names, Vector layouts, Vector selects, Vector creates, Vector ids,int mode) throws Exception
+  {
+    FM2SQL.ProgressDialog dialog = null;
+    if (FM2SQL.fmInstance != null)
+    {
+      dialog = new FM2SQL.ProgressDialog(FM2SQL.fmInstance);
+      dialog.setTitle("Conversion running ...");
+      dialog.title.setText("Getting table data ...");
+      dialog.setLocation(FM2SQL.fmInstance.getLocationOnScreen().x + (FM2SQL.fmInstance.getWidth() - 400) / 2, FM2SQL.fmInstance.getLocationOnScreen().y + (FM2SQL.fmInstance.getHeight() - 250) / 2);
+      dialog.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR));
+      FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR));
+      dialog.thread = Thread.currentThread();
+    }
+    // setting user and passwd 
+    bean.setUserAndPasswd(user, passwd);
+    // setting user and passwd 
+    beanDest.setUserAndPasswd(userDest, passwdDest);
+    if (dialog != null)
+      dialog.setSize(400, 250);
+    StringBuffer command = null;
+    String query = null;
+    try
+    {
+      //bean.setConnection("jdbc:fmpro:http://141.14.237.74:8050");    
+      //bean.setConnection("jdbc:postgresql://erebos/test","postgres","rogo");
+      bean.setConnection(source);
+      if (names == null)
+        names = bean.getTableNames();
+      // Collections.sort(names);
+      int tbIndex = 1;
+
+      // System.out.println("Start at "+names.indexOf("archimedes_facsimiles"));
+      for (tbIndex = 0; tbIndex < names.size(); ++tbIndex)
+      {
+        Vector[] result = null;
+        try
+        {
+          query = "select * from " + bean.getQC() + names.get(tbIndex).toString() + bean.getQC();
+          String layout = (layouts.isEmpty()) ? "" : layouts.get(tbIndex).toString();
+          query = (selects != null) ? selects.get(tbIndex).toString() : query;
+          //if  vectors[1].get(i) != null)
+          if (layout != "")
+          {
+            layout = " layout " + bean.getQC() + layout + bean.getQC();
+            String name = names.get(tbIndex).toString();
+            StringBuffer queryLayout = new StringBuffer(query);
+            queryLayout.insert(queryLayout.indexOf(name) + name.length() + 1, " " + layout);
+            query = queryLayout.toString();
+            System.out.println("added layout  " + query);
+
+          }
+          dialog.title.setText("Getting table data ...");
+          dialog.table.setText(names.get(tbIndex).toString());
+          dialog.status.setText("Table " + (tbIndex + 1) + " of " + names.size());
+          dialog.show();
+          bean.getConnection();
+          bean.makeQuery(query, 0);
+        } catch (Exception e)
+        {
+          continue;
+        }
+        //beanDest.setConnection("jdbc:postgresql://erebos/test3");
+        beanDest.setConnection(destination);
+
+        Statement stm = beanDest.getConnection().createStatement();
+
+        Vector tables = beanDest.getTableNames();
+        // Collections.sort(tables);
+        System.out.println(names.get(tbIndex) + " " + tables.indexOf(convertText((String) names.get(tbIndex)))); // "//beanDest.getTypeNames()); 
+        tables = beanDest.getTableNames();
+        // System.out.println(beanDest.getTableNames(beanDest.getCatalogs().get(2).toString()));
+        stm = beanDest.getConnection().createStatement();
+        // System.exit(0);
+    
+        if (dialog != null)
+          dialog.title.setText("Writing table data ...");
+
+        int j = -1;
+        Vector row = null;
+        command = new StringBuffer();
+
+        command.append("UPDATE ");
+        command.append(beanDest.getQC());
+        command.append(convertText((String) names.get(tbIndex)));
+        command.append(beanDest.getQC());
+        command.append(" SET  ");
+
+        int size = bean.getColumnNames().size();
+        for (int i = 0; i < size - 1; ++i)
+          command.append(convertText((String)bean.getColumnNames().get(i))+" = ? ,");
+        command.append(convertText((String)bean.getColumnNames().get(size-1))+" = ? ");
+        command.append("WHERE "+ids.get(tbIndex)+ " =  ?");
+        PreparedStatement pstm = beanDest.getConnection().prepareStatement(command.toString());
+        System.out.println(command+" "+tbIndex);
+        int rowCount = bean.getRowCount(query);
+        int idIndex = bean.getColumnNames().indexOf(ids.get(tbIndex) );
+        while ((row = bean.getNextRow()) != null)
+        {
+          j++;
+          //print rows
+          Object obj = null;
+          /* for(int k=0;k<row.size()-1;++k)
+           {
+          		obj = row.get(k);
+          		//System.out.println("row "+obj+" "+k);
+          	 if(obj!=null&&!(obj instanceof ArrayList))
+          	 command.append("'"+convertUml(obj.toString())+"',"); 
+          	 else if(obj!=null&&   obj instanceof ArrayList)
+          	 command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"',"); 
+          	 else command.append("NULL,");
+           }
+           obj = row.get(row.size() - 1);
+           if (obj != null && !(obj instanceof ArrayList))
+           command.append("'"+convertUml(obj.toString())+"')"); 
+          	else
+          	if(obj!=null&&   obj instanceof ArrayList)
+          	 command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"')");         //command.append(obj.toString()+")");
+          	 else command.append("NULL)");
+          	*/
+          //command.append("'"+row.get(row.size()-1)+"')"); 
+          //command.append(" )");
+          //  for(int k=0;k<row.size();++k)
+
+          // System.out.println();
+          //   System.out.println(command+" "+j+" "+row.size()+" "+  ((Vector)result2[0].get(j)).size());
+          // System.out.println(command);
+          for (int k = 0; k < row.size(); ++k)
+          {
+            obj = row.get(k);
+            if (obj instanceof ArrayList)
+              obj = ((List) obj).get(0);
+            String str = (obj == null) ? "NULL" : obj.toString();
+            if (!str.equals("NULL"))
+              pstm.setString(k + 1, str);
+            else
+              pstm.setNull(k + 1, Types.NULL);
+          }
+         pstm.setString(row.size()+1,row.get(idIndex).toString());
+				 //System.out.println(pstm.toString());
+				// System.exit(0);
+          pstm.execute();
+          //stm.executeUpdate(command.toString());
+          if(dialog!=null)
+          dialog.progress.setValue((int) (((double) (j + 1) / (double) rowCount) * 100.0));
+          // System.out.println( (int)(((double)(j+1)/(double)result[0].size())*100.0)+" "+result[0].size()+" "+j);
+          command = null;
+        } // to for loop    
+
+      }
+    } catch (Exception e)
+    {
+      System.out.println("Error while connecting to database " + e);
+      dialog.setVisible(false);
+      dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
+      FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
+      java.io.ByteArrayOutputStream b = new java.io.ByteArrayOutputStream();
+      java.io.PrintStream stream = new java.io.PrintStream(b);
+      stream.print(command + "\n\n");
+      e.printStackTrace(stream);
+      FM2SQL.showErrorDialog(b.toString(), "Error occured !");
+
+    }
+    dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
+    FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
+
+    dialog.setVisible(false);
+  }
+
+
 
   public static void  convert(String source,String destination,Vector names,Vector layouts,Vector selects,Vector creates,int mode) throws Exception
   {
@@ -627,6 +794,8 @@ class Convert
         alterMe.delete(j, j); 
         length--;
       }
+			else
+			alterMe.setCharAt(j,'_');
     }
 
     ++j;
@@ -786,7 +955,8 @@ class Convert
       Vector layouts = new Vector();
       Vector selects = new Vector();
       Vector creates = new Vector();
-			int mode = -1;
+			Vector ids     = new Vector();
+      int mode = -1;
    
       try
       {
@@ -802,7 +972,7 @@ class Convert
           layouts = new Vector();
           selects = new Vector();
           creates = new Vector();
-
+          ids     = new Vector();
          // parse dataBase
           Node node = root.find("convert/source/database/url", new int[] { 1, 1, i, 1 });
           Node node1 = root.find("convert/source/database/user", new int[] { 1, 1, i, 1, 1 });
@@ -858,11 +1028,15 @@ class Convert
             // if(node6==null) throw new Error("parse error create tag missing");
             String name = (String)node4.attributes.get("name");
             String layout = (String)node4.attributes.get("layout");
+            String id = (String)node4.attributes.get("id");
+            System.out.println("id was "+id);
             if(name==null) throw new Error("parse error required table tag attribute name missing");
             if(layout==null) layout ="";
+            if(id==null)  id = "";
             if(name.equals("")) throw new Error("parse error table tag attribute must not be empty");
             tables.add(name);
             layouts.add(layout);
+            ids.add(id);
             String query = (node5==null) ? "":node5.getCharacters(); 
             if(query.equals("")) System.err.println("Warning empty select tag or  select tag missing !!");
             query = (query.equals("")) ? "select * from "+database.getQC()+name+database.getQC():query;
@@ -872,7 +1046,7 @@ class Convert
               creates.add("");
             
           }
-          databases.add(new DataBase(database, tables, layouts, selects,creates,mode));
+          databases.add(new DataBase(database, tables, layouts, selects,creates,ids,mode));
         }
         DBBean database = new DBBean();
         // parse dataBase
@@ -889,7 +1063,7 @@ class Convert
        for (Iterator iter = databases.iterator(); iter.hasNext();)
       {
         DataBase db = (DataBase) iter.next();
-        convertBatch(db.bean,database,db.tables,db.layouts,db.selects,db.creates);
+        convertBatch(db.bean,database,db.tables,db.layouts,db.selects,db.creates,mode);
         
       }
         // printContents(node3);
@@ -1018,6 +1192,8 @@ class Convert
        Vector layouts = new Vector();
        Vector selects = new Vector();
        Vector creates = new Vector();
+       Vector ids     = new Vector();
+       
        int mode = -1;
        try
        {
@@ -1033,7 +1209,7 @@ class Convert
            layouts = new Vector();
            selects = new Vector();
            creates = new Vector();
-
+           ids     = new Vector();
           // parse dataBase
            Node node = root.find("convert/source/database/url", new int[] { 1, 1, i, 1 });
            Node node1 = root.find("convert/source/database/user", new int[] { 1, 1, i, 1, 1 });
@@ -1091,11 +1267,16 @@ class Convert
              // if(node6==null) throw new Error("parse error create tag missing");
              String name = (String)node4.attributes.get("name");
              String layout = (String)node4.attributes.get("layout");
+             String id = (String)node4.attributes.get("id");
+             System.out.println("id was "+id);
+         
              if(name==null) throw new Error("parse error required table tag attribute name missing");
              if(layout==null) layout ="";
+             if(id == null)  id="";
              if(name.equals("")) throw new Error("parse error table tag attribute must not be empty");
              tables.add(name);
              layouts.add(layout);
+             ids.add(id);
              String query = (node5==null) ? "":node5.getCharacters(); 
              if(query.equals("")) System.err.println("Warning empty select tag or  select tag missing !!");
              query = (query.equals("")) ? "select * from "+database.getQC()+name+database.getQC():query;
@@ -1105,7 +1286,7 @@ class Convert
                creates.add("");
             
            }
-           databases.add(new DataBase(database, tables, layouts, selects,creates,mode));
+           databases.add(new DataBase(database, tables, layouts, selects,creates,ids,mode));
          }
          DBBean database = new DBBean();
          // parse dataBase
@@ -1118,7 +1299,7 @@ class Convert
          System.out.println(url);
          database.setURL(url.trim());
          database.setUserAndPasswd(user.trim(), password.trim());
-         databases.add(new DataBase(database,null,null,null,null,0));
+         databases.add(new DataBase(database,null,null,null,null,null,0));
          //databases.add(database);
     /*    for (Iterator iter = databases.iterator(); iter.hasNext();)
        {
@@ -1198,22 +1379,26 @@ public static class DataBase
   Vector selects;
   Vector layouts;
   Vector tables;
+  Vector ids;
   final static int CONVERT_MODE = 1;
 	final static int APPEND_MODE  = 2;
 	final static int UPDATE_MODE  = 3;
   int mode = -1;
   
-  public DataBase(DBBean bean,Vector tables,Vector layouts,Vector selects,Vector creates,int mode)
+  public DataBase(DBBean bean,Vector tables,Vector layouts,Vector selects,Vector creates,Vector ids,int mode)
   {
     this.bean = bean;
     this.tables = tables;
     this.layouts = layouts;
     this.selects = selects;
     this.creates = creates;
+    this.ids     = ids;
     this.mode = mode;
+    this.bean.setIDVector(ids);
   }
   public void exportToXML(BufferedWriter buffr) throws Exception
    {
+    // ids=bean.getIDVector();
      buffr.write("    <database>\n");
      buffr.write("      <url>"+bean.url+"</url>\n");
      buffr.write("      <user>"+bean.user+"</user>\n");
@@ -1236,8 +1421,9 @@ public static class DataBase
        String layout=(String)layouts.get(index);
        String select=(String)selects.get(index);
        String create=(String)creates.get(index);
+       String id=(String)ids.get(index);
    
-       buffr.write("      <table name = \""+table+"\" layout = \""+layout+"\">\n");
+       buffr.write("      <table name = \""+table+"\" layout = \""+layout+"\" id = \""+id+"\" >\n");
        buffr.write("         <select>"+ convertToEntities(select)+"</select>\n");
        if(!create.equals(""))
        buffr.write("         <create>"+create+"         </create>\n");