testinsertsql.java

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

package com.qixuan.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

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 TestInsertSQl {
	public static void main(String[] args) {
		Connection connection = null;
		PreparedStatement pstmt = null;
		ResultSetMetaData rsmd = null;
		Map<String, List<ColumnData>> tableDes = new HashMap();
		try {
			Class.forName("com.mysql.jdbc.Driver");
			connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/diims?autoReconnect=true","root","admin123");
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		//connection = DataSourcePool.getConnection();
		DatabaseMetaDataUtil dbmu = new DatabaseMetaDataUtil(connection);
		ResultSetMetaDataUtil rmdu = new ResultSetMetaDataUtil(connection);
		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.setColumns(dataList);
			ird.setTabName(tableName);
			ird.setCount(count);
			try{
			ird.ExecuteInsertSql();
			}catch(RuntimeException e){
				System.out.println("RuntimeException"+e.getMessage());
			}
			tableDes.put(tableName, rmdu.getColumns());
		}
		//printScreen(tableDes,tableNames);
	}
	public static void printScreen(Map<String, List<ColumnData>> map,
			List<String> tableNames) {
		for (String tableName : tableNames) {
			List<ColumnData> dataList = (List<ColumnData>) map.get(tableName);
			System.out.println("表名："+tableName);
			for (ColumnData entity : dataList) {
				//InsertRecordsToDb.getInsertSql();
				System.out.println(entity);
			}
		}
	}
}