dbtablemanager.java

农业银行ATM对帐查询系统后台类包的源代码,实现了FTP,数据库管理等等功能

package boco.DBManager.Tree;

//******************************************************************************
//:功能:实现从DBTable表中取出数据表信息
//:时间:2002-07
//:作者:王建宾
//:特殊描述::test:为DEBUG时启用
//:程序描述:
//
//******************************************************************************

import COM.ibm.db2.jdbc.net.DB2Driver;
import java.util.*;
import java.sql.*;
import boco.shabank.dbconnection.*;
public class DBTableManager {
  //定义变量
  ResultSet rs=null;
  int DBTID=0;
  int DBSID=0;
  int judge=0;
  String DBTName="";
  String DBTType="";
  String DBTRemark="";
  String DBTKey="";
  String DBTPower="";

  String sql=null;
  Vector vDBTID=new Vector();
  Vector vDBSID=new Vector();
  Vector vDBTName=new Vector();
  Vector vDBTType=new Vector();
  Vector vDBTRemark=new Vector();
  Vector vDBTPower=new Vector();
  Vector vDBTKey=new Vector();
  DBConnectionManager objDBConnection=null;
  Connection m_Connection=null;
  DBAccess db=null;
  //构造函数，初始化变量
  public DBTableManager() {
  }
  //返回所有数据类型
  public DBTableManager(String dbsid,String thePower){
    db=new DBAccess();
    ChineseTransfer ct = new ChineseTransfer();
    sql="select distinct DBTType,powersite from DBTable where DBSid = "+dbsid+" order by dbttype";
    //:test:System.out.println(sql) ;
    try{
      objDBConnection=objDBConnection.getInstance() ;
      m_Connection = objDBConnection.getConnection("access") ;
      rs = db.executeQuery(m_Connection,sql) ;
      //:test:System.out.println(sql);
      while(rs.next()){
        if(rs.getString(2)!=null&&!rs.getString(2).trim().equals("")){
          judge=Integer.parseInt(rs.getString(2).trim());
          if(!thePower.substring(judge,judge+1).equals("0")){
            vDBTType.addElement(ct.AsciiToChineseString(rs.getString(1).toString()));
            vDBTPower.addElement(thePower.substring(judge,judge+1));
          }
        }
      }
      rs.close() ;
      objDBConnection.freeConnection("access",m_Connection) ;
    }
    catch(Exception e){
      System.out.println("errMsg:"+e.getMessage()) ;
    }
  }
  //返回所有数据源记录
  public void getAllTableRecode(String FRDBSID,String FRTType){
    ChineseTransfer ct = new ChineseTransfer();
    FRTType = ct.ChineseStringToAscii(FRTType) ;
    sql="select * from dbtable where DBSID=" + FRDBSID + " and DBTType='"+FRTType+"'"+" order by dbttype";
    //:test:System.out.println(sql);
    //connect to urls and execute sql
    try{
      db=new DBAccess();
      objDBConnection=objDBConnection.getInstance() ;
      m_Connection = objDBConnection.getConnection("access") ;
      rs = db.executeQuery(m_Connection,sql) ;
      while(rs.next()){
        //:test:System.out.println("rs2="+rs.getString(3)) ;
        vDBTID.addElement(rs.getString(1));
        vDBSID.addElement(rs.getString(2));
        vDBTName.addElement(rs.getString(3)) ;
        vDBTRemark.addElement(rs.getString(5));
        vDBTKey.addElement(rs.getString(6));
      }
      //free connection
      rs.close() ;
      objDBConnection.freeConnection("access",m_Connection) ;
    }
    catch(Exception e){
      System.out.println("erro="+e.getMessage());
    }
  }
  //取得所有数据源信息
  public Vector getAllDBTID(){
    return vDBTID;
  }
  public Vector getAllDBSID(){
    return vDBSID;
  }
  public Vector getAllDBTName(){
    return vDBTName;
  }
  public Vector getAllDBTType(){
    return vDBTType;
  }
  public Vector getAllDBTPower(){
    return vDBTPower;
  }
  public Vector getAllDBTRemark(){
    return vDBTRemark;
  }
  public Vector getAllDBTKey(){
    return vDBTKey;
  }

  //取属性
  public int getDBTID(){
    return DBTID;
  }
  public int getDBSID(){
    return DBSID;
  }
  public String getDBTName(){
    return DBTName;
  }
  public String getDBTType(){
    return DBTType;
  }
  public String getDBTRemark(){
    return DBTRemark;
  }
  public String getDBTKey(){
    return DBTKey;
  }
  //main test
  public static void main(String[] args){
    DBSourceManager dbs = new DBSourceManager();
    dbs.getAllSourceRecode("1111111111111111111111111111111111111111111111");
    Vector DBSID = new Vector();
    DBSID = dbs.getAllDBSID();
    for(int i=0;i<DBSID.size();i++){
      DBTableManager dbm = new DBTableManager(DBSID.elementAt(i).toString(),"111111111111111111111111111111");
      Vector DBTName = new Vector();
      //System.out.println(DBSID.elementAt(i).toString());
      DBTName = dbm.getAllDBTPower();
      System.out.println(DBTName.toString());
      DBTName.removeAllElements();
    }
  }
}