tradetable.java

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

package boco.webtrade;

/**
 * <p>Title: dbmanager</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: boco</p>
 * @author wangjb
 * @version 1.0
 */
import java.util.*;
import java.sql.*;
import boco.shabank.dbconnection.*;
public class TradeTable {
  //定义变量
  ResultSet rs=null;
  int TradeId;
  String sTradeName;
  String sTradeHost;
  String sTradePort;
  String sTradeRemark;
  String sComCode;
  String sTradeCode;
  String sComName;
  String sComRemark;
  Vector vTradeId;
  Vector vTradeName;
  Vector vTradeHost;
  Vector vTradePort;
  Vector vTradeRemark;
  Vector vTradeComCode;
  Vector vComCode;
  Vector vTradeCode;
  Vector vNewComCode;
  Vector vComName;
  Vector vComRemark;
  DBConnectionManager objDBConnection;
  Connection m_Connection;
  DBAccess dba;
  //构造函数，初始化变量
  public TradeTable() {
    dba=new DBAccess();
    objDBConnection.getInstance() ;
    TradeId=0;
    sTradeName="";
    sTradeHost="";
    sTradePort="";
    sTradeRemark="";
    sComCode="";
    sTradeCode="";
    sComName="";
    sComRemark="";
    vTradeId=new Vector();
    vTradeName=new Vector();
    vTradeHost=new Vector();
    vTradePort=new Vector();
    vTradeRemark=new Vector();
    vTradeComCode=new Vector();
    vTradeCode=new Vector();
    vComCode=new Vector();
    vNewComCode= new Vector();
    vComName=new Vector();
    vComRemark=new Vector();
  }
  //返回所有数据源记录
  public void getAllTableRecord(){
    //get sql statement
    String sql="";
    dba=new DBAccess();
    sql="select * from WebTrade";
    //connect to urls and execute sql
    try{
      objDBConnection=objDBConnection.getInstance() ;
      m_Connection = objDBConnection.getConnection("access") ;
      rs = dba.executeQuery(m_Connection,sql) ;
      //:test:System.out.println(sql);
      while(rs.next()){
        vTradeId.addElement(rs.getString(1));
        vTradeName.addElement(rs.getString(2));
        vTradeHost.addElement(rs.getString(3)) ;
        vTradePort.addElement(rs.getString(4));
        vTradeRemark.addElement(rs.getString(5));
        vComCode.addElement(rs.getString(6));
        vTradeCode.addElement(rs.getString(7));
      }
      //free connection
      rs.close() ;
    }
    catch(Exception e){
      System.out.println(e.getMessage());
      return;
    }
    objDBConnection.freeConnection("access",m_Connection) ;
  }
  public void getInfo(String TradeName){
    //通过业务名称查询对应地址、端口号、命令编码、交易编码
    dba=new DBAccess();
    ChineseTransfer atoc = new ChineseTransfer();
    String sTradeName=atoc.ChineseStringToAscii(TradeName);
    String sql="";
    sql="select TradeHost,TradePort,ComCode,TradeCode from WebTrade where TradeName="+"'"+sTradeName+"'";
    //connect to urls and execute sql
    try{
      objDBConnection=objDBConnection.getInstance() ;
      m_Connection = objDBConnection.getConnection("access") ;
      rs = dba.executeQuery(m_Connection,sql) ;
      while(rs.next()){
          sTradeHost=rs.getString(1);
          sTradePort=rs.getString(2);
          sComCode  =rs.getString(3);
          sTradeCode=rs.getString(4);
      }
      //free connection
      rs.close() ;
      objDBConnection.freeConnection("access",m_Connection) ;
    }
    catch(Exception e){
      System.out.println(e.getMessage());
      return;
    }
    finally{
        StringTokenizer tokenizer = new StringTokenizer(sComCode);
        while(tokenizer.hasMoreTokens()){
            String token=tokenizer.nextToken();
            vTradeComCode.addElement(token);
            //:test:System.out.println(token);
        }
    }
  }
  public void getComNameAndCode(){
    //取得所有命令名称和编码
    dba=new DBAccess();
    ChineseTransfer atoc = new ChineseTransfer();
    String sql="";
    sql="select ComCode,ComName from WebCom";
    //connect to urls and execute sql
    try{
      objDBConnection=objDBConnection.getInstance() ;
      m_Connection = objDBConnection.getConnection("access") ;
      rs = dba.executeQuery(m_Connection,sql) ;
      String sComCode = "";
      String sComName = "";
      while(rs.next()){
          sComCode = atoc.AsciiToChineseString(rs.getString(1));
          sComName = atoc.AsciiToChineseString(rs.getString(2));
          vNewComCode.addElement(sComCode);
          vComName.addElement(sComName);
      }
      //free connection
      rs.close() ;
      objDBConnection.freeConnection("access",m_Connection);
    }
    catch(Exception e){
      System.out.println("wrong"+e.getMessage());
      return;
    }
  }

      //取得所有数据源信息
    public Vector getAllTradeId(){
      return vTradeId;
    }
    public Vector getAllTradeName(){
      return vTradeName;
    }
    public Vector getAllTradeHost(){
      return vTradeHost;
    }
    public Vector getAllTradePort(){
      return vTradePort;
    }
    public Vector getAllTradeRemark(){
      return vTradeRemark;
    }
    public Vector getAllTradeComCode(){
        return vTradeComCode;
    }
    public Vector getAllTradeCode(){
        return vTradeCode;
    }
    public Vector getAllComCode(){
        return vComCode;
    }
    public Vector getAllNewComCode(){
        return vNewComCode;
    }
    public Vector getAllComName(){
        return vComName;
    }
    public Vector getAllComRemark(){
        return vComRemark;
    }
    //取得业务名称对应的地址和端口号
    public String getCorrespondTradeHost(){
        return sTradeHost;
    }
    public String getCorrespondTradePort(){
        return sTradePort;
    }
    public String getCorrespondComCode(){
        return sComCode;
    }
    public String getCorrespondTradeCode(){
        return sTradeCode;
    }
    public String getCorrespondComName(){
        return sComName;
    }
    /*//main test
    public static void main(String[] args){
      ChineseTransfer atoc = new ChineseTransfer();
      TradeTable tt=new TradeTable();
      tt.getAllTableRecode();
      Vector vTradeName = new Vector();
      vTradeName=tt.getAllTradeName();
      System.out.println("size="+vTradeName.size());
      for(int i=0;i<vTradeName.size();i++){
      System.out.println(atoc.AsciiToChineseString(vTradeName.elementAt(i).toString()));
        //vTradeName.removeAllElements();仅当在外部定义时才加上此句
      }
    }*/
}