inputtodb.java

一个用于实现不同数据库数据同步的程序

import java.io.*; 
import java.sql.*;
import javax.sql.*;

public class inputToDB
{
	private static String databaseName="";private static String txtAddress="";///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

	public static void main(String[] args)
	{
		sqlOperation so=new sqlOperation();
		File file=null;
		FileReader fr=null;

		try
		{
			file=new File(txtAddress+"information\\databases.txt");
			fr=new FileReader(file);
		}
		catch(FileNotFoundException e){}
		BufferedReader br=new BufferedReader(fr);

		
		//建新表DBINFORMATION，保存各数据库信息
		String sqlString="create table DBINFORMATION (DBNAME varchar(30) not null, DBTYPE varchar(30) not null, SSL varchar(30) not null,PASSWORD varchar(30) not null, DBHOST varchar(30) not null, DBSENDPORT varchar(30) not null, DBRECEIVEPORT varchar(30) not null, JNDI varchar(30) not null, MESS varchar(30) not null, EMAIL varchar(70) not null, STATE int not null)";
		so.updateTable(sqlString);

		try
		{
			String s="";
			int start=0,mid=0;		
			dealMessage cutingMessage=new dealMessage();
			while((s=br.readLine())!=null)
			{
				sqlString="insert into DBINFORMATION values('";
				s=s.replace("|||","\t");
				while((mid=s.indexOf("\t"))!=-1)
				{
					start=0;
					sqlString+=cutingMessage.cutMessage(s,start,mid)+"','";
					start=mid;
					mid=s.length();
					s=cutingMessage.cutMessage(s,start,mid);
				}
				sqlString+=s+"',0)";
				so.updateTable(sqlString);
			}
			fr.close();
			sqlString="update DBINFORMATION set STATE=1 where DBNAME='"+databaseName+"'";
			so.updateTable(sqlString);
		}
		catch(IOException e){}



		String tablename="";
		sqlString="create table TABLELIST (TABLE_NAME varchar(30) not null, COLUMN_NAME varchar(30) not null)";
		so.updateTable(sqlString);

		sqlString="SELECT Sysobjects.name AS TABLE_NAME, syscolumns.name AS COLUMN_NAME FROM syscolumns INNER JOIN systypes ON syscolumns.xtype = systypes.xtype LEFT JOIN sysobjects ON syscolumns.id = sysobjects.id LEFT OUTER JOIN sysproperties ON ( sysproperties.smallid = syscolumns.colid AND sysproperties.id = syscolumns.id) LEFT OUTER JOIN syscomments ON syscolumns.cdefault = syscomments.id WHERE syscolumns.id IN (SELECT id FROM SYSOBJECTS WHERE xtype = 'U' and Sysobjects.name!='DBINFORMATION') AND (systypes.name <> 'sysname')ORDER BY Sysobjects.name";

		ResultSet rs=so.ResultSetFromDB(sqlString);
		try
		{
			while(rs.next())
			{
				tablename=rs.getString("TABLE_NAME");
				if(!tablename.equals("TABLELIST"))
				{
					sqlString="insert into TABLELIST values('"+tablename+"','"+rs.getString("COLUMN_NAME")+"')";
					so.updateTable(sqlString);
				}
			}
			
			
		}
		catch(Exception e){}
	}
}