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(); |