testsql.java

来自「数据库远程同步软件NetBeans项目源文件 项目采用Jdesktop集成组件」· Java 代码 · 共 55 行

package com.qixuan.jdbc;

import java.sql.Connection;
import java.util.List;

import com.qixuan.jdbc.common.SourceDataBaseBean;
import com.qixuan.jdbc.common.TargetDataBaseBean;
import com.qixuan.jdbc.util.ALTERTablesUtil;
import com.qixuan.jdbc.util.ColumnData;
import com.qixuan.jdbc.util.DatabaseMetaDataUtil;
import com.qixuan.jdbc.util.InsertRecordsToDb;
import com.qixuan.jdbc.util.ResultSetMetaDataUtil;

public class TestSQL {
	static Connection connection_source = null;
	static Connection connection_target=null;
	public static void main(String[] args) {
        SourceDataBaseBean source = new SourceDataBaseBean();
        TargetDataBaseBean target = new TargetDataBaseBean();
		connection_source=source.getConnection();
		connection_target=target.getConnection();
		//ALTERTablesUtil.UpdateColumnRecordFlag(connection_source,0);
		run();
	
	}
	public static void run(){
		ALTERTablesUtil.AddColumnByRecordFlag(connection_source);
		ALTERTablesUtil.AddColumnByRecordFlag(connection_target);
		System.out.println("------------------同步开始-------------");
		DatabaseMetaDataUtil dbmu = new DatabaseMetaDataUtil(connection_source);
		
		List<String> tableNames = dbmu.getTableNames();
		for (String tableName : tableNames) {
             if("dtproperties".equals(tableName)){
				continue;
			}
             ResultSetMetaDataUtil rmdu = new ResultSetMetaDataUtil(connection_source,tableName);
			List<ColumnData> dataList =  rmdu.getColumns();			
			int count=rmdu.getColumnCount();
			System.out.println("表名："+tableName+",列数="+count+",行数:"+dataList.size());
			InsertRecordsToDb ird=new InsertRecordsToDb();
			ird.setConn(connection_target);
			ird.setColumns(dataList);
			ird.setTabName(tableName);
			ird.setCount(count);
			try{
			ird.ExecuteInsertSql();
			}catch(RuntimeException e){
				System.out.println("RuntimeException"+e.getMessage());
			}		
		}
		ALTERTablesUtil.UpdateColumnRecordFlag(connection_source,1);
	}
}