getsourcetabfield.java

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

package com.unimas.dbsync.manage;


import com.unimas.dbsync.input.SourceDataBase;
import com.unimas.dbsync.entity.SourceTabBaseBean;

import java.sql.*;

/**
 * Created by IntelliJ IDEA.
 * User: 孔加亮
 * Date: 2008-12-11
 * Time: 12:19:39
 */

/**
 * 返回源端中表的字段信息
 */
public class GetSourceTabField {
    Connection conn = null;
    Statement stmt = null;
    ResultSet resultSet = null;
    String SourceTabName;//从配置文件中读出的表名
    private String[] SourceTabFieldMessage = null;

    public boolean getCTF(SourceTabBaseBean bean) {
        /**
         * 返回连接到指定数据库的true或者false
         * 对象数组ServerTabInf指向所有的表字段名等信息
         */
        boolean getServerTabField = false;

        try {
            conn = SourceDataBase.getInstance().getConnection();
            //建立与数据库的连接
            stmt = conn.createStatement();
            resultSet = stmt.executeQuery("select * from" + SourceTabName); //得到表信息
            if (!resultSet.wasNull()) {
                ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
                DatabaseMetaData dmd = conn.getMetaData();
                //获取表的基本信息
                System.out.println("表字段个数:" + resultSetMetaData.getColumnCount());
                System.out.println("表字段信息");
                for (int i = 1; i <= resultSetMetaData.getColumnCount(); i++) {
                    SourceTabFieldMessage[i] = "(" + resultSetMetaData.getColumnName(i) +
                            "," + resultSetMetaData.getColumnTypeName(i) +
                            "," + resultSetMetaData.getColumnDisplaySize(i) +
                            "," + dmd.getPrimaryKeys(null, null, SourceTabName) +
                            ")";//源端表字段信息
                }
                bean.setTabFieldMessage(SourceTabFieldMessage); //将表字段信息存入TargetTabFieldMessagd对象
                if (SourceTabFieldMessage != null) {
                    getServerTabField = true;
                }

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

}