--- FM2SQL/Attic/Convert.java	2003/12/05 11:46:39	1.1.1.1
+++ FM2SQL/Attic/Convert.java	2004/01/13 12:30:28	1.7
@@ -63,7 +63,6 @@ class Convert
   }
   public static void  convertBatch(DBBean source,DBBean destination,Vector names,Vector layouts,Vector selects,Vector creates) throws Exception
   {
-   // @TODO Convert change to convert row wise
    /*FM2SQL.ProgressDialog dialog = new  FM2SQL.ProgressDialog(FM2SQL.fmInstance);
    dialog.setTitle("Conversion running ...");
    dialog.title.setText("Getting table data ...");
@@ -214,9 +213,22 @@ class Convert
     //dialog.title.setText("Writing table data ...");
     Vector row = null;
     //for (int j = 0; j < result[0].size(); ++j)
+    command = new StringBuffer();
+
+    command.append("INSERT  INTO ");
+    command.append(beanDest.getQC());
+    command.append(convertText((String) names.get(tbIndex)));
+    command.append(beanDest.getQC());
+    command.append(" values ( ");
+
+    for (int i = 0; i < bean.getColumnNames().size() - 1; ++i)
+      command.append("?,");
+    command.append("?)");
+    PreparedStatement pstm = beanDest.getConnection().prepareStatement(command.toString());
+    System.out.println(command);
     while((row=bean.getNextRow())!=null)
     {
-      //Vector row = (Vector) result[0].get(j);
+/*      //Vector row = (Vector) result[0].get(j);
       command = new StringBuffer();
 
         command.append("INSERT  INTO ");
@@ -224,8 +236,10 @@ class Convert
         command.append(convertText((String) names.get(tbIndex)));
         command.append(beanDest.getQC());
         command.append(" values ( ");
-        //print rows
+   */
+             //print rows
      Object obj = null;
+     /*
      for(int k=0;k<row.size()-1;++k)
      {
         obj = row.get(k);
@@ -254,6 +268,20 @@ class Convert
   // dialog.progress.setValue((int)(((double)(j+1)/(double)result[0].size())*100.0));
   // System.out.println( (int)(((double)(j+1)/(double)result[0].size())*100.0)+" "+result[0].size()+" "+j);
    command = null;
+*/
+    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.execute();
+
 }// to for loop    
    
     }
@@ -279,7 +307,7 @@ class Convert
 
 
 
