/**
封装了对数据库的连接,用于处理sql语句。
@author:yancheng(sharetop studio)
@version:1.0.0
*/
package dbutil;
import java.sql.*;
import java.io.*;
import javax.sql.*;
import javax.naming.*;
import oracle.jdbc.pool.*;
public class orapooledsql
{
private pooledconnection dbpool;
/**
@param connectionurl 连接名 如: jdbc:odbc:myodbc
@param userid 用户名
@param password 用户密码
*/
public orapooledsql(string connectionurl,string userid,string password)
{
try{
oracleconnectionpooldatasource ocpds = new oracleconnectionpooldatasource();
ocpds.seturl(connectionurl);
ocpds.setuser(userid);
ocpds.setpassword(password);
dbpool = ocpds.getpooledconnection();
}
catch(exception ex)
{
system.err.println("error in pooledsql-construct : ");
ex.printstacktrace(system.err);
}
}//end orapooledsql
//close dbpool
protected void finalize()
{
if( dbpool != null )
{
try
{
dbpool.close();
}
catch(exception ex)
{
}
}
}
/**
用于更新、添加或删除的sql语句
@param sql sql语句字串,如:insert into tablename values(id,......)
*/
public int update(string sql)
{
statement stmt = null;
int rc = 0;
connection connection = null;
try
{
connection = dbpool.getconnection();
stmt = connection.createstatement();
rc = stmt.executeupdate(sql);
}
catch( exception ex )
{
system.err.println("error in update - orapooledsql : ");
ex.printstacktrace(system.err);
}
return rc;
} //end update()
/**
用于查询的sql语句
@param sql sql语句字串,如:select * from tablename
*/
public resultset query(string sql)
{
statement stmt = null;
resultset rs = null;
connection connection = null;
try
{
connection = dbpool.getconnection();
stmt = connection.createstatement();
rs = stmt.executequery(sql);
}
catch( exception ex )
{
system.err.println("error in query - sqlbean : ");
ex.printstacktrace(system.err);
}
return rs;
} //end query
} //end class
文章整理:西部数码--专业提供域名注册、虚拟主机服务
http://www.west263.com
以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息,谢谢!


