pointdb.java

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

package boco.atmmonitor.docmonitor;

//******************************************************************************
//:功能:实现对地图上设备的查询/增加/编辑/删除/移动操作
//:时间:2002-08
//:作者:王建宾
//:特殊描述::test:为DEBUG时启用
//:程序描述:
// (1)在地图上点击一设备时,则查询该设备的坐标信息
// (2)在地图上增加一设备,则INSERT新增设备信息进ATMMAP表
// (3)在地图上编辑一设备的名称,则UPDATE ATMMAP表,修改设备名称
// (4)在地图上删除一设备,则从ATMMAP表中DELETE该设备
// (5)在地图上移动一设备,则UPDATE ATMMAP表,修改设备的坐标
//******************************************************************************

import java.sql.*;
import COM.ibm.db2.jdbc.net.*;
import java.util.*;
//****************************************************************************
//类名称：数据库存取类
//类功能：完成数据库的连接、插入、删除操作
//****************************************************************************
public class pointDB {
  String Driver;//数据库驱动
  String connStr;//数据库连接字符串
  String dbUser;//数据库用户
  String passWord;//数据库密码
  Connection conn;//数据库连接
  Statement stmt;//数据库STMT
  String errMsg;//错误信息返回
//***************************************************************************
//方法名称：构造函数
//方法功能：初始化数据库连接字符串、用户名、密码，数据库连接
//***************************************************************************
  public pointDB(String dbDriver,String ConnStr,String username,String pass) {
    Driver=dbDriver;
    connStr=ConnStr;
    dbUser=username;
    passWord=pass;
    conn = null;
    stmt = null;
    errMsg = "";
    DbConn();
  }
//***************************************************************************
//方法名称：数据库连接
//方法功能：初始化数据库连接
//***************************************************************************
  public void DbConn()
  {
    try{
      Class.forName(Driver).newInstance() ;
      Properties SysProps = System.getProperties();
      SysProps.put("user",dbUser);
      SysProps.put("password",passWord);
      conn= DriverManager.getConnection(connStr, SysProps);
      stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
    }
    catch (Exception e){
      System.out.println("连接数据库出现错误:"+e.getMessage());
    }
  }
//***************************************************************************
//方法名称：插入监控节点到数据库
//方法功能：插入节点的名称、坐标到数据库
//***************************************************************************
  public void insertPoint(String atmid,int x,int y,String areaid){
        try{
                String insertSql="insert into AtmMap values('"+atmid+"',"+x+","+y+",'"+areaid+"')";
                //stmt=conn.createStatement();
                //:test:System.out.println("insertSQL:"+insertSql);
                stmt.execute(insertSql);
                errMsg = "";
          }
        catch (Exception e){
                System.err.println("插入监控节点时出现错误:"+e.getMessage());
                errMsg = "insert Fail";
          }
          DbClose();
  }
//***************************************************************************
//方法名称：从数据库删除监控节点
//方法功能：根据节点名称删除相应节点
//***************************************************************************
  public void deletePoint(String atmid){
        try{
                String delSql="delete from AtmMap where atmid='"+atmid+"'";
                //stmt=conn.createStatement();
                //:test:System.out.println("delSQL:"+delSql);
                stmt.execute(delSql);
                errMsg = "";
          }
        catch (Exception e){
                System.err.println("删除监控节点时出现错误:"+e.getMessage());
                errMsg = "delete Fail";
          }
          DbClose();
  }
//***************************************************************************
//方法名称：移动监控节点
//方法功能：根据条件移动相应节点
//***************************************************************************
  public void moveLamp(String atmid,int x,int y){
        try{
                String moveSql="update AtmMap set atmx="+x+","+"atmy="+y+" where atmid="+"'"+atmid+"'";
                //stmt=conn.createStatement();
                //:test:System.out.println("moveSQL:"+moveSql);
                stmt.execute(moveSql);
                errMsg = "";
          }
        catch (Exception e){
                System.err.println("删除移动节点时出现错误:"+e.getMessage());
                errMsg = "move Fail";
          }
          DbClose();
  }
//***************************************************************************
//方法名称：更新监控节点名称
//方法功能：把相应的节点名更新为新的节点名
//***************************************************************************
  public void updateLampName(String oldatmid,String newatmid){
        try{
                String updateSql="update AtmMap set atmid='"+newatmid+"' where atmid='"+oldatmid+"'";
                //stmt=conn.createStatement();
                //:test:System.out.println("updateSQL:"+updateSql);
                stmt.execute(updateSql);
                errMsg = "";
            }
        catch (Exception e){
                System.err.println("更新节点名时出现错误:"+e.getMessage());
                errMsg = "update AtmId Fail";
            }
          DbClose();
  }
//***************************************************************************
//方法名称：查询监控节点
//方法功能：从数据库中查询所有的监控节点
//***************************************************************************
  public ResultSet queryLamp(){
         ResultSet rs=null;
         String sql="select * from AtmMap";
        try{
                //stmt=conn.createStatement();
                //:test:System.out.println("querySQL:"+sql);
                rs=stmt.executeQuery(sql);
                errMsg = "";
          }
        catch (Exception e){
                System.err.println("查询节点时出现错误:"+e.getMessage());
                errMsg = "query AtmId Fail";
          }
          DbClose();
          return rs;
  }
//***************************************************************************
//方法名称：取得节点坐标
//方法功能：通过监控节点名取得节点坐标
//***************************************************************************
  public ResultSet getLampPointByName(String atmid){
         ResultSet rs=null;
         String sql="select * from AtmMap where atmid='"+atmid+"'";
         //:test:System.out.println(sql);
        try{
                //stmt=conn.createStatement();
                rs=stmt.executeQuery(sql);
                errMsg = "";
            }
        catch (Exception e){
                System.err.println("查询节点坐标时出现错误:"+e.getMessage());
                errMsg = "query Point Fail";
          }
          DbClose();
          return rs;
  }
//*****************************************************************************
//方法名称：返回错误信息
//*****************************************************************************
  public String getErrMsg(){
      return errMsg;
  }
//*****************************************************************************
//方法名称：数据库关闭
//关闭数据库连接
//*****************************************************************************
  public void DbClose(){
        try{
                if(stmt!=null){
                    stmt.close();
                }
                if(conn!=null){
                    conn.close();
                }
          }
        catch (Exception e){
                System.err.println("数据库关闭出现错误:"+e.getMessage());
          }
    }

}