atmstatus.java

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

package boco.atmmonitor.picmonitor;

//******************************************************************************
//:功能:实现从atmstatus表中取出设备状态值
//:时间:2002-08
//:作者:王建宾
//:特殊描述::test:为DEBUG时启用
//:程序描述:
//
//******************************************************************************

import java.util.*;
import java.sql.*;
public class AtmStatus {
  //定义全局变量
  ResultSet rs=null;
  String AtmId;
  Vector AtmStatus;
  String sql;
  String driver;
  String url;
  String name;
  String passwd;
  Connection conn;
  Statement stmt;
  //构造函数，初始化变量
  public AtmStatus(String dbDriver,String ConnStr,String UserName,String Pass) {
    driver = dbDriver;
    url = ConnStr;
    name = UserName;
    passwd = Pass;
    conn = null;
    stmt = null;
    AtmId = "";
    AtmStatus = new Vector();
    sql="";
  }
  //连数据库并取出设备的当前状态信息
  public void AtmStatus(Vector 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);
      for(int i=0;i<id.size();i++){
        sql="select * from DevBaseInfo where DevNo =" + "'" + id.elementAt(i) + "'";
        //:test:System.out.println("The SQL:"+sql);
        ResultSet rs=stmt.executeQuery(sql);
        if(rs.next()){
          //:test:System.out.print("AreaName=" + rs.getString(13)) ;
          AtmStatus.addElement(rs.getString(13));
        }
        else{
          //删除AtmMap表中存在但在DevBaseInfo表中不存在的设备
          sql="delete from AtmMap where atmid = " + "'" + id.elementAt(i) + "'";
          stmt.executeUpdate(sql);
        }
        rs.close() ;
      }
      //断开连接,释放资源
      try{
        stmt.close();
        conn.close();
      }catch(Exception ex){
        System.out.print(ex.getMessage()) ;
      }
    }
    catch(Exception e){
      System.out.print("errorMsg=" + e.getMessage()) ;
    }
  }
  public boolean isAtmExist(String atmid){
    boolean isThere=false;
    sql="select * from DevBaseInfo where DevNo =" + "'" + atmid + "'";
    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);
      if(rs.next()){
        isThere=true;
      }
      //断开连接,释放资源
      rs.close() ;
      //断开连接,释放资源
      try{
        stmt.close();
        conn.close();
      }catch(Exception ex){
        System.out.print(ex.getMessage()) ;
      }
    }
    catch(Exception e){
      System.out.print("errorMsg=" + e.getMessage()) ;
    }
    return isThere;
  }
  //返回设备状态
  public Vector getAtmStatus(){
    return AtmStatus;
  }
  //测试主程序
  public static void main(String[] args){
    AtmStatus as = new AtmStatus("","","","");
    Vector Atm = new Vector();
    Atm.addElement("0300Y002");
    Atm.addElement("0300Y006");
    as.AtmStatus(Atm);
    System.out.println(as.getAtmStatus()) ;
  }
}