dodelcurrow.java

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

package boco.DBManager.Tree;

//******************************************************************************
//:功能:实现从数据表中删除选中的当前行
//:时间:2002-07
//:作者:王建宾
//:特殊描述::test:为DEBUG时启用
//:程序描述:
//
//******************************************************************************

import java.util.*;
import java.sql.*;
import boco.shabank.dbconnection.*;
public class doDelCurRow {
  //定义变量
  String sql;
  String errMsg;
  DBConnectionAny objDBConnection;
  Connection m_Connection;
  DBAccess db;
  //构造函数，初始化变量
  public doDelCurRow() {
    sql="";
    errMsg="success";
  }
  //返回所有数据源记录
  public void doDelCurRow(String DBSourceName,String DBTName,Vector KeyName,Vector KeyValue,Vector KeyType){
    String type="";
    String name="";
    String value="";
    db=new DBAccess(DBSourceName);
    sql="delete from " + DBTName + " where ";
    //根据类型返回sql语句
    for(int i=0;i<KeyType.size();i++){
      type=KeyType.elementAt(i).toString();
      name=KeyName.elementAt(i).toString();
      value=KeyValue.elementAt(i).toString().trim();
      if(i==KeyType.size()-1){
        if(type.equalsIgnoreCase("INTeger")||type.equalsIgnoreCase("INT")||type.equalsIgnoreCase("BIGINT")||type.equalsIgnoreCase("SMALLINT")||type.equalsIgnoreCase("DOUBLE")||type.equalsIgnoreCase("TINYINT")||type.equalsIgnoreCase("DECIMAL")){
          sql = sql + name + "=" + value;
        }
        else{
          sql = sql + name + "='" + value + "'";
        }
      }
      else{
        if(type.equalsIgnoreCase("INTeger")||type.equalsIgnoreCase("INT")||type.equalsIgnoreCase("BIGINT")||type.equalsIgnoreCase("SMALLINT")||type.equalsIgnoreCase("DOUBLE")||type.equalsIgnoreCase("TINYINT")||type.equalsIgnoreCase("DECIMAL")){
          sql = sql + name + "=" + value + " and ";
        }
        else{
          sql = sql + name + "='" + value + "'" + " and ";
        }
      }
    }

    //:test:System.out.println("delete sql="+sql);
    objDBConnection = objDBConnection.getInstance() ;
    try{
      m_Connection = objDBConnection.getConnection(DBSourceName) ;
      db.executeUpdate(m_Connection,sql);
      //关闭连接,释放资源
      objDBConnection.freeConnection(DBSourceName,m_Connection) ;
    }
    catch(Exception e){
      errMsg = e.getMessage().toString();
      //System.out.print("errorMsg=" + e.getMessage()) ;
    }

  }
    public String getErrMsg()
    {
      return errMsg;
    }
    //测试主程序
    public static void main(String[] args){
      doDelCurRow del = new doDelCurRow();
      Vector KeyName = new Vector();
      KeyName.addElement("bbbb");
      KeyName.addElement("cccc");
      Vector KeyType = new Vector();
      KeyType.addElement("INT");
      KeyType.addElement("Char");
      Vector KeyValue = new Vector();
      KeyValue.addElement("test1");
      KeyValue.addElement("test2");
      del.doDelCurRow("dbmng","bbbb",KeyName,KeyValue,KeyType);
      System.out.println("OK!");
    }
}