Diff for /FM2SQL/Attic/Convert.java between versions 1.81 and 1.82

version 1.81, 2004/10/19 11:12:19 version 1.82, 2004/10/19 11:57:26
Line 1465  class Convert Line 1465  class Convert
                 else if (modeString.equals("delete"))                  else if (modeString.equals("delete"))
                     mode = DataBase.DELETE_MODE;                      mode = DataBase.DELETE_MODE;
   
                   else if (modeString.equals("synchronize"))
                       mode = DataBase.SYNCHRONIZE_MODE;
                 //   if(node3!=null)                  //   if(node3!=null)
                 // System.out.println(node3.name);                  // System.out.println(node3.name);
   
Line 2233  class Convert Line 2235  class Convert
                             if (dialog != null)                              if (dialog != null)
                                 dialog.title.setText("Writing table data ...");                                  dialog.title.setText("Writing table data ...");
   
                             performSynchronize(idField, vec, tempQuery, linesToDelete, linesToAppend, insPst, updPst, delPSt, deltaID, delimiter);                              performSynchronize(idField, vec, tempQuery, linesToDelete, linesToAppend, insPst, updPst, delPSt, deltaID, delimiter, dialog);
                             // System.out.println("ID LIST SIZE " +                              // System.out.println("ID LIST SIZE " +
                             // Math.round((double) myIds.size() / (double)                              // Math.round((double) myIds.size() / (double)
                             // numIntervalls) + " " + myIdsDest.size());                              // numIntervalls) + " " + myIdsDest.size());
Line 2257  class Convert Line 2259  class Convert
                             //    bean.makeQuery(tempQuery, 0);                              //    bean.makeQuery(tempQuery, 0);
                             if (dialog != null)                              if (dialog != null)
                                 dialog.title.setText("Writing table data ...");                                  dialog.title.setText("Writing table data ...");
                             performSynchronize(idField, vec, tempQuery, linesToDelete, linesToAppend, insPst, updPst, delPSt, deltaID, delimiter);                              performSynchronize(idField, vec, tempQuery, linesToDelete, linesToAppend, insPst, updPst, delPSt, deltaID, delimiter, dialog);
                             // System.out.println("ID LIST SIZE " +                              // System.out.println("ID LIST SIZE " +
                             // Math.round((double) myIds.size() / (double)                              // Math.round((double) myIds.size() / (double)
                             // numIntervalls) + " " + myIdsDest.size());                              // numIntervalls) + " " + myIdsDest.size());
Line 2270  class Convert Line 2272  class Convert
   
                     }                      }
                     String tableName = names.get(tbIndex).toString();                      String tableName = names.get(tbIndex).toString();
                       if (indexList.isEmpty())
                       {
                     IndexList idList = (IndexList) indexList.get(0);                      IndexList idList = (IndexList) indexList.get(0);
                     System.out.println("found list " + idList);                      System.out.println("found list " + idList);
                     Statement stm = beanDest.getConnection().createStatement();                      Statement stm = beanDest.getConnection().createStatement();
Line 2321  class Convert Line 2325  class Convert
                         // "+destTableName+"_"+indexField);                          // "+destTableName+"_"+indexField);
   
                     }                      }
                       }
                     //  CREATE UNIQUE INDEX title_idx ON films (title);                      //  CREATE UNIQUE INDEX title_idx ON films (title);
                     for (Iterator iter = linesToDelete.iterator(); iter.hasNext();)                      for (Iterator iter = linesToDelete.iterator(); iter.hasNext();)
                     {                      {
Line 2376  class Convert Line 2381  class Convert
     }      }
   
     private static void performSynchronize(String idField, Vector vec, String tempQuery, TreeSet linesToDelete, TreeSet linesToAppend, PreparedStatement insPst, PreparedStatement updPst,      private static void performSynchronize(String idField, Vector vec, String tempQuery, TreeSet linesToDelete, TreeSet linesToAppend, PreparedStatement insPst, PreparedStatement updPst,
             PreparedStatement delPSt, int deltaID, String delimiter) throws SQLException, ParseException              PreparedStatement delPSt, int deltaID, String delimiter, FM2SQL.ProgressDialog dialog) throws SQLException, ParseException
       {
           if (dialog != null)
     {      {
               dialog.progress.setValue(0);
               dialog.title.setText("Retrieving new data");
           }
   
         Vector[] vectors = bean.getQueryData(tempQuery, deltaID);          Vector[] vectors = bean.getQueryData(tempQuery, deltaID);
           int count = 0, size = vectors[0].size();
         int idIndex = vectors[1].indexOf(idField);          int idIndex = vectors[1].indexOf(idField);
         System.out.println(idIndex + " " + vectors[1] + " " + idField);          //System.out.println(idIndex + " " + vectors[1] + " " + idField);
         // todo arraylist code has to be added          // todo arraylist code has to be added
           if (dialog != null)
               dialog.title.setText("Synchronize with new data");
   
         for (Iterator iter = vectors[0].iterator(); iter.hasNext();)          for (Iterator iter = vectors[0].iterator(); iter.hasNext();)
         {          {
             Vector line = (Vector) iter.next();              Vector line = (Vector) iter.next();
Line 2418  class Convert Line 2433  class Convert
                 }                  }
                 updPst.setString(line.size() + 1, line.get(idIndex).toString());                  updPst.setString(line.size() + 1, line.get(idIndex).toString());
                 //updPst.addBatch();                  //updPst.addBatch();
                 updPst.execute();                  //updPst.execute();
               }
               if (dialog != null)
               {
                   int value = (int) Math.round(((double) count / (double) size) * 100.0);
                   dialog.progress.setValue(value);
                   count++;
             }              }
         }          }
         //updPst.executeBatch();          //updPst.executeBatch();

Removed from v.1.81  
changed lines
  Added in v.1.82


FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>