testmetadata.java#1.1.1.1

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

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 TestMetaData {

	public static void main(String[] args) {
		/*MetaDataDemo demo = new MetaDataDemo();
		demo.databaseMetadata();*/
		// demo.resultSetMetadata();
		Connection connection = null;
		PreparedStatement pstmt = null;
		ResultSetMetaData rsmd = null;
		Map<String, List<ColumnData>> tableDes = new HashMap<String, List<ColumnData>>();
		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);
			tableDes.put(tableName, rmdu.getColumnNames());
			System.out.println("表名："+tableName+",columnCount="+rmdu.getColumnCount());
		}
		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("表名：");
			for (ColumnData entity : dataList) {
				//InsertRecordsToDb.getInsertSql();
				System.out.println(entity);
			}
		}
	}

}