atmmap.java

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

package boco.atmmonitor.picmonitor;

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

import java.util.*;
import java.sql.*;
public class AtmMap {
  //定义全局变量
  ResultSet rs=null;
  String AtmId;
  String AtmX;
  String AtmY;
  String AreaId;
  String sql;
  Vector vAtmId;
  Vector vAtmX;
  Vector vAtmY;
  Vector vAreaId;
  String driver;
  String url;
  String name;
  String passwd;
  Connection conn;
  Statement stmt;
  ChineseTransfer A2C;
  //构造函数，初始化变量
  public AtmMap(String dbDriver,String ConnStr,String UserName,String Pass) {
    driver = dbDriver;
    url = ConnStr;
    name = UserName;
    passwd = Pass;
    conn = null;
    stmt = null;
    AtmId = "";
    AtmX = "";
    AtmY = "";
    AreaId = "";
    sql="";
    vAtmId=new Vector();
    vAtmX=new Vector();
    vAtmY=new Vector();
    vAreaId=new Vector();
    A2C = new ChineseTransfer();
  }
  //连接数据库并取得所有设备坐标信息
  public void getAllAtm(String id){
    //sql="select * from AtmMap where areaid ='" + id + "' order by atmid";
    if(id.length() == 2){
      sql="select * from AtmMap where areaid ='" + id + "' order by atmid";
    }
    else if(id.length()==4){
      String tmp = id.substring(0,2) ;
      sql="select t1.* from AtmMap t1,DevBaseInfo t2 where t1.atmid=t2.DevNo and t2.Branch ='" + id + "' and areaid = '"+tmp+"' order by atmid";
    }
    else{
      sql="select * from AtmMap";
    }
    //System.out.println("sql:"+sql+id) ;
    try{
      Class.forName(driver).newInstance() ;
      Properties SysProps = System.getProperties();
      SysProps.put("user",name);
      SysProps.put("password",passwd);
      conn= DriverManager.getConnection(url, SysProps);
      stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
      ResultSet rs=stmt.executeQuery(sql);
      while(rs.next()){
        //:test:System.out.print("AreaName=" + rs.getString(2)) ;
        vAtmId.addElement(rs.getString(1).trim());
        vAtmX.addElement(rs.getString(2).trim());
        vAtmY.addElement(rs.getString(3).trim()) ;
        vAreaId.addElement(rs.getString(4).trim());
      }
      //断开连接,释放资源
      rs.close() ;
    }
    catch(Exception e){
      System.out.print("errorMsg=" + e.getMessage()) ;
    }
    //断开连接,释放资源
    try{
      stmt.close();
      conn.close();
    }catch(Exception ex){
      System.out.print(ex.getMessage()) ;
    }
  }
  //返回设备ID
  public Vector getAllAtmId(){
    return vAtmId;
  }
  //返回设备在地图上的X坐标
  public Vector getAllAtmX(){
    return vAtmX;
  }
  //返回设备在地图上的Y坐标
  public Vector getAllAtmY(){
    return vAtmY;
  }
  //返回设备所在的区县ID
  public Vector getAllAreaId(){
    return vAreaId;
  }
  //测试主程序
  public static void main(String[] args){
    AtmMap am = new AtmMap("com.sybase.jdbc2.jdbc.SybDriver","jdbc:sybase:Tds:196.168.1.32:9999/apdb","apdbo","apdbop");
    am.getAllAtm("1");
    Vector vAtmId = am.getAllAtmId() ;
    System.out.println("size="+vAtmId.size() ) ;
    for(int i=0 ;i<vAtmId.size() ;i++){
      String AtmId=vAtmId.elementAt(i).toString() ;
      System.out.println(AtmId) ;
    }
  }
}