gettargettabname.java

来自「一个简单的数据库同步系统」· Java 代码 · 共 67 行

package com.unimas.dbsync.manage;

import com.unimas.dbsync.input.SourceDataBase;
import com.unimas.dbsync.output.TargetDataBase;
import com.unimas.dbsync.entity.TargetDataBaseBean;


import java.sql.*;

/**
 * Created by IntelliJ IDEA.
 * User: 孔加亮
 * Date: 2008-12-10
 * Time: 16:08:56
 */

/**
 * 读取源端的表名,判断数据库是否连通
 */
public class GetTargetTabName {
    public boolean getCTN(TargetDataBaseBean bean) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        boolean bl = false;
        String TabName = "";
        try {
            conn = TargetDataBase.getInstance().getConnection();
            stmt = conn.createStatement();
            DatabaseMetaData dmd = conn.getMetaData();
            rs = dmd.getTables(null, null, "%", null);
            while (rs.next()) {
                TabName += rs.getString(3) + "\n";
                System.out.println("表的名称" + TabName);
            }
            bean.setTablesName(TabName);
            if (conn != null) {
                bl = true;
            }
        } catch (SQLException sqle) {
            sqle.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (NullPointerException e) {
            e.printStackTrace();
        }
        finally {
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException sqlE) {
                    sqlE.printStackTrace();
                }
            }
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException sqle) {
                    sqle.printStackTrace();
                }
            }
            SourceDataBase.getInstance().closeConnection(conn);
        }
        return bl;
    }
}