Annotation of FM2SQL/src/Convert.java, revision 1.4
1.1 rogo 1: /*
2: * Convert.java -- Converter class - Filemaker to SQL Converter Copyright (C)
3: * 2003 Robert Gordesch (rogo@mpiwg-berlin.mpg.de) This program is free
4: * software; you can redistribute it and/or modify it under the terms of the GNU
5: * General Public License as published by the Free Software Foundation; either
6: * version 2 of the License, or (at your option) any later version. Please read
7: * license.txt for the full details. A copy of the GPL may be found at
8: * http://www.gnu.org/copyleft/lgpl.html You should have received a copy of the
9: * GNU General Public License along with this program; if not, write to the Free
10: * Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
11: * USA Created on 15.09.2003 by rogo
12: */
13:
14: import java.awt.Cursor;
15: import java.io.BufferedReader;
16: import java.io.BufferedWriter;
17: import java.io.File;
18: import java.io.FileInputStream;
19: import java.io.FileNotFoundException;
20: import java.io.FileOutputStream;
21: import java.io.IOException;
22: import java.io.InputStream;
23: import java.io.InputStreamReader;
24: import java.io.OutputStreamWriter;
25: import java.io.PrintStream;
26: import java.net.URL;
27: import java.sql.PreparedStatement;
28: import java.sql.ResultSet;
29: import java.sql.SQLException;
30: import java.sql.Statement;
31: import java.sql.Types;
32: import java.text.ParseException;
33: import java.util.ArrayList;
34: import java.util.Hashtable;
35: import java.util.Iterator;
36: import java.util.List;
37: import java.util.StringTokenizer;
38: import java.util.TreeSet;
39: import java.util.Vector;
40:
41: import javax.swing.JDialog;
42: import javax.swing.JLabel;
43: import javax.swing.JPanel;
44:
45: import com.exploringxml.xml.Node;
46: import com.exploringxml.xml.Xparse;
47:
48: class Convert
49: {
1.4 ! rogo 50: /**
! 51: * Helper class for index creation
! 52: *
! 53: * @author rogo
! 54: *
! 55: */
! 56: public static class IndexList extends Vector
! 57: {
! 58: public String toString()
! 59: {
! 60: StringBuffer buff = new StringBuffer(1000);
! 61: int count = 0;
! 62: for (Iterator iter = this.iterator(); iter.hasNext();)
! 63: {
! 64: String element = (String) iter.next();
! 65: if (count < elementCount - 1)
! 66: {
! 67: buff.append(element).append(", ");
! 68: count++;
! 69: } else
! 70: buff.append(element);
! 71:
! 72: }
! 73:
! 74: return buff.toString();
! 75: }
! 76: }
! 77:
! 78: /**
! 79: * Helper class for pre/or post execution of SQLCommands
! 80: * @author rogo
! 81: *
! 82: */
! 83: public static class SQLCommand
! 84: {
! 85: private DBBean bean;
! 86: private String command;
! 87:
! 88: public SQLCommand(DBBean bean, String command)
! 89: {
! 90: this.bean = bean;
! 91: this.command = command;
! 92: }
! 93:
! 94: public void executeCommand() throws SQLException, Exception
! 95: {
! 96: java.sql.Connection con = bean.getConnection();
! 97: Statement stm = con.createStatement();
! 98: stm.execute(command);
! 99: }
! 100: }
! 101:
! 102: static DBBean bean = new DBBean();
! 103:
! 104: static DBBean beanDest = new DBBean();
! 105:
! 106: static String user = "", passwd = "e1nste1n";
! 107:
! 108: static String userDest = "postgres", passwdDest = "rogo";
! 109:
! 110: static boolean batchRun = false;
! 111:
! 112: static Vector databases = new Vector();
! 113:
! 114: final static int numHits = 5000;
! 115:
! 116: final static int numIntervalls = 4;
! 117:
! 118: static boolean debug = true;
! 119:
! 120: static boolean isGUI = true;
! 121:
! 122: /**
! 123: * Vector for all SQLCommands to executed before any conversion action is performed
! 124: */
! 125: static Vector preSQLCommands = new Vector();
! 126: /**
! 127: * Vector for all SQLCommands to executed after any conversion action has been performed
! 128: */
! 129:
! 130: static Vector postSQLCommands = new Vector();
! 131:
! 132: public static void main(String args[]) throws IOException
! 133: {
! 134: /*
! 135: * try { //byte[] b = "�".getBytes("UTF-8"); //
! 136: * System.out.println("QueryString " +b[0]+" "+b[1]+(new
! 137: * String(b).getBytes()[0])+" "+new String(b).getBytes()[1]);
! 138: * //System.out.println(new String(b,"UTF-8")); } catch
! 139: * (UnsupportedEncodingException e) { e.printStackTrace(); }
! 140: */
! 141: isGUI = false;
! 142: FileOutputStream file = null;
! 143: if (args.length != 1)
! 144: {
! 145: System.out.println("Usage: java Convert <xml config file>");
! 146: System.exit(-1);
! 147: }
! 148: try
! 149: {
! 150: File temp = File.createTempFile("fm2sql", ".txt");
! 151: file = new FileOutputStream(temp);
! 152: } catch (FileNotFoundException e1)
! 153: {
! 154: e1.printStackTrace();
! 155: }
! 156: PrintStream stream = new PrintStream(file, true);
! 157: if (!debug)
! 158: {
! 159: System.setOut(stream);
! 160: System.setErr(stream);
! 161: }
! 162: StringBuffer sb = readXMLFile(args[0]);
! 163: parseXMLConfig(sb);
! 164: if (!(new File(args[0]).exists()))
! 165: System.exit(0);
! 166:
! 167: System.out.println("Finished!");
! 168: // convert("jdbc:fmpro:http://141.14.237.74:8050","jdbc:postgresql://erebos/test",null,null);
! 169: }
! 170:
! 171: public static void convertBatch(DBBean source, DBBean destination, Vector names, Vector layouts,
! 172: Vector selects, Vector creates, Vector ids, int mode, String delimiter) throws Exception
! 173: {
! 174: bean = source;
! 175: beanDest = destination;
! 176: convert(null, null, names, layouts, selects, creates, ids, mode, delimiter);
! 177: }
! 178:
! 179: public static String formatFileMakerArray(List list, String delimiter)
! 180: {
! 181: StringBuffer formattedString = new StringBuffer();
! 182: for (int i = 0; i < list.size(); ++i)
! 183: {
! 184: formattedString.append(list.get(i).toString());
! 185: if (i < list.size() - 1)
! 186: formattedString.append(delimiter);
! 187: }
! 188: return formattedString.toString();
! 189: }
! 190:
! 191: /**
! 192: * Method for SQL UPDATE
! 193: *
! 194: * @param source
! 195: * @param destination
! 196: * @param names
! 197: * @param layouts
! 198: * @param selects
! 199: * @param creates
! 200: * @param ids
! 201: * @param mode
! 202: * @throws Exception
! 203: */
! 204: public static void update(String source, String destination, Vector names, Vector layouts,
! 205: Vector selects, Vector creates, Vector ids, int mode) throws Exception
! 206: {
! 207:
! 208: FM2SQL.ProgressDialog dialog = null;
! 209: if (isGUI)
! 210: {
! 211: dialog = initDialog();
! 212: }
! 213: // setting user and passwd
! 214: bean.setUserAndPasswd(user, passwd);
! 215: // setting user and passwd
! 216: beanDest.setUserAndPasswd(userDest, passwdDest);
! 217:
! 218: StringBuffer command = null;
! 219: String query = null;
! 220: try
! 221: {
! 222:
! 223: bean.setConnection(source);
! 224:
! 225: if (names == null)
! 226: names = bean.getTableNames();
! 227: // Collections.sort(names);
! 228: int tbIndex = 1;
! 229:
! 230: System.out.println("Start at table " + names.firstElement());
! 231: for (tbIndex = 0; tbIndex < names.size(); ++tbIndex)
! 232: {
! 233: Vector[] result = null;
! 234: String destTableName = "";
! 235: try
! 236: {
! 237: query = "select * from " + bean.getQC() + names.get(tbIndex).toString() + bean.getQC();
! 238: String layout = (layouts.isEmpty()) ? "" : layouts.get(tbIndex).toString();
! 239: query = (selects != null) ? selects.get(tbIndex).toString() : query;
! 240: // if vectors[1].get(i) != null)
! 241: if (layout != "")
! 242: {
! 243: query = addLayoutToQuery(names, query, tbIndex, layout);
! 244:
! 245: }
! 246: if (dialog != null)
! 247: {
! 248: prepareDialogforUse(names, dialog, tbIndex);
! 249: }
! 250: bean.getConnection();
! 251: bean.makeQuery(query, 0);
! 252:
! 253: } catch (Exception e)
! 254: {
! 255: System.out.println("Warning exception occured \n " + e);
! 256:
! 257: continue;
! 258: }
! 259: // determine destTableName from createStatement or from source
! 260: // table name
! 261: if (!creates.get(tbIndex).equals(""))
! 262: {
! 263: String create = creates.get(tbIndex).toString().toLowerCase();
! 264: int fromIndex = create.indexOf("table") + 5;
! 265: int toIndex = create.indexOf("(");
! 266: destTableName = create.substring(fromIndex, toIndex).replaceAll(beanDest.getQC(), "")
! 267: .trim();
! 268: System.out.println("destTable " + destTableName);
! 269:
! 270: } else
! 271: destTableName = convertText(names.get(tbIndex).toString());
! 272:
! 273: beanDest.setConnection(destination);
! 274:
! 275: Statement stm = beanDest.getConnection().createStatement();
! 276:
! 277: Vector tables = beanDest.getTableNames();
! 278:
! 279: System.out.println(names.get(tbIndex) + " "
! 280: + tables.indexOf(convertText((String) names.get(tbIndex)))); // "//beanDest.getTypeNames());
! 281: tables = beanDest.getTableNames();
! 282: stm = beanDest.getConnection().createStatement();
! 283:
! 284: if (dialog != null)
! 285: dialog.title.setText("Updating table data ...");
! 286: else
! 287: System.out.println("Updating table data ...");
! 288: int j = -1;
! 289:
! 290: Vector row = null;
! 291: command = new StringBuffer();
! 292:
! 293: command.append("UPDATE ");
! 294: command.append(beanDest.getQC());
! 295: command.append(destTableName);
! 296: // command.append(convertText((String) names.get(tbIndex)));
! 297: command.append(beanDest.getQC());
! 298: command.append(" SET ");
! 299:
! 300: int size = bean.getColumnNames().size();
! 301: for (int i = 0; i < size - 1; ++i)
! 302: command.append(beanDest.getQC() + convertText((String) bean.getColumnNames().get(i))
! 303: + beanDest.getQC() + " = ? ,");
! 304: command.append(convertText((String) bean.getColumnNames().get(size - 1)) + " = ? ");
! 305: command.append("WHERE " + convertText(ids.get(tbIndex).toString()) + " = ?");
! 306: PreparedStatement pstm = beanDest.getConnection().prepareStatement(command.toString());
! 307: System.out.println(command + " " + tbIndex);
! 308: int rowCount = bean.getRowCount(query);
! 309: int idIndex = bean.getColumnNames().indexOf(ids.get(tbIndex));
! 310: while ((row = bean.getNextRow()) != null)
! 311: {
! 312: j++;
! 313: // print rows
! 314: Object obj = null;
! 315: for (int k = 0; k < row.size(); ++k)
! 316: {
! 317: obj = row.get(k);
! 318: if (obj instanceof ArrayList)
! 319: obj = ((List) obj).get(0);
! 320: String str = (obj == null) ? "NULL" : obj.toString();
! 321: if (!str.equals("NULL"))
! 322: pstm.setString(k + 1, str);
! 323: else
! 324: pstm.setNull(k + 1, Types.NULL);
! 325: }
! 326: pstm.setString(row.size() + 1, row.get(idIndex).toString());
! 327: pstm.execute();
! 328: if (dialog != null)
! 329: dialog.progress.setValue((int) (((double) (j + 1) / (double) rowCount) * 100.0));
! 330: command = null;
! 331: } // to for loop
! 332:
! 333: }
! 334: } catch (Exception e)
! 335: {
! 336: System.out.println("Error while connecting to database " + e);
! 337: if (isGUI)
! 338: {
! 339: showExceptionDialog(dialog, command, e);
! 340: } else
! 341: {
! 342: e.printStackTrace();
! 343:
! 344: }
! 345: } finally
! 346: {
! 347: if (isGUI)
! 348: {
! 349: resetGUI(dialog);
! 350: }
! 351: }
! 352: }
! 353:
! 354: /**
! 355: * @param dialog
! 356: */
! 357: private static void resetGUI(FM2SQL.ProgressDialog dialog)
! 358: {
! 359: dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 360: FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 361: dialog.setVisible(false);
! 362: }
! 363:
! 364: /**
! 365: * @param dialog
! 366: * @param command
! 367: * @param e
! 368: */
! 369: private static void showExceptionDialog(FM2SQL.ProgressDialog dialog, StringBuffer command,
! 370: Exception e)
! 371: {
! 372: dialog.setVisible(false);
! 373: dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 374: FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 375: java.io.ByteArrayOutputStream b = new java.io.ByteArrayOutputStream();
! 376: java.io.PrintStream stream = new java.io.PrintStream(b);
! 377: stream.print(command + "\n\n");
! 378: e.printStackTrace(stream);
! 379: FM2SQL.showErrorDialog(b.toString(), "Error occured !");
! 380: }
! 381:
! 382: /**
! 383: * @return
! 384: */
! 385: private static FM2SQL.ProgressDialog initDialog()
! 386: {
! 387: FM2SQL.ProgressDialog dialog;
! 388: dialog = new FM2SQL.ProgressDialog(FM2SQL.fmInstance, bean);
! 389: dialog.setTitle("Conversion running ...");
! 390: dialog.title.setText("Getting table data ...");
! 391: dialog.setLocation(FM2SQL.fmInstance.getLocationOnScreen().x
! 392: + (FM2SQL.fmInstance.getWidth() - 400) / 2, FM2SQL.fmInstance.getLocationOnScreen().y
! 393: + (FM2SQL.fmInstance.getHeight() - 250) / 2);
! 394: dialog.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR));
! 395: FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR));
! 396: dialog.thread = Thread.currentThread();
! 397: dialog.setSize(420, 250);
! 398: return dialog;
! 399: }
! 400:
! 401: /**
! 402: * transfers the specified array of tables to the destination database and
! 403: * creates the table if it does not exist if it exists and mode is not append
! 404: * the table is dropped
! 405: *
! 406: * @param source
! 407: * @param destination
! 408: * @param names
! 409: * @param layouts
! 410: * @param selects
! 411: * @param creates
! 412: * @param ids
! 413: * @param mode
! 414: * @throws Exception
! 415: */
! 416:
! 417: public static void convert(String source, String destination, Vector names, Vector layouts,
! 418: Vector selects, Vector creates, Vector ids, int mode, String delimiter) throws Exception
! 419: {
! 420:
! 421: FM2SQL.ProgressDialog dialog = null;
! 422:
! 423: if (isGUI)
! 424: {
! 425: dialog = initDialog();
! 426: }
! 427:
! 428: System.out.println("connection established " + source + " " + bean.url);
! 429:
! 430: java.util.TreeSet myIds = new TreeSet();
! 431: int deltaID = 1;
! 432: String idField = "";
! 433: String destTableName = "";
! 434: String[] fieldNames = null;
! 435:
! 436: if (source != null && destination != null)
! 437: {
! 438: // setting user and passwd
! 439: bean.setUserAndPasswd(user, passwd);
! 440: // setting user and passwd
! 441: beanDest.setUserAndPasswd(userDest, passwdDest);
! 442: }
! 443:
! 444: StringBuffer command = null;
! 445: String query = null;
! 446: try
! 447: {
! 448:
! 449: if (source != null)
! 450: bean.setConnection(source);
! 451: else
! 452: bean.setConnection(bean.url);
! 453: if (names == null)
! 454: names = bean.getTableNames();
! 455: int tbIndex = 1;
! 456:
! 457: for (tbIndex = 0; tbIndex < names.size(); ++tbIndex)
! 458: {
! 459: Vector[] result = null;
! 460: try
! 461: {
! 462: String layout = (layouts.isEmpty()) ? "" : layouts.get(tbIndex).toString();
! 463: query = (selects != null) ? selects.get(tbIndex).toString() : "select * from "
! 464: + bean.getQC() + names.get(tbIndex).toString() + bean.getQC();
! 465: if (layout != "")
! 466: {
! 467: query = addLayoutToQuery(names, query, tbIndex, layout);
! 468:
! 469: }
! 470: if (dialog != null)
! 471: {
! 472: prepareDialogforUse(names, dialog, tbIndex);
! 473: }
! 474:
! 475: bean.getConnection();
! 476: bean.makeQuery(query, 50);
! 477: idField = ids.get(tbIndex).toString();
! 478:
! 479: } catch (Exception e)
! 480: {
! 481: System.out.println("Warning exception occured \n " + e);
! 482:
! 483: continue;
! 484: }
! 485: if (destination != null)
! 486: beanDest.setConnection(destination);
! 487: else
! 488: beanDest.setConnection(beanDest.url);
! 489: Statement stm = beanDest.getConnection().createStatement();
! 490:
! 491: Vector tables = beanDest.getTableNames();
! 492: // Collections.sort(tables);
! 493: System.out.println(names.get(tbIndex) + " "
! 494: + tables.indexOf(convertText((String) names.get(tbIndex)))); // "//beanDest.getTypeNames());
! 495: tables = beanDest.getTableNames();
! 496: // System.out.println(beanDest.getTableNames(beanDest.getCatalogs().get(2).toString()));
! 497: stm = beanDest.getConnection().createStatement();
! 498: // System.exit(0);
! 499:
! 500: // determine destTableName from createStatement or from source
! 501: // table name
! 502: ConversionProperties prop = getFieldNamesAndDestTableName(creates.get(tbIndex).toString(),
! 503: query, names.get(tbIndex).toString());
! 504: destTableName = prop.destTableName;
! 505: fieldNames = prop.fieldNames;
! 506: if (mode == Convert.DataBase.CONVERT_MODE)
! 507: {
! 508:
! 509: if (tables.indexOf(destTableName) >= 0)
! 510: {
! 511: stm.executeUpdate("drop table " + beanDest.getQC() + destTableName + beanDest.getQC());
! 512: tables.remove(destTableName);
! 513: System.out.println("dropped table" + destTableName);
! 514:
! 515: }
! 516: if ((tables.indexOf(destTableName) < 0))
! 517: {
! 518:
! 519: if (creates.get(tbIndex).equals("")
! 520: || creates.get(tbIndex).toString().toLowerCase().indexOf("create") < 0)
! 521: {
! 522: System.out
! 523: .println("Warning empty or invalid create statement - creating one for you\n");
! 524:
! 525: command = new StringBuffer(50);
! 526: command.append("CREATE TABLE ");
! 527: command.append(beanDest.getQC());
! 528: command.append(convertText((String) names.get(tbIndex)));
! 529: command.append(beanDest.getQC());
! 530: command.append("(");
! 531: String type = null;
! 532: Vector columnNames = bean.getColumnNames();
! 533: for (int i = 0; i < columnNames.size() - 1; ++i)
! 534: {
! 535: type = bean.metaData.getColumnTypeName(i + 1);
! 536: // System.out.println(i+" "+result[1].get(i)+"
! 537: // "+type);
! 538: type = (type.equals("NUMBER")) ? "INT4" : type;
! 539: type = (type.equals("CONTAINER")) ? "TEXT" : type;
! 540:
! 541: command.append(beanDest.getQC() + convertText((String) columnNames.get(i))
! 542: + beanDest.getQC() + " " + type + ", ");
! 543: }
! 544: type = bean.metaData.getColumnTypeName(columnNames.size());
! 545: type = (type.equals("NUMBER")) ? "INT4" : type;
! 546: type = (type.equals("CONTAINER")) ? "TEXT" : type;
! 547: command.append(beanDest.getQC()
! 548: + convertText((String) columnNames.get(columnNames.size() - 1))
! 549: + beanDest.getQC() + " " + type);
! 550: command.append(" )");
! 551:
! 552: } else
! 553: command = new StringBuffer().append(creates.get(tbIndex).toString().toLowerCase());
! 554: stm.executeUpdate(command.toString());
! 555:
! 556: }
! 557: }
! 558: if (dialog != null)
! 559: dialog.title.setText("Writing table data ...");
! 560:
! 561: // prepare the insert statement
! 562: int j = -1;
! 563: Vector row = null;
! 564: command = new StringBuffer();
! 565:
! 566: command.append("INSERT INTO ");
! 567: command.append(beanDest.getQC());
! 568: command.append(destTableName);
! 569: command.append(beanDest.getQC());
! 570: command.append(" (");
! 571: for (int i = 0; i < fieldNames.length; i++)
! 572: {
! 573: command.append(fieldNames[i]);
! 574: if (i < fieldNames.length - 1)
! 575: command.append(",");
! 576: }
! 577: command.append(") ");
! 578:
! 579: command.append(" values ( ");
! 580:
! 581: // add a question marks for every field
! 582: for (int i = 0; i < bean.getColumnNames().size() - 1; ++i)
! 583: command.append("?,");
! 584: command.append("?)");
! 585: PreparedStatement pstm = beanDest.getConnection().prepareStatement(command.toString());
! 586: System.out.println(command);
! 587: int rowCount = (idField != "") ? myIds.size() : bean.getRowCount(query);
! 588: Vector vec = new Vector(myIds);
! 589: int endIndex = -1;
! 590: String tempQuery = query;
! 591: String tempID = bean.getQC() + idField + bean.getQC();
! 592: // if id_field not do incremental conversion else do it all at
! 593: // once
! 594: if (!idField.equals(""))
! 595: {
! 596: long startTime = System.currentTimeMillis();
! 597: int counter = -1;
! 598: while (true)
! 599: {
! 600: ++counter;
! 601: if (counter == 0 && dialog != null)
! 602: dialog.title.setText("Check if data is available");
! 603: else if (dialog != null)
! 604: dialog.title.setText("Check if more data is available");
! 605: myIds = bean.getIDVector(ids.get(tbIndex).toString(), (String) names.get(tbIndex),
! 606: tempQuery, numHits);
! 607: if (myIds.isEmpty())
! 608: break;
! 609: vec = new Vector(myIds);
! 610: rowCount = vec.size();
! 611: System.out.println("ID LIST SIZE "
! 612: + Math.round((double) myIds.size() / (double) numIntervalls) + " " + myIds.size());
! 613: deltaID = (int) Math.round((double) myIds.size() / (double) numIntervalls);
! 614: if (vec.size() <= numIntervalls)
! 615: {
! 616: endIndex = 0;
! 617: deltaID = vec.size();
! 618: }
! 619: for (int k = 0; k < vec.size() - deltaID; k = k + deltaID)
! 620: {
! 621: System.out.println(vec.get(k) + " " + vec.get(k + deltaID) + " " + vec.lastElement());
! 622: if (query.indexOf("where") > 0)
! 623: tempQuery = query + " and " + tempID + ">='" + vec.get(k) + "' and " + tempID
! 624: + "<='" + vec.get(k + deltaID) + "'";
! 625: else
! 626: tempQuery = query + " where " + tempID + ">='" + vec.get(k) + "' and " + tempID
! 627: + "<='" + vec.get(k + deltaID) + "'";
! 628: System.out.println(tempQuery);
! 629: if (dialog != null)
! 630: dialog.title.setText("Reading table data ...");
! 631:
! 632: bean.makeQuery(tempQuery, deltaID);
! 633: if (dialog != null)
! 634: dialog.title.setText("Writing table data ...");
! 635:
! 636: command = writeDatainDestTable(dialog, command, k, pstm, rowCount, delimiter);
! 637: endIndex = k + deltaID;
! 638: }
! 639: System.out.println(endIndex);
! 640: // all data written ? if not write last chunk of data
! 641: if (endIndex == vec.size() - 1)
! 642: System.out.println("fits");
! 643: else
! 644: {
! 645: System.out.println(" last intervall from " + vec.get(endIndex) + " "
! 646: + vec.lastElement());
! 647:
! 648: if (query.indexOf("where") > 0)
! 649: tempQuery = query + " and " + tempID + ">='" + vec.get(endIndex) + "' and "
! 650: + tempID + "<='" + vec.lastElement() + "'";
! 651: else
! 652: tempQuery = query + " where " + tempID + ">='" + vec.get(endIndex) + "' and "
! 653: + tempID + "<='" + vec.lastElement() + "'";
! 654: System.out.println(tempQuery);
! 655: if (dialog != null)
! 656: dialog.title.setText("Reading table data ...");
! 657: bean.makeQuery(tempQuery, 0);
! 658: if (dialog != null)
! 659: dialog.title.setText("Writing table data ...");
! 660: command = writeDatainDestTable(dialog, command, endIndex, pstm, rowCount, delimiter);
! 661: }
! 662: // prepare new query for next chunk
! 663: if (query.indexOf("where") > 0)
! 664: tempQuery = query + " and " + tempID + ">'" + vec.lastElement() + "'";
! 665: else
! 666: tempQuery = query + " where " + tempID + ">'" + vec.lastElement() + "'";
! 667:
! 668: }
! 669: long endTime = System.currentTimeMillis();
! 670: System.out.println("Time for incremental convert elapsed " + (endTime - startTime));
! 671: } else
! 672: {
! 673: // read and write all in one big chunk
! 674: long startTime = System.currentTimeMillis();
! 675:
! 676: bean.makeQuery(query, 0);
! 677: command = writeDatainDestTable(dialog, command, j, pstm, rowCount, delimiter);
! 678: long endTime = System.currentTimeMillis();
! 679: System.out.println("Time for old convert elapsed " + (endTime - startTime));
! 680:
! 681: }
! 682: if (isGUI)
! 683: resetGUI(dialog);
! 684: }
! 685: } catch (Exception e)
! 686: {
! 687: System.out.println("Error while connecting to database " + e);
! 688: if (isGUI)
! 689: {
! 690: showExceptionDialog(dialog, command, e);
! 691: resetGUI(dialog);
! 692: } else
! 693: {
! 694: e.printStackTrace();
! 695:
! 696: }
! 697: }
! 698:
! 699: }
! 700:
! 701: /**
! 702: * @param names
! 703: * @param dialog
! 704: * @param tbIndex
! 705: */
! 706: private static void prepareDialogforUse(Vector names, FM2SQL.ProgressDialog dialog, int tbIndex)
! 707: {
! 708: dialog.title.setText("Reading table data ...");
! 709: dialog.table.setText(names.get(tbIndex).toString());
! 710: dialog.status.setText("Table " + (tbIndex + 1) + " of " + names.size());
! 711: dialog.setVisible(true);
! 712: }
! 713:
! 714: /**
! 715: * @param names
! 716: * @param query
! 717: * @param tbIndex
! 718: * @param layout
! 719: * @return
! 720: */
! 721: private static String addLayoutToQuery(Vector names, String query, int tbIndex, String layout)
! 722: {
! 723: layout = " layout " + bean.getQC() + layout + bean.getQC();
! 724: String name = names.get(tbIndex).toString();
! 725: StringBuffer queryLayout = new StringBuffer(query);
! 726: queryLayout.insert(queryLayout.indexOf(name) + name.length() + 1, " " + layout);
! 727: query = queryLayout.toString();
! 728: System.out.println("added layout " + query);
! 729: return query;
! 730: }
! 731:
! 732: /**
! 733: * Writes data to the destination table
! 734: *
! 735: * @param dialog
! 736: * progress dialog
! 737: * @param command
! 738: * @param j
! 739: * data index for progress bar
! 740: * @param pstm
! 741: * prepared statement
! 742: * @param rowCount
! 743: * number of datasets
! 744: * @return command
! 745: * @throws Exception
! 746: * @throws SQLException
! 747: */
! 748: private static StringBuffer writeDatainDestTable(FM2SQL.ProgressDialog dialog,
! 749: StringBuffer command, int j, PreparedStatement pstm, int rowCount, String delimiter)
! 750: throws Exception, SQLException
! 751: {
! 752: Vector row;
! 753: while ((row = bean.getNextRow()) != null)
! 754: {
! 755: j++;
! 756: Object obj = null;
! 757: for (int k = 0; k < row.size(); ++k)
! 758: {
! 759: obj = row.get(k);
! 760:
! 761: if (obj instanceof ArrayList)
! 762: obj = formatFileMakerArray((List) obj, delimiter);
! 763:
! 764: String str = (obj == null) ? "NULL" : obj.toString();
! 765: if (obj instanceof Double)
! 766: {
! 767: pstm.setDouble(k + 1, ((Double) obj).doubleValue());
! 768: } else if (!str.equals("NULL"))
! 769: pstm.setString(k + 1, str);
! 770: else
! 771: pstm.setNull(k + 1, Types.NULL);
! 772: }
! 773: pstm.execute();
! 774: if (isGUI)
! 775: dialog.progress.setValue((int) (((double) (j + 1) / (double) rowCount) * 100.0));
! 776: command = null;
! 777: } // to while loop
! 778: return command;
! 779: }
! 780:
! 781: /**
! 782: * removes special characters from the input string as well as .fp5
! 783: *
! 784: * @param newName
! 785: * String to change
! 786: * @return
! 787: */
! 788: public static String convertText(String newName)
! 789: {
! 790: StringBuffer alterMe = new StringBuffer(newName.trim().toLowerCase());
! 791: int length = alterMe.length();
! 792: int j = 0;
! 793: int index = alterMe.indexOf(".fp5");
! 794: if (index >= 0)
! 795: {
! 796: alterMe.delete(index, index + 4);
! 797: length = length - 4;
! 798: }
! 799:
! 800: while (j < length)
! 801: {
! 802: if (alterMe.charAt(j) == ' ')
! 803: {
! 804: alterMe.setCharAt(j, '_');
! 805: // if(j<length-1) j=j+1;
! 806: } else if (alterMe.charAt(j) == '_')
! 807: {
! 808:
! 809: if (alterMe.charAt(j + 1) == '_')
! 810: alterMe.deleteCharAt(j);
! 811: length = length - 1;
! 812: // if(j<length-1) j=j+1;
! 813: } else if (alterMe.charAt(j) == 'ä')
! 814: {
! 815: alterMe.setCharAt(j, 'a');
! 816: alterMe.insert(j + 1, "e");
! 817: length = length + 1;
! 818: if (j < length - 1)
! 819: j = j + 1;
! 820: } else if (alterMe.charAt(j) == 'ö')
! 821: {
! 822: alterMe.setCharAt(j, 'o');
! 823: alterMe.insert(j + 1, "e");
! 824: length = length + 1;
! 825: if (j < length - 1)
! 826: j = j + 1;
! 827: } else if (alterMe.charAt(j) == 'ü')
! 828: {
! 829: alterMe.setCharAt(j, 'u');
! 830: alterMe.insert(j + 1, "e");
! 831: length = length + 1;
! 832: if (j < length - 1)
! 833: j = j + 1;
! 834: } else if (alterMe.charAt(j) == 'ß')
! 835: {
! 836: alterMe.setCharAt(j, 's');
! 837: alterMe.insert(j + 1, "s");
! 838: length = length + 1;
! 839: if (j < length - 1)
! 840: j = j + 1;
! 841: } else if (alterMe.charAt(j) == ':')
! 842: {
! 843: if (j < length - 1)
! 844: {
! 845: if (alterMe.charAt(j + 1) == ':')
! 846: {
! 847: alterMe.setCharAt(j, '_');
! 848: alterMe.delete(j + 1, j + 2);
! 849: length = length - 1;
! 850:
! 851: }
! 852:
! 853: if (j < length - 1)
! 854: j = j + 1;
! 855: }
! 856: } else if (alterMe.charAt(j) == '-')
! 857: {
! 858: alterMe.setCharAt(j, '_');
! 859:
! 860: } else if (alterMe.charAt(j) == '?')
! 861: {
! 862: // changed ? to _ because of update statement
! 863: alterMe.setCharAt(j, '_');
! 864: // length = length + 1;
! 865: // j=j+1;
! 866: System.out.println(alterMe);
! 867: } else if (alterMe.charAt(j) == '.')
! 868: {
! 869: if (j == length - 1)
! 870: {
! 871: alterMe.delete(j, j);
! 872: length--;
! 873: } else
! 874: alterMe.setCharAt(j, '_');
! 875: }
! 876:
! 877: ++j;
! 878: }
! 879: return alterMe.toString();
! 880: }
! 881:
! 882: /**
! 883: * Converts > and < in an entity (> or <)
! 884: *
! 885: * @param newName
! 886: * @return
! 887: */
! 888: public static String convertToEntities(String newName)
! 889: {
! 890: StringBuffer alterMe = new StringBuffer(newName.trim());
! 891: int length = alterMe.length();
! 892: int j = 0;
! 893:
! 894: while (j < length)
! 895: {
! 896:
! 897: if (alterMe.charAt(j) == '>')
! 898: {
! 899: alterMe.setCharAt(j, '&');
! 900: alterMe.insert(j + 1, "gt;");
! 901: length = length + 2;
! 902: if (j < length - 1)
! 903: j = j + 1;
! 904:
! 905: } else if (alterMe.charAt(j) == '<')
! 906: {
! 907: alterMe.setCharAt(j, '&');
! 908: alterMe.insert(j + 1, "lt;");
! 909: length = length + 2;
! 910: if (j < length - 1)
! 911: j = j + 1;
! 912:
! 913: }
! 914: ++j;
! 915: }
! 916: return alterMe.toString();
! 917: }
! 918:
! 919: /**
! 920: * Masks the single quote character '-->\'
! 921: *
! 922: * @param newName
! 923: * @return
! 924: */
! 925: public static String convertUml(String newName)
! 926: {
! 927: StringBuffer alterMe = new StringBuffer(newName.trim());
! 928: int length = alterMe.length();
! 929: int j = 0;
! 930:
! 931: while (j < length)
! 932: {
! 933:
! 934: if (alterMe.charAt(j) == '\'')
! 935: {
! 936: alterMe.setCharAt(j, '\\');
! 937: alterMe.insert(j + 1, "'");
! 938: length = length + 1;
! 939: if (j < length - 1)
! 940: j = j + 1;
! 941: }
! 942: /*
! 943: * else if (alterMe.charAt(j) == '"') { alterMe.setCharAt(j, '\\');
! 944: * alterMe.insert(j + 1, "\""); length = length + 1; if(j <length-1)
! 945: * j=j+1; } else if (alterMe.charAt(j) == '>') { alterMe.setCharAt(j,
! 946: * '\\'); alterMe.insert(j + 1, ">"); length = length + 1; if(j <length-1)
! 947: * j=j+1; } else if (alterMe.charAt(j) == ' <') { alterMe.setCharAt(j,
! 948: * '\\'); alterMe.insert(j + 1, " <"); length = length + 1; if(j
! 949: * <length-1) j=j+1; } else if (alterMe.charAt(j) == '?') {
! 950: * alterMe.setCharAt(j, '\\'); alterMe.insert(j + 1, "?"); length = length +
! 951: * 1; if(j <length-1) j=j+1; } else if (alterMe.charAt(j) == '&') {
! 952: * alterMe.setCharAt(j, '\\'); alterMe.insert(j + 1, "&"); length = length +
! 953: * 1; if(j <length-1) j=j+1; } else if (alterMe.charAt(j) == '=') {
! 954: * alterMe.setCharAt(j, '\\'); alterMe.insert(j + 1, "="); length = length +
! 955: * 1; if(j <length-1) j=j+1; } else if (alterMe.charAt(j) == ',') {
! 956: * alterMe.setCharAt(j, '\\'); alterMe.insert(j + 1, ","); length = length +
! 957: * 1; if(j <length-1) j=j+1; } else if (alterMe.charAt(j) == '.') {
! 958: * alterMe.setCharAt(j, '\\'); alterMe.insert(j + 1, "."); length = length +
! 959: * 1; if(j <length-1) j=j+1; } else if (alterMe.charAt(j) == '[') {
! 960: * alterMe.setCharAt(j, '\\'); alterMe.insert(j + 1, "."); length = length +
! 961: * 1; if(j <length-1) j=j+1; } else if (alterMe.charAt(j) == ']') {
! 962: * alterMe.setCharAt(j, '\\'); alterMe.insert(j + 1, "."); length = length +
! 963: * 1; if(j <length-1) j=j+1; } else if (alterMe.charAt(j) == '%') {
! 964: * alterMe.setCharAt(j, '\\'); alterMe.insert(j + 1, "%"); length = length +
! 965: * 1; if(j <length-1) j=j+1; }
! 966: */
! 967: ++j;
! 968: }
! 969: return alterMe.toString();
! 970: }
! 971:
! 972: /**
! 973: * parses the input xml file for batch conversion called from readXMLFile *
! 974: *
! 975: * @param sb
! 976: */
! 977: public static void parseXMLConfig(StringBuffer sb)
! 978: {
! 979: // boolean finished = false;
! 980: Vector databases = new Vector();
! 981: try
! 982: {
! 983: databases = getXMLConfig(sb);
! 984:
! 985: DBBean database = ((DataBase) databases.lastElement()).bean;
! 986: databases.remove(databases.size() - 1);
! 987: // databases.add(database);
! 988: for (Iterator iter = databases.iterator(); iter.hasNext();)
! 989: {
! 990: DataBase db = (DataBase) iter.next();
! 991: for (Iterator iterator = db.preCommands.iterator(); iterator.hasNext();)
! 992: {
! 993: SQLCommand sqlCommand = (SQLCommand) iterator.next();
! 994: sqlCommand.executeCommand();
! 995: }
! 996: int mode = db.mode;
! 997: if (mode == DataBase.CONVERT_MODE || mode == DataBase.APPEND_MODE)
! 998: convertBatch(db.bean, database, db.tables, db.layouts, db.selects, db.creates, db.ids,
! 999: mode, db.delimiter);
! 1000: else if (mode == DataBase.UPDATE_MODE)
! 1001: {
! 1002:
! 1003: Convert.user = db.bean.user;
! 1004: Convert.passwd = db.bean.passwd;
! 1005: userDest = database.user;
! 1006: passwdDest = database.passwd;
! 1007:
! 1008: update(db.bean.url, database.url, db.tables, db.layouts, db.selects, db.creates, db.ids,
! 1009: mode);
! 1010: } else if (mode == DataBase.SYNCHRONIZE_MODE)
! 1011: {
! 1012: Convert.user = db.bean.user;
! 1013: Convert.passwd = db.bean.passwd;
! 1014: userDest = database.user;
! 1015: passwdDest = database.passwd;
! 1016:
! 1017: synchronize(db.bean.url, database.url, db.tables, db.layouts, db.selects, db.creates,
! 1018: db.ids, mode, db.delimiter, new Vector(db.htIndex.values()));
! 1019: }
! 1020: for (Iterator iterator = db.postCommands.iterator(); iterator.hasNext();)
! 1021: {
! 1022: SQLCommand sqlCommand = (SQLCommand) iterator.next();
! 1023: sqlCommand.executeCommand();
! 1024: }
! 1025:
! 1026: }
! 1027:
! 1028: } catch (Exception e)
! 1029: {
! 1030:
! 1031: e.printStackTrace();
! 1032:
! 1033: } finally
! 1034: {
! 1035: bean.closeAllConnections();
! 1036: beanDest.closeAllConnections();
! 1037: }
! 1038: }
! 1039:
! 1040: public static Vector getXMLConfig(StringBuffer sb)
! 1041: {
! 1042:
! 1043: boolean finished = false;
! 1044: // parse string and build document tree
! 1045: Xparse parser = new Xparse();
! 1046: parser.changeEntities = true;
! 1047: Node root = parser.parse(sb.toString());
! 1048: // printContents(root);
! 1049: Vector databases = new Vector();
! 1050: Vector tables = new Vector();
! 1051: Vector layouts = new Vector();
! 1052: Vector selects = new Vector();
! 1053: Vector creates = new Vector();
! 1054: Vector ids = new Vector();
! 1055: Vector preSQLCommands = new Vector();
! 1056: Vector postSQLCommands = new Vector();
! 1057:
! 1058: String delimiter = "|";
! 1059: int mode = -1;
! 1060: try
! 1061: {
! 1062: Node tempNode = root.find("convert/source", new int[]
! 1063: { 1, 1 });
! 1064: if (tempNode == null)
! 1065: throw new Error("parse error source tag missing");
! 1066: System.out.println(tempNode.name);
! 1067: int length = countNodes(tempNode);
! 1068: for (int i = 1; i <= length; i++)
! 1069: {
! 1070:
! 1071: DBBean database = new DBBean();
! 1072: tables = new Vector();
! 1073: layouts = new Vector();
! 1074: selects = new Vector();
! 1075: creates = new Vector();
! 1076: ids = new Vector();
! 1077: preSQLCommands = new Vector();
! 1078: postSQLCommands = new Vector();
! 1079:
! 1080: // parse dataBase
! 1081: Node node = root.find("convert/source/database/url", new int[]
! 1082: { 1, 1, i, 1 });
! 1083: Node node1 = root.find("convert/source/database/user", new int[]
! 1084: { 1, 1, i, 1, 1 });
! 1085: Node node2 = root.find("convert/source/database/password", new int[]
! 1086: { 1, 1, i, 1, 1 });
! 1087: Node node3 = root.find("convert/source/database", new int[]
! 1088: { 1, 1, i });
! 1089: Node nodeMode = root.find("convert/source/database/mode", new int[]
! 1090: { 1, 1, i, 1, 1 });
! 1091: Node delimiterNode = root.find("convert/source/database/delimiter", new int[]
! 1092: { 1, 1, i, 1, 1 });
! 1093:
! 1094: Node commandNodes = root.find("convert/source/database/sqlcommands", new int[]
! 1095: { 1, 1, i, 1, 1 });
! 1096: if (commandNodes != null)
! 1097: {
! 1098: parseCommandNode(commandNodes, database, preSQLCommands, postSQLCommands);
! 1099: }
! 1100: Node useNormanToUnicodeMapper = root.find(
! 1101: "convert/source/database/usenormantounicodemapper", new int[]
! 1102: { 1, 1, i, 1, 1 });
! 1103:
! 1104: if (delimiterNode != null)
! 1105: delimiter = delimiterNode.getCharacters();
! 1106: if (useNormanToUnicodeMapper != null)
! 1107: {
! 1108: database.setUseNormanToUnicodeMapper(Boolean.valueOf(
! 1109: useNormanToUnicodeMapper.getCharacters()).booleanValue());
! 1110: System.out.println("useMapper "
! 1111: + Boolean.valueOf(useNormanToUnicodeMapper.getCharacters().trim()).booleanValue());
! 1112: }
! 1113:
! 1114: if (node3 == null)
! 1115: throw new Error("parse error database tag missing");
! 1116: if (node == null)
! 1117: throw new Error("parse error url tag missing");
! 1118: if (node1 == null)
! 1119: throw new Error("parse error user tag missing");
! 1120: if (node2 == null)
! 1121: throw new Error("parse error password tag missing");
! 1122: String url = node.getCharacters();
! 1123: String user = node1.getCharacters();
! 1124: String password = node2.getCharacters();
! 1125: database.setURL(url.trim());
! 1126: database.setUserAndPasswd(user.trim(), password.trim());
! 1127: System.out.println(node.name + " " + node.getCharacters());
! 1128: System.out.println(node1.name + " " + node1.getCharacters());
! 1129: System.out.println(node2.name + " " + node2.getCharacters());
! 1130: String modeString = "";
! 1131: if (nodeMode == null)
! 1132: modeString = "convert";
! 1133: else
! 1134: modeString = nodeMode.getCharacters();
! 1135: if (modeString.equals("convert"))
! 1136: mode = DataBase.CONVERT_MODE;
! 1137: else if (modeString.equals("append"))
! 1138: mode = DataBase.APPEND_MODE;
! 1139: else if (modeString.equals("update"))
! 1140: mode = DataBase.UPDATE_MODE;
! 1141: else if (modeString.equals("delete"))
! 1142: mode = DataBase.DELETE_MODE;
! 1143:
! 1144: else if (modeString.equals("synchronize"))
! 1145: mode = DataBase.SYNCHRONIZE_MODE;
! 1146: // if(node3!=null)
! 1147: // System.out.println(node3.name);
! 1148:
! 1149: int length2 = countNodes(node3);
! 1150:
! 1151: System.out.println("number of tables " + length2);
! 1152:
! 1153: for (int j = 1; j <= length2; ++j)
! 1154: {
! 1155: Node node4 = root.find("convert/source/database/table", new int[]
! 1156: { 1, 1, i, j });
! 1157: Node node5 = root.find("convert/source/database/table/select", new int[]
! 1158: { 1, 1, i, j, 1 });
! 1159: Node node6 = root.find("convert/source/database/table/create", new int[]
! 1160: { 1, 1, i, j, 1 });
! 1161:
! 1162: if (node4 != null)
! 1163: System.out.println(node4.name + " " + node4.attributes.get("layout").equals(""));
! 1164: if (node5 != null)
! 1165: System.out.println(node5.name + " " + node5.getCharacters());
! 1166: if (node6 != null)
! 1167: System.out.println(node6.name + " " + node6.getCharacters());
! 1168: if (node4 == null)
! 1169: throw new Error("parse error table tag missing");
! 1170: // if(node5==null) throw new Error("parse error select tag
! 1171: // missing");
! 1172: // if(node6==null) throw new Error("parse error create tag
! 1173: // missing");
! 1174: String name = (String) node4.attributes.get("name");
! 1175: String layout = (String) node4.attributes.get("layout");
! 1176: String id = (String) node4.attributes.get("id");
! 1177: System.out.println("id was " + id);
! 1178:
! 1179: if (name == null)
! 1180: throw new Error("parse error required table tag attribute name missing");
! 1181: if (layout == null)
! 1182: layout = "";
! 1183: if (id == null)
! 1184: id = "";
! 1185: if (name.equals(""))
! 1186: throw new Error("parse error table tag attribute must not be empty");
! 1187: tables.add(name);
! 1188: layouts.add(layout);
! 1189: ids.add(id);
! 1190: String query = (node5 == null) ? "" : node5.getCharacters();
! 1191: if (query.equals(""))
! 1192: System.err.println("Warning empty select tag or select tag missing !!");
! 1193: query = (query.equals("")) ? "select * from " + database.getQC() + name
! 1194: + database.getQC() : query;
! 1195: selects.add(query);
! 1196: if (node6 != null)
! 1197: creates.add(node6.getCharacters().trim());
! 1198: else
! 1199: creates.add("");
! 1200:
! 1201: }
! 1202: DataBase dataBase = new DataBase(database, tables, layouts, selects, creates, ids, mode);
! 1203: dataBase.delimiter = delimiter;
! 1204: dataBase.preCommands = new Vector(preSQLCommands);
! 1205: dataBase.postCommands = new Vector(postSQLCommands);
! 1206: databases.add(dataBase);
! 1207: }
! 1208: DBBean database = new DBBean();
! 1209:
! 1210: preSQLCommands.clear();
! 1211: postSQLCommands.clear();
! 1212:
! 1213: // parse dataBase
! 1214: Node node = root.find("convert/destination/database/url", new int[]
! 1215: { 1, 1, 1, 1 });
! 1216: Node node1 = root.find("convert/destination/database/user", new int[]
! 1217: { 1, 1, 1, 1, 1 });
! 1218: Node node2 = root.find("convert/destination/database/password", new int[]
! 1219: { 1, 1, 1, 1, 1 });
! 1220: Node commandNodes = root.find("convert/destination/database/sqlcommands", new int[]
! 1221: { 1, 1, 1, 1, 1 });
! 1222: if (commandNodes != null)
! 1223: {
! 1224: parseCommandNode(commandNodes, database, preSQLCommands, postSQLCommands);
! 1225: }
! 1226:
! 1227: String url = node.getCharacters();
! 1228: String user = node1.getCharacters();
! 1229: String password = node2.getCharacters();
! 1230: System.out.println(url);
! 1231: database.setURL(url.trim());
! 1232: database.setUserAndPasswd(user.trim(), password.trim());
! 1233: DataBase db = new DataBase(database, new Vector(), null, null, null, null, 0);
! 1234: databases.add(db);
! 1235: db.preCommands = new Vector(preSQLCommands);
! 1236: db.postCommands = new Vector(postSQLCommands);
! 1237:
! 1238: } catch (Exception e)
! 1239: {
! 1240: e.printStackTrace();
! 1241: }
! 1242: return databases;
! 1243: }
! 1244:
! 1245: /**
! 1246: *
! 1247: * @param commandNode
! 1248: * @param database
! 1249: * @param preSQLCommands
! 1250: * @param postSQLCommand
! 1251: */
! 1252: private static void parseCommandNode(Node commandNode, DBBean database,
! 1253: java.util.Vector preSQLCommands, java.util.Vector postSQLCommands)
! 1254: {
! 1255: // System.out.println(commandNode.name + " " + countNodes(commandNode));
! 1256: int numCommands = commandNode.contents.length();
! 1257: for (int j = 0; j < numCommands; ++j)
! 1258: {
! 1259: Node node = (Node) commandNode.contents.v.elementAt(j);
! 1260: if (node.type.equals("element"))
! 1261: {
! 1262: // System.out.println(node.name + " " + node.getCharacters() + database);
! 1263: String execute = node.attributes.get("execute").toString();
! 1264: if (execute.equals("before"))
! 1265: {
! 1266: preSQLCommands.add(new SQLCommand(database, node.getCharacters()));
! 1267: }
! 1268: if (execute.equals("after"))
! 1269: {
! 1270: postSQLCommands.add(new SQLCommand(database, node.getCharacters()));
! 1271: }
! 1272:
! 1273: }
! 1274:
! 1275: }
! 1276: }
! 1277:
! 1278: private static int countNodes(Node tempNode)
! 1279: {
! 1280: int length = 0;
! 1281: for (int i = 0; i < tempNode.contents.v.size(); ++i)
! 1282: {
! 1283: Node node = (Node) tempNode.contents.v.elementAt(i);
! 1284: if (node.type.equals("element"))
! 1285: {
! 1286: if (node.name.equals("database"))
! 1287: length++;
! 1288: if (node.name.equals("table"))
! 1289: length++;
! 1290: if (node.name.equals("sqlcommand"))
! 1291: length++;
! 1292:
! 1293: }
! 1294:
! 1295: // System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+"
! 1296: // "+i);
! 1297: }
! 1298: return length;
! 1299: }
! 1300:
! 1301: private static void printContents(Node root)
! 1302: {
! 1303:
! 1304: Vector contents = (root.index == null) ? root.contents.v : root.index.v;
! 1305: for (int i = 0; i < contents.size(); ++i)
! 1306: {
! 1307: Node n = (Node) contents.elementAt(i);
! 1308: if (n.type.equals("element"))
! 1309: {
! 1310: System.out.println("tag " + n.name);
! 1311: System.out.println(n.getCharacters());
! 1312: // contents=n.contents.v i=0;
! 1313: }
! 1314: // System.out.println(n.type);
! 1315: }
! 1316: }
! 1317:
! 1318: /**
! 1319: * reads the specified xml file
! 1320: *
! 1321: * @param xmlFile
! 1322: */
! 1323: public static StringBuffer readXMLFile(String xmlFile)
! 1324: {
! 1325: InputStream stream = null;
! 1326: StringBuffer sb = new StringBuffer();
! 1327:
! 1328: try
! 1329: {
! 1330:
! 1331: if (xmlFile.indexOf("file://") >= 0 || xmlFile.indexOf("http://") >= 0)
! 1332: {
! 1333: URL url = new URL(xmlFile);
! 1334: stream = url.openStream();
! 1335: } else
! 1336: // read XML Metadata from a file
! 1337: stream = new FileInputStream(xmlFile);
! 1338: InputStreamReader isr = new InputStreamReader(stream, "UTF-8");
! 1339: BufferedReader buffr = new BufferedReader(isr);
! 1340: int c = 0;
! 1341: while ((c = buffr.read()) != -1)
! 1342: {
! 1343: char ch = (char) c;
! 1344: sb.append(ch);
! 1345: // System.out.print((char)c);
! 1346: }
! 1347: } catch (Exception e)
! 1348: {
! 1349: e.printStackTrace();
! 1350: } finally
! 1351: {
! 1352:
! 1353: try
! 1354: {
! 1355: stream.close();
! 1356: } catch (IOException e1)
! 1357: {
! 1358: // TODO Auto-generated catch block
! 1359: e1.printStackTrace();
! 1360: }
! 1361: }
! 1362: return sb;
! 1363: }
! 1364:
! 1365: /**
! 1366: * Helper class for Conversion etc. Contains data needed for the conversion
! 1367: *
! 1368: * @author rogo
! 1369: *
! 1370: */
! 1371:
! 1372: public static class ConversionProperties
! 1373: {
! 1374: String destTableName;
! 1375:
! 1376: String[] fieldNames;
! 1377:
! 1378: public ConversionProperties()
! 1379: {
! 1380: }
! 1381:
! 1382: public ConversionProperties(String destTableName, String[] fieldNames)
! 1383: {
! 1384: this.destTableName = destTableName;
! 1385: this.fieldNames = fieldNames;
! 1386:
! 1387: }
! 1388:
! 1389: }
! 1390:
! 1391: /**
! 1392: * Helper class for XML-File parsing Holds the parsed data
! 1393: *
! 1394: * @author rogo
! 1395: *
! 1396: */
! 1397: public static class DataBase
! 1398: {
! 1399: DBBean bean;
! 1400:
! 1401: Vector creates;
! 1402:
! 1403: Vector selects;
! 1404:
! 1405: Vector layouts;
! 1406:
! 1407: Vector tables=new Vector();
! 1408:
! 1409: Vector ids;
! 1410:
! 1411: String delimiter = "//";
! 1412:
! 1413: Vector preCommands;
! 1414: Vector postCommands;
! 1415:
! 1416: /**
! 1417: * maps table name to index fields
! 1418: */
! 1419: Hashtable htIndex = new Hashtable();
! 1420:
! 1421: boolean useNormanToUnicodeMapper = false;
! 1422:
! 1423: final static int CONVERT_MODE = 1;
! 1424:
! 1425: final static int APPEND_MODE = 2;
! 1426:
! 1427: final static int UPDATE_MODE = 3;
! 1428:
! 1429: final static int DELETE_MODE = 4;
! 1430:
! 1431: final static int SYNCHRONIZE_MODE = 5;
! 1432:
! 1433: int mode = -1;
! 1434:
! 1435: public DataBase(DBBean bean, Vector tables, Vector layouts, Vector selects, Vector creates,
! 1436: Vector ids, int mode)
! 1437: {
! 1438: this.bean = bean;
! 1439: this.tables = tables;
! 1440: this.layouts = layouts;
! 1441: this.selects = selects;
! 1442: this.creates = creates;
! 1443: this.ids = ids;
! 1444: this.mode = mode;
! 1445: this.bean.setIDVector(ids);
! 1446: }
! 1447:
! 1448: /**
! 1449: * @param indexListVec
! 1450: */
! 1451: public void buildIndexTable(Vector indexListVec)
! 1452: {
! 1453: for (int i = 0; i < tables.size(); i++)
! 1454: {
! 1455: fillIndexList((String) tables.get(i), (String) indexListVec.get(i));
! 1456: }
! 1457: }
! 1458:
! 1459: /**
! 1460: * writes the data contained in this object to the buffered writer *
! 1461: *
! 1462: * @param buffr
! 1463: * @throws Exception
! 1464: */
! 1465: public void exportToXML(BufferedWriter buffr) throws Exception
! 1466: {
! 1467: // ids=bean.getIDVector();
! 1468: buffr.write(" <database>\n");
! 1469: buffr.write(" <url>" + bean.url + "</url>\n");
! 1470: buffr.write(" <user>" + bean.user + "</user>\n");
! 1471: buffr.write(" <password>" + bean.passwd + "</password>\n");
! 1472: buffr.write(" <delimiter>" + delimiter + "</delimiter>\n");
! 1473: String modeString = "";
! 1474: if (mode == CONVERT_MODE)
! 1475: modeString = "convert";
! 1476: else if (mode == APPEND_MODE)
! 1477: modeString = "append";
! 1478: else if (mode == UPDATE_MODE)
! 1479: modeString = "update";
! 1480: else if (mode == DELETE_MODE)
! 1481: modeString = "delete";
! 1482: else if (mode == SYNCHRONIZE_MODE)
! 1483: modeString = "synchronize";
! 1484:
! 1485: buffr.write(" <mode>" + modeString + "</mode>\n");
! 1486: buffr.write(" <usenormantounicodemapper>" + useNormanToUnicodeMapper
! 1487: + "</usenormantounicodemapper>\n");
! 1488: if (preCommands != null || postCommands != null)
! 1489: {
! 1490: int count = 0;
! 1491:
! 1492: buffr.write(" <sqlcommands> \n");
! 1493:
! 1494: if (preCommands != null)
! 1495: {
! 1496: while (count < preCommands.size())
! 1497: {
! 1498: SQLCommand sqlcommand=(SQLCommand)preCommands.get(count);
! 1499: buffr.write(" <sqlcommand execute=\"before\">" + sqlcommand.command + "</sqlcommand>\n");
! 1500: count++;
! 1501: }
! 1502: }
! 1503: if (postCommands != null)
! 1504: {
! 1505: count = 0;
! 1506: while (count < postCommands.size())
! 1507: {
! 1508: SQLCommand sqlcommand=(SQLCommand)postCommands.get(count);
! 1509:
! 1510: buffr.write(" <sqlcommand execute=\"after\">" + sqlcommand.command + "</sqlcommand>\n");
! 1511: count++;
! 1512: }
! 1513: }
! 1514: buffr.write(" </sqlcommands> \n");
! 1515:
! 1516: }
! 1517: int index = 0;
! 1518: while (index < tables.size())
! 1519: {
! 1520: String table = (String) tables.get(index);
! 1521: String layout = (String) layouts.get(index);
! 1522: String select = (String) selects.get(index);
! 1523: String create = (String) creates.get(index);
! 1524: String id = (String) ids.get(index);
! 1525: IndexList indexList = (IndexList) htIndex.get(table);
! 1526: if (indexList == null)
! 1527: indexList = new IndexList();
! 1528: buffr.write(" <table name = \"" + table + "\" layout = \"" + layout + "\" id = \""
! 1529: + id + "\" indexList =\"" + indexList + "\">\n");
! 1530: buffr.write(" <select>" + convertToEntities(select) + "</select>\n");
! 1531: if (!create.equals(""))
! 1532: buffr.write(" <create>" + create + " </create>\n");
! 1533: buffr.write(" </table>\n");
! 1534: index++;
! 1535: }
! 1536: buffr.write(" </database>\n");
! 1537: }
! 1538:
! 1539: public void fillIndexList(String table, String list)
! 1540: {
! 1541: IndexList indexList = new IndexList();
! 1542: StringTokenizer tokenizer = new StringTokenizer(list, ",");
! 1543: while (tokenizer.hasMoreTokens())
! 1544: {
! 1545: indexList.add(tokenizer.nextToken());
! 1546: }
! 1547: System.out.println(indexList);
! 1548:
! 1549: htIndex.put(table, indexList);
! 1550: }
! 1551:
! 1552: public String toString()
! 1553: {
! 1554: return bean.url + " " + tables;
! 1555: }
! 1556:
! 1557: }
! 1558:
! 1559: public static void writeConfig(String file, DataBase source, DataBase destination)
! 1560: throws Exception
! 1561: {
! 1562: if (!file.toLowerCase().endsWith(".xml"))
! 1563: file += ".xml";
! 1564: File f = new File(file);
! 1565:
! 1566: FileOutputStream fout = new FileOutputStream(f);
! 1567: OutputStreamWriter outsw = new OutputStreamWriter(fout, "UTF-8");
! 1568: BufferedWriter buffw = new BufferedWriter(outsw);
! 1569: buffw.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
! 1570: buffw.newLine();
! 1571: buffw.write("<convert>\n");
! 1572: buffw.write(" <source>\n");
! 1573: source.exportToXML(buffw);
! 1574: buffw.write(" </source>\n");
! 1575: buffw.write("\n <destination>\n");
! 1576: destination.exportToXML(buffw);
! 1577: buffw.write(" </destination>\n");
! 1578: buffw.write("</convert>\n");
! 1579: buffw.close();
! 1580: }
! 1581:
! 1582: public static void delete(String source, String destination, Vector names, Vector layouts,
! 1583: Vector selects, Vector creates, Vector ids, int mode) throws Exception
! 1584: {
! 1585: FM2SQL.ProgressDialog dialog = null;
! 1586: if (isGUI)
! 1587: {
! 1588: dialog = initDialog();
! 1589: }
! 1590: // setting user and passwd
! 1591: bean.setUserAndPasswd(user, passwd);
! 1592: // setting user and passwd
! 1593: beanDest.setUserAndPasswd(userDest, passwdDest);
! 1594: StringBuffer command = null;
! 1595: String query = null;
! 1596: try
! 1597: {
! 1598: // bean.setConnection("jdbc:fmpro:http://141.14.237.74:8050");
! 1599: // bean.setConnection("jdbc:postgresql://erebos/test","postgres","rogo");
! 1600: bean.setConnection(source);
! 1601: if (names == null)
! 1602: names = bean.getTableNames();
! 1603: // Collections.sort(names);
! 1604: int tbIndex = 1;
! 1605:
! 1606: // System.out.println("Start at
! 1607: // "+names.indexOf("archimedes_facsimiles"));
! 1608: for (tbIndex = 0; tbIndex < names.size(); ++tbIndex)
! 1609: {
! 1610: Vector[] result = null;
! 1611: java.util.TreeSet myIds = new TreeSet();
! 1612: java.util.TreeSet myIdsDest = new TreeSet();
! 1613: int deltaID = 1;
! 1614: String idField = "";
! 1615: String destTableName = "";
! 1616:
! 1617: try
! 1618: {
! 1619: query = "select * from " + bean.getQC() + names.get(tbIndex).toString() + bean.getQC();
! 1620: String layout = (layouts.isEmpty()) ? "" : layouts.get(tbIndex).toString();
! 1621: query = (selects != null) ? selects.get(tbIndex).toString() : query;
! 1622: // if vectors[1].get(i) != null)
! 1623: if (layout != "")
! 1624: {
! 1625: layout = " layout " + bean.getQC() + layout + bean.getQC();
! 1626: String name = names.get(tbIndex).toString();
! 1627: StringBuffer queryLayout = new StringBuffer(query);
! 1628: queryLayout.insert(queryLayout.indexOf(name) + name.length() + 1, " " + layout);
! 1629: query = queryLayout.toString();
! 1630: System.out.println("added layout " + query);
! 1631:
! 1632: }
! 1633: dialog.title.setText("Getting table data ...");
! 1634: dialog.table.setText(names.get(tbIndex).toString());
! 1635: dialog.status.setText("Table " + (tbIndex + 1) + " of " + names.size());
! 1636: dialog.setVisible(true);
! 1637: bean.getConnection();
! 1638: bean.makeQuery(query, 50);
! 1639: idField = ids.get(tbIndex).toString();
! 1640:
! 1641: } catch (Exception e)
! 1642: {
! 1643: continue;
! 1644: }
! 1645: // determine destTableName from createStatement or from source
! 1646: // table name
! 1647: if (!creates.get(tbIndex).equals(""))
! 1648: {
! 1649: String create = creates.get(tbIndex).toString().toLowerCase();
! 1650: int fromIndex = create.indexOf("table") + 5;
! 1651: int toIndex = create.indexOf("(");
! 1652: destTableName = create.substring(fromIndex, toIndex).replaceAll(beanDest.getQC(), "")
! 1653: .trim();
! 1654: System.out.println("destTable " + destTableName);
! 1655:
! 1656: } else
! 1657: destTableName = convertText(names.get(tbIndex).toString());
! 1658:
! 1659: // for id kram
! 1660: Vector vec = null;
! 1661: Vector vecDest = null;
! 1662: // tempo
! 1663: beanDest.setConnection(destination);
! 1664: int rowCount = (idField != "") ? myIds.size() : bean.getRowCount(query);
! 1665: String tempID = bean.getQC() + idField + bean.getQC();
! 1666: String tempIDdest = beanDest.getQC() + convertText(idField) + beanDest.getQC();
! 1667:
! 1668: int endIndex = -1;
! 1669: String tempQuery = query;
! 1670: String destQuery = query.replaceAll(names.get(tbIndex).toString(), destTableName);
! 1671: String tempQueryDest = destQuery;
! 1672: // remove extra query parts
! 1673: // destQuery.substring(0,destQuery.lastIndexOf(destTableName)+destTableName.length()+1);
! 1674: System.out.println("new Query " + tempQueryDest);
! 1675: if (!idField.equals(""))
! 1676: {
! 1677: long startTime = System.currentTimeMillis();
! 1678: int counter = -1;
! 1679: while (true)
! 1680: {
! 1681: ++counter;
! 1682: if (counter == 0 && dialog != null)
! 1683: dialog.title.setText("Check if data is available");
! 1684: else if (dialog != null)
! 1685: dialog.title.setText("Check if more data is available");
! 1686: myIds = bean.getIDVector(ids.get(tbIndex).toString(), (String) names.get(tbIndex),
! 1687: tempQuery, numHits);
! 1688: myIdsDest = beanDest.getIDVector(convertText(idField), destTableName, tempQueryDest,
! 1689: numHits);
! 1690: if (myIds.isEmpty())
! 1691: break;
! 1692: vec = new Vector(myIds);
! 1693: vecDest = new Vector(myIdsDest);
! 1694: rowCount = vec.size();
! 1695: // Deletion will work this way
! 1696: Vector deleted = new Vector(vec);
! 1697: Vector linesToDelete = new Vector(vecDest);
! 1698: // remove all lines that should not be deleted
! 1699: linesToDelete.removeAll(deleted);
! 1700: // System.out.println("ID LIST SIZE " +
! 1701: // Math.round((double) myIds.size() / (double)
! 1702: // numIntervalls) + " " + myIdsDest.size());
! 1703: // / @TODO complete delete task remove query show lines
! 1704: // to be deleted let user choose if he wants that
! 1705: System.out.println("number of lines to be deleted " + linesToDelete.size());
! 1706: deltaID = (int) Math.round((double) myIds.size() / (double) numIntervalls);
! 1707: beanDest.setConnection(destination);
! 1708:
! 1709: Statement stm = beanDest.getConnection().createStatement();
! 1710:
! 1711: Vector tables = beanDest.getTableNames();
! 1712: // Collections.sort(tables);
! 1713: System.out.println(names.get(tbIndex) + " "
! 1714: + tables.indexOf(convertText((String) names.get(tbIndex)))); // "//beanDest.getTypeNames());
! 1715: tables = beanDest.getTableNames();
! 1716: // System.out.println(beanDest.getTableNames(beanDest.getCatalogs().get(2).toString()));
! 1717: stm = beanDest.getConnection().createStatement();
! 1718:
! 1719: if (dialog != null)
! 1720: dialog.title.setText(" Deleting table data ...");
! 1721:
! 1722: int j = -1;
! 1723:
! 1724: Vector row = null;
! 1725: command = new StringBuffer();
! 1726:
! 1727: command.append("DELETE FROM");
! 1728: command.append(beanDest.getQC());
! 1729: command.append(destTableName);
! 1730: command.append(beanDest.getQC());
! 1731: int size = bean.getColumnNames().size();
! 1732: command.append("WHERE " + convertText(ids.get(tbIndex).toString()) + " = ?");
! 1733: PreparedStatement pstm = beanDest.getConnection().prepareStatement(command.toString());
! 1734: System.out.println(command + " " + tbIndex);
! 1735: while (true)
! 1736: {
! 1737:
! 1738: ++j;
! 1739: if (j == linesToDelete.size())
! 1740: break;
! 1741: // print rows
! 1742: pstm.setString(1, linesToDelete.get(j).toString());
! 1743: System.out.println(pstm.toString());
! 1744: pstm.execute();
! 1745: if (isGUI)
! 1746: dialog.progress.setValue((int) (((double) (j + 1) / (double) rowCount) * 100.0));
! 1747: command = null;
! 1748: }
! 1749: // prepare new query for next chunk
! 1750: if (query.indexOf("where") > 0)
! 1751: tempQuery = query + " and " + tempID + ">'" + vec.lastElement() + "'";
! 1752: else
! 1753: tempQuery = query + " where " + tempID + ">'" + vec.lastElement() + "'";
! 1754:
! 1755: } // to outer while
! 1756: } // to idfield if
! 1757: } // table loop
! 1758:
! 1759: } catch (Exception e)
! 1760: {
! 1761: System.out.println("Error while connecting to database " + e);
! 1762: if (isGUI)
! 1763: {
! 1764: showExceptionDialog(dialog, command, e);
! 1765: resetGUI(dialog);
! 1766: } else
! 1767: {
! 1768: e.printStackTrace();
! 1769: }
! 1770: }
! 1771: } // to method
! 1772:
! 1773: /**
! 1774: * synchronize method based on delete method code
! 1775: *
! 1776: * @param source
! 1777: * @param destination
! 1778: * @param names
! 1779: * @param layouts
! 1780: * @param selects
! 1781: * @param creates
! 1782: * @param ids
! 1783: * @param mode
! 1784: * @throws Exception
! 1785: */
! 1786: // TODO implement append,update and delete in one method
! 1787: // TODO using id based algorithm
! 1788: public static void synchronize(String source, String destination, Vector names, Vector layouts,
! 1789: Vector selects, Vector creates, Vector ids, int mode, String delimiter, Vector indexList)
! 1790: throws Exception
! 1791: {
! 1792: System.out.println(" bin in synchronize!!!");
! 1793: FM2SQL.ProgressDialog dialog = null;
! 1794: if (isGUI)
! 1795: {
! 1796: dialog = initDialog();
! 1797: dialog.setTitle("Synchronize running ...");
! 1798:
! 1799: }
! 1800: // setting user and passwd
! 1801: bean.setUserAndPasswd(user, passwd);
! 1802: // setting user and passwd
! 1803: beanDest.setUserAndPasswd(userDest, passwdDest);
! 1804: StringBuffer command = null;
! 1805: String query = null;
! 1806: try
! 1807: {
! 1808: bean.setConnection(source);
! 1809: if (names == null)
! 1810: names = bean.getTableNames();
! 1811: int tbIndex = 1;
! 1812:
! 1813: for (tbIndex = 0; tbIndex < names.size(); ++tbIndex)
! 1814: {
! 1815: Vector[] result = null;
! 1816: java.util.TreeSet myIds = new TreeSet();
! 1817: java.util.TreeSet myIdsDest = new TreeSet();
! 1818: int deltaID = 1;
! 1819: String idField = "";
! 1820: String destTableName = "";
! 1821:
! 1822: try
! 1823: {
! 1824: query = "select * from " + bean.getQC() + names.get(tbIndex).toString() + bean.getQC();
! 1825: String layout = (layouts.isEmpty()) ? "" : layouts.get(tbIndex).toString();
! 1826: query = (selects != null) ? selects.get(tbIndex).toString() : query;
! 1827: // if vectors[1].get(i) != null)
! 1828: if (!layout.equals(""))
! 1829: {
! 1830: query = addLayoutToQuery(names, query, tbIndex, layout);
! 1831:
! 1832: }
! 1833: if (dialog != null)
! 1834: {
! 1835: prepareDialogforUse(names, dialog, tbIndex);
! 1836: }
! 1837: bean.getConnection();
! 1838: bean.makeQuery(query, 50);
! 1839: idField = ids.get(tbIndex).toString();
! 1840:
! 1841: } catch (Exception e)
! 1842: {
! 1843: System.out.println("Warning exception occured \n " + e);
! 1844:
! 1845: continue;
! 1846: }
! 1847: // determine destTableName from createStatement or from source
! 1848: // table name
! 1849: if (!creates.get(tbIndex).equals(""))
! 1850: {
! 1851: String create = creates.get(tbIndex).toString().toLowerCase();
! 1852: int fromIndex = create.indexOf("table") + 5;
! 1853: int toIndex = create.indexOf("(");
! 1854: destTableName = create.substring(fromIndex, toIndex).replaceAll(beanDest.getQC(), "")
! 1855: .trim();
! 1856: System.out.println("destTable " + destTableName);
! 1857:
! 1858: } else
! 1859: destTableName = convertText(names.get(tbIndex).toString());
! 1860:
! 1861: // for id kram
! 1862: Vector vec = null;
! 1863: Vector vecDest = null;
! 1864: // tempo
! 1865: beanDest.setConnection(destination);
! 1866: int rowCount = (idField != "") ? myIds.size() : bean.getRowCount(query);
! 1867: String tempID = bean.getQC() + idField + bean.getQC();
! 1868: String tempIDdest = beanDest.getQC() + convertText(idField) + beanDest.getQC();
! 1869:
! 1870: int endIndex = -1;
! 1871: String tempQuery = query;
! 1872: String destQuery = query.replaceAll(names.get(tbIndex).toString(), destTableName);
! 1873: destQuery = destQuery.replaceAll(bean.getQC(), beanDest.getQC());
! 1874: destQuery = removeLayoutPartFromQuery(destQuery, layouts.get(tbIndex).toString());
! 1875: // TODO remove layout part for destQuery
! 1876: String tempQueryDest = destQuery;
! 1877: // remove extra query parts
! 1878: // destQuery.substring(0,destQuery.lastIndexOf(destTableName)+destTableName.length()+1);
! 1879: System.out.println("new Query " + tempQueryDest);
! 1880: System.out.println("idfield " + idField + " " + ids.get(tbIndex).toString());
! 1881: if (!idField.equals(""))
! 1882: {
! 1883: long startTime = System.currentTimeMillis();
! 1884: int counter = -1;
! 1885: TreeSet linesToDelete = null;
! 1886: PreparedStatement delPSt = null;
! 1887: while (true)
! 1888: {
! 1889: ++counter;
! 1890: if (counter == 0 && dialog != null)
! 1891: dialog.title.setText("Check if data is available");
! 1892: else if (dialog != null)
! 1893: dialog.title.setText("Check if more data is available");
! 1894:
! 1895: myIds = bean.getIDVector(ids.get(tbIndex).toString(), (String) names.get(tbIndex),
! 1896: tempQuery, 0);
! 1897: myIdsDest = beanDest.getIDVector(convertText(idField), destTableName, tempQueryDest, 0);
! 1898: // System.out.println("status of remove
! 1899: // "+myIds.remove("b015892"));
! 1900: System.out.println("ids found for " + idField + " " + !myIds.isEmpty());
! 1901: if (myIds.isEmpty())
! 1902: break;
! 1903: vec = new Vector(myIds);
! 1904: vecDest = new Vector(myIdsDest);
! 1905: rowCount = vec.size();
! 1906: // Deletion will work this way
! 1907: Vector deleted = new Vector(vec);
! 1908:
! 1909: TreeSet linesToAppend = new TreeSet(vec);
! 1910: linesToAppend.addAll(vec);
! 1911: linesToDelete = new TreeSet(vecDest);
! 1912: // remove all lines that are already in dest database
! 1913: linesToAppend.removeAll(vecDest);
! 1914: // remove all lines that should not be deleted
! 1915: linesToDelete.removeAll(deleted);
! 1916: System.out.println("linesToAppend " + linesToAppend.size() + " " + destTableName);
! 1917: System.out.println("linesToDelete " + linesToDelete.size() + " " + destTableName);
! 1918: System.out.println("ID LIST SIZE "
! 1919: + Math.round((double) myIds.size() / (double) numIntervalls) + " " + myIds.size());
! 1920: deltaID = (int) Math.round((double) myIds.size() / (double) numIntervalls);
! 1921: ConversionProperties prop = getFieldNamesAndDestTableName(creates.get(tbIndex)
! 1922: .toString(), query, names.get(tbIndex).toString());
! 1923: StringBuffer insCommand = createInsertCommand(prop.destTableName, prop.fieldNames);
! 1924: StringBuffer updCommand = createUpdateCommand(prop.destTableName, prop.fieldNames,
! 1925: tempIDdest);
! 1926: StringBuffer delCommand = createDeleteCommand(destTableName, tempIDdest);
! 1927: PreparedStatement insPst = beanDest.getConnection().prepareStatement(
! 1928: insCommand.toString());
! 1929: PreparedStatement updPst = beanDest.getConnection().prepareStatement(
! 1930: updCommand.toString());
! 1931: delPSt = beanDest.getConnection().prepareStatement(delCommand.toString());
! 1932: // delPSt.setString(1,"b015892");
! 1933: // delPSt.execute();
! 1934: // if (true)
! 1935: // return;
! 1936: if (vec.size() <= numIntervalls)
! 1937: {
! 1938: endIndex = 0;
! 1939: deltaID = vec.size();
! 1940: }
! 1941: for (int k = 0; k < vec.size() - deltaID; k = k + deltaID)
! 1942: {
! 1943: System.out.println(vec.get(k) + " " + vec.get(k + deltaID) + " " + vec.lastElement());
! 1944: if (query.indexOf("where") > 0)
! 1945: tempQuery = query + " and " + tempID + ">='" + vec.get(k) + "' and " + tempID
! 1946: + "<='" + vec.get(k + deltaID) + "'";
! 1947: else
! 1948: tempQuery = query + " where " + tempID + ">='" + vec.get(k) + "' and " + tempID
! 1949: + "<='" + vec.get(k + deltaID) + "'";
! 1950: System.out.println(tempQuery);
! 1951: if (dialog != null)
! 1952: dialog.title.setText("Reading table data ...");
! 1953:
! 1954: // bean.makeQuery(tempQuery, deltaID);
! 1955: if (dialog != null)
! 1956: dialog.title.setText("Writing table data ...");
! 1957:
! 1958: performSynchronize(idField, vec, tempQuery, linesToDelete, linesToAppend, insPst,
! 1959: updPst, delPSt, deltaID, delimiter, dialog);
! 1960: // System.out.println("ID LIST SIZE " +
! 1961: // Math.round((double) myIds.size() / (double)
! 1962: // numIntervalls) + " " + myIdsDest.size());
! 1963: endIndex = k + deltaID;
! 1964: }
! 1965: System.out.println(endIndex);
! 1966: // all data written ? if not write last chunk of data
! 1967: if (endIndex == vec.size() - 1)
! 1968: System.out.println("fits");
! 1969: else
! 1970: {
! 1971: System.out.println(" last intervall from " + vec.get(endIndex) + " "
! 1972: + vec.lastElement());
! 1973:
! 1974: if (query.indexOf("where") > 0)
! 1975: tempQuery = query + " and " + tempID + ">='" + vec.get(endIndex) + "' and "
! 1976: + tempID + "<='" + vec.lastElement() + "'";
! 1977: else
! 1978: tempQuery = query + " where " + tempID + ">='" + vec.get(endIndex) + "' and "
! 1979: + tempID + "<='" + vec.lastElement() + "'";
! 1980: System.out.println(tempQuery);
! 1981: if (dialog != null)
! 1982: dialog.title.setText("Reading table data ...");
! 1983: // bean.makeQuery(tempQuery, 0);
! 1984: if (dialog != null)
! 1985: dialog.title.setText("Writing table data ...");
! 1986: performSynchronize(idField, vec, tempQuery, linesToDelete, linesToAppend, insPst,
! 1987: updPst, delPSt, deltaID, delimiter, dialog);
! 1988: // System.out.println("ID LIST SIZE " +
! 1989: // Math.round((double) myIds.size() / (double)
! 1990: // numIntervalls) + " " + myIdsDest.size());
! 1991: }
! 1992: // prepare new query for next chunk
! 1993: if (query.indexOf("where") > 0)
! 1994: tempQuery = query + " and " + tempID + ">'" + vec.lastElement() + "'";
! 1995: else
! 1996: tempQuery = query + " where " + tempID + ">'" + vec.lastElement() + "'";
! 1997:
! 1998: }
! 1999: String tableName = names.get(tbIndex).toString();
! 2000: if (!indexList.isEmpty())
! 2001: {
! 2002: IndexList idList = (IndexList) indexList.get(0);
! 2003: System.out.println("found list " + idList);
! 2004: Statement stm = beanDest.getConnection().createStatement();
! 2005: Vector destTables = beanDest.getTableNames();
! 2006: System.out.println("tempQueryDest" + tempQueryDest);
! 2007: beanDest.makeQuery(tempQueryDest, 0);
! 2008: for (Iterator iter = idList.iterator(); iter.hasNext();)
! 2009: {
! 2010: String indexField = (String) iter.next();
! 2011: indexField = convertText(indexField);
! 2012: String indexName = destTableName + "_" + indexField;
! 2013: if (destTables.contains(indexName))
! 2014: {
! 2015: stm.execute("DROP INDEX " + destTableName + "_" + indexField);
! 2016: // continue;
! 2017: }
! 2018: // stm.execute("DROP INDEX
! 2019: // "+destTableName+"_"+indexField);
! 2020:
! 2021: String type = beanDest.getColumnType(indexField).toLowerCase();
! 2022: // System.out.println(indexField+" "+type+"
! 2023: // "+(type.indexOf("text") >= 0 ||
! 2024: // type.indexOf("varchar") >= 0 || type.indexOf("char")
! 2025: // >= 0));
! 2026: if (type.indexOf("text") >= 0 || type.indexOf("varchar") >= 0
! 2027: || type.indexOf("char") >= 0)
! 2028: {
! 2029: if (beanDest.url.indexOf("mysql") >= 0)
! 2030: {
! 2031: // System.out.println("CREATE INDEX " +
! 2032: // indexName + " ON " + destTableName + " (" +
! 2033: // indexField + "(10))");
! 2034: // TODO problem if index exist !!!
! 2035: stm.execute("CREATE INDEX " + indexName + " ON " + destTableName + " ("
! 2036: + indexField + "(10))");
! 2037: } else
! 2038: {
! 2039: stm.execute("CREATE INDEX " + indexName + " ON " + destTableName + " (lower( "
! 2040: + indexField + "))");
! 2041:
! 2042: }
! 2043:
! 2044: } else
! 2045: {
! 2046: stm.execute("CREATE INDEX " + destTableName + "_" + indexField + " ON "
! 2047: + destTableName + "(" + indexField + ")");
! 2048:
! 2049: }
! 2050:
! 2051: // stm.execute("DROP INDEX
! 2052: // "+destTableName+"_"+indexField);
! 2053:
! 2054: }
! 2055: }
! 2056: // CREATE UNIQUE INDEX title_idx ON films (title);
! 2057: for (Iterator iter = linesToDelete.iterator(); iter.hasNext();)
! 2058: {
! 2059: String id = (String) iter.next();
! 2060: delPSt.setString(1, id);
! 2061: delPSt.execute();
! 2062:
! 2063: }
! 2064:
! 2065: long endTime = System.currentTimeMillis();
! 2066: System.out.println("Time for incremental synchronize elapsed " + (endTime - startTime));
! 2067: } // to idfield if
! 2068: } // table loop
! 2069:
! 2070: } catch (Exception e)
! 2071: {
! 2072: System.out.println("Error while connecting to database " + e);
! 2073: e.printStackTrace();
! 2074: if (isGUI)
! 2075: showExceptionDialog(dialog, command, e);
! 2076: }
! 2077: if (isGUI)
! 2078: {
! 2079: resetGUI(dialog);
! 2080: }
! 2081: }
! 2082:
! 2083: /**
! 2084: * @param destQuery
! 2085: * @param string
! 2086: * @return
! 2087: */
! 2088: private static String removeLayoutPartFromQuery(String destQuery, String layoutName)
! 2089: {
! 2090: String removeString = "layout " + beanDest.getQC() + layoutName + beanDest.getQC();
! 2091: destQuery = destQuery.replaceFirst(removeString, "");
! 2092: System.out.println("destQuery change to " + destQuery);
! 2093: return destQuery;
! 2094: }
! 2095:
! 2096: private static void performSynchronize(String idField, Vector vec, String tempQuery,
! 2097: TreeSet linesToDelete, TreeSet linesToAppend, PreparedStatement insPst,
! 2098: PreparedStatement updPst, PreparedStatement delPSt, int deltaID, String delimiter,
! 2099: FM2SQL.ProgressDialog dialog) throws SQLException, ParseException, Exception
! 2100: {
! 2101: if (dialog != null)
! 2102: {
! 2103: dialog.progress.setValue(0);
! 2104: dialog.title.setText("Retrieving new data");
! 2105: }
! 2106:
! 2107: Vector[] vectors = bean.getQueryData(tempQuery, deltaID);
! 2108: int count = 0, size = vectors[0].size();
! 2109: int idIndex = vectors[1].indexOf(idField);
! 2110: // System.out.println(idIndex + " " + vectors[1] + " " + idField);
! 2111: // todo arraylist code has to be added
! 2112: if (dialog != null)
! 2113: dialog.title.setText("Synchronize with new data");
! 2114:
! 2115: for (Iterator iter = vectors[0].iterator(); iter.hasNext();)
! 2116: {
! 2117: Vector line = (Vector) iter.next();
! 2118: Object lineIDIndex = line.get(idIndex);
! 2119: if (linesToAppend.contains(lineIDIndex))
! 2120: System.out.println("line " + linesToAppend.contains(line.get(idIndex)) + " " + lineIDIndex);
! 2121: if (linesToAppend.contains(lineIDIndex))
! 2122: {
! 2123: for (int l = 0; l < line.size(); ++l)
! 2124: {
! 2125: Object obj = line.get(l);
! 2126: if (obj instanceof ArrayList)
! 2127: obj = formatFileMakerArray((List) obj, delimiter);
! 2128: if (obj != null)
! 2129: insPst.setString(l + 1, obj.toString());
! 2130: else
! 2131: insPst.setNull(l + 1, Types.NULL);
! 2132: }
! 2133: insPst.execute();
! 2134:
! 2135: } else
! 2136: // update
! 2137: {
! 2138: for (int l = 0; l < line.size(); ++l)
! 2139: {
! 2140: Object obj = line.get(l);
! 2141: if (obj instanceof ArrayList)
! 2142: obj = formatFileMakerArray((List) obj, delimiter);
! 2143: if (obj != null)
! 2144: updPst.setString(l + 1, obj.toString());
! 2145: else
! 2146: updPst.setNull(l + 1, Types.NULL);
! 2147: }
! 2148: updPst.setString(line.size() + 1, line.get(idIndex).toString());
! 2149: // updPst.addBatch();
! 2150: // updPst.execute();
! 2151: }
! 2152: if (dialog != null)
! 2153: {
! 2154: int value = (int) Math.round(((double) count / (double) size) * 100.0);
! 2155: dialog.progress.setValue(value);
! 2156: count++;
! 2157: }
! 2158: }
! 2159: // updPst.executeBatch();
! 2160: } // to method
! 2161:
! 2162: /**
! 2163: * Converts input String in norman encoding to unicode
! 2164: *
! 2165: * @param inp
! 2166: * @return converted String
! 2167: */
! 2168: static public String normanToUnicode(String inp)
! 2169: {
! 2170: StringBuffer buf = new StringBuffer();
! 2171: for (int i = 0; i < inp.length(); i++)
! 2172: {
! 2173: char c = inp.charAt(i);
! 2174: // System.out.println("char "+c+" "+(int)c);
! 2175: switch (c)
! 2176: {
! 2177: case 1:
! 2178: buf.append("\u00d0");
! 2179: break; // Eth
! 2180: case 2:
! 2181: buf.append("\u00f0");
! 2182: break; // eth
! 2183: case 3:
! 2184: buf.append("\u0141");
! 2185: break; // Lslash
! 2186: case 4:
! 2187: buf.append("\u0142");
! 2188: break; // lslash
! 2189: case 5:
! 2190: buf.append("\u0160");
! 2191: break; // S caron
! 2192: case 6:
! 2193: buf.append("\u0161");
! 2194: break; // s caron
! 2195: case 7:
! 2196: buf.append("\u00dd");
! 2197: break; // Y acute
! 2198: case 8:
! 2199: buf.append("\u00fd");
! 2200: break; // y acute
! 2201: case 11:
! 2202: buf.append("\u00de");
! 2203: break; // Thorn
! 2204: case 12:
! 2205: buf.append("\u00fe");
! 2206: break; // thorn
! 2207: case 14:
! 2208: buf.append("\u017d");
! 2209: break; // Z caron
! 2210: case 15:
! 2211: buf.append("\u017e");
! 2212: break; // z caron
! 2213: case 17:
! 2214: buf.append("\u0073");
! 2215: break; // asciitilde
! 2216: case 18:
! 2217: buf.append("j\u0305");
! 2218: break; // j macron [does a single char exist?]
! 2219: case 19:
! 2220: buf.append("^");
! 2221: break; // circumflex
! 2222: case 20:
! 2223: buf.append("\u0303");
! 2224: break; // tilde
! 2225: case 21:
! 2226: buf.append("\u00bd");
! 2227: break; // onehalf
! 2228: case 22:
! 2229: buf.append("\u00bc");
! 2230: break; // onequarter
! 2231: case 23:
! 2232: buf.append("\u00b9");
! 2233: break; // onesuperior
! 2234: case 24:
! 2235: buf.append("\u00be");
! 2236: break; // threequarters
! 2237: case 25:
! 2238: buf.append("\u00b3");
! 2239: break; // threesuperior
! 2240: case 26:
! 2241: buf.append("\u00b2");
! 2242: break; // twosuperior
! 2243: case 27:
! 2244: buf.append("\u00a6");
! 2245: break; // brokenbar
! 2246: case 28:
! 2247: buf.append("-");
! 2248: break; // minus
! 2249: case 29:
! 2250: buf.append("\u00d7");
! 2251: break; // multiply
! 2252: case 39:
! 2253: buf.append("'");
! 2254: break; // quotesingle
! 2255: case 94:
! 2256: buf.append("\u0302");
! 2257: break; // circumflex
! 2258: case 96:
! 2259: buf.append("\u0300");
! 2260: break; // grave
! 2261: case 196:
! 2262: buf.append("\u00c4");
! 2263: break; // A dieresis
! 2264: case 197:
! 2265: buf.append("\u00c5");
! 2266: break; // A ring
! 2267: case 201:
! 2268: buf.append("\u00c9");
! 2269: break; // E acute
! 2270: case 209:
! 2271: buf.append("\u00d1");
! 2272: break; // N tilde
! 2273: case 214:
! 2274: buf.append("\u00d6");
! 2275: break; // O dieresis
! 2276: case 220:
! 2277: buf.append("\u00dc");
! 2278: break; // U dieresis
! 2279: case 225:
! 2280: buf.append("\u00e1");
! 2281: break; // a acute
! 2282: case 224:
! 2283: buf.append("\u00e0");
! 2284: break; // a grave
! 2285: case 226:
! 2286: buf.append("\u00e2");
! 2287: break; // a circumflex
! 2288: case 228:
! 2289: buf.append("\u00e4");
! 2290: break; // a dieresis
! 2291: case 227:
! 2292: buf.append("\u00e3");
! 2293: break; // a tilde
! 2294: case 229:
! 2295: buf.append("\u0101");
! 2296: break; // a macron
! 2297: case 231:
! 2298: buf.append("\u00e7");
! 2299: break; // c cedilla
! 2300: case 233:
! 2301: buf.append("\u00e9");
! 2302: break; // e acute
! 2303: case 232:
! 2304: buf.append("\u00e8");
! 2305: break; // e grave
! 2306: case 234:
! 2307: buf.append("\u00ea");
! 2308: break; // e circumflex
! 2309: case 235:
! 2310: buf.append("\u00eb");
! 2311: break; // e dieresis
! 2312: case 237:
! 2313: buf.append("\u00ed");
! 2314: break; // i acute
! 2315: case 236:
! 2316: buf.append("\u00ec");
! 2317: break; // i grave
! 2318: case 238:
! 2319: buf.append("\u00ee");
! 2320: break; // i circumflex
! 2321: case 239:
! 2322: buf.append("\u00ef");
! 2323: break; // i dieresis
! 2324: case 241:
! 2325: buf.append("\u00f1");
! 2326: break; // n tilde
! 2327: case 243:
! 2328: buf.append("\u00f3");
! 2329: break; // o acute
! 2330: case 242:
! 2331: buf.append("\u00f2");
! 2332: break; // o grave
! 2333: case 244:
! 2334: buf.append("\u00f4");
! 2335: break; // o circumflex
! 2336: case 246:
! 2337: buf.append("\u00f6");
! 2338: break; // o dieresis
! 2339: case 245:
! 2340: buf.append("\u00f5");
! 2341: break; // o tilde
! 2342: case 250:
! 2343: buf.append("\u00fa");
! 2344: break; // u acute
! 2345: case 249:
! 2346: buf.append("\u00f9");
! 2347: break; // u grave
! 2348: case 251:
! 2349: buf.append("\u00fb");
! 2350: break; // u circumflex
! 2351: case 252:
! 2352: buf.append("\u00fc");
! 2353: break; // u dieresis
! 2354: case 8224:
! 2355: buf.append("\u1e6d");
! 2356: break; // t underdot
! 2357: case 176:
! 2358: buf.append("\u00b0");
! 2359: break; // degree
! 2360: case 162:
! 2361: buf.append("\u1ebd");
! 2362: break; // e tilde
! 2363: case 163:
! 2364: buf.append("\u00a3");
! 2365: break; // sterling
! 2366: case 167:
! 2367: buf.append("\u00a7");
! 2368: break; // section
! 2369: case 182:
! 2370: buf.append("\u00b6");
! 2371: break; // paragraph
! 2372: case 223:
! 2373: buf.append("\u015b");
! 2374: break; // s acute
! 2375: case 174:
! 2376: buf.append("\u1e5b");
! 2377: break; // r underdot
! 2378: case 169:
! 2379: buf.append("\u1e45");
! 2380: break; // n overdot
! 2381: case 353:
! 2382: buf.append("\u1e45");
! 2383: break; // n overdot
! 2384: case 180:
! 2385: buf.append("\u0301");
! 2386: break; // acute
! 2387: case 168:
! 2388: buf.append("\u0308");
! 2389: break; // dieresis
! 2390: case 8800:
! 2391: buf.append("\u1e6d");
! 2392: break; // t underdot
! 2393: case 198:
! 2394: buf.append("\u00c6");
! 2395: break; // AE
! 2396: case 216:
! 2397: buf.append("\u014d");
! 2398: break; // o macron
! 2399: case 8734:
! 2400: buf.append("\u0129");
! 2401: break; // i tilde
! 2402: case 177:
! 2403: buf.append("\u00b1");
! 2404: break; // plusminus
! 2405: case 165:
! 2406: buf.append("\u012b");
! 2407: break; // i macron
! 2408: case 181:
! 2409: buf.append("\u1e43");
! 2410: break; // m underdot
! 2411: case 8706:
! 2412: buf.append("\u1e0d");
! 2413: break; // d underdot
! 2414: case 240:
! 2415: buf.append("\u1e0d");
! 2416: break; // d underdot
! 2417:
! 2418: case 8721:
! 2419: buf.append("\u1e63");
! 2420: break; // s underdot
! 2421: case 960:
! 2422: buf.append("\u017a");
! 2423: break; // z acute
! 2424: case 8747:
! 2425: buf.append("\u1e45");
! 2426: break; // n overdot
! 2427: case 937:
! 2428: buf.append("\u0169");
! 2429: break; // u tilde
! 2430: case 230:
! 2431: buf.append("\u00e6");
! 2432: break; // ae
! 2433: case 248:
! 2434: buf.append("\u00f8");
! 2435: break; // oslash
! 2436: case 191:
! 2437: buf.append("\u0304\u0306");
! 2438: break; // macron breve
! 2439: case 172:
! 2440: buf.append("\u1e37");
! 2441: break; //
! 2442: case 8730:
! 2443: buf.append("j\u0305");
! 2444: break; // j macron [does a single char exist?]
! 2445: case 402:
! 2446: buf.append("\u0103");
! 2447: break; // a breve
! 2448: case 8776:
! 2449: buf.append("\u016d");
! 2450: break; // u breve
! 2451: case 187:
! 2452: buf.append("\u1e42");
! 2453: break; // M underdot
! 2454: case 8230:
! 2455: buf.append("\u2026");
! 2456: break; // ellipsis
! 2457: case 192:
! 2458: buf.append("\u00c0");
! 2459: break; // A grave
! 2460: case 195:
! 2461: buf.append("\u00c3");
! 2462: break; // A tilde
! 2463: case 213:
! 2464: buf.append("\u00d5");
! 2465: break; // O tilde
! 2466: case 338:
! 2467: buf.append("m\u0306");
! 2468: break; // m breve
! 2469: case 339:
! 2470: buf.append("\u0153");
! 2471: break; // oe
! 2472: case 8211:
! 2473: buf.append("\u2013");
! 2474: break; // endash
! 2475: case 8212:
! 2476: buf.append("\u2014");
! 2477: break; // emdash
! 2478: case 8220:
! 2479: buf.append("\u201c");
! 2480: break; // quotedblleft
! 2481: case 8221:
! 2482: buf.append("\u201d");
! 2483: break; // quotedblright
! 2484: case 8216:
! 2485: buf.append("\u2018");
! 2486: break; // quoteleft
! 2487: case 8217:
! 2488: buf.append("\u2019");
! 2489: break; // quoteright
! 2490: case 247:
! 2491: buf.append("\u1e37");
! 2492: break; // l underring [actually underdot]
! 2493: case 9674:
! 2494: buf.append("\u1e41");
! 2495: break; // m overdot
! 2496: case 255:
! 2497: buf.append("n\u0306");
! 2498: break; // n breve
! 2499: case 376:
! 2500: buf.append("\u00d7");
! 2501: break; // multiply
! 2502: case 8364:
! 2503: buf.append("\u1e5b");
! 2504: break; // r underring [actually underdot]
! 2505: case 8249:
! 2506: buf.append("\u1e44");
! 2507: break; // N overdot
! 2508: case 8250:
! 2509: buf.append("\u1e62");
! 2510: break; // S underdot
! 2511: case 64257:
! 2512: buf.append("\u1e24");
! 2513: break; // H underdot
! 2514: case 64258:
! 2515: buf.append("\u1e0c");
! 2516: break; // D underdot
! 2517: case 8225:
! 2518: buf.append("\u2021");
! 2519: break; // daggerdbl
! 2520: case 8218:
! 2521: buf.append("\u1e36");
! 2522: break; // L underdot
! 2523: case 8222:
! 2524: buf.append("\u0113");
! 2525: break; // e macron
! 2526: case 194:
! 2527: buf.append("\u1e5f");
! 2528: break; // r underbar
! 2529: case 202:
! 2530: buf.append("r\u0324");
! 2531: break; // r underdieresis
! 2532: case 193:
! 2533: buf.append("\u012a");
! 2534: break; // I macron
! 2535: case 8486:
! 2536: case 203:
! 2537: buf.append("\u016b");
! 2538: break; // u macron
! 2539: case 200:
! 2540: buf.append("\u1e6c");
! 2541: break; // T underdot
! 2542: case 205:
! 2543: buf.append("\u1e64");
! 2544: break; // S acute
! 2545: case 206:
! 2546: buf.append("\u2020");
! 2547: break; // dagger
! 2548: case 207:
! 2549: buf.append("\u0115");
! 2550: break; // e breve
! 2551: case 204:
! 2552: buf.append("\u014f");
! 2553: break; // o breve
! 2554: case 211:
! 2555: buf.append("\u0100");
! 2556: break; // A macron
! 2557: case 212:
! 2558: buf.append("\u1e46");
! 2559: break; // N underdot
! 2560: case 210:
! 2561: buf.append("\u1e3b");
! 2562: break; // l underbar
! 2563: case 218:
! 2564: buf.append("\u016a");
! 2565: break; // U macron
! 2566: case 219:
! 2567: buf.append("\u0179");
! 2568: break; // Z acute
! 2569: case 217:
! 2570: buf.append("\u1e5a");
! 2571: break; // R underdot
! 2572: case 305:
! 2573: buf.append("\u0131");
! 2574: break; // dotlessi
! 2575: case 710:
! 2576: buf.append("\u1e47");
! 2577: break; // n underdot
! 2578: case 732:
! 2579: buf.append("\u1e49");
! 2580: break; // n underbar
! 2581: case 175:
! 2582: buf.append("\u0304");
! 2583: break; // macron
! 2584: case 728:
! 2585: buf.append("\u0306");
! 2586: break; // breve
! 2587: case 729:
! 2588: case 215:
! 2589: buf.append("\u1e25");
! 2590: break; // h underdot
! 2591: case 730:
! 2592: buf.append("\u012d");
! 2593: break; // i breve
! 2594: case 184:
! 2595: buf.append("\u0327");
! 2596: break; // cedilla
! 2597: case 733:
! 2598: buf.append("\u030b");
! 2599: break; // hungarumlaut
! 2600: case 731:
! 2601: buf.append("\u0328");
! 2602: break; // ogonek
! 2603: case 711:
! 2604: buf.append("\u030c");
! 2605: break; // caron
! 2606: case 199:
! 2607: buf.append("\u012b\u0303");
! 2608: break; // imacron tilde
! 2609: case 8226:
! 2610: buf.append("\u1e5d");
! 2611: break; // runderdot macron
! 2612: case 8482:
! 2613: buf.append("\u016b\0306");
! 2614: break; // umacron breve
! 2615: case 8804:
! 2616: buf.append("\u0101\u0301");
! 2617: break; // amacron acute
! 2618: case 8805:
! 2619: buf.append("\u016b\u0301");
! 2620: break; // umacron acute
! 2621: case 8719:
! 2622: buf.append("\u0113\u0301");
! 2623: break; // emacron acute
! 2624: case 170:
! 2625: buf.append("\u0113\u0300");
! 2626: break; // emacron breve
! 2627: case 186:
! 2628: buf.append("\u014d\u0300");
! 2629: break; // omacron breve
! 2630: case 161:
! 2631: buf.append("\u0101\u0306");
! 2632: break; // amacron breve
! 2633: case 8710:
! 2634: buf.append("\u0101\u0303");
! 2635: break; // amacron tilde
! 2636: case 171:
! 2637: buf.append("\u012b\u0301");
! 2638: break; // imacron acute
! 2639: case 8260:
! 2640: buf.append("\u1e00");
! 2641: break; // runderdotmacron acute
! 2642: case 183:
! 2643: buf.append("\u1e5b\u0301");
! 2644: break; // runderdot acute
! 2645: case 8240:
! 2646: buf.append("\u012b\u0306");
! 2647: break; // imacron breve
! 2648: case 63743:
! 2649: buf.append("\u016b\u0303");
! 2650: break; // umacron tilde
! 2651: default:
! 2652: buf.append(c);
! 2653: if ((int) c > 127)
! 2654: System.out.println("char " + c + " " + (int) c);
! 2655: break;
! 2656: }
! 2657: }
! 2658: return buf.toString();
! 2659: }
! 2660:
! 2661: static public String normanToUnicodeOld(String inp)
! 2662: {
! 2663: StringBuffer buf = new StringBuffer();
! 2664: for (int i = 0; i < inp.length(); i++)
! 2665: {
! 2666: char c = inp.charAt(i);
! 2667: switch (c)
! 2668: {
! 2669: case 1:
! 2670: buf.append("\u00d0");
! 2671: break; // Eth
! 2672: case 2:
! 2673: buf.append("\u00f0");
! 2674: break; // eth
! 2675: case 3:
! 2676: buf.append("\u0141");
! 2677: break; // Lslash
! 2678: case 4:
! 2679: buf.append("\u0142");
! 2680: break; // lslash
! 2681: case 5:
! 2682: buf.append("\u0160");
! 2683: break; // S caron
! 2684: case 6:
! 2685: buf.append("\u0161");
! 2686: break; // s caron
! 2687: case 7:
! 2688: buf.append("\u00dd");
! 2689: break; // Y acute
! 2690: case 8:
! 2691: buf.append("\u00fd");
! 2692: break; // y acute
! 2693: case 11:
! 2694: buf.append("\u00de");
! 2695: break; // Thorn
! 2696: case 12:
! 2697: buf.append("\u00fe");
! 2698: break; // thorn
! 2699: case 14:
! 2700: buf.append("\u017d");
! 2701: break; // Z caron
! 2702: case 15:
! 2703: buf.append("\u017e");
! 2704: break; // z caron
! 2705: case 17:
! 2706: buf.append("\u0073");
! 2707: break; // asciitilde
! 2708: case 18:
! 2709: buf.append("j\u0305");
! 2710: break; // j macron [does a single char exist?]
! 2711: case 19:
! 2712: buf.append("^");
! 2713: break; // circumflex
! 2714: case 20:
! 2715: buf.append("\u0303");
! 2716: break; // tilde
! 2717: case 21:
! 2718: buf.append("\u00bd");
! 2719: break; // onehalf
! 2720: case 22:
! 2721: buf.append("\u00bc");
! 2722: break; // onequarter
! 2723: case 23:
! 2724: buf.append("\u00b9");
! 2725: break; // onesuperior
! 2726: case 24:
! 2727: buf.append("\u00be");
! 2728: break; // threequarters
! 2729: case 25:
! 2730: buf.append("\u00b3");
! 2731: break; // threesuperior
! 2732: case 26:
! 2733: buf.append("\u00b2");
! 2734: break; // twosuperior
! 2735: case 27:
! 2736: buf.append("\u00a6");
! 2737: break; // brokenbar
! 2738: case 28:
! 2739: buf.append("-");
! 2740: break; // minus
! 2741: case 29:
! 2742: buf.append("\u00d7");
! 2743: break; // multiply
! 2744: case 39:
! 2745: buf.append("'");
! 2746: break; // quotesingle
! 2747: case 94:
! 2748: buf.append("\u0302");
! 2749: break; // circumflex
! 2750: case 96:
! 2751: buf.append("\u0300");
! 2752: break; // grave
! 2753: case 128:
! 2754: buf.append("\u00c4");
! 2755: break; // A dieresis
! 2756: case 129:
! 2757: buf.append("\u00c5");
! 2758: break; // A ring
! 2759: case 131:
! 2760: buf.append("\u00c9");
! 2761: break; // E acute
! 2762: case 132:
! 2763: buf.append("\u00d1");
! 2764: break; // N tilde
! 2765: case 133:
! 2766: buf.append("\u00d6");
! 2767: break; // O dieresis
! 2768: case 134:
! 2769: buf.append("\u00dc");
! 2770: break; // U dieresis
! 2771: case 135:
! 2772: buf.append("\u00e1");
! 2773: break; // a acute
! 2774: case 136:
! 2775: buf.append("\u00e0");
! 2776: break; // a grave
! 2777: case 137:
! 2778: buf.append("\u00e2");
! 2779: break; // a circumflex
! 2780: case 138:
! 2781: buf.append("\u00e4");
! 2782: break; // a dieresis
! 2783: case 139:
! 2784: buf.append("\u00e3");
! 2785: break; // a tilde
! 2786: case 140:
! 2787: buf.append("\u0101");
! 2788: break; // a macron
! 2789: case 141:
! 2790: buf.append("\u00e7");
! 2791: break; // c cedilla
! 2792: case 142:
! 2793: buf.append("\u00e9");
! 2794: break; // e acute
! 2795: case 143:
! 2796: buf.append("\u00e8");
! 2797: break; // e grave
! 2798: case 144:
! 2799: buf.append("\u00ea");
! 2800: break; // e circumflex
! 2801: case 145:
! 2802: buf.append("\u00eb");
! 2803: break; // e dieresis
! 2804: case 146:
! 2805: buf.append("\u00ed");
! 2806: break; // i acute
! 2807: case 147:
! 2808: buf.append("\u00ec");
! 2809: break; // i grave
! 2810: case 148:
! 2811: buf.append("\u00ee");
! 2812: break; // i circumflex
! 2813: case 149:
! 2814: buf.append("\u00ef");
! 2815: break; // i dieresis
! 2816: case 150:
! 2817: buf.append("\u00f1");
! 2818: break; // n tilde
! 2819: case 151:
! 2820: buf.append("\u00f3");
! 2821: break; // o acute
! 2822: case 152:
! 2823: buf.append("\u00f2");
! 2824: break; // o grave
! 2825: case 153:
! 2826: buf.append("\u00f4");
! 2827: break; // o circumflex
! 2828: case 154:
! 2829: buf.append("\u00f6");
! 2830: break; // o dieresis
! 2831: case 155:
! 2832: buf.append("\u00f5");
! 2833: break; // o tilde
! 2834: case 156:
! 2835: buf.append("\u00fa");
! 2836: break; // u acute
! 2837: case 157:
! 2838: buf.append("\u00f9");
! 2839: break; // u grave
! 2840: case 158:
! 2841: buf.append("\u00fb");
! 2842: break; // u circumflex
! 2843: case 159:
! 2844: buf.append("\u00fc");
! 2845: break; // u dieresis
! 2846: case 160:
! 2847: buf.append("\u1e6d");
! 2848: break; // t underdot
! 2849: case 161:
! 2850: buf.append("\u00b0");
! 2851: break; // degree
! 2852: case 162:
! 2853: buf.append("\u1ebd");
! 2854: break; // e tilde
! 2855: case 163:
! 2856: buf.append("\u00a3");
! 2857: break; // sterling
! 2858: case 164:
! 2859: buf.append("\u00a7");
! 2860: break; // section
! 2861: case 166:
! 2862: buf.append("\u00b6");
! 2863: break; // paragraph
! 2864: case 167:
! 2865: buf.append("\u015b");
! 2866: break; // s acute
! 2867: case 168:
! 2868: buf.append("\u1e5b");
! 2869: break; // r underdot
! 2870: case 169:
! 2871: buf.append("\u1e67");
! 2872: break; // s caron
! 2873: case 171:
! 2874: buf.append("\u0301");
! 2875: break; // acute
! 2876: case 172:
! 2877: buf.append("\u0308");
! 2878: break; // dieresis
! 2879: case 173:
! 2880: buf.append("\u1e6d");
! 2881: break; // t underdot
! 2882: case 174:
! 2883: buf.append("\u00c6");
! 2884: break; // AE
! 2885: case 175:
! 2886: buf.append("\u014d");
! 2887: break; // o macron
! 2888: case 176:
! 2889: buf.append("\u0129");
! 2890: break; // i tilde
! 2891: case 177:
! 2892: buf.append("\u00b1");
! 2893: break; // plusminus
! 2894: case 180:
! 2895: buf.append("\u012b");
! 2896: break; // i macron
! 2897: case 181:
! 2898: buf.append("\u1e43");
! 2899: break; // m underdot
! 2900: case 182:
! 2901: buf.append("\u1e0d");
! 2902: break; // d underdot
! 2903: case 183:
! 2904: buf.append("\u1e63");
! 2905: break; // s underdot
! 2906: case 185:
! 2907: buf.append("\u017a");
! 2908: break; // z acute
! 2909: case 186:
! 2910: buf.append("\u1e45");
! 2911: break; // n overdot
! 2912: case 189:
! 2913: buf.append("\u0169");
! 2914: break; // u tilde
! 2915: case 190:
! 2916: buf.append("\u00e6");
! 2917: break; // ae
! 2918: case 191:
! 2919: buf.append("\u00f8");
! 2920: break; // oslash
! 2921: case 192:
! 2922: buf.append("\u0304\u0306");
! 2923: break; // macron breve
! 2924: case 194:
! 2925: buf.append("\u1e37");
! 2926: break; //
! 2927: case 195:
! 2928: buf.append("j\u0305");
! 2929: break; // j macron [does a single char exist?]
! 2930: case 196:
! 2931: buf.append("\u0103");
! 2932: break; // a breve
! 2933: case 197:
! 2934: buf.append("\u016d");
! 2935: break; // u breve
! 2936: case 200:
! 2937: buf.append("\u1e42");
! 2938: break; // M underdot
! 2939: case 201:
! 2940: buf.append("\u2026");
! 2941: break; // ellipsis
! 2942: case 203:
! 2943: buf.append("\u00c0");
! 2944: break; // A grave
! 2945: case 204:
! 2946: buf.append("\u00c3");
! 2947: break; // A tilde
! 2948: case 205:
! 2949: buf.append("\u00d5");
! 2950: break; // O tilde
! 2951: case 206:
! 2952: buf.append("m\u0306");
! 2953: break; // m breve
! 2954: case 207:
! 2955: buf.append("\u0153");
! 2956: break; // oe
! 2957: case 208:
! 2958: buf.append("\u2013");
! 2959: break; // endash
! 2960: case 209:
! 2961: buf.append("\u2014");
! 2962: break; // emdash
! 2963: case 210:
! 2964: buf.append("\u201c");
! 2965: break; // quotedblleft
! 2966: case 211:
! 2967: buf.append("\u201d");
! 2968: break; // quotedblright
! 2969: case 212:
! 2970: buf.append("\u2018");
! 2971: break; // quoteleft
! 2972: case 213:
! 2973: buf.append("\u2019");
! 2974: break; // quoteright
! 2975: case 214:
! 2976: buf.append("\u1e37");
! 2977: break; // l underring [actually underdot]
! 2978: case 215:
! 2979: buf.append("\u1e41");
! 2980: break; // m overdot
! 2981: case 216:
! 2982: buf.append("n\u0306");
! 2983: break; // n breve
! 2984: case 217:
! 2985: buf.append("\u00d7");
! 2986: break; // multiply
! 2987: case 219:
! 2988: buf.append("\u1e5b");
! 2989: break; // r underring [actually underdot]
! 2990: case 220:
! 2991: buf.append("\u1e44");
! 2992: break; // N overdot
! 2993: case 221:
! 2994: buf.append("\u1e62");
! 2995: break; // S underdot
! 2996: case 222:
! 2997: buf.append("\u1e24");
! 2998: break; // H underdot
! 2999: case 223:
! 3000: buf.append("\u1e0c");
! 3001: break; // D underdot
! 3002: case 224:
! 3003: buf.append("\u2021");
! 3004: break; // daggerdbl
! 3005: case 226:
! 3006: buf.append("\u1e36");
! 3007: break; // L underdot
! 3008: case 227:
! 3009: buf.append("\u0113");
! 3010: break; // e macron
! 3011: case 229:
! 3012: buf.append("\u1e5f");
! 3013: break; // r underbar
! 3014: case 230:
! 3015: buf.append("r\u0324");
! 3016: break; // r underdieresis
! 3017: case 231:
! 3018: buf.append("\u012a");
! 3019: break; // I macron
! 3020: case 232:
! 3021: buf.append("\u016b");
! 3022: break; // u macron
! 3023: case 233:
! 3024: buf.append("\u01e6c");
! 3025: break; // T underdot
! 3026: case 234:
! 3027: buf.append("\u1e64");
! 3028: break; // S acute
! 3029: case 235:
! 3030: buf.append("\u2020");
! 3031: break; // dagger
! 3032: case 236:
! 3033: buf.append("\u0115");
! 3034: break; // e breve
! 3035: case 237:
! 3036: buf.append("\u014f");
! 3037: break; // o breve
! 3038: case 238:
! 3039: buf.append("\u0100");
! 3040: break; // A macron
! 3041: case 239:
! 3042: buf.append("\u1e46");
! 3043: break; // N underdot
! 3044: case 241:
! 3045: buf.append("\u1e3b");
! 3046: break; // l underbar
! 3047: case 242:
! 3048: buf.append("\u016a");
! 3049: break; // U macron
! 3050: case 243:
! 3051: buf.append("\u0179");
! 3052: break; // Z acute
! 3053: case 244:
! 3054: buf.append("\u1e5a");
! 3055: break; // R underdot
! 3056: case 245:
! 3057: buf.append("\u0131");
! 3058: break; // dotlessi
! 3059: case 246:
! 3060: buf.append("\u1e47");
! 3061: break; // n underdot
! 3062: case 247:
! 3063: buf.append("\u1e49");
! 3064: break; // n underbar
! 3065: case 248:
! 3066: buf.append("\u0304");
! 3067: break; // macron
! 3068: case 249:
! 3069: buf.append("\u0306");
! 3070: break; // breve
! 3071: case 250:
! 3072: buf.append("\u1e25");
! 3073: break; // h underdot
! 3074: case 251:
! 3075: buf.append("\u012d");
! 3076: break; // i breve
! 3077: case 252:
! 3078: buf.append("\u0327");
! 3079: break; // cedilla
! 3080: case 253:
! 3081: buf.append("\u030b");
! 3082: break; // hungarumlaut
! 3083: case 254:
! 3084: buf.append("\u0328");
! 3085: break; // ogonek
! 3086: case 255:
! 3087: buf.append("\u030c");
! 3088: break; // caron
! 3089: case 130:
! 3090: buf.append("\u012b\u0303");
! 3091: break; // imacron tilde
! 3092: case 165:
! 3093: buf.append("\u1e5d");
! 3094: break; // runderdot macron
! 3095: case 170:
! 3096: buf.append("\u016b\0306");
! 3097: break; // umacron breve
! 3098: case 178:
! 3099: buf.append("\u0101\u0301");
! 3100: break; // amacron acute
! 3101: case 179:
! 3102: buf.append("\u016b\u0301");
! 3103: break; // umacron acute
! 3104: case 184:
! 3105: buf.append("\u0113\u0301");
! 3106: break; // emacron acute
! 3107: case 187:
! 3108: buf.append("\u0113\u0300");
! 3109: break; // emacron breve
! 3110: case 188:
! 3111: buf.append("\u014d\u0300");
! 3112: break; // omacron breve
! 3113: case 193:
! 3114: buf.append("\u0101\u0306");
! 3115: break; // amacron breve
! 3116: case 198:
! 3117: buf.append("\u0101\u0303");
! 3118: break; // amacron tilde
! 3119: case 199:
! 3120: buf.append("\u012b\u0301");
! 3121: break; // imacron acute
! 3122: case 218:
! 3123: buf.append("\u1e00");
! 3124: break; // runderdotmacron acute
! 3125: case 225:
! 3126: buf.append("\u1e5b\u0301");
! 3127: break; // runderdot acute
! 3128: case 228:
! 3129: buf.append("\u012b\u0306");
! 3130: break; // imacron breve
! 3131: case 240:
! 3132: buf.append("\u016b\u0303");
! 3133: break; // umacron tilde
! 3134: default:
! 3135: buf.append(c);
! 3136: break;
! 3137: }
! 3138: }
! 3139: return buf.toString();
! 3140: }
! 3141:
! 3142: static public String normanToUnicodeNew(String inp)
! 3143: {
! 3144: StringBuffer buf = new StringBuffer();
! 3145: for (int i = 0; i < inp.length(); i++)
! 3146: {
! 3147: char c = inp.charAt(i);
! 3148: switch (c)
! 3149: {
! 3150: case 1:
! 3151: buf.append("\u00d0");
! 3152: break; // Eth
! 3153: case 2:
! 3154: buf.append("\u00f0");
! 3155: break; // eth
! 3156: case 3:
! 3157: buf.append("\u0141");
! 3158: break; // Lslash
! 3159: case 4:
! 3160: buf.append("\u0142");
! 3161: break; // lslash
! 3162: case 5:
! 3163: buf.append("\u0160");
! 3164: break; // S caron
! 3165: case 6:
! 3166: buf.append("\u0161");
! 3167: break; // s caron
! 3168: case 7:
! 3169: buf.append("\u00dd");
! 3170: break; // Y acute
! 3171: case 8:
! 3172: buf.append("\u00fd");
! 3173: break; // y acute
! 3174: case 11:
! 3175: buf.append("\u00de");
! 3176: break; // Thorn
! 3177: case 12:
! 3178: buf.append("\u00fe");
! 3179: break; // thorn
! 3180: case 14:
! 3181: buf.append("\u017d");
! 3182: break; // Z caron
! 3183: case 15:
! 3184: buf.append("\u017e");
! 3185: break; // z caron
! 3186: case 17:
! 3187: buf.append("\u0073");
! 3188: break; // asciitilde
! 3189: case 18:
! 3190: buf.append("j\u0305");
! 3191: break; // j macron [does a single char exist?]
! 3192: case 19:
! 3193: buf.append("^");
! 3194: break; // circumflex
! 3195: case 20:
! 3196: buf.append("\u0303");
! 3197: break; // tilde
! 3198: case 21:
! 3199: buf.append("\u00bd");
! 3200: break; // onehalf
! 3201: case 22:
! 3202: buf.append("\u00bc");
! 3203: break; // onequarter
! 3204: case 23:
! 3205: buf.append("\u00b9");
! 3206: break; // onesuperior
! 3207: case 24:
! 3208: buf.append("\u00be");
! 3209: break; // threequarters
! 3210: case 25:
! 3211: buf.append("\u00b3");
! 3212: break; // threesuperior
! 3213: case 26:
! 3214: buf.append("\u00b2");
! 3215: break; // twosuperior
! 3216: case 27:
! 3217: buf.append("\u00a6");
! 3218: break; // brokenbar
! 3219: case 28:
! 3220: buf.append("-");
! 3221: break; // minus
! 3222: case 29:
! 3223: buf.append("\u00d7");
! 3224: break; // multiply
! 3225: case 39:
! 3226: buf.append("'");
! 3227: break; // quotesingle
! 3228: case 94:
! 3229: buf.append("\u0302");
! 3230: break; // circumflex
! 3231: case 96:
! 3232: buf.append("\u0300");
! 3233: break; // grave
! 3234: case 196:
! 3235: buf.append("\u00c4");
! 3236: break; // A dieresis
! 3237: case 197:
! 3238: buf.append("\u00c5");
! 3239: break; // A ring
! 3240: case 201:
! 3241: buf.append("\u00c9");
! 3242: break; // E acute
! 3243: case 209:
! 3244: buf.append("\u00d1");
! 3245: break; // N tilde
! 3246: case 214:
! 3247: buf.append("\u00d6");
! 3248: break; // O dieresis
! 3249: case 220:
! 3250: buf.append("\u00dc");
! 3251: break; // U dieresis
! 3252: case 225:
! 3253: buf.append("\u00e1");
! 3254: break; // a acute
! 3255: case 224:
! 3256: buf.append("\u00e0");
! 3257: break; // a grave
! 3258: case 226:
! 3259: buf.append("\u00e2");
! 3260: break; // a circumflex
! 3261: case 228:
! 3262: buf.append("\u00e4");
! 3263: break; // a dieresis
! 3264: case 227:
! 3265: buf.append("\u00e3");
! 3266: break; // a tilde
! 3267: case 229:
! 3268: buf.append("\u0101");
! 3269: break; // a macron
! 3270: case 231:
! 3271: buf.append("\u00e7");
! 3272: break; // c cedilla
! 3273: case 233:
! 3274: buf.append("\u00e9");
! 3275: break; // e acute
! 3276: case 232:
! 3277: buf.append("\u00e8");
! 3278: break; // e grave
! 3279: case 234:
! 3280: buf.append("\u00ea");
! 3281: break; // e circumflex
! 3282: case 235:
! 3283: buf.append("\u00eb");
! 3284: break; // e dieresis
! 3285: case 237:
! 3286: buf.append("\u00ed");
! 3287: break; // i acute
! 3288: case 236:
! 3289: buf.append("\u00ec");
! 3290: break; // i grave
! 3291: case 238:
! 3292: buf.append("\u00ee");
! 3293: break; // i circumflex
! 3294: case 239:
! 3295: buf.append("\u00ef");
! 3296: break; // i dieresis
! 3297: case 241:
! 3298: buf.append("\u00f1");
! 3299: break; // n tilde
! 3300: case 243:
! 3301: buf.append("\u00f3");
! 3302: break; // o acute
! 3303: case 242:
! 3304: buf.append("\u00f2");
! 3305: break; // o grave
! 3306: case 244:
! 3307: buf.append("\u00f4");
! 3308: break; // o circumflex
! 3309: case 246:
! 3310: buf.append("\u00f6");
! 3311: break; // o dieresis
! 3312: case 245:
! 3313: buf.append("\u00f5");
! 3314: break; // o tilde
! 3315: case 250:
! 3316: buf.append("\u00fa");
! 3317: break; // u acute
! 3318: case 249:
! 3319: buf.append("\u00f9");
! 3320: break; // u grave
! 3321: case 251:
! 3322: buf.append("\u00fb");
! 3323: break; // u circumflex
! 3324: case 252:
! 3325: buf.append("\u00fc");
! 3326: break; // u dieresis
! 3327: case 8224:
! 3328: buf.append("\u1e6d");
! 3329: break; // t underdot
! 3330: case 176:
! 3331: buf.append("\u00b0");
! 3332: break; // degree
! 3333: case 162:
! 3334: buf.append("\u1ebd");
! 3335: break; // e tilde
! 3336: case 163:
! 3337: buf.append("\u00a3");
! 3338: break; // sterling
! 3339: case 167:
! 3340: buf.append("\u00a7");
! 3341: break; // section
! 3342: case 182:
! 3343: buf.append("\u00b6");
! 3344: break; // paragraph
! 3345: case 223:
! 3346: buf.append("\u015b");
! 3347: break; // s acute
! 3348: case 174:
! 3349: buf.append("\u1e5b");
! 3350: break; // r underdot
! 3351: case 169:
! 3352: buf.append("\u1e45");
! 3353: break; // n overdot
! 3354: case 180:
! 3355: buf.append("\u0301");
! 3356: break; // acute
! 3357: case 168:
! 3358: buf.append("\u0308");
! 3359: break; // dieresis
! 3360: case 8800:
! 3361: buf.append("\u1e6d");
! 3362: break; // t underdot
! 3363: case 198:
! 3364: buf.append("\u00c6");
! 3365: break; // AE
! 3366: case 216:
! 3367: buf.append("\u014d");
! 3368: break; // o macron
! 3369: case 8734:
! 3370: buf.append("\u0129");
! 3371: break; // i tilde
! 3372: case 177:
! 3373: buf.append("\u00b1");
! 3374: break; // plusminus
! 3375: case 165:
! 3376: buf.append("\u012b");
! 3377: break; // i macron
! 3378: case 181:
! 3379: buf.append("\u1e43");
! 3380: break; // m underdot
! 3381: case 8706:
! 3382: buf.append("\u1e0d");
! 3383: break; // d underdot
! 3384: case 8721:
! 3385: buf.append("\u1e63");
! 3386: break; // s underdot
! 3387: case 960:
! 3388: buf.append("\u017a");
! 3389: break; // z acute
! 3390: case 8747:
! 3391: buf.append("\u1e45");
! 3392: break; // n overdot
! 3393: case 937:
! 3394: buf.append("\u0169");
! 3395: break; // u tilde
! 3396: case 230:
! 3397: buf.append("\u00e6");
! 3398: break; // ae
! 3399: case 248:
! 3400: buf.append("\u00f8");
! 3401: break; // oslash
! 3402: case 191:
! 3403: buf.append("\u0304\u0306");
! 3404: break; // macron breve
! 3405: case 172:
! 3406: buf.append("\u1e37");
! 3407: break; //
! 3408: case 8730:
! 3409: buf.append("j\u0305");
! 3410: break; // j macron [does a single char exist?]
! 3411: case 402:
! 3412: buf.append("\u0103");
! 3413: break; // a breve
! 3414: case 8776:
! 3415: buf.append("\u016d");
! 3416: break; // u breve
! 3417: case 187:
! 3418: buf.append("\u1e42");
! 3419: break; // M underdot
! 3420: case 8230:
! 3421: buf.append("\u2026");
! 3422: break; // ellipsis
! 3423: case 192:
! 3424: buf.append("\u00c0");
! 3425: break; // A grave
! 3426: case 195:
! 3427: buf.append("\u00c3");
! 3428: break; // A tilde
! 3429: case 213:
! 3430: buf.append("\u00d5");
! 3431: break; // O tilde
! 3432: case 338:
! 3433: buf.append("m\u0306");
! 3434: break; // m breve
! 3435: case 339:
! 3436: buf.append("\u0153");
! 3437: break; // oe
! 3438: case 8211:
! 3439: buf.append("\u2013");
! 3440: break; // endash
! 3441: case 8212:
! 3442: buf.append("\u2014");
! 3443: break; // emdash
! 3444: case 8220:
! 3445: buf.append("\u201c");
! 3446: break; // quotedblleft
! 3447: case 8221:
! 3448: buf.append("\u201d");
! 3449: break; // quotedblright
! 3450: case 8216:
! 3451: buf.append("\u2018");
! 3452: break; // quoteleft
! 3453: case 8217:
! 3454: buf.append("\u2019");
! 3455: break; // quoteright
! 3456: case 247:
! 3457: buf.append("\u1e37");
! 3458: break; // l underring [actually underdot]
! 3459: case 9674:
! 3460: buf.append("\u1e41");
! 3461: break; // m overdot
! 3462: case 255:
! 3463: buf.append("n\u0306");
! 3464: break; // n breve
! 3465: case 376:
! 3466: buf.append("\u00d7");
! 3467: break; // multiply
! 3468: case 8364:
! 3469: buf.append("\u1e5b");
! 3470: break; // r underring [actually underdot]
! 3471: case 8249:
! 3472: buf.append("\u1e44");
! 3473: break; // N overdot
! 3474: case 8250:
! 3475: buf.append("\u1e62");
! 3476: break; // S underdot
! 3477: case 64257:
! 3478: buf.append("\u1e24");
! 3479: break; // H underdot
! 3480: case 64258:
! 3481: buf.append("\u1e0c");
! 3482: break; // D underdot
! 3483: case 8225:
! 3484: buf.append("\u2021");
! 3485: break; // daggerdbl
! 3486: case 8218:
! 3487: buf.append("\u1e36");
! 3488: break; // L underdot
! 3489: case 8222:
! 3490: buf.append("\u0113");
! 3491: break; // e macron
! 3492: case 194:
! 3493: buf.append("\u1e5f");
! 3494: break; // r underbar
! 3495: case 202:
! 3496: buf.append("r\u0324");
! 3497: break; // r underdieresis
! 3498: case 193:
! 3499: buf.append("\u012a");
! 3500: break; // I macron
! 3501: case 203:
! 3502: buf.append("\u016b");
! 3503: break; // u macron
! 3504: case 200:
! 3505: buf.append("\u1e6c");
! 3506: break; // T underdot
! 3507: case 205:
! 3508: buf.append("\u1e64");
! 3509: break; // S acute
! 3510: case 206:
! 3511: buf.append("\u2020");
! 3512: break; // dagger
! 3513: case 207:
! 3514: buf.append("\u0115");
! 3515: break; // e breve
! 3516: case 204:
! 3517: buf.append("\u014f");
! 3518: break; // o breve
! 3519: case 211:
! 3520: buf.append("\u0100");
! 3521: break; // A macron
! 3522: case 212:
! 3523: buf.append("\u1e46");
! 3524: break; // N underdot
! 3525: case 210:
! 3526: buf.append("\u1e3b");
! 3527: break; // l underbar
! 3528: case 218:
! 3529: buf.append("\u016a");
! 3530: break; // U macron
! 3531: case 219:
! 3532: buf.append("\u0179");
! 3533: break; // Z acute
! 3534: case 217:
! 3535: buf.append("\u1e5a");
! 3536: break; // R underdot
! 3537: case 305:
! 3538: buf.append("\u0131");
! 3539: break; // dotlessi
! 3540: case 710:
! 3541: buf.append("\u1e47");
! 3542: break; // n underdot
! 3543: case 732:
! 3544: buf.append("\u1e49");
! 3545: break; // n underbar
! 3546: case 175:
! 3547: buf.append("\u0304");
! 3548: break; // macron
! 3549: case 728:
! 3550: buf.append("\u0306");
! 3551: break; // breve
! 3552: case 729:
! 3553: buf.append("\u1e25");
! 3554: break; // h underdot
! 3555: case 730:
! 3556: buf.append("\u012d");
! 3557: break; // i breve
! 3558: case 184:
! 3559: buf.append("\u0327");
! 3560: break; // cedilla
! 3561: case 733:
! 3562: buf.append("\u030b");
! 3563: break; // hungarumlaut
! 3564: case 731:
! 3565: buf.append("\u0328");
! 3566: break; // ogonek
! 3567: case 711:
! 3568: buf.append("\u030c");
! 3569: break; // caron
! 3570: case 199:
! 3571: buf.append("\u012b\u0303");
! 3572: break; // imacron tilde
! 3573: case 8226:
! 3574: buf.append("\u1e5d");
! 3575: break; // runderdot macron
! 3576: case 8482:
! 3577: buf.append("\u016b\0306");
! 3578: break; // umacron breve
! 3579: case 8804:
! 3580: buf.append("\u0101\u0301");
! 3581: break; // amacron acute
! 3582: case 8805:
! 3583: buf.append("\u016b\u0301");
! 3584: break; // umacron acute
! 3585: case 8719:
! 3586: buf.append("\u0113\u0301");
! 3587: break; // emacron acute
! 3588: case 170:
! 3589: buf.append("\u0113\u0300");
! 3590: break; // emacron breve
! 3591: case 186:
! 3592: buf.append("\u014d\u0300");
! 3593: break; // omacron breve
! 3594: case 161:
! 3595: buf.append("\u0101\u0306");
! 3596: break; // amacron breve
! 3597: case 8710:
! 3598: buf.append("\u0101\u0303");
! 3599: break; // amacron tilde
! 3600: case 171:
! 3601: buf.append("\u012b\u0301");
! 3602: break; // imacron acute
! 3603: case 8260:
! 3604: buf.append("\u1e00");
! 3605: break; // runderdotmacron acute
! 3606: case 183:
! 3607: buf.append("\u1e5b\u0301");
! 3608: break; // runderdot acute
! 3609: case 8240:
! 3610: buf.append("\u012b\u0306");
! 3611: break; // imacron breve
! 3612: case 63743:
! 3613: buf.append("\u016b\u0303");
! 3614: break; // umacron tilde
! 3615: default:
! 3616: buf.append(c);
! 3617: break;
! 3618: }
! 3619: }
! 3620: return buf.toString();
! 3621: }
! 3622:
! 3623: public static ConversionProperties getFieldNamesAndDestTableName(String create, String query,
! 3624: String tableName)
! 3625: {
! 3626: String[] fieldNames = null;
! 3627: String destTableName = null;
! 3628: // determine destTableName from createStatement or from source table
! 3629: // name
! 3630: if (!create.equals(""))
! 3631: {
! 3632: int fromIndex = create.toLowerCase().indexOf("table") + 5;
! 3633: int toIndex = create.indexOf("(");
! 3634: int endIndex = create.indexOf(")", toIndex);
! 3635:
! 3636: destTableName = create.substring(fromIndex, toIndex).replaceAll(beanDest.getQC(), "").trim();
! 3637: System.out.println("destTable " + destTableName);
! 3638: // retrieve field_names from select statement
! 3639: // TODO problem with different fieldNames in create statement will
! 3640: // overwrite them
! 3641: if (query.indexOf("*") < 0)
! 3642: {
! 3643: int selectEndIndex = query.indexOf("from");
! 3644: StringTokenizer tokenizer = new StringTokenizer(query.substring(6, selectEndIndex), ",");
! 3645: int numFields = tokenizer.countTokens();
! 3646: fieldNames = new String[numFields];
! 3647: int fieldIndex = 0;
! 3648: while (tokenizer.hasMoreTokens())
! 3649: {
! 3650: String fieldName = tokenizer.nextToken().trim();
! 3651: fieldNames[fieldIndex] = convertText(fieldName);
! 3652: System.out.println(fieldNames[fieldIndex]);
! 3653: fieldIndex++;
! 3654: }
! 3655:
! 3656: } else
! 3657: {
! 3658: // use create statement for field names
! 3659: StringTokenizer tokenizer = new StringTokenizer(create.substring(toIndex + 1, endIndex),
! 3660: ",");
! 3661: int numFields = tokenizer.countTokens();
! 3662: fieldNames = new String[numFields];
! 3663: int fieldIndex = 0;
! 3664: while (tokenizer.hasMoreTokens())
! 3665: {
! 3666: String fieldName = tokenizer.nextToken().trim();
! 3667: int index = fieldName.lastIndexOf(" ");
! 3668: fieldNames[fieldIndex] = fieldName.substring(0, index);
! 3669: System.out.println(fieldNames[fieldIndex]);
! 3670: fieldIndex++;
! 3671: }
! 3672: }
! 3673: } else
! 3674: {
! 3675: destTableName = convertText(tableName);
! 3676:
! 3677: // retrieve field_names from select statement
! 3678: if (query.indexOf("*") < 0)
! 3679: {
! 3680: int selectEndIndex = query.indexOf("from");
! 3681: StringTokenizer tokenizer = new StringTokenizer(query.substring(6, selectEndIndex), ",");
! 3682: int numFields = tokenizer.countTokens();
! 3683: fieldNames = new String[numFields];
! 3684: int fieldIndex = 0;
! 3685: while (tokenizer.hasMoreTokens())
! 3686: {
! 3687: String fieldName = tokenizer.nextToken().trim();
! 3688: fieldNames[fieldIndex] = beanDest.getQC() + convertText(fieldName) + beanDest.getQC();
! 3689: // System.out.println("field "+ fieldNames[fieldIndex]);
! 3690: fieldIndex++;
! 3691: }
! 3692:
! 3693: } else
! 3694: {
! 3695: Vector fieldNamesVec = bean.getColumnNames();
! 3696: fieldNames = new String[fieldNamesVec.size()];
! 3697: int fieldIndex = -1;
! 3698: for (Iterator iter = fieldNamesVec.iterator(); iter.hasNext();)
! 3699: {
! 3700: String element = (String) iter.next();
! 3701: fieldNames[++fieldIndex] = beanDest.getQC() + convertText(element) + beanDest.getQC();
! 3702: // System.out.println("field " + fieldNames[fieldIndex]);
! 3703: }
! 3704: }
! 3705: }
! 3706: return new ConversionProperties(destTableName, fieldNames);
! 3707: }
! 3708:
! 3709: /**
! 3710: * creates an insert into statement for the specified table and given field
! 3711: * names
! 3712: *
! 3713: * @param destTableName
! 3714: * @param fieldNames
! 3715: * @return
! 3716: */
! 3717: public static StringBuffer createInsertCommand(String destTableName, String[] fieldNames)
! 3718: {
! 3719: StringBuffer command = new StringBuffer();
! 3720: command.append("INSERT INTO ");
! 3721: command.append(beanDest.getQC());
! 3722: command.append(destTableName); // convertText((String)
! 3723: // names.get(tbIndex)));
! 3724: command.append(beanDest.getQC());
! 3725: command.append(" (");
! 3726: for (int i = 0; i < fieldNames.length; i++)
! 3727: {
! 3728: command.append(fieldNames[i]);
! 3729: if (i < fieldNames.length - 1)
! 3730: command.append(",");
! 3731: }
! 3732: command.append(") ");
! 3733:
! 3734: command.append(" values ( ");
! 3735: // add a question marks for every field
! 3736: for (int i = 0; i < fieldNames.length - 1; ++i)
! 3737: command.append("?,");
! 3738: command.append("?)");
! 3739: return command;
! 3740: }
! 3741:
! 3742: public static StringBuffer createUpdateCommand(String destTableName, String[] fieldNames,
! 3743: String id)
! 3744: {
! 3745: StringBuffer command = new StringBuffer();
! 3746:
! 3747: command.append("UPDATE ");
! 3748: command.append(beanDest.getQC());
! 3749: command.append(destTableName);
! 3750: command.append(beanDest.getQC());
! 3751: command.append(" SET ");
! 3752:
! 3753: int size = bean.getColumnNames().size();
! 3754: for (int i = 0; i < size - 1; ++i)
! 3755: command.append(fieldNames[i] + " = ? ,");
! 3756: command.append(fieldNames[size - 1] + " = ? ");
! 3757: command.append("WHERE " + id + " = ?");
! 3758: return command;
! 3759: }
! 3760:
! 3761: public static StringBuffer createDeleteCommand(String destTableName, String idField)
! 3762: {
! 3763: StringBuffer command = new StringBuffer();
! 3764:
! 3765: command.append("DELETE FROM");
! 3766: command.append(beanDest.getQC());
! 3767: command.append(destTableName);
! 3768: // command.append(convertText((String) names.get(tbIndex)));
! 3769: command.append(beanDest.getQC());
! 3770: command.append("WHERE " + idField + " = ?");
! 3771: return command;
! 3772: }
! 3773:
! 3774: public void makeTest(String table, String idField, String tempQuery) throws Exception
! 3775: {
! 3776: int counter = 0;
! 3777:
! 3778: // ****** test code *****
! 3779:
! 3780: bean.getConnection();
! 3781: ResultSet resultSet = null;
! 3782: String lastResult = "P227634.11";// "P227625.79554";//"P227625.77391";//"P116034.970998";
! 3783: String myQuery = "select " + bean.getQC() + idField + bean.getQC() + ",serial " + " from "
! 3784: + bean.getQC() + table + bean.getQC();
! 3785: System.out.println("Query is now " + myQuery);
! 3786: JDialog statusDialog = new JDialog();
! 3787: statusDialog.setTitle("Status Information");
! 3788: JLabel status = new JLabel("actual DataSet : ");
! 3789: JLabel status2 = new JLabel(Integer.toString(++counter));
! 3790: JLabel status3 = new JLabel(lastResult);
! 3791:
! 3792: JPanel statusPanel = new JPanel();
! 3793: JPanel statusPanel2 = new JPanel();
! 3794: statusPanel.add(status);
! 3795: statusPanel.add(status2);
! 3796: statusPanel2.add(status3);
! 3797: statusDialog.getContentPane().add(statusPanel, "North");
! 3798: statusDialog.getContentPane().add(statusPanel2, "Center");
! 3799: statusDialog.setLocation(400, 500);
! 3800: statusDialog.setSize(300, 150);
! 3801: statusDialog.setVisible(true);
! 3802: while (true)
! 3803: {
! 3804: if (!statusDialog.isVisible())
! 3805: statusDialog.setVisible(true);
! 3806: tempQuery = myQuery + " where " + bean.getQC() + idField + bean.getQC() + ">'" + lastResult
! 3807: + "'";
! 3808: resultSet = bean.makeQuery(tempQuery, 1);
! 3809: if (resultSet == null)
! 3810: {
! 3811: System.out.println("lastResult was " + lastResult + " counter was " + counter);
! 3812: break;
! 3813: } else
! 3814: {
! 3815: resultSet.next();
! 3816: lastResult = resultSet.getString(1);
! 3817: counter++;
! 3818: status2.setText(Integer.toString(counter));
! 3819: status3.setText(lastResult + " " + resultSet.getString(2));
! 3820: if (counter % 100 == 0)
! 3821: {
! 3822: System.out.println("actual Result was " + lastResult + " counter was " + counter);
! 3823: // break;
! 3824: }
! 3825: }
! 3826: resultSet = null;
! 3827: }
! 3828: System.exit(0);
1.1 rogo 3829:
1.4 ! rogo 3830: // ****** end Test ******
1.1 rogo 3831:
1.4 ! rogo 3832: }
1.1 rogo 3833: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/cvs/cvsweb/icons/back.gif){kind=icon}
Return to Convert.java CVS log ![[TXT]](/cvs/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvs/cvsweb/icons/dir.gif){kind=icon}
Up to [Repository] / FM2SQL / src