dbtablemanager.java

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

package boco.shabank.dbmanager;

/**
 * <p>Title: dbmanager</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: boco</p>
 * @author wangjb
 * @version 1.0
 */
//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;
  int DBSID;
  String DBTName;
  String DBTType;
  String DBTRemark;
  String DBTKey;

  String sql=null;
  Vector vDBTID=new Vector();
  Vector vDBSID=new Vector();
  Vector vDBTName=new Vector();
  Vector vDBTType=new Vector();
  Vector vDBTRemark=new Vector();
  Vector vDBTKey=new Vector();
  DBConnectionManager objDBConnection;
  Connection m_Connection;
  DBAccess db;
  //构造函数，初始化变量
  public DBTableManager() {
    //objDBConnection = new DBConnectionManager();
    db=new DBAccess();
    DBTID=0;
    DBSID=0;
    DBTName="";
    DBTType="";
    DBTRemark="";
    DBTKey="";
  }
  //返回所有数据类型
   public DBTableManager(String dbsid){
    db=new DBAccess();
    ChineseTransfer ct = new ChineseTransfer();
    DBTID=0;
    DBSID=0;
    DBTName="";
    DBTType="";
    DBTRemark="";
    DBTKey="";
    sql="select distinct DBTType from DBTable where DBSid = "+ dbsid;
    //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()){
            vDBTType.addElement(ct.AsciiToChineseString(rs.getString(1).toString()));
        }
        rs.close() ;
        objDBConnection.freeConnection("access",m_Connection) ;
    }
    catch(Exception e){
        System.out.println("error:"+e.getMessage()) ;
    }
  }
  //单个表信息
  public DBTableManager(String dbsid,String tablename){
    //System.out.println("========="+dbsid+tablename) ;
    db=new DBAccess();
    sql="select * from DBTable where DBSid = "+ dbsid+" and dbtname='"+tablename+"'";
    //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()){
            DBTID=rs.getInt(1);
            DBSID=rs.getInt(2) ;
            DBTName=rs.getString(3) ;
            DBTType=rs.getString(4) ;
            DBTRemark=rs.getString(5) ;
            DBTKey=rs.getString(6) ;
        }
        rs.close() ;
        objDBConnection.freeConnection("access",m_Connection) ;
    }
    catch(Exception e){
        System.out.println("error:"+e.getMessage()) ;
    }
  }
  //返回所有数据源记录
  public void getAllTableRecode(String FRDBSID,String FRTType){
    //get sql statement buy type
    //if(FRTType.equals("01"))
    //sql="select * from dbtable where DBSID=" + FRDBSID + " and DBTType='01'";
    //if(FRTType.equals("02"))
    ChineseTransfer ct = new ChineseTransfer();
    FRTType = ct.ChineseStringToAscii(FRTType) ;
    sql="select * from dbtable where DBSID=" + FRDBSID + " and DBTType='"+FRTType+"'";

    //connect to urls and execute sql
    try{
      objDBConnection=objDBConnection.getInstance() ;
      m_Connection = objDBConnection.getConnection("access") ;
      rs = db.executeQuery(m_Connection,sql) ;
      //:test:System.out.println(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)) ;
        vDBTType.addElement(rs.getString(4));
        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("error:"+e.getMessage());
      //return;
    }
  }
  //取dbtid的最大值
  public int getMaxDBTid(){
    int maxid=0;
    sql="select max(dbtid) from dbtable";
   try{
      objDBConnection=objDBConnection.getInstance() ;
      m_Connection = objDBConnection.getConnection("access") ;
      rs = db.executeQuery(m_Connection,sql) ;
      //:test:System.out.println(sql);
      while(rs.next()){
        maxid = rs.getInt(1);
      }
      rs.close() ;
      objDBConnection.freeConnection("access",m_Connection) ;
    }
    catch(Exception e){
      System.out.println("error:"+e.getMessage());
    }
    return maxid;
  }
    //取dbfid的最大值
  public int getMaxDBFid(){
    int maxid=0;
    sql="select max(dbfid) from dbfield";
   try{
      objDBConnection=objDBConnection.getInstance() ;
      m_Connection = objDBConnection.getConnection("access") ;
      rs = db.executeQuery(m_Connection,sql) ;
      //:test:System.out.println(sql);
      while(rs.next()){
        maxid = rs.getInt(1);
      }
      rs.close() ;
      objDBConnection.freeConnection("access",m_Connection) ;
    }
    catch(Exception e){
      System.out.println("error:"+e.getMessage());
    }
    return maxid;
  }
  //取dbsid的最大值
  public int getMaxDBSid(){
    int maxid=0;
    sql="select max(dbsid) from dbsource";
   try{
      objDBConnection=objDBConnection.getInstance() ;
      m_Connection = objDBConnection.getConnection("access") ;
      rs = db.executeQuery(m_Connection,sql) ;
      //:test:System.out.println(sql);
      while(rs.next()){
        maxid = rs.getInt(1);
      }
      rs.close() ;
      objDBConnection.freeConnection("access",m_Connection) ;
    }
    catch(Exception e){
      System.out.println("error:"+e.getMessage());
    }
    return maxid;
  }
      //取得所有数据源信息
    public Vector getAllDBTID(){
      return vDBTID;
    }
    public Vector getAllDBSID(){
      return vDBSID;
    }
    public Vector getAllDBTName(){
      return vDBTName;
    }
    public Vector getAllDBTType(){
      return vDBTType;
    }
    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();
      Vector DBSID = new Vector();
      DBSID = dbs.getAllDBSID();
      for(int i=0;i<DBSID.size();i++){
      DBTableManager dbm = new DBTableManager();
      Vector DBTName = new Vector();
      //System.out.println(DBSID.elementAt(i).toString());
      dbm.getAllTableRecode(DBSID.elementAt(i).toString(),"02");
      DBTName = dbm.getAllDBTName();
        for(int j=0 ;j<DBTName.size();j++){
          System.out.println(DBTName.elementAt(j).toString());
        }
        DBTName.removeAllElements();
      }
    }
}