-  public static void  convert(String source,String destination,Vector names,Vector layouts,Vector selects,Vector creates) throws Exception
+  public static void  convert(String source,String 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 ...");
@@ -349,7 +377,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) 
         {
@@ -424,37 +452,51 @@ class Convert
     //for (int j = 0; j < result[0].size(); ++j)
     int j=-1;
     Vector row = null;
+    command = new StringBuffer();
+
+    command.append("INSERT  INTO ");
+    command.append(beanDest.getQC());
+    command.append(convertText((String) names.get(tbIndex)));
+    command.append(beanDest.getQC());
+    command.append(" values ( ");
+    
+    for(int i=0;i<bean.getColumnNames().size()-1;++i) command.append("?,");
+    command.append("?)");
+    PreparedStatement pstm = beanDest.getConnection().prepareStatement(command.toString());
+    System.out.println(command);
     int rowCount= bean.getRowCount(query);
     while((row=bean.getNextRow())!=null)
     {
       j++;
       // row = (Vector) result[0].get(j);
-      command = new StringBuffer();
+   /*   command = new StringBuffer();
 
         command.append("INSERT  INTO ");
         command.append(beanDest.getQC());
         command.append(convertText((String) names.get(tbIndex)));
         command.append(beanDest.getQC());
         command.append(" values ( ");
-        //print rows
+     */
+           //print rows
      Object obj = null;
-     for(int k=0;k<row.size()-1;++k)
+    /* 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(new String(obj.toString().getBytes("UTF-8"),"UTF-8"))+"',"); 
+       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(new String(obj.toString().getBytes("UTF-8"),"UTF-8"))+"')"); 
+     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)
@@ -462,7 +504,17 @@ class Convert
       // System.out.println();
       //   System.out.println(command+" "+j+" "+row.size()+" "+  ((Vector)result2[0].get(j)).size());
       // System.out.println(command);
-      stm.executeUpdate(command.toString());
+      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.execute();
+      //stm.executeUpdate(command.toString());
       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;
@@ -493,6 +545,13 @@ class Convert
     StringBuffer alterMe = new StringBuffer(newName.trim().toLowerCase());
     int length = alterMe.length();
     int j = 0;
+    int index=alterMe.indexOf(".fp5");
+    if ( index >= 0 )
+     {
+       alterMe.delete(index, index + 4);
+       length = length - 4;
+     }
+ 
     while (j < length)
     { 
       if (alterMe.charAt(j) == ' ')
@@ -561,11 +620,49 @@ class Convert
       alterMe.setCharAt(j, '_');
 
     }
+    else if (alterMe.charAt(j) == '.')
+    {
+      if(j==length-1)
+      {
+        alterMe.delete(j, j); 
+        length--;
+      }
+    }
 
     ++j;
   }
     return alterMe.toString();
   }
+  public static String convertToEntities(String newName)
+  {
+    StringBuffer alterMe = new StringBuffer(newName.trim());
+    int length = alterMe.length();
+    int j = 0;
+
+    while (j < length)
+    {
+
+      if (alterMe.charAt(j) == '>')
+      {
+        alterMe.setCharAt(j, '&');
+        alterMe.insert(j + 1, "gt;");
+        length = length + 2;
+        if (j < length - 1)
+          j = j + 1;
+
+      } else if (alterMe.charAt(j) == '<')
+      {
+        alterMe.setCharAt(j, '&');
+        alterMe.insert(j + 1, "lt;");
+        length = length + 2;
+        if (j < length - 1)
+          j = j + 1;
+
+      }
+      ++j;
+    }
+    return alterMe.toString();
+  }
   public static String convertUml(String newName)
    {
 	 StringBuffer alterMe = new StringBuffer(newName.trim());
@@ -680,14 +777,17 @@ class Convert
     {
       boolean finished = false;
       // parse string and build document tree
-      Node  root = new Xparse().parse(sb.toString());
+      Xparse parser =new Xparse();
+      parser.changeEntities = true;
+      Node  root = parser.parse(sb.toString());
        // printContents(root);
       Vector databases= new Vector();
       Vector tables = new Vector();
       Vector layouts = new Vector();
       Vector selects = new Vector();
       Vector creates = new Vector();
-     
+			int mode = -1;
+   
       try
       {
         Node tempNode = root.find("convert/source", new int[] { 1, 1 });
@@ -708,6 +808,8 @@ class Convert
           Node node1 = root.find("convert/source/database/user", new int[] { 1, 1, i, 1, 1 });
           Node node2 = root.find("convert/source/database/password", new int[] { 1, 1, i, 1, 1 });
           Node node3 = root.find("convert/source/database", new int[] { 1, 1, i});
+    			Node nodeMode = root.find("convert/source/database/mode/", new int[] {1, 1, i, 1,1});
+
           if(node3== null) throw new Error("parse error database tag missing");
           if(node==null) throw new Error("parse error url tag missing");
           if(node1==null) throw new Error("parse error user tag missing");
@@ -720,7 +822,19 @@ class Convert
           System.out.println(node.name + " " + node.getCharacters());
           System.out.println(node1.name + " " + node1.getCharacters());
           System.out.println(node2.name + " " + node2.getCharacters());
-       
+          String modeString = "";
+          if (nodeMode == null)
+            modeString = "convert";
+          else
+            modeString = nodeMode.getCharacters();
+          if (modeString.equals("convert"))
+            mode = DataBase.CONVERT_MODE;
+          else
+            if (modeString.equals("append"))
+              mode = DataBase.APPEND_MODE;
+            else
+              if (modeString.equals("update"))
+                mode = DataBase.UPDATE_MODE;
        //   if(node3!=null)
          // System.out.println(node3.name);
           
@@ -758,7 +872,7 @@ class Convert
               creates.add("");
             
           }
-          databases.add(new DataBase(database, tables, layouts, selects,creates));
+          databases.add(new DataBase(database, tables, layouts, selects,creates,mode));
         }
         DBBean database = new DBBean();
         // parse dataBase
@@ -895,14 +1009,16 @@ class Convert
   
        boolean finished = false;
        // parse string and build document tree
-       Node  root = new Xparse().parse(sb.toString());
-        // printContents(root);
+       Xparse parser =new Xparse();
+       parser.changeEntities = true;
+       Node  root = parser.parse(sb.toString());
+   // printContents(root);
        Vector databases= new Vector();
        Vector tables = new Vector();
        Vector layouts = new Vector();
        Vector selects = new Vector();
        Vector creates = new Vector();
-     
+       int mode = -1;
        try
        {
          Node tempNode = root.find("convert/source", new int[] { 1, 1 });
@@ -923,6 +1039,8 @@ class Convert
            Node node1 = root.find("convert/source/database/user", new int[] { 1, 1, i, 1, 1 });
            Node node2 = root.find("convert/source/database/password", new int[] { 1, 1, i, 1, 1 });
            Node node3 = root.find("convert/source/database", new int[] { 1, 1, i});
+           Node nodeMode = root.find("convert/source/database/mode", new int[] { 1, 1, i, 1, 1 });
+           
            if(node3== null) throw new Error("parse error database tag missing");
            if(node==null) throw new Error("parse error url tag missing");
            if(node1==null) throw new Error("parse error user tag missing");
@@ -935,7 +1053,21 @@ class Convert
            System.out.println(node.name + " " + node.getCharacters());
            System.out.println(node1.name + " " + node1.getCharacters());
            System.out.println(node2.name + " " + node2.getCharacters());
-       
+           String modeString = "";  
+          if (nodeMode == null)
+            modeString = "convert";
+          else
+            modeString = nodeMode.getCharacters();
+          if (modeString.equals("convert"))
+            mode = DataBase.CONVERT_MODE;
+          else
+            if (modeString.equals("append"))
+              mode = DataBase.APPEND_MODE;
+            else
+              if (modeString.equals("update"))
+                mode = DataBase.UPDATE_MODE;
+			 
+        
         //   if(node3!=null)
           // System.out.println(node3.name);
           
@@ -973,7 +1105,7 @@ class Convert
                creates.add("");
             
            }
-           databases.add(new DataBase(database, tables, layouts, selects,creates));
+           databases.add(new DataBase(database, tables, layouts, selects,creates,mode));
          }
          DBBean database = new DBBean();
          // parse dataBase
@@ -986,7 +1118,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));
+         databases.add(new DataBase(database,null,null,null,null,0));
          //databases.add(database);
     /*    for (Iterator iter = databases.iterator(); iter.hasNext();)
        {
@@ -1066,13 +1198,19 @@ public static class DataBase
   Vector selects;
   Vector layouts;
   Vector tables;
-  public DataBase(DBBean bean,Vector tables,Vector layouts,Vector selects,Vector creates)
+  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)
   {
     this.bean = bean;
     this.tables = tables;
     this.layouts = layouts;
     this.selects = selects;
     this.creates = creates;
+    this.mode = mode;
   }
   public void exportToXML(BufferedWriter buffr) throws Exception
    {
@@ -1080,7 +1218,17 @@ public static class DataBase
      buffr.write("      <url>"+bean.url+"</url>\n");
      buffr.write("      <user>"+bean.user+"</user>\n");
      buffr.write("      <password>"+bean.passwd+"</password>\n");
-
+     String modeString ="";
+    if (mode == CONVERT_MODE)
+      modeString = "convert";
+    else
+      if (mode == APPEND_MODE)
+        modeString = "append";
+      else
+        if (mode == UPDATE_MODE)
+          modeString = "update";
+  
+     buffr.write("      <mode>"+ modeString+"</mode>\n");
      int index = 0;
      while(index<tables.size())
      {
@@ -1090,7 +1238,7 @@ public static class DataBase
        String create=(String)creates.get(index);
    
        buffr.write("      <table name = \""+table+"\" layout = \""+layout+"\">\n");
-       buffr.write("         <select>"+select+"</select>\n");
+       buffr.write("         <select>"+ convertToEntities(select)+"</select>\n");
        if(!create.equals(""))
        buffr.write("         <create>"+create+"         </create>\n"); 
        buffr.write("      </table>\n");