gettargettabfield.java

一个简单的数据库同步系统

package com.unimas.dbsync.manage;


import com.unimas.dbsync.output.TargetDataBase;
import com.unimas.dbsync.entity.TargetTabBaseBean;

import java.sql.*;


/**
 * Created by IntelliJ IDEA.
 * User: Administrator
 * Date: 2008-12-11
 * Time: 12:18:22
 */

/**
 * 获取目标端的表字段信息
 */
public class GetTargetTabField {
    Connection conn = null;
    Statement stmt = null;
    ResultSet resultSet = null;
    String ClientTabName;//从配置文件中读出的目标端的表名
    private String[] TargetTabFieldMessage = null;

    public boolean getCTF(TargetTabBaseBean bean) {
        boolean getClientTabField = false;
        try {
            conn = TargetDataBase.getInstance().getConnection();
            //建立与数据库的连接
            stmt = conn.createStatement();
            resultSet = stmt.executeQuery("select * from" + ClientTabName);//读取表信息
            DatabaseMetaData dmd = conn.getMetaData();

            /**
             *  得到表列名等信息
             */
            if (!resultSet.wasNull()) {
                ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
                //获取表的基本信息
                System.out.println("该表的基本信息");
                System.out.println("表字段个数:" + resultSetMetaData.getColumnCount());
                for (int i = 1; i <= resultSetMetaData.getColumnCount(); i++) {
                    TargetTabFieldMessage[i] = "(" + resultSetMetaData.getColumnName(i) +
                            "," + resultSetMetaData.getColumnTypeName(i) +
                            "," + resultSetMetaData.getColumnDisplaySize(i) +
                            "," + dmd.getPrimaryKeys(null, null, ClientTabName)
                            + ")";//目标端表字段信息（依次为表名.列名.列的最大宽度。表的主键名）
                }
                bean.setTargetTabFieldMessage(TargetTabFieldMessage);
                if (TargetTabFieldMessage != null) {
                    getClientTabField = true;
                }

            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        catch (SQLException sqle) {
            sqle.printStackTrace();
        }
        return getClientTabField;
    }

}