import java.util.*;
import java.sql.*;
import java.awt.Cursor;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintStream;
import java.io.UnsupportedEncodingException;
import com.exploringxml.xml.Node;
import com.exploringxml.xml.Xparse;
class Convert
{
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 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)
{
e.printStackTrace();
}*/
FileOutputStream file = null;
if(args.length!=1)
{
System.out.println("Usage: java Convert <xml config file>");
System.exit(-1);
}
if(!(new File(args[0]).exists())) System.exit(0);
try
{
file = new FileOutputStream("./log.txt");
} catch (FileNotFoundException e1)
{
e1.printStackTrace();
}
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,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;
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();
//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 {
String 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.equals(""))
{
System.out.println("before "+query+" table"+names.get(tbIndex));
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();
/* dialog.title.setText("Getting table data ...");
dialog.table.setText(names.get(tbIndex).toString());
dialog.status.setText("Table " + (tbIndex + 1) + " of " + names.size());
dialog.show();
*/
System.out.println(" performing query "+query);
//result = bean.getQueryData(query, null, 0);
bean.getConnection();
bean.makeQuery(query,0);
} catch (Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
continue;
}
//beanDest.setConnection("jdbc:postgresql://erebos/test3");
beanDest.setConnection(destination.url);
Statement stm = beanDest.getConnection().createStatement();
Vector tables = beanDest.getTableNames();
// Collections.sort(tables);
System.out.println("converting table "+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(tables.indexOf(names.get(tbIndex))>=0)
{
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)
{
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());
}
}
// 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 + "' ");
*/
// 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();
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<row.size()-1;++k)
{
obj = row.get(k);
//System.out.println("row "+obj+" "+k);
if(obj!=null&&!(obj instanceof ArrayList))
command.append("'"+convertUml(new String(obj.toString().getBytes("UTF-8"),"UTF-8"))+"',");
else if(obj!=null&& obj instanceof ArrayList)
command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"',");
else command.append("NULL,");
}
obj = row.get(row.size() - 1);
if (obj != null && !(obj instanceof ArrayList))
command.append("'"+convertUml(new String(obj.toString().getBytes("UTF-8"),"UTF-8"))+"')");
else
if(obj!=null&& obj instanceof ArrayList)
command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"')"); //command.append(obj.toString()+")");
else command.append("NULL)");
//command.append("'"+row.get(row.size()-1)+"')");
//command.append(" )");
// for(int k=0;k<row.size();++k)
// System.out.println();
// System.out.println(command+" "+j+" "+row.size()+" "+ ((Vector)result2[0].get(j)).size());
// System.out.println(command);
stm.executeUpdate(command.toString());
// dialog.progress.setValue((int)(((double)(j+1)/(double)result[0].size())*100.0));
// System.out.println( (int)(((double)(j+1)/(double)result[0].size())*100.0)+" "+result[0].size()+" "+j);
command = null;
*/
for (int k = 0; k < row.size(); ++k)
{
obj = row.get(k);
if (obj instanceof ArrayList)
obj = ((List) obj).get(0);
String str = (obj == null) ? "NULL" : obj.toString();
if (!str.equals("NULL"))
pstm.setString(k + 1, str);
else
pstm.setNull(k + 1, Types.NULL);
}
pstm.execute();
}// to for loop
}
} catch(Exception e)
{
System.out.println("Error while connecting to database "+ e);
//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);
System.err.println(b);
//FM2SQL.showErrorDialog(b.toString(), "Error occured !");
}
// dialog.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
//FM2SQL.fmInstance.setCursor(Cursor.getPredefinedCursor(Cursor.DEFAULT_CURSOR));
// dialog.setVisible(false);
}
public static void update(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();
}
// setting user and passwd
bean.setUserAndPasswd(user, passwd);
// setting user and passwd
beanDest.setUserAndPasswd(userDest, passwdDest);
if (dialog != null)
dialog.setSize(400, 250);
StringBuffer command = null;
String query = null;
try
{
//bean.setConnection("jdbc:fmpro:http://141.14.237.74:8050");
//bean.setConnection("jdbc:postgresql://erebos/test","postgres","rogo");
bean.setConnection(source);
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
{
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);
}
dialog.title.setText("Getting table data ...");
dialog.table.setText(names.get(tbIndex).toString());
dialog.status.setText("Table " + (tbIndex + 1) + " of " + names.size());
dialog.show();
bean.getConnection();
bean.makeQuery(query, 0);
} catch (Exception e)
{
continue;
}
//beanDest.setConnection("jdbc:postgresql://erebos/test3");
beanDest.setConnection(destination);
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 (dialog != null)
dialog.title.setText("Writing table data ...");
int j = -1;
Vector row = null;
command = new StringBuffer();
command.append("UPDATE ");
command.append(beanDest.getQC());
command.append(convertText((String) names.get(tbIndex)));
command.append(beanDest.getQC());
command.append(" SET ");
int size = bean.getColumnNames().size();
for (int i = 0; i < size - 1; ++i)
command.append(beanDest.getQC()+convertText((String)bean.getColumnNames().get(i))+beanDest.getQC()+" = ? ,");
command.append(convertText((String)bean.getColumnNames().get(size-1))+" = ? ");
command.append("WHERE "+convertText(ids.get(tbIndex).toString())+ " = ?");
PreparedStatement pstm = beanDest.getConnection().prepareStatement(command.toString());
System.out.println(command+" "+tbIndex);
int rowCount = bean.getRowCount(query);
int idIndex = bean.getColumnNames().indexOf(ids.get(tbIndex) );
while ((row = bean.getNextRow()) != null)
{
j++;
//print rows
Object obj = null;
/* for(int k=0;k<row.size()-1;++k)
{
obj = row.get(k);
//System.out.println("row "+obj+" "+k);
if(obj!=null&&!(obj instanceof ArrayList))
command.append("'"+convertUml(obj.toString())+"',");
else if(obj!=null&& obj instanceof ArrayList)
command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"',");
else command.append("NULL,");
}
obj = row.get(row.size() - 1);
if (obj != null && !(obj instanceof ArrayList))
command.append("'"+convertUml(obj.toString())+"')");
else
if(obj!=null&& obj instanceof ArrayList)
command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"')"); //command.append(obj.toString()+")");
else command.append("NULL)");
*/
//command.append("'"+row.get(row.size()-1)+"')");
//command.append(" )");
// for(int k=0;k<row.size();++k)
// System.out.println();
// System.out.println(command+" "+j+" "+row.size()+" "+ ((Vector)result2[0].get(j)).size());
// System.out.println(command);
for (int k = 0; k < row.size(); ++k)
{
obj = row.get(k);
if (obj instanceof ArrayList)
obj = ((List) obj).get(0);
String str = (obj == null) ? "NULL" : obj.toString();
if (!str.equals("NULL"))
pstm.setString(k + 1, str);
else
pstm.setNull(k + 1, Types.NULL);
}
pstm.setString(row.size()+1,row.get(idIndex).toString());
//System.out.println(pstm.toString());
// System.exit(0);
pstm.execute();
//stm.executeUpdate(command.toString());
if(dialog!=null)
dialog.progress.setValue((int) (((double) (j + 1) / (double) rowCount) * 100.0));
// System.out.println( (int)(((double)(j+1)/(double)result[0].size())*100.0)+" "+result[0].size()+" "+j);
command = null;
} // to for loop
}
} 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 !");
}
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 = 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));
java.util.TreeSet myIds = new TreeSet();
int deltaID = 1;
String idField = "";
dialog.thread=Thread.currentThread();
// setting user and passwd
bean.setUserAndPasswd(user,passwd);
// setting user and passwd
beanDest.setUserAndPasswd(userDest,passwdDest);
dialog.setSize(400,250);
StringBuffer command= null;
String query = null;
try
{
//bean.setConnection("jdbc:fmpro:http://141.14.237.74:8050");
//bean.setConnection("jdbc:postgresql://erebos/test","postgres","rogo");
bean.setConnection(source);
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
{
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();
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);
// @TODO id Vector must be used in querys while loop over id ranges where id>=start and id<=end
idField = ids.get(tbIndex).toString();
} catch (Exception e)
{
System.out.println(e);
continue;
}
//beanDest.setConnection("jdbc:postgresql://erebos/test3");
beanDest.setConnection(destination);
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(tables.indexOf(names.get(tbIndex))>=0)
{
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)
{
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());
}
}
dialog.title.setText("Writing table data ...");
// prepare the insert statement
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<bean.getColumnNames().size()-1;++i) command.append("?,");
command.append("?)");
PreparedStatement pstm = beanDest.getConnection().prepareStatement(command.toString());
System.out.println(command);
int rowCount= (idField!="") ? myIds.size():bean.getRowCount(query);
Vector vec = new Vector(myIds);
int endIndex = -1;
String tempQuery=query;String tempID = bean.getQC()+idField+bean.getQC();
if (!idField.equals(""))
{
long startTime = System.currentTimeMillis();
while (true)
{
dialog.title.setText("Retrieving next ID Vector ");
myIds = bean.getIDVector(ids.get(tbIndex).toString(), (String) names.get(tbIndex), tempQuery, numHits);
if(myIds.isEmpty()) break;
vec = new Vector(myIds);
rowCount = vec.size()/numIntervalls;
System.out.println("ID LIST SIZE " + Math.round((double) myIds.size() / (double) numIntervalls) + " " + myIds.size());
deltaID = (int) Math.round((double) myIds.size() / (double) numIntervalls);
for (int k = 0; k < vec.size() - deltaID; k = k + deltaID)
{
System.out.println(vec.get(k) + " " + vec.get(k + deltaID) + " " + vec.lastElement());
if (query.indexOf("where") > 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);
dialog.title.setText("Reading table data ...");
bean.makeQuery(tempQuery, deltaID);
dialog.title.setText("Writing table data ...");
command = writeDatainDestTable(dialog, command, k, pstm, rowCount);
endIndex = k + deltaID;
}
if ((vec.size() - 1) % numIntervalls == 0)
System.out.println("fits");
else
{
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);
dialog.title.setText("Reading table data ...");
bean.makeQuery(tempQuery, 0);
dialog.title.setText("Writing table data ...");
command = writeDatainDestTable(dialog, command, j, pstm, rowCount);
System.out.println(" last intervall from " + vec.get(endIndex) + " " + vec.lastElement());
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);
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 !");
}
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<row.size()-1;++k)
{
obj = row.get(k);
//System.out.println("row "+obj+" "+k);
if(obj!=null&&!(obj instanceof ArrayList))
command.append("'"+convertUml(obj.toString())+"',");
else if(obj!=null&& obj instanceof ArrayList)
command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"',");
else command.append("NULL,");
}
obj = row.get(row.size() - 1);
if (obj != null && !(obj instanceof ArrayList))
command.append("'"+convertUml(obj.toString())+"')");
else
if(obj!=null&& obj instanceof ArrayList)
command.append("'"+convertUml(((ArrayList)obj).get(0).toString())+"')"); //command.append(obj.toString()+")");
else command.append("NULL)");
*/
//command.append("'"+row.get(row.size()-1)+"')");
//command.append(" )");
// for(int k=0;k<row.size();++k)
// System.out.println();
// System.out.println(command+" "+j+" "+row.size()+" "+ ((Vector)result2[0].get(j)).size());
// System.out.println(command);
for(int k=0;k<row.size();++k)
{
obj = row.get(k);
if(obj instanceof ArrayList) obj=((List)obj).get(0);
String str =(obj==null) ? "NULL":obj.toString();
if(!str.equals("NULL"))
pstm.setString(k+1,str);
else pstm.setNull(k+1,Types.NULL);
}
pstm.execute();
//stm.executeUpdate(command.toString());
dialog.progress.setValue((int) (((double) (j + 1) / (double) rowCount) * 100.0));
// System.out.println( (int)(((double)(j+1)/(double)result[0].size())*100.0)+" "+result[0].size()+" "+j);
command = null;
}// to while loop
return command;
}
public static String convertText(String newName)
{
StringBuffer alterMe = new StringBuffer(newName.trim().toLowerCase());
int length = alterMe.length();
int j = 0;
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<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == '_')
{
if(alterMe.charAt(j+1)=='_')
alterMe.deleteCharAt(j);
length = length-1;
// if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == 'ä')
{
alterMe.setCharAt(j, 'a');
alterMe.insert(j+1,"e");
length=length+1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == 'ö')
{
alterMe.setCharAt(j, 'o');
alterMe.insert(j+1,"e");
length=length+1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == 'ü')
{
alterMe.setCharAt(j, 'u');
alterMe.insert(j+1,"e");
length=length+1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == 'ß')
{
alterMe.setCharAt(j, 's');
alterMe.insert(j + 1, "s");
length = length + 1;
if (j < length - 1)
j = j + 1;
} else if (alterMe.charAt(j) == ':')
{
if(j<length-1)
{
if (alterMe.charAt(j + 1) == ':')
{
alterMe.setCharAt(j,'_');
alterMe.delete(j+1,j+2);
length = length - 1;
}
if (j < length - 1)
j = j + 1;
}
} else if (alterMe.charAt(j) == '-')
{
alterMe.setCharAt(j, '_');
} else if (alterMe.charAt(j) == '?')
{
// changed ? to _ because of update statement
alterMe.setCharAt(j,'_');
// length = length + 1;
// j=j+1;
System.out.println(alterMe);
}
else if (alterMe.charAt(j) == '.')
{
if(j==length-1)
{
alterMe.delete(j, j);
length--;
}
else
alterMe.setCharAt(j,'_');
}
++j;
}
return alterMe.toString();
}
public static String convertToEntities(String newName)
{
StringBuffer alterMe = new StringBuffer(newName.trim());
int length = alterMe.length();
int j = 0;
while (j < length)
{
if (alterMe.charAt(j) == '>')
{
alterMe.setCharAt(j, '&');
alterMe.insert(j + 1, "gt;");
length = length + 2;
if (j < length - 1)
j = j + 1;
} else if (alterMe.charAt(j) == '<')
{
alterMe.setCharAt(j, '&');
alterMe.insert(j + 1, "lt;");
length = length + 2;
if (j < length - 1)
j = j + 1;
}
++j;
}
return alterMe.toString();
}
public static String convertUml(String newName)
{
StringBuffer alterMe = new StringBuffer(newName.trim());
int length = alterMe.length();
int j = 0;
while (j < length)
{
if (alterMe.charAt(j) == '\'')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, "'");
length = length + 1;
if(j<length-1) j=j+1;
}
/* else
if (alterMe.charAt(j) == '"')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, "\"");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == '>')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, ">");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == '<')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, "<");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == '?')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, "?");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == '&')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, "&");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == '=')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, "=");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == ',')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, ",");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == '.')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, ".");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == '[')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, ".");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == ']')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, ".");
length = length + 1;
if(j<length-1) j=j+1;
}
else
if (alterMe.charAt(j) == '%')
{
alterMe.setCharAt(j, '\\');
alterMe.insert(j + 1, "%");
length = length + 1;
if(j<length-1) j=j+1;
}*/
++j;
}
return alterMe.toString();
}
public static void parseXMLConfig(StringBuffer sb)
{
boolean finished = false;
// parse string and build document tree
Xparse parser =new Xparse();
parser.changeEntities = true;
Node root = parser.parse(sb.toString());
// printContents(root);
Vector databases= new Vector();
Vector tables = new Vector();
Vector layouts = new Vector();
Vector selects = new Vector();
Vector creates = new Vector();
Vector ids = new Vector();
int mode = -1;
try
{
Node tempNode = root.find("convert/source", new int[] { 1, 1 });
if(tempNode==null) throw new Error("parse error source tag missing");
System.out.println(tempNode.name);
int length =countNodes(tempNode);
for (int i = 1; i <= length; i++)
{
DBBean database = new DBBean();
tables = new Vector();
layouts = new Vector();
selects = new Vector();
creates = new Vector();
ids = new Vector();
// parse dataBase
Node node = root.find("convert/source/database/url", new int[] { 1, 1, i, 1 });
Node node1 = root.find("convert/source/database/user", new int[] { 1, 1, i, 1, 1 });
Node node2 = root.find("convert/source/database/password", new int[] { 1, 1, i, 1, 1 });
Node node3 = root.find("convert/source/database", new int[] { 1, 1, i});
Node nodeMode = root.find("convert/source/database/mode", new int[] {1, 1, i, 1,1});
if(node3== null) throw new Error("parse error database tag missing");
if(node==null) throw new Error("parse error url tag missing");
if(node1==null) throw new Error("parse error user tag missing");
if(node2==null) throw new Error("parse error password tag missing");
String url=node.getCharacters();
String user=node1.getCharacters();
String password=node2.getCharacters();
database.setURL(url.trim());
database.setUserAndPasswd(user.trim(),password.trim());
System.out.println(node.name + " " + node.getCharacters());
System.out.println(node1.name + " " + node1.getCharacters());
System.out.println(node2.name + " " + node2.getCharacters());
String modeString = "";
if (nodeMode == null)
modeString = "convert";
else
modeString = nodeMode.getCharacters();
if (modeString.equals("convert"))
mode = DataBase.CONVERT_MODE;
else
if (modeString.equals("append"))
mode = DataBase.APPEND_MODE;
else
if (modeString.equals("update"))
mode = DataBase.UPDATE_MODE;
// if(node3!=null)
// System.out.println(node3.name);
int length2= countNodes(node3);
System.out.println("number of tables " +length2);
for(int j=1;j<=length2;++j)
{
Node node4 = root.find("convert/source/database/table", new int[] { 1, 1, i, j });
Node node5 = root.find("convert/source/database/table/select", new int[] { 1, 1, i, j, 1 });
Node node6 = root.find("convert/source/database/table/create", new int[] { 1, 1, i, j, 1 });
if(node4!=null)
System.out.println(node4.name + " " + node4.attributes.get("layout").equals(""));
if(node5!=null)
System.out.println(node5.name + " " + node5.getCharacters());
if(node6!=null)
System.out.println(node6.name + " " + node6.getCharacters());
if(node4==null) throw new Error("parse error table tag missing");
// if(node5==null) throw new Error("parse error select tag missing");
// if(node6==null) throw new Error("parse error create tag missing");
String name = (String)node4.attributes.get("name");
String layout = (String)node4.attributes.get("layout");
String id = (String)node4.attributes.get("id");
System.out.println("id was "+id);
if(name==null) throw new Error("parse error required table tag attribute name missing");
if(layout==null) layout ="";
if(id==null) id = "";
if(name.equals("")) throw new Error("parse error table tag attribute must not be empty");
tables.add(name);
layouts.add(layout);
ids.add(id);
String query = (node5==null) ? "":node5.getCharacters();
if(query.equals("")) System.err.println("Warning empty select tag or select tag missing !!");
query = (query.equals("")) ? "select * from "+database.getQC()+name+database.getQC():query;
selects.add(query);
if(node6!=null) creates.add(node6.getCharacters().trim());
else
creates.add("");
}
databases.add(new DataBase(database, tables, layouts, selects,creates,ids,mode));
}
DBBean database = new DBBean();
// parse dataBase
Node node = root.find("convert/destination/database/url", new int[] { 1, 1, 1, 1 });
Node node1 = root.find("convert/destination/database/user", new int[] { 1, 1, 1, 1, 1 });
Node node2 = root.find("convert/destination/database/password", new int[] { 1, 1, 1, 1, 1 });
String url = node.getCharacters();
String user = node1.getCharacters();
String password = node2.getCharacters();
System.out.println(url);
database.setURL(url.trim());
database.setUserAndPasswd(user.trim(), password.trim());
//databases.add(database);
for (Iterator iter = databases.iterator(); iter.hasNext();)
{
DataBase db = (DataBase) iter.next();
if(mode!=DataBase.UPDATE_MODE)
convertBatch(db.bean,database,db.tables,db.layouts,db.selects,db.creates,mode);
else
update(db.bean.url,database.url,db.tables,db.layouts,db.selects,db.creates,db.ids,mode);
}
// printContents(node3);
// FM2SQL.fmInstance=new FM2SQL();
} catch (Exception e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
/*
Node tempNode=root.find(rootNode,new int[] {1});
if(tempNode==null) return rtTag;
int count=1;
/*
for(int i=0;i<tempNode.contents.v.size();++i)
{
// System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
}*/
/*
if(tempNode.contents.v.size()==0) return rtTag;
Node notNull=null;
Node rtNode=root.find(rootNode+"/rt",new int[] {1,1});
rtTag=(rtNode==null) ? "finished":rtNode.getCharacters();
System.out.println("rt tag is "+ rtTag);
int length=0;//(tempNode.contents.length()-1)/2;
for(int i=0;i<tempNode.contents.v.size();++i) {
Node node=(Node)tempNode.contents.v.elementAt(i);
if(node.type.equals("element"))
if(node.name.equals("doc"))length++;
// System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
}
if(length==0) rtTag="finished";
while(count<=length)
{
//System.out.println(count+" "+length);
tempNode=root.find(rootNode+"/doc",new int[] {1,count});
if(tempNode==null)
{
rtTag="finished";
break;
}
Bundle.Document doc = new Bundle.Document();
Hashtable attributes=tempNode.attributes;
int docID=0;
int ver=0;
if(attributes != null)
{
docID=Integer.parseInt((String)attributes.get("id"));
ver=Integer.parseInt((String)attributes.get("ver"));
doc.addData("docID",(String)attributes.get("id"));
doc.addData("ver",(String)attributes.get("ver"));
}
bundle.docs.put(new Integer(docID),doc);
bundle.documents.addElement(doc);
// System.out.println("id " +docID+" ver "+ver);
Node fileNode=root.find(rootNode+"/doc/file",new int[] {1,count,1});
attributes=(fileNode==null)? null:fileNode.attributes;
int fileID=0;
int fileVer=0;
if(attributes != null)
{
fileID=Integer.parseInt((String)attributes.get("id"));
fileVer=Integer.parseInt((String)attributes.get("ver"));
doc.addData("fileID",(String)attributes.get("id"));
doc.addData("fileVer",(String)attributes.get("ver"));
// System.out.println("fileid " +fileID+" ver "+fileVer);
}
// add all Document tags to actual Document
for(int i=0;i<tempNode.contents.v.size();++i)
{
Node node=(Node)tempNode.contents.v.elementAt(i);
if(node.type.equals("element"))
{
//System.out.println(node.name+" "+node.getCharacters()+" "+node.contents.v.size());
if(node.contents.v.size()>1)
{
for(int j=0;j<node.contents.v.size();++j)
{
Node node2=(Node)node.contents.v.elementAt(j);
if(node2.type.equals("element"))
{
doc.addData(node2.name,node2.getCharacters());
//System.out.println(node2.name+" "+node2.getCharacters()+" "+node2.contents.v.size());
}
}
} else doc.addData(node.name,node.getCharacters());
}
}
bundle.docsLocator.put(doc.locator,doc);
bundle.documents.addElement(doc);
count++;
} */
// System.out.println(bundle.docs.size());
// return rtTag;
}
public static Vector getXMLConfig(String xmlFile)
{
StringBuffer sb=null;
try
{
// read XML Metadata from a file
FileInputStream fi= new FileInputStream(xmlFile);
InputStreamReader isr= new InputStreamReader(fi,"UTF-8");
BufferedReader buffr = new BufferedReader(isr);
sb=new StringBuffer();
int c=0;
while ((c = buffr.read()) != -1)
{
char ch=(char)c;
sb.append(ch);
// System.out.print((char)c);
}
} catch(Exception e) { e.printStackTrace();}
boolean finished = false;
// parse string and build document tree
Xparse parser =new Xparse();
parser.changeEntities = true;
Node root = parser.parse(sb.toString());
// printContents(root);
Vector databases= new Vector();
Vector tables = new Vector();
Vector layouts = new Vector();
Vector selects = new Vector();
Vector creates = new Vector();
Vector ids = new Vector();
int mode = -1;
try
{
Node tempNode = root.find("convert/source", new int[] { 1, 1 });
if(tempNode==null) throw new Error("parse error source tag missing");
System.out.println(tempNode.name);
int length =countNodes(tempNode);
for (int i = 1; i <= length; i++)
{
DBBean database = new DBBean();
tables = new Vector();
layouts = new Vector();
selects = new Vector();
creates = new Vector();
ids = new Vector();
// parse dataBase
Node node = root.find("convert/source/database/url", new int[] { 1, 1, i, 1 });
Node node1 = root.find("convert/source/database/user", new int[] { 1, 1, i, 1, 1 });
Node node2 = root.find("convert/source/database/password", new int[] { 1, 1, i, 1, 1 });
Node node3 = root.find("convert/source/database", new int[] { 1, 1, i});
Node nodeMode = root.find("convert/source/database/mode", new int[] { 1, 1, i, 1, 1 });
if(node3== null) throw new Error("parse error database tag missing");
if(node==null) throw new Error("parse error url tag missing");
if(node1==null) throw new Error("parse error user tag missing");
if(node2==null) throw new Error("parse error password tag missing");
String url=node.getCharacters();
String user=node1.getCharacters();
String password=node2.getCharacters();
database.setURL(url.trim());
database.setUserAndPasswd(user.trim(),password.trim());
System.out.println(node.name + " " + node.getCharacters());
System.out.println(node1.name + " " + node1.getCharacters());
System.out.println(node2.name + " " + node2.getCharacters());
String modeString = "";
if (nodeMode == null)
modeString = "convert";
else
modeString = nodeMode.getCharacters();
if (modeString.equals("convert"))
mode = DataBase.CONVERT_MODE;
else
if (modeString.equals("append"))
mode = DataBase.APPEND_MODE;
else
if (modeString.equals("update"))
mode = DataBase.UPDATE_MODE;
// if(node3!=null)
// System.out.println(node3.name);
int length2= countNodes(node3);
System.out.println("number of tables " +length2);
for(int j=1;j<=length2;++j)
{
Node node4 = root.find("convert/source/database/table", new int[] { 1, 1, i, j });
Node node5 = root.find("convert/source/database/table/select", new int[] { 1, 1, i, j, 1 });
Node node6 = root.find("convert/source/database/table/create", new int[] { 1, 1, i, j, 1 });
if(node4!=null)
System.out.println(node4.name + " " + node4.attributes.get("layout").equals(""));
if(node5!=null)
System.out.println(node5.name + " " + node5.getCharacters());
if(node6!=null)
System.out.println(node6.name + " " + node6.getCharacters());
if(node4==null) throw new Error("parse error table tag missing");
// if(node5==null) throw new Error("parse error select tag missing");
// if(node6==null) throw new Error("parse error create tag missing");
String name = (String)node4.attributes.get("name");
String layout = (String)node4.attributes.get("layout");
String id = (String)node4.attributes.get("id");
System.out.println("id was "+id);
if(name==null) throw new Error("parse error required table tag attribute name missing");
if(layout==null) layout ="";
if(id == null) id="";
if(name.equals("")) throw new Error("parse error table tag attribute must not be empty");
tables.add(name);
layouts.add(layout);
ids.add(id);
String query = (node5==null) ? "":node5.getCharacters();
if(query.equals("")) System.err.println("Warning empty select tag or select tag missing !!");
query = (query.equals("")) ? "select * from "+database.getQC()+name+database.getQC():query;
selects.add(query);
if(node6!=null) creates.add(node6.getCharacters().trim());
else
creates.add("");
}
databases.add(new DataBase(database, tables, layouts, selects,creates,ids,mode));
}
DBBean database = new DBBean();
// parse dataBase
Node node = root.find("convert/destination/database/url", new int[] { 1, 1, 1, 1 });
Node node1 = root.find("convert/destination/database/user", new int[] { 1, 1, 1, 1, 1 });
Node node2 = root.find("convert/destination/database/password", new int[] { 1, 1, 1, 1, 1 });
String url = node.getCharacters();
String user = node1.getCharacters();
String password = node2.getCharacters();
System.out.println(url);
database.setURL(url.trim());
database.setUserAndPasswd(user.trim(), password.trim());
databases.add(new DataBase(database,null,null,null,null,null,0));
//databases.add(database);
/* for (Iterator iter = databases.iterator(); iter.hasNext();)
{
DataBase db = (DataBase) iter.next();
convertBatch(db.bean,database,db.tables,db.layouts,db.selects,db.creates);
}*/
// printContents(node3);
// FM2SQL.fmInstance=new FM2SQL();
} catch (Exception e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
return databases;
}
private static int countNodes(Node tempNode)
{
int length = 0;
for(int i=0;i<tempNode.contents.v.size();++i) {
Node node=(Node)tempNode.contents.v.elementAt(i);
if(node.type.equals("element"))
{
if(node.name.equals("database"))length++;
if(node.name.equals("table"))length++;
}
// System.out.println(((Node)tempNode.contents.v.elementAt(i)).attributes+" "+i);
}
return length;
}
private static void printContents(Node root)
{
Vector contents=(root.index==null)? root.contents.v:root.index.v;
for (int i=0;i<contents.size();++i)
{
Node n=(Node)contents.elementAt(i);
if(n.type.equals("element"))
{
System.out.println("tag "+n.name);
System.out.println(n.getCharacters());
//contents=n.contents.v i=0;
}
// System.out.println(n.type);
}
}
public static void readXMLFile(String xmlFile)
{
try
{
// read XML Metadata from a file
FileInputStream fi= new FileInputStream(xmlFile);
InputStreamReader isr= new InputStreamReader(fi,"UTF-8");
BufferedReader buffr = new BufferedReader(isr);
StringBuffer sb=new StringBuffer();
int c=0;
while ((c = buffr.read()) != -1)
{
char ch=(char)c;
sb.append(ch);
// System.out.print((char)c);
}
parseXMLConfig(sb);
} catch(Exception e) { e.printStackTrace();}
}
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(" <database>\n");
buffr.write(" <url>"+bean.url+"</url>\n");
buffr.write(" <user>"+bean.user+"</user>\n");
buffr.write(" <password>"+bean.passwd+"</password>\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(" <mode>"+ modeString+"</mode>\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(" <table name = \""+table+"\" layout = \""+layout+"\" id = \""+id+"\" >\n");
buffr.write(" <select>"+ convertToEntities(select)+"</select>\n");
if(!create.equals(""))
buffr.write(" <create>"+create+" </create>\n");
buffr.write(" </table>\n");
index++;
}
buffr.write(" </database>\n");
}
public String toString() {return bean.url+" "+tables;}
}
public static String convertToUTF8(Object command)
{
String str = null;
try
{
str = new String(command.toString().getBytes("UTF-8"));
} catch (UnsupportedEncodingException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
return str;
}
public static void writeConfig(String file, DataBase source, DataBase destination) throws Exception
{
if(!file.toLowerCase().endsWith(".xml")) file+=".xml";
File f = new File(file);
FileOutputStream fout= new FileOutputStream(f);
OutputStreamWriter outsw = new OutputStreamWriter(fout,"UTF-8");
BufferedWriter buffw = new BufferedWriter(outsw);
buffw.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
buffw.newLine();
buffw.write("<convert>\n");
buffw.write(" <source>\n");
source.exportToXML(buffw);
buffw.write(" </source>\n");
buffw.write("\n <destination>\n");
destination.exportToXML(buffw);
buffw.write(" </destination>\n");
buffw.write("</convert>\n");
buffw.close();
}
}
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