dbsourcemanager.java

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

package boco.DBManager.Tree;

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

import java.util.*;
import java.sql.*;
import boco.shabank.dbconnection.*;
public class DBSourceManager {
  //定义全局变量
  ResultSet rs=null;
  int DBSID;
  String DBSName;
  String DBSDriver;
  String DBSURL;
  String DBUser;
  String DBPin;
  String DBSRemark;
  String DBSPower;
  String sql;
  Vector vDBSID;
  Vector vDBSDriver;
  Vector vDBSName;
  Vector vDBUser;
  Vector vDBSURL;
  Vector vDBPin;
  Vector vDBSRemark;
  Vector vDBSPower;
  int judge;
  DBConnectionManager objDBConnection;
  Connection m_Connection;
  DBAccess db;
  //构造函数，初始化变量
  public DBSourceManager() {
    db=new DBAccess();
    objDBConnection=objDBConnection.getInstance() ;
    DBSID=1;
    DBSName="";
    DBSDriver="";
    DBSURL="";
    DBUser="";
    DBPin="";
    DBSRemark="";
    DBSPower="";
    sql="";
    vDBSID=new Vector();
    vDBSDriver=new Vector();
    vDBSName=new Vector();
    vDBUser=new Vector();
    vDBSURL=new Vector();
    vDBPin=new Vector();
    vDBSRemark=new Vector();
    vDBSPower=new Vector();
    judge=0;
  }
  //返回所有数据源记录
  public void getAllSourceRecode(String thePower){
    sql="select * from dbsource order by dbsid";
    objDBConnection = objDBConnection.getInstance() ;
    try{
      m_Connection = objDBConnection.getConnection("access") ;
      rs = db.executeQuery(m_Connection,sql) ;
      while(rs.next()){
        //:test:System.out.print("DbSource=" + rs.getString(2)) ;
        //判断对应权限位
        judge=Integer.parseInt(rs.getString(8).trim());
        if(!thePower.substring(judge,judge+1).equals("0")){
          vDBSID.addElement(rs.getString(1));
          vDBSName.addElement(rs.getString(2)) ;
          vDBSDriver.addElement(rs.getString(3));
          vDBSURL.addElement(rs.getString(4)) ;
          vDBUser.addElement(rs.getString(5));
          vDBPin.addElement(rs.getString(6));
          vDBSRemark.addElement(rs.getString(7));
          vDBSPower.addElement(thePower.substring(judge,judge+1));
        }
      }
      //断开连接,释放资源
      rs.close() ;
      objDBConnection.freeConnection("access",m_Connection) ;
    }
    catch(Exception e){
      System.out.print("errorMsg=" + e.getMessage()) ;
    }
  }
      //取得所有数据源信息
    public Vector getAllDBSID(){
      return vDBSID;
    }
    public Vector getAllDBSName(){
      return vDBSName;
    }
    public Vector getAllDBSURL(){
      return vDBSURL;

    }
    public Vector getAllDBSDriver(){
      return vDBSDriver;
    }
    public Vector getAllDBUser(){
      return vDBUser;
    }
    public Vector getAllDBPin(){
      return vDBPin;
    }
    public Vector getAllDBSRemark(){
      return vDBSRemark;
    }
    public Vector getAllDBSPower(){
      return vDBSPower;
    }
    //测试主程序
    public static void main(String[] args){
      DBSourceManager dbm = new DBSourceManager();
      dbm.getAllSourceRecode("10101010121010101010101010") ;
      Vector vDBname = dbm.getAllDBSPower() ;
      for(int i=0 ;i<vDBname.size() ;i++){
        String dbsname=vDBname.elementAt(i).toString() ;
        System.out.print(dbsname) ;
      }
      System.out.print("Test OK!") ;
    }
}