Java直连数据库代码还有连接池代码

package com.myblog.dao; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties; import org.apache.commons.dbcp.BasicDataSource; import org.apache.commons.dbcp.BasicDataSourceFactory; public class DBConnection { private static BasicDataSource dataSource = null; public static void init() { if (dataSource != null) { try { dataSource.close(); } catch (Exception e) { e.printStackTrace(); } dataSource = null; } try { Properties p = new Properties(); p.setProperty("driverClassName", "com.microsoft.sqlserver.jdbc.SQLServerDriver"); p.setProperty("url", "jdbc:sqlserver://localhost:1433;DatabaseName=diary"); p.setProperty("password", "buteng"); p.setProperty("username", "sa"); 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) { e.printStackTrace(); } } public static synchronized Connection getConnection() { if (dataSource == null) { init(); } Connection connection = null; if (dataSource != null) { try { connection = dataSource.getConnection(); } catch (SQLException sqle) { sqle.printStackTrace(); } } return connection; } /** * 关闭结果集 * * @param rs */ public static void closeResultSet(ResultSet rs) { if (rs != null) { try { rs.close(); } catch (SQLException sqle) { sqle.printStackTrace(); } } } /** * 关闭Statement * * @param stmt */ public static void closeStatement(Statement stmt) { if (stmt != null) { try { stmt.close(); } catch (SQLException sqle) { sqle.printStackTrace(); } } } /** * 关闭数据库连接 * * @param connection */ public static void closeConnection(Connection connection) { if (connection != null) { try { connection.close(); } catch (SQLException sqle) { sqle.printStackTrace(); } } } }