Annotation of FM2SQL/Convert.java, revision 1.1
1.1 ! rogo 1:
! 2:
! 3: import java.util.*;
! 4: import java.sql.*;
! 5: import java.awt.Cursor;
! 6: import java.io.BufferedReader;
! 7: import java.io.BufferedWriter;
! 8: import java.io.File;
! 9: import java.io.FileInputStream;
! 10: import java.io.FileNotFoundException;
! 11: import java.io.FileOutputStream;
! 12: import java.io.InputStreamReader;
! 13: import java.io.OutputStreamWriter;
! 14: import java.io.PrintStream;
! 15: import java.io.UnsupportedEncodingException;
! 16:
! 17: import com.exploringxml.xml.Node;
! 18: import com.exploringxml.xml.Xparse;
! 19:
! 20: class Convert
! 21: {
! 22: static DBBean bean = new DBBean();
! 23: static DBBean beanDest = new DBBean();
! 24:
! 25: static String user ="",passwd="e1nste1n";
! 26: static String userDest="postgres",passwdDest="rogo";
! 27: static boolean batchRun=false;
! 28: static Vector databases = new Vector();
! 29:
! 30: public static void main(String args[])
! 31: {
! 32: /* try
! 33: {
! 34: //byte[] b = "ö".getBytes("UTF-8");
! 35: // System.out.println("QueryString " +b[0]+" "+b[1]+(new String(b).getBytes()[0])+" "+new String(b).getBytes()[1]);
! 36: //System.out.println(new String(b,"UTF-8"));
! 37: } catch (UnsupportedEncodingException e)
! 38: {
! 39: // TODO Auto-generated catch block
! 40: e.printStackTrace();
! 41: }*/
! 42: FileOutputStream file = null;
! 43: if(args.length!=1)
! 44: {
! 45: System.out.println("Usage: java Convert <xml config file>");
! 46: System.exit(-1);
! 47: }
! 48: if(!(new File(args[0]).exists())) System.exit(0);
! 49: try
! 50: {
! 51: file = new FileOutputStream("./log.txt");
! 52: } catch (FileNotFoundException e1)
! 53: {
! 54: // TODO Auto-generated catch block
! 55: e1.printStackTrace();
! 56: }
! 57: PrintStream stream= new PrintStream(file);
! 58: System.setOut(stream);
! 59: System.setErr(stream);
! 60: readXMLFile(args[0]);
! 61: System.out.println("Finished!");
! 62: //convert("jdbc:fmpro:http://141.14.237.74:8050","jdbc:postgresql://erebos/test",null,null);
! 63: }
! 64: public static void convertBatch(DBBean source,DBBean destination,Vector names,Vector layouts,Vector selects,Vector creates) throws Exception
! 65: {
! 66: // @TODO Convert change to convert row wise
! 67: /*FM2SQL.ProgressDialog dialog = new FM2SQL.ProgressDialog(FM2SQL.fmInstance);
! 68: dialog.setTitle("Conversion running ...");
! 69: dialog.title.setText("Getting table data ...");
! 70: dialog.setLocation(500,500);
! 71: dialog.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR));
! 72: */
! 73: // FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR));
! 74: //dialog.thread=Thread.currentThread();
! 75: bean=source;
! 76: beanDest = destination;
! 77: /* // setting user and passwd
! 78: bean.setUserAndPasswd(user,passwd);
! 79: // setting user and passwd
! 80: beanDest.setUserAndPasswd(userDest,passwdDest);
! 81: */
! 82: //dialog.setSize(400,250);
! 83: StringBuffer command= null;
! 84: try
! 85: {
! 86: //bean.setConnection("jdbc:fmpro:http://141.14.237.74:8050");
! 87: //bean.setConnection("jdbc:postgresql://erebos/test","postgres","rogo");
! 88: bean.setConnection(source.url);
! 89: if(names==null)
! 90: names=bean.getTableNames();
! 91: //Collections.sort(names);
! 92: int tbIndex = 1;
! 93:
! 94: // System.out.println("Start at "+names.indexOf("archimedes_facsimiles"));
! 95: for(tbIndex=0;tbIndex<names.size();++tbIndex)
! 96: {
! 97: Vector[] result = null;
! 98: try {
! 99: String query = "select * from " + bean.getQC() +names.get(tbIndex).toString() + bean.getQC();
! 100: String layout=(layouts.isEmpty()) ? "":layouts.get(tbIndex).toString();
! 101: query = (selects!=null) ? selects.get(tbIndex).toString():query;
! 102: //if vectors[1].get(i) != null)
! 103: if (!layout.equals(""))
! 104: {
! 105: System.out.println("before "+query+" table"+names.get(tbIndex));
! 106: layout = " layout " + bean.getQC() + layout + bean.getQC();
! 107: String name = names.get(tbIndex).toString();
! 108: StringBuffer queryLayout = new StringBuffer(query);
! 109: queryLayout.insert(queryLayout.indexOf(name) + name.length() + 1, " " + layout);
! 110: query = queryLayout.toString();
! 111: System.out.println("added layout " + query);
! 112:
! 113: }
! 114: // if ( layout!= "")
! 115: // query += " layout " + bean.getQC() + layout + bean.getQC();
! 116: /* dialog.title.setText("Getting table data ...");
! 117: dialog.table.setText(names.get(tbIndex).toString());
! 118: dialog.status.setText("Table " + (tbIndex + 1) + " of " + names.size());
! 119: dialog.show();
! 120: */
! 121: System.out.println(" performing query "+query);
! 122: //result = bean.getQueryData(query, null, 0);
! 123: bean.getConnection();
! 124: bean.makeQuery(query,0);
! 125: } catch (Exception e)
! 126: {
! 127: System.out.println(e.getMessage());
! 128: e.printStackTrace();
! 129: continue;
! 130: }
! 131: //beanDest.setConnection("jdbc:postgresql://erebos/test3");
! 132: beanDest.setConnection(destination.url);
! 133:
! 134: Statement stm = beanDest.getConnection().createStatement();
! 135:
! 136: Vector tables = beanDest.getTableNames();
! 137: // Collections.sort(tables);
! 138: System.out.println("converting table "+names.get(tbIndex) + " " + tables.indexOf(convertText((String) names.get(tbIndex)))); // "//beanDest.getTypeNames());
! 139: tables = beanDest.getTableNames();
! 140: // System.out.println(beanDest.getTableNames(beanDest.getCatalogs().get(2).toString()));
! 141: stm = beanDest.getConnection().createStatement();
! 142: // System.exit(0);
! 143: if(true)
! 144: {
! 145: if(tables.indexOf(names.get(tbIndex))>=0)
! 146: {
! 147: stm.executeUpdate("drop table "+beanDest.getQC()+names.get(tbIndex)+beanDest.getQC());
! 148: tables.remove((String)names.get(tbIndex));
! 149: System.out.println("dropped table "+ names.get(tbIndex));
! 150: }
! 151: else
! 152: if(tables.indexOf(convertText(names.get(tbIndex).toString()))>=0)
! 153: {
! 154: stm.executeUpdate("drop table "+beanDest.getQC()+convertText((String)names.get(tbIndex))+beanDest.getQC());
! 155: tables.remove(convertText((String)names.get(tbIndex)));
! 156: System.out.println("dropped table "+ names.get(tbIndex));
! 157: }
! 158:
! 159: if(tables.indexOf(names.get(tbIndex))<0&&tables.indexOf(convertText(names.get(tbIndex).toString()))<0)
! 160: {
! 161: if(creates.get(tbIndex).equals("")||creates.get(tbIndex).toString().toLowerCase().indexOf("create")<0)
! 162: {
! 163: System.out.println("Warning empty or invalid create statement - creating one for you\n");
! 164:
! 165: command = new StringBuffer(50);
! 166: command.append("CREATE TABLE ");
! 167: command.append(beanDest.getQC());
! 168: command.append(convertText((String)names.get(tbIndex)));
! 169: command.append(beanDest.getQC());
! 170: command.append("(");
! 171: String type = null;
! 172: Vector columnNames=bean.getColumnNames();
! 173: for(int i=0;i<columnNames.size()-1;++i)
! 174: {
! 175: type = bean.metaData.getColumnTypeName(i+1);
! 176: // System.out.println(i+" "+result[1].get(i)+" "+type);
! 177: type = (type.equals("NUMBER")) ?"INT4":type;
! 178: type = (type.equals("CONTAINER")) ?"TEXT":type;
! 179:
! 180: command.append(beanDest.getQC() + convertText((String) columnNames.get(i)) + beanDest.getQC() + " " + type + ", ");
! 181: }
! 182: type = bean.metaData.getColumnTypeName(columnNames.size());
! 183: type = (type.equals("NUMBER")) ? "INT4" : type;
! 184: type = (type.equals("CONTAINER")) ? "TEXT" : type;
! 185: command.append(beanDest.getQC() + convertText((String) columnNames.get(columnNames.size() - 1)) + beanDest.getQC() + " " + type);
! 186: command.append(" )");
! 187: }
! 188: else
! 189: command=new StringBuffer().append(creates.get(tbIndex).toString());
! 190:
! 191: System.out.println(command);
! 192: // System.exit(0);
! 193: //command.append(DBBean.getQC());
! 194: stm.executeUpdate(command.toString());
! 195:
! 196: }
! 197: }
! 198: // System.out.println(names);
! 199: /*
! 200: if (idVal == "")
! 201: stm.executeUpdate("INSERT INTO " + DBBean.getQC() + box.getSelectedItem() + DBBean.getQC() + " (" + DBBean.getQC() + columnName + DBBean.getQC() + ") VALUES ('" + value + "') ");
! 202: else
! 203: stm.executeUpdate("UPDATE " + DBBean.getQC() + box.getSelectedItem() + DBBean.getQC() + " SET " + DBBean.getQC() + columnName + DBBean.getQC() + "='" + value + "' WHERE ID='" + idVal + "' ");
! 204: */
! 205:
! 206: // Vector[] result2=beanDest.getQueryData(names.get(tbIndex).toString());
! 207: // print results to screen
! 208: /* for (int i = 0; i < result[1].size(); ++i)
! 209: {
! 210: //print Header
! 211: // System.out.println(" "+result[1].get(i)+" "+result2[1].get(i)+" "+i);
! 212: }*/
! 213: // System.out.println();
! 214: //dialog.title.setText("Writing table data ...");
! 215: Vector row = null;
! 216: //for (int j = 0; j < result[0].size(); ++j)
! 217: while((row=bean.getNextRow())!=null)
! 218: {
! 219: //Vector row = (Vector) result[0].get(j);
! 220: command = new StringBuffer();
! 221:
! 222: command.append("INSERT INTO ");
! 223: command.append(beanDest.getQC());
! 224: command.append(convertText((String) names.get(tbIndex)));
! 225: command.append(beanDest.getQC());
! 226: command.append(" values ( ");
! 227: //print rows
! 228: Object obj = null;
! 229: for(int k=0;k<row.size()-1;++k)
! 230: {
! 231: obj = row.get(k);
! 232: //System.out.println("row "+obj+" "+k);
! 233: if(obj!=null&&!(obj instanceof ArrayList))
! 234: command.append("'"+convertUml(new String(obj.toString().getBytes("UTF-8"),"UTF-8"))+"',");
! 235: else if(obj!=null&& obj instanceof ArrayList)
! 236: command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"',");
! 237: else command.append("NULL,");
! 238: }
! 239: obj = row.get(row.size() - 1);
! 240: if (obj != null && !(obj instanceof ArrayList))
! 241: command.append("'"+convertUml(new String(obj.toString().getBytes("UTF-8"),"UTF-8"))+"')");
! 242: else
! 243: if(obj!=null&& obj instanceof ArrayList)
! 244: command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"')"); //command.append(obj.toString()+")");
! 245: else command.append("NULL)");
! 246: //command.append("'"+row.get(row.size()-1)+"')");
! 247: //command.append(" )");
! 248: // for(int k=0;k<row.size();++k)
! 249:
! 250: // System.out.println();
! 251: // System.out.println(command+" "+j+" "+row.size()+" "+ ((Vector)result2[0].get(j)).size());
! 252: // System.out.println(command);
! 253: stm.executeUpdate(command.toString());
! 254: // dialog.progress.setValue((int)(((double)(j+1)/(double)result[0].size())*100.0));
! 255: // System.out.println( (int)(((double)(j+1)/(double)result[0].size())*100.0)+" "+result[0].size()+" "+j);
! 256: command = null;
! 257: }// to for loop
! 258:
! 259: }
! 260: } catch(Exception e)
! 261: {
! 262: System.out.println("Error while connecting to database "+ e);
! 263: //dialog.setVisible(false);
! 264: //dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 265: //FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 266: java.io.ByteArrayOutputStream b = new java.io.ByteArrayOutputStream();
! 267: java.io.PrintStream stream = new java.io.PrintStream(b);
! 268: stream.print(command+"\n\n");
! 269: e.printStackTrace(stream);
! 270: System.err.println(b);
! 271: //FM2SQL.showErrorDialog(b.toString(), "Error occured !");
! 272:
! 273: }
! 274: // dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 275: //FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 276:
! 277: // dialog.setVisible(false);
! 278: }
! 279:
! 280:
! 281:
! 282: public static void convert(String source,String destination,Vector names,Vector layouts,Vector selects,Vector creates) throws Exception
! 283: {
! 284: FM2SQL.ProgressDialog dialog = new FM2SQL.ProgressDialog(FM2SQL.fmInstance);
! 285: dialog.setTitle("Conversion running ...");
! 286: dialog.title.setText("Getting table data ...");
! 287: dialog.setLocation(FM2SQL.fmInstance.getLocationOnScreen().x+(FM2SQL.fmInstance.getWidth()-400)/2,FM2SQL.fmInstance.getLocationOnScreen().y+(FM2SQL.fmInstance.getHeight()-250)/2);
! 288: dialog.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR));
! 289: FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR));
! 290: dialog.thread=Thread.currentThread();
! 291: // setting user and passwd
! 292: bean.setUserAndPasswd(user,passwd);
! 293: // setting user and passwd
! 294: beanDest.setUserAndPasswd(userDest,passwdDest);
! 295: dialog.setSize(400,250);
! 296: StringBuffer command= null;
! 297: String query = null;
! 298: try
! 299: {
! 300: //bean.setConnection("jdbc:fmpro:http://141.14.237.74:8050");
! 301: //bean.setConnection("jdbc:postgresql://erebos/test","postgres","rogo");
! 302: bean.setConnection(source);
! 303: if(names==null)
! 304: names=bean.getTableNames();
! 305: // Collections.sort(names);
! 306: int tbIndex = 1;
! 307:
! 308: // System.out.println("Start at "+names.indexOf("archimedes_facsimiles"));
! 309: for(tbIndex=0;tbIndex<names.size();++tbIndex)
! 310: {
! 311: Vector[] result = null;
! 312: try {
! 313: query = "select * from " + bean.getQC() +names.get(tbIndex).toString() + bean.getQC();
! 314: String layout=(layouts.isEmpty()) ? "":layouts.get(tbIndex).toString();
! 315: query = (selects!=null) ? selects.get(tbIndex).toString():query;
! 316: //if vectors[1].get(i) != null)
! 317: if (layout != "")
! 318: {
! 319: layout = " layout " + bean.getQC() + layout + bean.getQC();
! 320: String name = names.get(tbIndex).toString();
! 321: StringBuffer queryLayout = new StringBuffer(query);
! 322: queryLayout.insert(queryLayout.indexOf(name) + name.length() + 1, " " + layout);
! 323: query = queryLayout.toString();
! 324: System.out.println("added layout "+ query);
! 325:
! 326: }
! 327: // if ( layout!= "")
! 328: // query += " layout " + bean.getQC() + layout + bean.getQC();
! 329: dialog.title.setText("Getting table data ...");
! 330: dialog.table.setText(names.get(tbIndex).toString());
! 331: dialog.status.setText("Table " + (tbIndex + 1) + " of " + names.size());
! 332: dialog.show();
! 333: //result = bean.getQueryData(query, dialog, 0);
! 334: bean.getConnection();
! 335: bean.makeQuery(query,0);
! 336: } catch (Exception e)
! 337: {
! 338: continue;
! 339: }
! 340: //beanDest.setConnection("jdbc:postgresql://erebos/test3");
! 341: beanDest.setConnection(destination);
! 342:
! 343: Statement stm = beanDest.getConnection().createStatement();
! 344:
! 345: Vector tables = beanDest.getTableNames();
! 346: // Collections.sort(tables);
! 347: System.out.println(names.get(tbIndex) + " " + tables.indexOf(convertText((String) names.get(tbIndex)))); // "//beanDest.getTypeNames());
! 348: tables = beanDest.getTableNames();
! 349: // System.out.println(beanDest.getTableNames(beanDest.getCatalogs().get(2).toString()));
! 350: stm = beanDest.getConnection().createStatement();
! 351: // System.exit(0);
! 352: if(true)
! 353: {
! 354: if(tables.indexOf(names.get(tbIndex))>=0)
! 355: {
! 356: stm.executeUpdate("drop table "+beanDest.getQC()+names.get(tbIndex)+beanDest.getQC());
! 357: tables.remove((String)names.get(tbIndex));
! 358: System.out.println("dropped table"+ names.get(tbIndex));
! 359: }
! 360: else
! 361: if(tables.indexOf(convertText(names.get(tbIndex).toString()))>=0)
! 362: {
! 363: stm.executeUpdate("drop table "+beanDest.getQC()+convertText((String)names.get(tbIndex))+beanDest.getQC());
! 364: tables.remove(convertText((String)names.get(tbIndex)));
! 365: System.out.println("dropped table"+ names.get(tbIndex));
! 366: }
! 367:
! 368: if(tables.indexOf(names.get(tbIndex))<0&&tables.indexOf(convertText(names.get(tbIndex).toString()))<0)
! 369: {
! 370: if(creates.get(tbIndex).equals("")||creates.get(tbIndex).toString().toLowerCase().indexOf("create")<0)
! 371: {
! 372: System.out.println("Warning empty or invalid create statement - creating one for you\n");
! 373:
! 374: command = new StringBuffer(50);
! 375: command.append("CREATE TABLE ");
! 376: command.append(beanDest.getQC());
! 377: command.append(convertText((String)names.get(tbIndex)));
! 378: command.append(beanDest.getQC());
! 379: command.append("(");
! 380: String type = null;
! 381: Vector columnNames = bean.getColumnNames();
! 382: for(int i=0;i<columnNames.size()-1;++i)
! 383: {
! 384: type = bean.metaData.getColumnTypeName(i+1);
! 385: // System.out.println(i+" "+result[1].get(i)+" "+type);
! 386: type = (type.equals("NUMBER")) ?"INT4":type;
! 387: type = (type.equals("CONTAINER")) ?"TEXT":type;
! 388:
! 389: command.append(beanDest.getQC() + convertText((String) columnNames.get(i)) + beanDest.getQC() + " " + type + ", ");
! 390: }
! 391: type = bean.metaData.getColumnTypeName(columnNames.size());
! 392: type = (type.equals("NUMBER")) ? "INT4" : type;
! 393: type = (type.equals("CONTAINER")) ? "TEXT" : type;
! 394: command.append(beanDest.getQC() + convertText((String) columnNames.get(columnNames.size() - 1)) + beanDest.getQC() + " " + type);
! 395: command.append(" )");
! 396:
! 397: // System.out.println(command);
! 398: // System.exit(0);
! 399: //command.append(DBBean.getQC());
! 400: } else
! 401: command=new StringBuffer().append(creates.get(tbIndex).toString());
! 402: stm.executeUpdate(command.toString());
! 403:
! 404: }
! 405: }
! 406: // System.out.println(names);
! 407: /*
! 408: if (idVal == "")
! 409: stm.executeUpdate("INSERT INTO " + DBBean.getQC() + box.getSelectedItem() + DBBean.getQC() + " (" + DBBean.getQC() + columnName + DBBean.getQC() + ") VALUES ('" + value + "') ");
! 410: else
! 411: stm.executeUpdate("UPDATE " + DBBean.getQC() + box.getSelectedItem() + DBBean.getQC() + " SET " + DBBean.getQC() + columnName + DBBean.getQC() + "='" + value + "' WHERE ID='" + idVal + "' ");
! 412: */
! 413:
! 414: // Vector[] result2=beanDest.getQueryData(names.get(tbIndex).toString());
! 415: // print results to screen
! 416: /* for (int i = 0; i < result[1].size(); ++i)
! 417: {
! 418: //print Header
! 419: // System.out.println(" "+result[1].get(i)+" "+result2[1].get(i)+" "+i);
! 420: }*/
! 421: // System.out.println();
! 422: dialog.title.setText("Writing table data ...");
! 423:
! 424: //for (int j = 0; j < result[0].size(); ++j)
! 425: int j=-1;
! 426: Vector row = null;
! 427: int rowCount= bean.getRowCount(query);
! 428: while((row=bean.getNextRow())!=null)
! 429: {
! 430: j++;
! 431: // row = (Vector) result[0].get(j);
! 432: command = new StringBuffer();
! 433:
! 434: command.append("INSERT INTO ");
! 435: command.append(beanDest.getQC());
! 436: command.append(convertText((String) names.get(tbIndex)));
! 437: command.append(beanDest.getQC());
! 438: command.append(" values ( ");
! 439: //print rows
! 440: Object obj = null;
! 441: for(int k=0;k<row.size()-1;++k)
! 442: {
! 443: obj = row.get(k);
! 444: //System.out.println("row "+obj+" "+k);
! 445: if(obj!=null&&!(obj instanceof ArrayList))
! 446: command.append("'"+convertUml(new String(obj.toString().getBytes("UTF-8"),"UTF-8"))+"',");
! 447: else if(obj!=null&& obj instanceof ArrayList)
! 448: command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"',");
! 449: else command.append("NULL,");
! 450: }
! 451: obj = row.get(row.size() - 1);
! 452: if (obj != null && !(obj instanceof ArrayList))
! 453: command.append("'"+convertUml(new String(obj.toString().getBytes("UTF-8"),"UTF-8"))+"')");
! 454: else
! 455: if(obj!=null&& obj instanceof ArrayList)
! 456: command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"')"); //command.append(obj.toString()+")");
! 457: else command.append("NULL)");
! 458: //command.append("'"+row.get(row.size()-1)+"')");
! 459: //command.append(" )");
! 460: // for(int k=0;k<row.size();++k)
! 461:
! 462: // System.out.println();
! 463: // System.out.println(command+" "+j+" "+row.size()+" "+ ((Vector)result2[0].get(j)).size());
! 464: // System.out.println(command);
! 465: stm.executeUpdate(command.toString());
! 466: dialog.progress.setValue((int) (((double) (j + 1) / (double) rowCount) * 100.0));
! 467: // System.out.println( (int)(((double)(j+1)/(double)result[0].size())*100.0)+" "+result[0].size()+" "+j);
! 468: command = null;
! 469: }// to for loop
! 470:
! 471: }
! 472: } catch(Exception e)
! 473: {
! 474: System.out.println("Error while connecting to database "+ e);
! 475: dialog.setVisible(false);
! 476: dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 477: FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 478: java.io.ByteArrayOutputStream b = new java.io.ByteArrayOutputStream();
! 479: java.io.PrintStream stream = new java.io.PrintStream(b);
! 480: stream.print(command+"\n\n");
! 481: e.printStackTrace(stream);
! 482: FM2SQL.showErrorDialog(b.toString(), "Error occured !");
! 483:
! 484: }
! 485: dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 486: FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
! 487:
! 488: dialog.setVisible(false);
! 489: }
! 490:
! 491: public static String convertText(String newName)
! 492: {
! 493: StringBuffer alterMe = new StringBuffer(newName.trim().toLowerCase());
! 494: int length = alterMe.length();
! 495: int j = 0;
! 496: while (j < length)
! 497: {
! 498: if (alterMe.charAt(j) == ' ')
! 499: {
! 500: alterMe.setCharAt(j, '_');
! 501: // if(j<length-1) j=j+1;
! 502: }
! 503: else
! 504: if (alterMe.charAt(j) == '_')
! 505: {
! 506:
! 507: if(alterMe.charAt(j+1)=='_')
! 508: alterMe.deleteCharAt(j);
! 509: length = length-1;
! 510: // if(j<length-1) j=j+1;
! 511: }
! 512: else
! 513: if (alterMe.charAt(j) == 'ä')
! 514: {
! 515: alterMe.setCharAt(j, 'a');
! 516: alterMe.insert(j+1,"e");
! 517: length=length+1;
! 518: if(j<length-1) j=j+1;
! 519: }
! 520: else
! 521: if (alterMe.charAt(j) == 'ö')
! 522: {
! 523: alterMe.setCharAt(j, 'o');
! 524: alterMe.insert(j+1,"e");
! 525: length=length+1;
! 526: if(j<length-1) j=j+1;
! 527: }
! 528: else
! 529: if (alterMe.charAt(j) == 'ü')
! 530: {
! 531: alterMe.setCharAt(j, 'u');
! 532: alterMe.insert(j+1,"e");
! 533: length=length+1;
! 534: if(j<length-1) j=j+1;
! 535: }
! 536: else
! 537: if (alterMe.charAt(j) == 'ß')
! 538: {
! 539: alterMe.setCharAt(j, 's');
! 540: alterMe.insert(j + 1, "s");
! 541: length = length + 1;
! 542: if (j < length - 1)
! 543: j = j + 1;
! 544: } else if (alterMe.charAt(j) == ':')
! 545: {
! 546: if(j<length-1)
! 547: {
! 548: if (alterMe.charAt(j + 1) == ':')
! 549: {
! 550: alterMe.setCharAt(j,'_');
! 551: alterMe.delete(j+1,j+2);
! 552: length = length - 1;
! 553:
! 554: }
! 555:
! 556: if (j < length - 1)
! 557: j = j + 1;
! 558: }
! 559: } else if (alterMe.charAt(j) == '-')
! 560: {
! 561: alterMe.setCharAt(j, '_');
! 562:
! 563: }
! 564:
! 565: ++j;
! 566: }
! 567: return alterMe.toString();
! 568: }
! 569: public static String convertUml(String newName)
! 570: {
! 571: StringBuffer alterMe = new StringBuffer(newName.trim());
! 572: int length = alterMe.length();
! 573: int j = 0;
! 574:
! 575:
! 576: while (j < length)
! 577: {
! 578:
! 579: if (alterMe.charAt(j) == '\'')
! 580: {
! 581: alterMe.setCharAt(j, '\\');
! 582: alterMe.insert(j + 1, "'");
! 583: length = length + 1;
! 584: if(j<length-1) j=j+1;
! 585: }
! 586: /* else
! 587: if (alterMe.charAt(j) == '"')
! 588: {
! 589: alterMe.setCharAt(j, '\\');
! 590: alterMe.insert(j + 1, "\"");
! 591: length = length + 1;
! 592: if(j<length-1) j=j+1;
! 593: }
! 594: else
! 595: if (alterMe.charAt(j) == '>')
! 596: {
! 597: alterMe.setCharAt(j, '\\');
! 598: alterMe.insert(j + 1, ">");
! 599: length = length + 1;
! 600: if(j<length-1) j=j+1;
! 601: }
! 602: else
! 603: if (alterMe.charAt(j) == '<')
! 604: {
! 605: alterMe.setCharAt(j, '\\');
! 606: alterMe.insert(j + 1, "<");
! 607: length = length + 1;
! 608: if(j<length-1) j=j+1;
! 609: }
! 610: else
! 611: if (alterMe.charAt(j) == '?')
! 612: {
! 613: alterMe.setCharAt(j, '\\');
! 614: alterMe.insert(j + 1, "?");
! 615: length = length + 1;
! 616: if(j<length-1) j=j+1;
! 617: }
! 618: else
! 619: if (alterMe.charAt(j) == '&')
! 620: {
! 621: alterMe.setCharAt(j, '\\');
! 622: alterMe.insert(j + 1, "&");
! 623: length = length + 1;
! 624: if(j<length-1) j=j+1;
! 625: }
! 626: else
! 627: if (alterMe.charAt(j) == '=')
! 628: {
! 629: alterMe.setCharAt(j, '\\');
! 630: alterMe.insert(j + 1, "=");
! 631: length = length + 1;
! 632: if(j<length-1) j=j+1;
! 633: }
! 634: else
! 635: if (alterMe.charAt(j) == ',')
! 636: {
! 637: alterMe.setCharAt(j, '\\');
! 638: alterMe.insert(j + 1, ",");
! 639: length = length + 1;
! 640: if(j<length-1) j=j+1;
! 641: }
! 642: else
! 643: if (alterMe.charAt(j) == '.')
! 644: {
! 645: alterMe.setCharAt(j, '\\');
! 646: alterMe.insert(j + 1, ".");
! 647: length = length + 1;
! 648: if(j<length-1) j=j+1;
! 649: }
! 650: else
! 651: if (alterMe.charAt(j) == '[')
! 652: {
! 653: alterMe.setCharAt(j, '\\');
! 654: alterMe.insert(j + 1, ".");
! 655: length = length + 1;
! 656: if(j<length-1) j=j+1;
! 657: }
! 658: else
! 659: if (alterMe.charAt(j) == ']')
! 660: {
! 661: alterMe.setCharAt(j, '\\');
! 662: alterMe.insert(j + 1, ".");
! 663: length = length + 1;
! 664: if(j<length-1) j=j+1;
! 665: }
! 666: else
! 667: if (alterMe.charAt(j) == '%')
! 668: {
! 669: alterMe.setCharAt(j, '\\');
! 670: alterMe.insert(j + 1, "%");
! 671: length = length + 1;
! 672: if(j<length-1) j=j+1;
! 673: }*/
! 674: ++j;
! 675: }
! 676: return alterMe.toString();
! 677: }
! 678:
! 679: public static void parseXMLConfig(StringBuffer sb)
! 680: {
! 681: boolean finished = false;
! 682: // parse string and build document tree
! 683: Node root = new Xparse().parse(sb.toString());
! 684: // printContents(root);
! 685: Vector databases= new Vector();
! 686: Vector tables = new Vector();
! 687: Vector layouts = new Vector();
! 688: Vector selects = new Vector();
! 689: Vector creates = new Vector();
! 690:
! 691: try
! 692: {
! 693: Node tempNode = root.find("convert/source", new int[] { 1, 1 });
! 694: if(tempNode==null) throw new Error("parse error source tag missing");
! 695: System.out.println(tempNode.name);
! 696: int length =countNodes(tempNode);
! 697: for (int i = 1; i <= length; i++)
! 698: {
! 699:
! 700: DBBean database = new DBBean();
! 701: tables = new Vector();
! 702: layouts = new Vector();
! 703: selects = new Vector();
! 704: creates = new Vector();
! 705:
! 706: // parse dataBase
! 707: Node node = root.find("convert/source/database/url", new int[] { 1, 1, i, 1 });
! 708: Node node1 = root.find("convert/source/database/user", new int[] { 1, 1, i, 1, 1 });
! 709: Node node2 = root.find("convert/source/database/password", new int[] { 1, 1, i, 1, 1 });
! 710: Node node3 = root.find("convert/source/database", new int[] { 1, 1, i});
! 711: if(node3== null) throw new Error("parse error database tag missing");
! 712: if(node==null) throw new Error("parse error url tag missing");
! 713: if(node1==null) throw new Error("parse error user tag missing");
! 714: if(node2==null) throw new Error("parse error password tag missing");
! 715: String url=node.getCharacters();
! 716: String user=node1.getCharacters();
! 717: String password=node2.getCharacters();
! 718: database.setURL(url.trim());
! 719: database.setUserAndPasswd(user.trim(),password.trim());
! 720: System.out.println(node.name + " " + node.getCharacters());
! 721: System.out.println(node1.name + " " + node1.getCharacters());
! 722: System.out.println(node2.name + " " + node2.getCharacters());
! 723:
! 724: // if(node3!=null)
! 725: // System.out.println(node3.name);
! 726:
! 727: int length2= countNodes(node3);
! 728:
! 729: System.out.println("number of tables " +length2);
! 730:
! 731: for(int j=1;j<=length2;++j)
! 732: {
! 733: Node node4 = root.find("convert/source/database/table", new int[] { 1, 1, i, j });
! 734: Node node5 = root.find("convert/source/database/table/select", new int[] { 1, 1, i, j, 1 });
! 735: Node node6 = root.find("convert/source/database/table/create", new int[] { 1, 1, i, j, 1 });
! 736: if(node4!=null)
! 737: System.out.println(node4.name + " " + node4.attributes.get("layout").equals(""));
! 738: if(node5!=null)
! 739: System.out.println(node5.name + " " + node5.getCharacters());
! 740: if(node6!=null)
! 741: System.out.println(node6.name + " " + node6.getCharacters());
! 742: if(node4==null) throw new Error("parse error table tag missing");
! 743: // if(node5==null) throw new Error("parse error select tag missing");
! 744: // if(node6==null) throw new Error("parse error create tag missing");
! 745: String name = (String)node4.attributes.get("name");
! 746: String layout = (String)node4.attributes.get("layout");
! 747: if(name==null) throw new Error("parse error required table tag attribute name missing");
! 748: if(layout==null) layout ="";
! 749: if(name.equals("")) throw new Error("parse error table tag attribute must not be empty");
! 750: tables.add(name);
! 751: layouts.add(layout);
! 752: String query = (node5==null) ? "":node5.getCharacters();
! 753: if(query.equals("")) System.err.println("Warning empty select tag or select tag missing !!");
! 754: query = (query.equals("")) ? "select * from "+database.getQC()+name+database.getQC():query;
! 755: selects.add(query);
! 756: if(node6!=null) creates.add(node6.getCharacters().trim());
! 757: else
! 758: creates.add("");
! 759:
! 760: }
! 761: databases.add(new DataBase(database, tables, layouts, selects,creates));
! 762: }
! 763: DBBean database = new DBBean();
! 764: // parse dataBase
! 765: Node node = root.find("convert/destination/database/url", new int[] { 1, 1, 1, 1 });
! 766: Node node1 = root.find("convert/destination/database/user", new int[] { 1, 1, 1, 1, 1 });
! 767: Node node2 = root.find("convert/destination/database/password", new int[] { 1, 1, 1, 1, 1 });
! 768: String url = node.getCharacters();
! 769: String user = node1.getCharacters();
! 770: String password = node2.getCharacters();
! 771: System.out.println(url);
! 772: database.setURL(url.trim());
! 773: database.setUserAndPasswd(user.trim(), password.trim());
! 774: //databases.add(database);
! 775: for (Iterator iter = databases.iterator(); iter.hasNext();)
! 776: {
! 777: DataBase db = (DataBase) iter.next();
! 778: convertBatch(db.bean,database,db.tables,db.layouts,db.selects,db.creates);
! 779:
! 780: }
! 781: // printContents(node3);
! 782: // FM2SQL.fmInstance=new FM2SQL();
! 783: } catch (Exception e)
! 784: {
! 785: // TODO Auto-generated catch block
! 786: e.printStackTrace();
! 787: }
! 788: /*
! 789: Node tempNode=root.find(rootNode,new int[] {1});
! 790: if(tempNode==null) return rtTag;
! 791: int count=1;
! 792: /*
! 793: for(int i=0;i<tempNode.contents.v.size();++i)
! 794: {
! 795: // System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
! 796: }*/
! 797: /*
! 798: if(tempNode.contents.v.size()==0) return rtTag;
! 799: Node notNull=null;
! 800: Node rtNode=root.find(rootNode+"/rt",new int[] {1,1});
! 801: rtTag=(rtNode==null) ? "finished":rtNode.getCharacters();
! 802: System.out.println("rt tag is "+ rtTag);
! 803: int length=0;//(tempNode.contents.length()-1)/2;
! 804: for(int i=0;i<tempNode.contents.v.size();++i) {
! 805: Node node=(Node)tempNode.contents.v.elementAt(i);
! 806: if(node.type.equals("element"))
! 807: if(node.name.equals("doc"))length++;
! 808: // System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
! 809: }
! 810: if(length==0) rtTag="finished";
! 811: while(count<=length)
! 812: {
! 813: //System.out.println(count+" "+length);
! 814: tempNode=root.find(rootNode+"/doc",new int[] {1,count});
! 815: if(tempNode==null)
! 816: {
! 817: rtTag="finished";
! 818: break;
! 819: }
! 820: Bundle.Document doc = new Bundle.Document();
! 821: Hashtable attributes=tempNode.attributes;
! 822: int docID=0;
! 823: int ver=0;
! 824: if(attributes != null)
! 825: {
! 826: docID=Integer.parseInt((String)attributes.get("id"));
! 827: ver=Integer.parseInt((String)attributes.get("ver"));
! 828: doc.addData("docID",(String)attributes.get("id"));
! 829: doc.addData("ver",(String)attributes.get("ver"));
! 830: }
! 831: bundle.docs.put(new Integer(docID),doc);
! 832: bundle.documents.addElement(doc);
! 833: // System.out.println("id " +docID+" ver "+ver);
! 834: Node fileNode=root.find(rootNode+"/doc/file",new int[] {1,count,1});
! 835: attributes=(fileNode==null)? null:fileNode.attributes;
! 836: int fileID=0;
! 837: int fileVer=0;
! 838: if(attributes != null)
! 839: {
! 840: fileID=Integer.parseInt((String)attributes.get("id"));
! 841: fileVer=Integer.parseInt((String)attributes.get("ver"));
! 842: doc.addData("fileID",(String)attributes.get("id"));
! 843: doc.addData("fileVer",(String)attributes.get("ver"));
! 844: // System.out.println("fileid " +fileID+" ver "+fileVer);
! 845: }
! 846: // add all Document tags to actual Document
! 847: for(int i=0;i<tempNode.contents.v.size();++i)
! 848: {
! 849: Node node=(Node)tempNode.contents.v.elementAt(i);
! 850: if(node.type.equals("element"))
! 851: {
! 852: //System.out.println(node.name+" "+node.getCharacters()+" "+node.contents.v.size());
! 853: if(node.contents.v.size()>1)
! 854: {
! 855: for(int j=0;j<node.contents.v.size();++j)
! 856: {
! 857: Node node2=(Node)node.contents.v.elementAt(j);
! 858: if(node2.type.equals("element"))
! 859: {
! 860: doc.addData(node2.name,node2.getCharacters());
! 861: //System.out.println(node2.name+" "+node2.getCharacters()+" "+node2.contents.v.size());
! 862: }
! 863: }
! 864: } else doc.addData(node.name,node.getCharacters());
! 865: }
! 866: }
! 867: bundle.docsLocator.put(doc.locator,doc);
! 868:
! 869: bundle.documents.addElement(doc);
! 870: count++;
! 871: } */
! 872:
! 873: // System.out.println(bundle.docs.size());
! 874: // return rtTag;
! 875: }
! 876: public static Vector getXMLConfig(String xmlFile)
! 877: {
! 878: StringBuffer sb=null;
! 879: try
! 880: {
! 881: // read XML Metadata from a file
! 882: FileInputStream fi= new FileInputStream(xmlFile);
! 883: InputStreamReader isr= new InputStreamReader(fi,"UTF-8");
! 884: BufferedReader buffr = new BufferedReader(isr);
! 885: sb=new StringBuffer();
! 886: int c=0;
! 887: while ((c = buffr.read()) != -1)
! 888: {
! 889: char ch=(char)c;
! 890: sb.append(ch);
! 891: // System.out.print((char)c);
! 892: }
! 893:
! 894: } catch(Exception e) { e.printStackTrace();}
! 895:
! 896: boolean finished = false;
! 897: // parse string and build document tree
! 898: Node root = new Xparse().parse(sb.toString());
! 899: // printContents(root);
! 900: Vector databases= new Vector();
! 901: Vector tables = new Vector();
! 902: Vector layouts = new Vector();
! 903: Vector selects = new Vector();
! 904: Vector creates = new Vector();
! 905:
! 906: try
! 907: {
! 908: Node tempNode = root.find("convert/source", new int[] { 1, 1 });
! 909: if(tempNode==null) throw new Error("parse error source tag missing");
! 910: System.out.println(tempNode.name);
! 911: int length =countNodes(tempNode);
! 912: for (int i = 1; i <= length; i++)
! 913: {
! 914:
! 915: DBBean database = new DBBean();
! 916: tables = new Vector();
! 917: layouts = new Vector();
! 918: selects = new Vector();
! 919: creates = new Vector();
! 920:
! 921: // parse dataBase
! 922: Node node = root.find("convert/source/database/url", new int[] { 1, 1, i, 1 });
! 923: Node node1 = root.find("convert/source/database/user", new int[] { 1, 1, i, 1, 1 });
! 924: Node node2 = root.find("convert/source/database/password", new int[] { 1, 1, i, 1, 1 });
! 925: Node node3 = root.find("convert/source/database", new int[] { 1, 1, i});
! 926: if(node3== null) throw new Error("parse error database tag missing");
! 927: if(node==null) throw new Error("parse error url tag missing");
! 928: if(node1==null) throw new Error("parse error user tag missing");
! 929: if(node2==null) throw new Error("parse error password tag missing");
! 930: String url=node.getCharacters();
! 931: String user=node1.getCharacters();
! 932: String password=node2.getCharacters();
! 933: database.setURL(url.trim());
! 934: database.setUserAndPasswd(user.trim(),password.trim());
! 935: System.out.println(node.name + " " + node.getCharacters());
! 936: System.out.println(node1.name + " " + node1.getCharacters());
! 937: System.out.println(node2.name + " " + node2.getCharacters());
! 938:
! 939: // if(node3!=null)
! 940: // System.out.println(node3.name);
! 941:
! 942: int length2= countNodes(node3);
! 943:
! 944: System.out.println("number of tables " +length2);
! 945:
! 946: for(int j=1;j<=length2;++j)
! 947: {
! 948: Node node4 = root.find("convert/source/database/table", new int[] { 1, 1, i, j });
! 949: Node node5 = root.find("convert/source/database/table/select", new int[] { 1, 1, i, j, 1 });
! 950: Node node6 = root.find("convert/source/database/table/create", new int[] { 1, 1, i, j, 1 });
! 951: if(node4!=null)
! 952: System.out.println(node4.name + " " + node4.attributes.get("layout").equals(""));
! 953: if(node5!=null)
! 954: System.out.println(node5.name + " " + node5.getCharacters());
! 955: if(node6!=null)
! 956: System.out.println(node6.name + " " + node6.getCharacters());
! 957: if(node4==null) throw new Error("parse error table tag missing");
! 958: // if(node5==null) throw new Error("parse error select tag missing");
! 959: // if(node6==null) throw new Error("parse error create tag missing");
! 960: String name = (String)node4.attributes.get("name");
! 961: String layout = (String)node4.attributes.get("layout");
! 962: if(name==null) throw new Error("parse error required table tag attribute name missing");
! 963: if(layout==null) layout ="";
! 964: if(name.equals("")) throw new Error("parse error table tag attribute must not be empty");
! 965: tables.add(name);
! 966: layouts.add(layout);
! 967: String query = (node5==null) ? "":node5.getCharacters();
! 968: if(query.equals("")) System.err.println("Warning empty select tag or select tag missing !!");
! 969: query = (query.equals("")) ? "select * from "+database.getQC()+name+database.getQC():query;
! 970: selects.add(query);
! 971: if(node6!=null) creates.add(node6.getCharacters().trim());
! 972: else
! 973: creates.add("");
! 974:
! 975: }
! 976: databases.add(new DataBase(database, tables, layouts, selects,creates));
! 977: }
! 978: DBBean database = new DBBean();
! 979: // parse dataBase
! 980: Node node = root.find("convert/destination/database/url", new int[] { 1, 1, 1, 1 });
! 981: Node node1 = root.find("convert/destination/database/user", new int[] { 1, 1, 1, 1, 1 });
! 982: Node node2 = root.find("convert/destination/database/password", new int[] { 1, 1, 1, 1, 1 });
! 983: String url = node.getCharacters();
! 984: String user = node1.getCharacters();
! 985: String password = node2.getCharacters();
! 986: System.out.println(url);
! 987: database.setURL(url.trim());
! 988: database.setUserAndPasswd(user.trim(), password.trim());
! 989: databases.add(new DataBase(database,null,null,null,null));
! 990: //databases.add(database);
! 991: /* for (Iterator iter = databases.iterator(); iter.hasNext();)
! 992: {
! 993: DataBase db = (DataBase) iter.next();
! 994: convertBatch(db.bean,database,db.tables,db.layouts,db.selects,db.creates);
! 995:
! 996: }*/
! 997: // printContents(node3);
! 998: // FM2SQL.fmInstance=new FM2SQL();
! 999: } catch (Exception e)
! 1000: {
! 1001: // TODO Auto-generated catch block
! 1002: e.printStackTrace();
! 1003: }
! 1004: return databases;
! 1005: }
! 1006:
! 1007:
! 1008: private static int countNodes(Node tempNode)
! 1009: {
! 1010: int length = 0;
! 1011: for(int i=0;i<tempNode.contents.v.size();++i) {
! 1012: Node node=(Node)tempNode.contents.v.elementAt(i);
! 1013: if(node.type.equals("element"))
! 1014: {
! 1015: if(node.name.equals("database"))length++;
! 1016: if(node.name.equals("table"))length++;
! 1017: }
! 1018:
! 1019: // System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
! 1020: }
! 1021: return length;
! 1022: }
! 1023: private static void printContents(Node root)
! 1024: {
! 1025:
! 1026:
! 1027: Vector contents=(root.index==null)? root.contents.v:root.index.v;
! 1028: for (int i=0;i<contents.size();++i)
! 1029: {
! 1030: Node n=(Node)contents.elementAt(i);
! 1031: if(n.type.equals("element"))
! 1032: {
! 1033: System.out.println("tag "+n.name);
! 1034: System.out.println(n.getCharacters());
! 1035: //contents=n.contents.v i=0;
! 1036: }
! 1037: // System.out.println(n.type);
! 1038:
! 1039:
! 1040:
! 1041: }
! 1042: }
! 1043: public static void readXMLFile(String xmlFile)
! 1044: {
! 1045: try
! 1046: {
! 1047: // read XML Metadata from a file
! 1048: FileInputStream fi= new FileInputStream(xmlFile);
! 1049: InputStreamReader isr= new InputStreamReader(fi,"UTF-8");
! 1050: BufferedReader buffr = new BufferedReader(isr);
! 1051: StringBuffer sb=new StringBuffer();
! 1052: int c=0;
! 1053: while ((c = buffr.read()) != -1)
! 1054: {
! 1055: char ch=(char)c;
! 1056: sb.append(ch);
! 1057: // System.out.print((char)c);
! 1058: }
! 1059: parseXMLConfig(sb);
! 1060: } catch(Exception e) { e.printStackTrace();}
! 1061: }
! 1062: public static class DataBase
! 1063: {
! 1064: DBBean bean;
! 1065: Vector creates;
! 1066: Vector selects;
! 1067: Vector layouts;
! 1068: Vector tables;
! 1069: public DataBase(DBBean bean,Vector tables,Vector layouts,Vector selects,Vector creates)
! 1070: {
! 1071: this.bean = bean;
! 1072: this.tables = tables;
! 1073: this.layouts = layouts;
! 1074: this.selects = selects;
! 1075: this.creates = creates;
! 1076: }
! 1077: public void exportToXML(BufferedWriter buffr) throws Exception
! 1078: {
! 1079: buffr.write(" <database>\n");
! 1080: buffr.write(" <url>"+bean.url+"</url>\n");
! 1081: buffr.write(" <user>"+bean.user+"</user>\n");
! 1082: buffr.write(" <password>"+bean.passwd+"</password>\n");
! 1083:
! 1084: int index = 0;
! 1085: while(index<tables.size())
! 1086: {
! 1087: String table=(String)tables.get(index);
! 1088: String layout=(String)layouts.get(index);
! 1089: String select=(String)selects.get(index);
! 1090: String create=(String)creates.get(index);
! 1091:
! 1092: buffr.write(" <table name = \""+table+"\" layout = \""+layout+"\">\n");
! 1093: buffr.write(" <select>"+select+"</select>\n");
! 1094: if(!create.equals(""))
! 1095: buffr.write(" <create>"+create+" </create>\n");
! 1096: buffr.write(" </table>\n");
! 1097: index++;
! 1098: }
! 1099: buffr.write(" </database>\n");
! 1100: }
! 1101: public String toString() {return bean.url+" "+tables;}
! 1102:
! 1103: }
! 1104: public static String convertToUTF8(Object command)
! 1105: {
! 1106: String str = null;
! 1107: try
! 1108: {
! 1109: str = new String(command.toString().getBytes("UTF-8"));
! 1110: } catch (UnsupportedEncodingException e)
! 1111: {
! 1112: // TODO Auto-generated catch block
! 1113: e.printStackTrace();
! 1114: }
! 1115: return str;
! 1116: }
! 1117: public static void writeConfig(String file, DataBase source, DataBase destination) throws Exception
! 1118: {
! 1119: if(!file.toLowerCase().endsWith(".xml")) file+=".xml";
! 1120: File f = new File(file);
! 1121:
! 1122: FileOutputStream fout= new FileOutputStream(f);
! 1123: OutputStreamWriter outsw = new OutputStreamWriter(fout,"UTF-8");
! 1124: BufferedWriter buffw = new BufferedWriter(outsw);
! 1125: buffw.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
! 1126: buffw.newLine();
! 1127: buffw.write("<convert>\n");
! 1128: buffw.write(" <source>\n");
! 1129: source.exportToXML(buffw);
! 1130: buffw.write(" </source>\n");
! 1131: buffw.write("\n <destination>\n");
! 1132: destination.exportToXML(buffw);
! 1133: buffw.write(" </destination>\n");
! 1134: buffw.write("</convert>\n");
! 1135: buffw.close();
! 1136: }
! 1137: }
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