利用Oracle自帶的連接池類的一例
2024-08-29 13:37:41
供稿：網友
/**
封裝了對數據庫的連接，用于處理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
