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