testsql.java#1.2

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

package com.qixuan.jdbc;

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

import com.qixuan.jdbc.common.SourceDataBase;
import com.qixuan.jdbc.common.TargetDataBase;
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) {
		
		//new SourceDataBase();
		//new TargetDataBase();
		connection_source=SourceDataBase.getConnection();
		connection_target=TargetDataBase.getConnection();
		ALTERTablesUtil.UpdateColumnRecordFlag(connection_source,0);
		//run();
	
	}
	public static void run(){
		ALTERTablesUtil.AddColumnByRecordFlag(connection_source);
		System.out.println("------------------同步开始-------------");
		DatabaseMetaDataUtil dbmu = new DatabaseMetaDataUtil(connection_source);
		ResultSetMetaDataUtil rmdu = new ResultSetMetaDataUtil(connection_source);
		List<String> tableNames = dbmu.getTableNames();
		for (String tableName : tableNames) {
			rmdu.setTableName(tableName);						
			List<ColumnData> dataList =  rmdu.getColumns();
			int count=rmdu.getColumnCount();
			System.out.println("表名："+tableName+",columnCount="+count);
			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);
	}
}