atmmap.java

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

package boco.javabean.areamanager;

import java.util.*;
import java.sql.*;
import boco.shabank.dbconnection.*;
public class AtmMap {
    //定义变量
    ResultSet rs=null;
    DBConnectionManager objDBConnection;
    Connection m_Connection;
    DBAccess dba;
    ChineseTransfer ct = new ChineseTransfer();
    String sql;
    Vector vBranch;
    Vector vBranchName;
    Vector vBranchMap;
    int maxid,i1,i2;
    //构造函数，初始化变量
    public AtmMap(){
        dba       = new DBAccess();
        sql       = "";
        vBranch   = new Vector();
        vBranchName = new Vector();
        vBranchMap  = new Vector();
        maxid        = 0;
        i1        = 0;
        i2        = 0;
    }
    //通过SQL语句取得所有信息并保存到各个向量里面
    public void getmap(){
        sql = "select * from branchcodepin";
        try{
            dba=new DBAccess();
            objDBConnection = objDBConnection.getInstance() ;
            m_Connection = objDBConnection.getConnection("access");
            rs = dba.executeQuery(m_Connection,sql) ;
            while(rs.next()){
                if(rs.getString(1).length()==2){
                    vBranch.addElement(rs.getString(1));
                    vBranchName.addElement(rs.getString(2));
                    vBranchMap.addElement(rs.getString(4));
                }
            }
            rs.close() ;
            objDBConnection.freeConnection("access",m_Connection) ;
        }
        catch(Exception e){
            System.out.print(e.getMessage()) ;
        }
    }
    //删除信息
    /*public boolean delmap(int iId){
        sql = "DELETE FROM  AREAINFO WHERE AREAID ="+iId;
        String sql2="";
        System.out.println(sql);
        try{
            dba=new DBAccess();
            objDBConnection = objDBConnection.getInstance() ;
            m_Connection = objDBConnection.getConnection("access") ;
            String tmpsql = "select powersite from areainfo where areaid="+iId;
            System.out.println(tmpsql) ;
            rs=dba.executeQuery(m_Connection,tmpsql) ;
            if(rs.next()){
                String powersite = rs.getString(1) ;
                sql2="delete from powermod where powerid="+powersite;
                System.out.println(sql2) ;
                dba.executeUpdate(m_Connection,sql2) ;
            }
            int i = dba.executeUpdate(m_Connection,sql) ;
            if(i ==0) return false;
            rs.close() ;
            objDBConnection.freeConnection("access",m_Connection) ;
        }
        catch(Exception e){
            System.out.print(e.getMessage()) ;
        }
        return true;
    }
    //修改区域名称
    public boolean editmap(int iId,String sAreaName){
        sql = "UPDATE    AREAINFO SET AREANAME = '"+sAreaName+"' WHERE   AREAID = "+iId;
        sql = ct.ChineseStringToAscii(sql);
        System.out.println(sql);
        try{
            dba=new DBAccess();
            objDBConnection = objDBConnection.getInstance() ;
            m_Connection = objDBConnection.getConnection("access") ;
            int i = dba.executeUpdate(m_Connection,sql) ;
            if(i ==0) return false;
            objDBConnection.freeConnection("access",m_Connection) ;
        }
        catch(Exception e){
            System.out.print(e.getMessage()) ;
        }
        return true;
    }
    //取keyid（最小的不存在的数）
    public int getKeyId(String tableName,String key){
	sql="select "+key+" from "+tableName;
	System.out.println("sql1="+sql);
	Vector vKey = new Vector();
        int keyvalue = 0;
	try{
	    dba=new DBAccess();
	    objDBConnection=objDBConnection.getInstance() ;
            m_Connection = objDBConnection.getConnection("access") ;
	    //取出最大的id，命名一个
	    int maxid=0;
	    String sqlMaxId = "select max("+key+") from "+tableName;
	    ResultSet res = dba.executeQuery(m_Connection,sqlMaxId);
	    if(res.next())
	        maxid = res.getInt(1) ;
	    res.close() ;
	    if(maxid>0){
	        for(int i=0;i<=maxid;i++)
		    vKey.addElement("") ;

                //:test:System.out.println("sql1="+sql+ maxid+vKey.size());
	        rs = dba.executeQuery(m_Connection,sql) ;
                while(rs.next()){
		    vKey.setElementAt(rs.getString(1),rs.getInt(1));
		}
	        rs.close() ;
	        objDBConnection.freeConnection("access",m_Connection) ;
                System.out.println("size="+vKey.size());
	        for(int i=0;i<vKey.size();i++){
		    if(vKey.elementAt(i).toString().equals("")){
		        keyvalue=i;
		        break;
		    }
		    else{
		        keyvalue=i+1;
		    }
		}
	    }
	    else
		keyvalue = 1;
	}
	catch(Exception e){
	     System.out.print(e.getMessage()) ;
	}
	return keyvalue;
    }

    //插入
    public boolean insertmap(String sAreaName){
	for(int i = 0;i<vAreaId.size();i++){
            i1 = Integer.parseInt(vAreaId.elementAt(i).toString());
            maxid=(i1>maxid?i1:maxid);
        }
        maxid++;
	//取powermod的id
    	int powerid = getKeyId("powermod","powerid");
	String strpowerid = Integer.toString(powerid);
	String path = "[ATM监控,"+sAreaName+"]";
	String name = sAreaName+"ATM监控";
	String des = "ATM监控";
	String temp="("+strpowerid+",'"+path+"','"+name+"','"+des+"')";
	temp= ct.ChineseStringToAscii(temp) ;
	String tempsql="insert into powermod values "+ temp;
	sql ="insert into areainfo values("+Integer.toString(maxid)+",'"+sAreaName+"','map.gif','','"+strpowerid+"');";
        sql= ct.ChineseStringToAscii(sql);
        //tempsql=ct.ChineseStringToAscii(tempsql);
        System.out.println(tempsql);
	System.out.println(sql);
        try{
            dba=new DBAccess();
            objDBConnection = objDBConnection.getInstance() ;
            m_Connection = objDBConnection.getConnection("access") ;
            dba.executeUpdate(m_Connection,tempsql) ;
	    int i = dba.executeUpdate(m_Connection,sql) ;
            if(i ==0)
	    return false;
            objDBConnection.freeConnection("access",m_Connection) ;
        }
        catch(Exception e){
            System.out.print(e.getMessage()) ;
        }
        return true;
    }*/
    //更新地图
    public void updatemap(String iId,String sBranchMap){
        sql = "UPDATE    branchcodepin SET branchdes='"+sBranchMap+"' WHERE   branchcode = '"+iId+"'";
        System.out.println(sql);
        try{
            dba=new DBAccess();
            objDBConnection = objDBConnection.getInstance() ;
            m_Connection = objDBConnection.getConnection("access") ;
            int i = dba.executeUpdate(m_Connection,sql) ;
            objDBConnection.freeConnection("access",m_Connection) ;
        }
        catch(Exception e){
            System.out.print(e.getMessage()) ;
        }
    }
    //取得所有数据源信息
    public Vector getAllBranch(){
        return vBranch;
    }
    public Vector getAllBranchName(){
        return vBranchName;
    }
    public Vector getAllBranchMap(){
        return vBranchMap;
    }
    //取得最大的序号
    public int getMaxId(){
        return maxid;
    }
    public static void main(String args[]){
	   //AtmMap am = new AtmMap();
           //am.updatemap(32,"j0002.jpg");
	   //am.insertmap("dddddd") ;
    }
}