日期:2014-05-16 浏览次数:20483 次
import java.sql.Connection; import java.sql.SQLException; import java.util.Properties; import org.apache.commons.dbcp.BasicDataSource; import org.apache.commons.dbcp.BasicDataSourceFactory; import org.apache.log4j.Logger; /** * 数据库连接池 * */ public class TestDbPools { static Logger logger = Logger.getLogger(TestDbPools.class); private static BasicDataSource dataSource = null; public TestDbPools(){ } public static void init() { if (dataSource != null) { try { dataSource.close(); } catch (Exception e) { logger.error(e.getMessage()); } dataSource = null; } try { Properties p = new Properties(); p.setProperty("driverClassName", "oracle.jdbc.driver.OracleDriver"); p.setProperty("url", "jdbc:oracle:thin:@192.168.1.10:1521:oraid"); p.setProperty("password", "zznode"); p.setProperty("username", "shihuan"); p.setProperty("maxActive", "30"); p.setProperty("maxIdle", "10"); p.setProperty("maxWait", "1000"); p.setProperty("removeAbandoned", "false"); p.setProperty("removeAbandonedTimeout", "120"); p.setProperty("testOnBorrow", "true"); p.setProperty("logAbandoned", "true"); dataSource = (BasicDataSource) BasicDataSourceFactory.createDataSource(p); } catch (Exception e) { logger.error(e.getMessage()); } } /** * 外口调用方法,调用此方法即可获取一个数据库的连接池 * */ public static synchronized Connection getConnection() { if (dataSource == null) { init(); } Connection conn = null; if (dataSource != null) { try { conn = dataSource.getConnection(); } catch (SQLException e) { logger.error(e.getMessage()); } } return conn; } }
private Connection conn = null; private PreparedStatement pstmt = null; private ResultSet rs = null; public ResultSet getRs(){ conn = TestDbPools.getConnection(); 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 = ?"; try { pstmt = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY); pstmt.setString(1, "CSZJFX"); rs = pstmt.executeQuery(); while(rs.next()){ System.out.println("shihuan= " + rs.getString(1) + " -- " + rs.getString("MODULE_NAME")); } } catch (SQLException e) { e.printStackTrace(); } return rs; } public void closeDb(){ if(rs != null){ //关闭记录集 try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } } if(pstmt != null){ //关闭声明 try { pstmt.close(); } catch (SQLException e) { e.printStackTrace(); } } if(conn != null){ ////关闭连接 try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } /** * @param args */ public static void main(String[] args) { OperatorDb odb = new OperatorDb(); odb.getRs(); odb.closeDb(); } }