--- FM2SQL/Attic/Convert.java 2004/01/12 13:22:36 1.5 +++ FM2SQL/Attic/Convert.java 2004/02/19 11:05:41 1.37 @@ -1,5 +1,3 @@ - - import java.util.*; import java.sql.*; import java.awt.Cursor; @@ -17,111 +15,90 @@ import java.io.UnsupportedEncodingExcept import com.exploringxml.xml.Node; import com.exploringxml.xml.Xparse; -class Convert +class Convert { - static DBBean bean = new DBBean(); - static DBBean beanDest = new DBBean(); + static DBBean bean = new DBBean(); + static DBBean beanDest = new DBBean(); - static String user ="",passwd="e1nste1n"; - static String userDest="postgres",passwdDest="rogo"; - static boolean batchRun=false; + static String user = "", passwd = "e1nste1n"; + static String userDest = "postgres", passwdDest = "rogo"; + static boolean batchRun = false; static Vector databases = new Vector(); - + final static int numHits = 5000; + final static int numIntervalls = 2; public static void main(String args[]) { -/* try - { - //byte[] b = "ö".getBytes("UTF-8"); - // System.out.println("QueryString " +b[0]+" "+b[1]+(new String(b).getBytes()[0])+" "+new String(b).getBytes()[1]); - //System.out.println(new String(b,"UTF-8")); - } catch (UnsupportedEncodingException e) - { - // TODO Auto-generated catch block - e.printStackTrace(); - }*/ + /* try + { + //byte[] b = "ö".getBytes("UTF-8"); + // System.out.println("QueryString " +b[0]+" "+b[1]+(new String(b).getBytes()[0])+" "+new String(b).getBytes()[1]); + //System.out.println(new String(b,"UTF-8")); + } catch (UnsupportedEncodingException e) + { + e.printStackTrace(); + }*/ FileOutputStream file = null; - if(args.length!=1) + if (args.length != 1) { - System.out.println("Usage: java Convert "); - System.exit(-1); + System.out.println("Usage: java Convert "); + System.exit(-1); } - if(!(new File(args[0]).exists())) System.exit(0); + if (!(new File(args[0]).exists())) + System.exit(0); try { file = new FileOutputStream("./log.txt"); } catch (FileNotFoundException e1) { - // TODO Auto-generated catch block e1.printStackTrace(); - } - PrintStream stream= new PrintStream(file); - System.setOut(stream); - System.setErr(stream); - readXMLFile(args[0]); - System.out.println("Finished!"); + } + PrintStream stream = new PrintStream(file); + System.setOut(stream); + System.setErr(stream); + readXMLFile(args[0]); + System.out.println("Finished!"); //convert("jdbc:fmpro:http://141.14.237.74:8050","jdbc:postgresql://erebos/test",null,null); } - public static void convertBatch(DBBean source,DBBean destination,Vector names,Vector layouts,Vector selects,Vector creates) throws Exception + public static void convertBatch(DBBean source, DBBean destination, Vector names, Vector layouts, Vector selects, Vector creates, Vector ids,int mode) throws Exception { - /*FM2SQL.ProgressDialog dialog = new FM2SQL.ProgressDialog(FM2SQL.fmInstance); - dialog.setTitle("Conversion running ..."); - dialog.title.setText("Getting table data ..."); - dialog.setLocation(500,500); - dialog.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR)); - */ - // FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR)); - //dialog.thread=Thread.currentThread(); - bean=source; - beanDest = destination; - /* // setting user and passwd - bean.setUserAndPasswd(user,passwd); - // setting user and passwd - beanDest.setUserAndPasswd(userDest,passwdDest); - */ - //dialog.setSize(400,250); - StringBuffer command= null; + bean = source; + beanDest = destination; + convert(null,null,names,layouts,selects,creates,ids,mode); + if(true) return; + StringBuffer command = null; try { - //bean.setConnection("jdbc:fmpro:http://141.14.237.74:8050"); - //bean.setConnection("jdbc:postgresql://erebos/test","postgres","rogo"); bean.setConnection(source.url); - if(names==null) - names=bean.getTableNames(); + if (names == null) + names = bean.getTableNames(); //Collections.sort(names); - int tbIndex = 1; - - // System.out.println("Start at "+names.indexOf("archimedes_facsimiles")); - for(tbIndex=0;tbIndex=0) + if (mode == Convert.DataBase.CONVERT_MODE) { - stm.executeUpdate("drop table "+beanDest.getQC()+names.get(tbIndex)+beanDest.getQC()); - tables.remove((String)names.get(tbIndex)); - System.out.println("dropped table "+ names.get(tbIndex)); - } - else - if(tables.indexOf(convertText(names.get(tbIndex).toString()))>=0) - { - stm.executeUpdate("drop table "+beanDest.getQC()+convertText((String)names.get(tbIndex))+beanDest.getQC()); - tables.remove(convertText((String)names.get(tbIndex))); - System.out.println("dropped table "+ names.get(tbIndex)); - } - - if(tables.indexOf(names.get(tbIndex))<0&&tables.indexOf(convertText(names.get(tbIndex).toString()))<0) - { - if(creates.get(tbIndex).equals("")||creates.get(tbIndex).toString().toLowerCase().indexOf("create")<0) + if (tables.indexOf(names.get(tbIndex)) >= 0) { - System.out.println("Warning empty or invalid create statement - creating one for you\n"); - - command = new StringBuffer(50); - command.append("CREATE TABLE "); - command.append(beanDest.getQC()); - command.append(convertText((String)names.get(tbIndex))); - command.append(beanDest.getQC()); - command.append("("); - String type = null; - Vector columnNames=bean.getColumnNames(); - for(int i=0;i= 0) { - type = bean.metaData.getColumnTypeName(i+1); - // System.out.println(i+" "+result[1].get(i)+" "+type); - type = (type.equals("NUMBER")) ?"INT4":type; - type = (type.equals("CONTAINER")) ?"TEXT":type; + stm.executeUpdate("drop table " + beanDest.getQC() + convertText((String) names.get(tbIndex)) + beanDest.getQC()); + tables.remove(convertText((String) names.get(tbIndex))); + System.out.println("dropped table " + names.get(tbIndex)); + } - command.append(beanDest.getQC() + convertText((String) columnNames.get(i)) + beanDest.getQC() + " " + type + ", "); - } - type = bean.metaData.getColumnTypeName(columnNames.size()); - type = (type.equals("NUMBER")) ? "INT4" : type; - type = (type.equals("CONTAINER")) ? "TEXT" : type; - command.append(beanDest.getQC() + convertText((String) columnNames.get(columnNames.size() - 1)) + beanDest.getQC() + " " + type); - command.append(" )"); - } - else - command=new StringBuffer().append(creates.get(tbIndex).toString()); - - System.out.println(command); - // System.exit(0); - //command.append(DBBean.getQC()); - stm.executeUpdate(command.toString()); - - } - } - // System.out.println(names); - /* - if (idVal == "") - stm.executeUpdate("INSERT INTO " + DBBean.getQC() + box.getSelectedItem() + DBBean.getQC() + " (" + DBBean.getQC() + columnName + DBBean.getQC() + ") VALUES ('" + value + "') "); - else - stm.executeUpdate("UPDATE " + DBBean.getQC() + box.getSelectedItem() + DBBean.getQC() + " SET " + DBBean.getQC() + columnName + DBBean.getQC() + "='" + value + "' WHERE ID='" + idVal + "' "); - */ + if (tables.indexOf(names.get(tbIndex)) < 0 && tables.indexOf(convertText(names.get(tbIndex).toString())) < 0) + { + if (creates.get(tbIndex).equals("") || creates.get(tbIndex).toString().toLowerCase().indexOf("create") < 0) + { + System.out.println("Warning empty or invalid create statement - creating one for you\n"); + + command = new StringBuffer(50); + command.append("CREATE TABLE "); + command.append(beanDest.getQC()); + command.append(convertText((String) names.get(tbIndex))); + command.append(beanDest.getQC()); + command.append("("); + String type = null; + Vector columnNames = bean.getColumnNames(); + for (int i = 0; i < columnNames.size() - 1; ++i) + { + type = bean.metaData.getColumnTypeName(i + 1); + // System.out.println(i+" "+result[1].get(i)+" "+type); + type = (type.equals("NUMBER")) ? "INT4" : type; + type = (type.equals("CONTAINER")) ? "TEXT" : type; + + command.append(beanDest.getQC() + convertText((String) columnNames.get(i)) + beanDest.getQC() + " " + type + ", "); + } + type = bean.metaData.getColumnTypeName(columnNames.size()); + type = (type.equals("NUMBER")) ? "INT4" : type; + type = (type.equals("CONTAINER")) ? "TEXT" : type; + command.append(beanDest.getQC() + convertText((String) columnNames.get(columnNames.size() - 1)) + beanDest.getQC() + " " + type); + command.append(" )"); + } else + command = new StringBuffer().append(creates.get(tbIndex).toString()); + + System.out.println(command); + // System.exit(0); + //command.append(DBBean.getQC()); + stm.executeUpdate(command.toString()); - // Vector[] result2=beanDest.getQueryData(names.get(tbIndex).toString()); - // print results to screen - /* for (int i = 0; i < result[1].size(); ++i) - { - //print Header - // System.out.println(" "+result[1].get(i)+" "+result2[1].get(i)+" "+i); - }*/ - // System.out.println(); - //dialog.title.setText("Writing table data ..."); - Vector row = null; - //for (int j = 0; j < result[0].size(); ++j) - command = new StringBuffer(); - - command.append("INSERT INTO "); - command.append(beanDest.getQC()); - command.append(convertText((String) names.get(tbIndex))); - command.append(beanDest.getQC()); - command.append(" values ( "); - - for (int i = 0; i < bean.getColumnNames().size() - 1; ++i) - command.append("?,"); - command.append("?)"); - PreparedStatement pstm = beanDest.getConnection().prepareStatement(command.toString()); - System.out.println(command); - while((row=bean.getNextRow())!=null) - { -/* //Vector row = (Vector) result[0].get(j); - command = new StringBuffer(); + } + } + Vector row = null; + command = new StringBuffer(); command.append("INSERT INTO "); command.append(beanDest.getQC()); command.append(convertText((String) names.get(tbIndex))); command.append(beanDest.getQC()); command.append(" values ( "); - */ - //print rows - Object obj = null; - /* - for(int k=0;k=0) + dialog.setVisible(false); + dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR)); + FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR)); + } + java.io.ByteArrayOutputStream b = new java.io.ByteArrayOutputStream(); + java.io.PrintStream stream = new java.io.PrintStream(b); + stream.print(command + "\n\n"); + e.printStackTrace(stream); + FM2SQL.showErrorDialog(b.toString(), "Error occured !"); + + } + if (dialog != null) + { + dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR)); + FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR)); + + dialog.setVisible(false); + } + + } + /** + transfers the specified array of tables to the destination database + and creates the table if it does not exist if it exists and mode is not append the table is dropped + + **/ + public static void convert(String source, String destination, Vector names, Vector layouts, Vector selects, Vector creates, Vector ids, int mode) throws Exception + { + + FM2SQL.ProgressDialog dialog = null; + + if (FM2SQL.fmInstance != null) + { + dialog = new FM2SQL.ProgressDialog(FM2SQL.fmInstance); + dialog.setTitle("Conversion running ..."); + dialog.title.setText("Getting table data ..."); + dialog.setLocation(FM2SQL.fmInstance.getLocationOnScreen().x + (FM2SQL.fmInstance.getWidth() - 400) / 2, FM2SQL.fmInstance.getLocationOnScreen().y + (FM2SQL.fmInstance.getHeight() - 250) / 2); + dialog.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR)); + FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.WAIT_CURSOR)); + dialog.thread = Thread.currentThread(); + dialog.setSize(400, 250); + } + java.util.TreeSet myIds = new TreeSet(); + int deltaID = 1; + String idField = ""; + if (source != null && destination != null) + { + // setting user and passwd + bean.setUserAndPasswd(user, passwd); + // setting user and passwd + beanDest.setUserAndPasswd(userDest, passwdDest); + } + StringBuffer command = null; + String query = null; + try + { + if(source!=null) + bean.setConnection(source); + else + bean.setConnection(bean.url); + + if (names == null) + names = bean.getTableNames(); + // Collections.sort(names); + int tbIndex = 1; + + // System.out.println("Start at "+names.indexOf("archimedes_facsimiles")); + for (tbIndex = 0; tbIndex < names.size(); ++tbIndex) + { + Vector[] result = null; + try { - stm.executeUpdate("drop table "+beanDest.getQC()+names.get(tbIndex)+beanDest.getQC()); - tables.remove((String)names.get(tbIndex)); - System.out.println("dropped table"+ names.get(tbIndex)); - } - else - if(tables.indexOf(convertText(names.get(tbIndex).toString()))>=0) + query = "select * from " + bean.getQC() + names.get(tbIndex).toString() + bean.getQC(); + String layout = (layouts.isEmpty()) ? "" : layouts.get(tbIndex).toString(); + query = (selects != null) ? selects.get(tbIndex).toString() : query; + //if vectors[1].get(i) != null) + if (layout != "") + { + layout = " layout " + bean.getQC() + layout + bean.getQC(); + String name = names.get(tbIndex).toString(); + StringBuffer queryLayout = new StringBuffer(query); + queryLayout.insert(queryLayout.indexOf(name) + name.length() + 1, " " + layout); + query = queryLayout.toString(); + System.out.println("added layout " + query); + + } + // if ( layout!= "") + // query += " layout " + bean.getQC() + layout + bean.getQC(); + if (dialog != null) + { + dialog.title.setText("Reading table data ..."); + dialog.table.setText(names.get(tbIndex).toString()); + dialog.status.setText("Table " + (tbIndex + 1) + " of " + names.size()); + dialog.show(); + } + //result = bean.getQueryData(query, dialog, 0); + bean.getConnection(); + bean.makeQuery(query, 50); + idField = ids.get(tbIndex).toString(); + + } catch (Exception e) { - stm.executeUpdate("drop table "+beanDest.getQC()+convertText((String)names.get(tbIndex))+beanDest.getQC()); - tables.remove(convertText((String)names.get(tbIndex))); - System.out.println("dropped table"+ names.get(tbIndex)); + System.out.println(e); + continue; } - - if(tables.indexOf(names.get(tbIndex))<0&&tables.indexOf(convertText(names.get(tbIndex).toString()))<0) + if(destination!=null) + beanDest.setConnection(destination); + else + beanDest.setConnection(beanDest.url); + Statement stm = beanDest.getConnection().createStatement(); + + Vector tables = beanDest.getTableNames(); + // Collections.sort(tables); + System.out.println(names.get(tbIndex) + " " + tables.indexOf(convertText((String) names.get(tbIndex)))); // "//beanDest.getTypeNames()); + tables = beanDest.getTableNames(); + // System.out.println(beanDest.getTableNames(beanDest.getCatalogs().get(2).toString())); + stm = beanDest.getConnection().createStatement(); + // System.exit(0); + if (mode == Convert.DataBase.CONVERT_MODE) { - if(creates.get(tbIndex).equals("")||creates.get(tbIndex).toString().toLowerCase().indexOf("create")<0) + if (tables.indexOf(names.get(tbIndex)) >= 0) { - System.out.println("Warning empty or invalid create statement - creating one for you\n"); - - command = new StringBuffer(50); - command.append("CREATE TABLE "); - command.append(beanDest.getQC()); - command.append(convertText((String)names.get(tbIndex))); - command.append(beanDest.getQC()); - command.append("("); - String type = null; - Vector columnNames = bean.getColumnNames(); - for(int i=0;i= 0) { - type = bean.metaData.getColumnTypeName(i+1); - // System.out.println(i+" "+result[1].get(i)+" "+type); - type = (type.equals("NUMBER")) ?"INT4":type; - type = (type.equals("CONTAINER")) ?"TEXT":type; + stm.executeUpdate("drop table " + beanDest.getQC() + convertText((String) names.get(tbIndex)) + beanDest.getQC()); + tables.remove(convertText((String) names.get(tbIndex))); + System.out.println("dropped table" + names.get(tbIndex)); + } - command.append(beanDest.getQC() + convertText((String) columnNames.get(i)) + beanDest.getQC() + " " + type + ", "); - } - type = bean.metaData.getColumnTypeName(columnNames.size()); - type = (type.equals("NUMBER")) ? "INT4" : type; - type = (type.equals("CONTAINER")) ? "TEXT" : type; - command.append(beanDest.getQC() + convertText((String) columnNames.get(columnNames.size() - 1)) + beanDest.getQC() + " " + type); - command.append(" )"); + if (tables.indexOf(names.get(tbIndex)) < 0 && tables.indexOf(convertText(names.get(tbIndex).toString())) < 0) + { + if (creates.get(tbIndex).equals("") || creates.get(tbIndex).toString().toLowerCase().indexOf("create") < 0) + { + System.out.println("Warning empty or invalid create statement - creating one for you\n"); + + command = new StringBuffer(50); + command.append("CREATE TABLE "); + command.append(beanDest.getQC()); + command.append(convertText((String) names.get(tbIndex))); + command.append(beanDest.getQC()); + command.append("("); + String type = null; + Vector columnNames = bean.getColumnNames(); + for (int i = 0; i < columnNames.size() - 1; ++i) + { + type = bean.metaData.getColumnTypeName(i + 1); + // System.out.println(i+" "+result[1].get(i)+" "+type); + type = (type.equals("NUMBER")) ? "INT4" : type; + type = (type.equals("CONTAINER")) ? "TEXT" : type; + + command.append(beanDest.getQC() + convertText((String) columnNames.get(i)) + beanDest.getQC() + " " + type + ", "); + } + type = bean.metaData.getColumnTypeName(columnNames.size()); + type = (type.equals("NUMBER")) ? "INT4" : type; + type = (type.equals("CONTAINER")) ? "TEXT" : type; + command.append(beanDest.getQC() + convertText((String) columnNames.get(columnNames.size() - 1)) + beanDest.getQC() + " " + type); + command.append(" )"); + + // System.out.println(command); + // System.exit(0); + //command.append(DBBean.getQC()); + } else + command = new StringBuffer().append(creates.get(tbIndex).toString()); + stm.executeUpdate(command.toString()); - // System.out.println(command); - // System.exit(0); - //command.append(DBBean.getQC()); - } else - command=new StringBuffer().append(creates.get(tbIndex).toString()); - stm.executeUpdate(command.toString()); - - } - } - // System.out.println(names); - /* - if (idVal == "") - stm.executeUpdate("INSERT INTO " + DBBean.getQC() + box.getSelectedItem() + DBBean.getQC() + " (" + DBBean.getQC() + columnName + DBBean.getQC() + ") VALUES ('" + value + "') "); - else - stm.executeUpdate("UPDATE " + DBBean.getQC() + box.getSelectedItem() + DBBean.getQC() + " SET " + DBBean.getQC() + columnName + DBBean.getQC() + "='" + value + "' WHERE ID='" + idVal + "' "); - */ + } + } + if(dialog!=null) + dialog.title.setText("Writing table data ..."); - // Vector[] result2=beanDest.getQueryData(names.get(tbIndex).toString()); - // print results to screen - /* for (int i = 0; i < result[1].size(); ++i) - { - //print Header - // System.out.println(" "+result[1].get(i)+" "+result2[1].get(i)+" "+i); - }*/ - // System.out.println(); - dialog.title.setText("Writing table data ..."); - - //for (int j = 0; j < result[0].size(); ++j) - int j=-1; - Vector row = null; - command = new StringBuffer(); - - command.append("INSERT INTO "); - command.append(beanDest.getQC()); - command.append(convertText((String) names.get(tbIndex))); - command.append(beanDest.getQC()); - command.append(" values ( "); - - for(int i=0;i 0) + tempQuery = query + " and " + tempID + ">=" + vec.get(k) + " and " + tempID + "<=" + vec.get(k + deltaID); + else + tempQuery = query + " where " + tempID + ">=" + vec.get(k) + " and " + tempID + "<=" + vec.get(k + deltaID); + System.out.println(tempQuery); + if(dialog!=null) + dialog.title.setText("Reading table data ..."); + + bean.makeQuery(tempQuery, deltaID); + if(dialog!=null) + dialog.title.setText("Writing table data ..."); + + command = writeDatainDestTable(dialog, command, k, pstm, rowCount); + endIndex = k + deltaID; + } + System.out.println(endIndex); + if (endIndex == vec.size() - 1) + System.out.println("fits"); + else + { + System.out.println(" last intervall from " + vec.get(endIndex) + " " + vec.lastElement()); + + if (query.indexOf("where") > 0) + tempQuery = query + " and " + tempID + ">=" + vec.get(endIndex) + " and " + tempID + "<=" + vec.lastElement(); + else + tempQuery = query + "where " + tempID + ">=" + vec.get(endIndex) + " and " + tempID + "<=" + vec.lastElement(); + System.out.println(tempQuery); + if(dialog!=null) + dialog.title.setText("Reading table data ..."); + bean.makeQuery(tempQuery, 0); + if(dialog!=null) + dialog.title.setText("Writing table data ..."); + command = writeDatainDestTable(dialog, command, endIndex, pstm, rowCount); + } + if (query.indexOf("where") > 0) + tempQuery = query + " and " + tempID + ">" + vec.lastElement(); + else + tempQuery = query + " where " + tempID + ">" + vec.lastElement(); + + } + long endTime = System.currentTimeMillis(); + System.out.println("Time for incremental convert elapsed " + (endTime - startTime)); + } else + { + long startTime = System.currentTimeMillis(); + + bean.makeQuery(query, 0); + command = writeDatainDestTable(dialog, command, j, pstm, rowCount); + long endTime = System.currentTimeMillis(); + System.out.println("Time for old convert elapsed " + (endTime - startTime)); + + } + } + } catch (Exception e) + { + System.out.println("Error while connecting to database " + e); + if (dialog != null) + { + dialog.setVisible(false); + dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR)); + FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR)); + java.io.ByteArrayOutputStream b = new java.io.ByteArrayOutputStream(); + java.io.PrintStream stream = new java.io.PrintStream(b); + stream.print(command + "\n\n"); + e.printStackTrace(stream); + FM2SQL.showErrorDialog(b.toString(), "Error occured !"); + } else + { + e.printStackTrace(); + + } + } + if (dialog != null) + { + dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR)); + FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR)); + dialog.setVisible(false); + } + } + private static StringBuffer writeDatainDestTable(FM2SQL.ProgressDialog dialog, StringBuffer command, int j, PreparedStatement pstm, int rowCount) throws Exception, SQLException + { + Vector row; + while ((row = bean.getNextRow()) != null) + { + j++; + // row = (Vector) result[0].get(j); + /* command = new StringBuffer(); + + command.append("INSERT INTO "); + command.append(beanDest.getQC()); + command.append(convertText((String) names.get(tbIndex))); + command.append(beanDest.getQC()); + command.append(" values ( "); + */ + //print rows + Object obj = null; + /* for(int k=0;k= 0 ) - { - alterMe.delete(index, index + 4); - length = length - 4; - } - + int index = alterMe.indexOf(".fp5"); + if (index >= 0) + { + alterMe.delete(index, index + 4); + length = length - 4; + } + while (j < length) - { + { if (alterMe.charAt(j) == ' ') { alterMe.setCharAt(j, '_'); - // if(j') - { - alterMe.setCharAt(j, '\\'); - alterMe.insert(j + 1, ">"); - length = length + 1; - if(j') + { + alterMe.setCharAt(j, '\\'); + alterMe.insert(j + 1, ">"); + length = length + 1; + if(j1) - { - for(int j=0;j\n"); - buffr.write(" "+bean.url+"\n"); - buffr.write(" "+bean.user+"\n"); - buffr.write(" "+bean.passwd+"\n"); - String modeString =""; - if (mode == CONVERT_MODE) - modeString = "convert"; - else - if (mode == APPEND_MODE) + public static class DataBase + { + DBBean bean; + Vector creates; + Vector selects; + Vector layouts; + Vector tables; + Vector ids; + final static int CONVERT_MODE = 1; + final static int APPEND_MODE = 2; + final static int UPDATE_MODE = 3; + int mode = -1; + + public DataBase(DBBean bean, Vector tables, Vector layouts, Vector selects, Vector creates, Vector ids, int mode) + { + this.bean = bean; + this.tables = tables; + this.layouts = layouts; + this.selects = selects; + this.creates = creates; + this.ids = ids; + this.mode = mode; + this.bean.setIDVector(ids); + } + public void exportToXML(BufferedWriter buffr) throws Exception + { + // ids=bean.getIDVector(); + buffr.write(" \n"); + buffr.write(" " + bean.url + "\n"); + buffr.write(" " + bean.user + "\n"); + buffr.write(" " + bean.passwd + "\n"); + String modeString = ""; + if (mode == CONVERT_MODE) + modeString = "convert"; + else if (mode == APPEND_MODE) modeString = "append"; - else - if (mode == UPDATE_MODE) - modeString = "update"; - - buffr.write(" "+ modeString+"\n"); - int index = 0; - while(index\n"); - buffr.write(" \n"); - if(!create.equals("")) - buffr.write(" "+create+" \n"); - buffr.write(" \n"); - index++; - } - buffr.write(" \n"); - } -public String toString() {return bean.url+" "+tables;} + else if (mode == UPDATE_MODE) + modeString = "update"; -} -public static String convertToUTF8(Object command) -{ - String str = null; - try - { - str = new String(command.toString().getBytes("UTF-8")); - } catch (UnsupportedEncodingException e) + buffr.write(" " + modeString + "\n"); + int index = 0; + while (index < tables.size()) + { + String table = (String) tables.get(index); + String layout = (String) layouts.get(index); + String select = (String) selects.get(index); + String create = (String) creates.get(index); + String id = (String) ids.get(index); + + buffr.write(" \n"); + buffr.write(" \n"); + if (!create.equals("")) + buffr.write(" " + create + " \n"); + buffr.write("
\n"); + index++; + } + buffr.write(" \n"); + } + public String toString() + { + return bean.url + " " + tables; + } + + } + public static String convertToUTF8(Object command) { - // TODO Auto-generated catch block - e.printStackTrace(); + String str = null; + try + { + str = new String(command.toString().getBytes("UTF-8")); + } catch (UnsupportedEncodingException e) + { + // TODO Auto-generated catch block + e.printStackTrace(); + } + return str; } - return str; -} public static void writeConfig(String file, DataBase source, DataBase destination) throws Exception { - if(!file.toLowerCase().endsWith(".xml")) file+=".xml"; + if (!file.toLowerCase().endsWith(".xml")) + file += ".xml"; File f = new File(file); - - FileOutputStream fout= new FileOutputStream(f); - OutputStreamWriter outsw = new OutputStreamWriter(fout,"UTF-8"); + + FileOutputStream fout = new FileOutputStream(f); + OutputStreamWriter outsw = new OutputStreamWriter(fout, "UTF-8"); BufferedWriter buffw = new BufferedWriter(outsw); buffw.write(""); buffw.newLine(); @@ -1281,5 +1439,5 @@ public static String convertToUTF8(Objec buffw.write(" \n"); buffw.write("\n"); buffw.close(); - } -} \ No newline at end of file + } +} \ No newline at end of file