dorunsql.java

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

package boco.shabank.dbmanager;
//******************************************************************************
//:功能:实现与数据源的连接并执行传入的SQL语句,返回结果信息
//:时间:2002-07
//:作者:王建宾
//:特殊描述::test:为DEBUG时启用
//:程序描述:
//
//******************************************************************************

import java.util.*;
import java.sql.*;
import boco.shabank.dbconnection.*;
public class doRunSQL {
  //定义变量
  String errMsg;
  DBConnectionManager objDBConnection;
  Connection m_Connection;
  DBAccess db;
  //构造函数，初始化变量
  public doRunSQL() {
    errMsg = "";
  }
  
  //添加记录时修改权限位记录
  public doRunSQL(String tablename,Object dbtype) {
    errMsg = "";
    ChineseTransfer ct=new ChineseTransfer();
    if(tablename.equalsIgnoreCase("dbtable")){
	String dbt= dbtype.toString() ;
	String powersite="";
	dbt=ct.ChineseStringToAscii(dbt) ;
	String sql="select powersite from dbtable where dbttype='"+dbt+"' order by dbtid" ;
	//System.out.println("sql1="+sql) ;
	try{
	     db=new DBAccess();
	     objDBConnection = objDBConnection.getInstance() ;
             m_Connection = objDBConnection.getConnection("access") ;
             ResultSet rs =db.executeQuery(m_Connection,sql);
	     if(rs.next()){
		powersite=rs.getString(1) ;
		if(!powersite.equals("")){
		    String tmpSql="update dbtable set powersite='"+powersite+"' where dbttype = '"+dbt.trim()+"'";
		    //System.out.println("tempsql:"+tmpSql) ;
		    db.executeUpdate(m_Connection,tmpSql) ;
		}
	    }
	    rs.close() ;
             //释放连接池
             objDBConnection.freeConnection("access",m_Connection) ;   
	}
	catch(Exception e){
	     System.out.println("err:"+e.getMessage()) ;    
	}
    }
  }
  //执行SQL
    public void doRunSQL(String DBSourceName,String sql){
    db=new DBAccess();
    errMsg="success";

    //System.out.println("Insert:"+sql);
    try{
        objDBConnection = objDBConnection.getInstance() ;
        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){
      doRunSQL add = new doRunSQL();
      add.doRunSQL("dbmng","insert into ");
      System.out.println("OK!");
    }
}