简易元数据管理操作

package cn.com.zhgl.test;

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;

public class TestMetaData {
	
	public static void test(String tableName,String tableOwner) {
		Connection conn = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		Map tableMap = new HashMap();
		Map pkMap = new HashMap();
		Map indexMap = new HashMap();
		Map columnsMap = new HashMap();
		
		try {
			
			Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
			String url="jdbc:oracle:thin:@localhost:1521:myorcl";
			String user = tableOwner;
			String password = tableOwner;
			conn = DriverManager.getConnection(url, user, password);
			
			if(conn == null) {
				System.out.println("链接为空");
			}else {
				DatabaseMetaData metaData = conn.getMetaData();
				
				//获取jwzh_tools_zsb这个用户下的数据库表对象
				rs = metaData.getTables(null, tableOwner, null, null);
				tableMap = getObjectMap(rs,"TABLE_NAME","TABLE_TYPE");//获取jwzh_tools_zsb这个用户下的数据库对象Map
				
				//获取jwzh_tools_zsb这个用户下的数据库主键对象
				rs = metaData.getPrimaryKeys(tableOwner, tableOwner, tableName);
				pkMap = getPKMap(rs, "COLUMN_NAME", "PK_NAME");
				
				String option  = (String) tableMap.get(tableName);//取得tableName名称的对象的类型/表/视图/同义词
				int type = Integer.parseInt(option);
				switch(type) {
				case 1:
					System.out.println("表操作");
					//获取jwzh_tools_zsb这个用户下的数据库索引对象
					rs = metaData.getIndexInfo(tableOwner, tableOwner, tableName, false, false);
					indexMap = getIndexMap(rs, "COLUMN_NAME", "INDEX_NAME");
					
					String querySQL = "select TABLE_NAME,COLUMN_NAME,COMMENTS FROM USER_COL_COMMENTS where TABLE_NAME=?";
					pstmt = conn.prepareStatement(querySQL);
					pstmt.setString(1, tableName);
					rs = pstmt.executeQuery();
					Map commentMap = getTableObjectMap(rs, "COLUMN_NAME", "COMMENTS");
					//获取jwzh_tools_zsb这个用户下的数据库列对象
					ResultSet rscol = metaData.getColumns(tableOwner, tableOwner, tableName, null);
					
					while(rscol.next()) {
						String columnName = rscol.getString("COLUMN_NAME");
						String typeName = rscol.getString("TYPE_NAME");
						int columnSize = rscol.getInt("COLUMN_SIZE");
						String comment = (String) commentMap.get(columnName);
						String index = (String) indexMap.get(columnName)==null?"0":"1";
						String pk = (String) pkMap.get(columnName)==null?"0":"1";
						
						//持久化操作，此处省略 。。。 
					}
					break;
				case 2:
					System.out.println("视图操作");
					pstmt = conn.prepareStatement("select * from "+tableName+" where rownum = 1");
					rs = pstmt.executeQuery();
					ResultSetMetaData ViewMetaData = rs.getMetaData();
					
					pstmt = conn.prepareStatement("SELECT TABLE_NAME, COLUMN_NAME, COMMENTS FROM USER_COL_COMMENTS WHERE TABLE_NAME=?");
					pstmt.setString(1, tableName);
					rs = pstmt.executeQuery();
					Map viewCommonMap = getTableObjectMap(rs, "COLUMN_NAME", "COMMENTS");
					int columnCount  = ViewMetaData.getColumnCount();
					for(int index  = 1;index<=columnCount;index++) {
						String columnName = ViewMetaData.getColumnName(index);
						String comment = (String) viewCommonMap.get(columnName);
						
						//持久化操作，此处省略 。。。 
					}
					
					
					break;
				}
				
			}
			
		}catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	public static Map getObjectMap(ResultSet rs,String s1,String s2) throws Exception {
		Map resultMap = new HashMap();
		String type = "1";
		while(rs.next()) {
			String key = "";
			String value = "";
			key = rs.getString(s1);
			value = rs.getString(s2);
			if("TABLE".equals(value)) {
				type = "1";
			}else if("VIEW".equals(value)) {
				type = "2";
			}
			resultMap.put(key, type);
		}
		return resultMap;
	}
	
	public static Map getTableObjectMap(ResultSet rs,String s1,String s2) throws Exception {
		Map resultMap = new HashMap();
		while(rs.next()) {
			String key = "";
			String value = "";
			key = rs.getString(s1);
			value = rs.getString(s2);
			resultMap.put(key, value);
		}
		return resultMap;
	}
	
	public static Map getColumnObjectMap(ResultSet rs,String s1,String s2) throws Exception {
		Map resultMap = new HashMap();
		while(rs.next()) {
			String key = "";
			String value = "";
			key = rs.getString(s1);
			value = rs.getString(s2);
			resultMap.put(key, value);
		}
		return resultMap;
	}
	
	public static Map getPKMap(ResultSet rs,String s1,String s2) throws Exception {
		Map resultMap = new HashMap();
		while(rs.next()) {
			String key = "";
			String value = "";
			key = rs.getString(s1);
			value = rs.getString(s2);
			resultMap.put(key, value);
		}
		return resultMap;
	}
	
	public static Map getIndexMap(ResultSet rs,String s1,String s2) throws Exception {
		Map resultMap = new HashMap();
		while(rs.next()) {
			String key = "";
			String value = "";
			key = rs.getString(s1);
			value = rs.getString(s2);
			resultMap.put(key, value);
		}
		return resultMap;
	}

	public static void main(String[] args) {
		test("S_USER","JWZH_TOOLS_ZSB");
	}
}