首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 数据库 > 其他数据库 >

Oracle自带连接池使用

2012-08-25 
Oracle自带连接池应用依赖ojdbc14.jar包OraclePooled.java代码:import java.sql.Connectionimport java.s

Oracle自带连接池应用
依赖ojdbc14.jar包

OraclePooled.java代码:

import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import javax.sql.PooledConnection;import oracle.jdbc.pool.OracleConnectionPoolDataSource;/** * Oracle自带连接池应用 * */public class OraclePooled {private PooledConnection dbpool;public OraclePooled(String ConnectionURL, String UserName, String PassWord) {try {OracleConnectionPoolDataSource ocpds = new OracleConnectionPoolDataSource();ocpds.setURL(ConnectionURL);ocpds.setUser(UserName);ocpds.setPassword(PassWord);dbpool = ocpds.getPooledConnection();} catch (Exception ex) {System.err.println("Error in PooledSQL-construct: ");ex.printStackTrace(System.err);}}protected void finalize() { if(dbpool != null) { try { dbpool.close();         } catch(Exception ex){            ex.printStackTrace();               }     } }public ResultSet Query(String sql, String[] params){ PreparedStatement pstmt = null;     ResultSet rs = null;     Connection connection = null;     try {         connection = dbpool.getConnection();         pstmt = connection.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);        for(int i=1; i<params.length+1; i++){        pstmt.setString(i, params[i-1]);        }rs = pstmt.executeQuery();while(rs.next()){    System.out.println(rs.getString(1));    System.out.println(rs.getString(2));    }    } catch(Exception ex) {         System.err.println("Error in Query - SQLBean: ");         ex.printStackTrace(System.err);     }     return rs; }public static void main(String[] args){OraclePooled op = new OraclePooled("jdbc:oracle:thin:@192.168.1.10:1521:oraid", "shihuan", "zznode");String sql = "SELECT T.MODULE_NAME, T.PARAM_NAME, T.SHOW_NAME, T.REL_SYMBOLS, T.GREEN_VALUE, T.YELLOW_VALUE, T.RED_VALUE, T.UNIT, T.SCPOE FROM TB_THRESHOLD_SETTING T WHERE T.PARAM_NAME = ?";String[] params = new String[]{"CSZJFX"};op.Query(sql, params);op.finalize();}}

热点排行