登 录
我们在使用数据库连接时候，很多时候会考虑使用数据库连接池，因为数据库连接池的机制，使得在大用户数量上进行交互的时候使得其效率比较有优势！
public class DBPool {<br /> private static DBPool dbPool;<br /> private ComboPooledDataSource dataSource;</p> <p> static {<br /> dbPool = new DBPool();<br /> }</p> <p> public DBPool() {<br /> try {<br /> dataSource = new ComboPooledDataSource();<br /> dataSource.setUser("root");<br /> dataSource.setPassword("123456");<br /> dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/game?user=root&password=123456&useUnicode=true");<br /> dataSource.setDriverClass("com.mysql.jdbc.Driver");<br /> // 设置初始连接池的大小！<br /> dataSource.setInitialPoolSize(2);<br /> // 设置连接池的最小值！<br /> dataSource.setMinPoolSize(1);<br /> // 设置连接池的最大值！<br /> dataSource.setMaxPoolSize(10);<br /> // 设置连接池中的最大Statements数量！<br /> dataSource.setMaxStatements(50);<br /> // 设置连接池的最大空闲时间！<br /> dataSource.setMaxIdleTime(60);<br /> } catch (PropertyVetoException e) {<br /> throw new RuntimeException(e);<br /> }<br /> }</p> <p> public final static DBPool getInstance() {<br /> return dbPool;<br /> }</p> <p> public final Connection getConnection() {<br /> try {<br /> return dataSource.getConnection();<br /> } catch (SQLException e) {<br /> throw new RuntimeException("无法从数据源获取连接 ", e);<br /> }<br /> }</p> <p> public static void main(String[] args) throws SQLException {<br /> Connection con = null;<br /> try {<br /> con = DBPool.getInstance().getConnection();<br /> ResultSet rs = con.createStatement().executeQuery("SELECT * FROM LESOGO_USER");<br /> while (rs.next()) {<br /> System.out.println(rs.getObject(1));<br /> System.out.println(rs.getObject(2));<br /> System.out.println(rs.getObject(3));<br /> }<br /> } catch (Exception e) {<br /> } finally {<br /> if (con != null)<br /> con.close();<br /> }<br /> }<br /> }<br />
/**<br /> * 此示例演示如何获得C3P0的数据源并将其绑定到一个JNDI名称服务。<br /> */<br /> public final class JndiBindDataSource {<br /> /**<br /> * 一定要载入数据库驱动程序类，要么通过Class.forName（）[如下]或外部显示（例如，通过使用- Djdbc.drivers启动时你的JVM）。<br /> */<br /> static {<br /> try {<br /> Class.forName("com.mysql.jdbc.Driver");<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> public static void main(String[] argv) {<br /> try {<br /> /**<br /> * 让一个命令行参数指定名称，将我们的数据源的绑定。<br /> */<br /> String jndiName = argv[0];<br /> /**<br /> * 获取数据源使用预设池params ...<br /> * 这是唯一的C3P0的特定代码在这里<br /> */<br /> DataSource unpooled = DataSources<br /> .unpooledDataSource("jdbc:mysql://127.0.0.1:3306/game?user=root&password=123456&useUnicode=true", "root", "123456");<br /> DataSource pooled = DataSources.pooledDataSource(unpooled);<br /> System.out.println("是否能够获得Connection : "+pooled.getConnection());</p> <p> /**<br /> * 创建的InitialContext，并绑定的数据源，以它在通常的方式。<br /> * 我们使用的是没有的的InitialContext的构造参数版本，因此通过jndi.properties的文件，<br /> * 系统属性，或通过其他手段，JNDI环境，必须先设置。<br /> */<br /> InitialContext ctx = new InitialContext();<br /> System.out.println("jndiName : " + jndiName);<br /> ctx.rebind(jndiName, pooled);<br /> System.out.println("DataSource bound to nameservice under the name /"" + jndiName + '/"');<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> static void attemptClose(ResultSet o) {<br /> try {<br /> if (o != null)<br /> o.close();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> static void attemptClose(Statement o) {<br /> try {<br /> if (o != null)<br /> o.close();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> static void attemptClose(Connection o) {<br /> try {<br /> if (o != null)<br /> o.close();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> private JndiBindDataSource() {<br /> }<br /> }
/**<br /> * 此示例演示如何以编程方式，直接使用unpooled数据源<br /> */<br /> public final class UseJndiDataSource {</p> <p> public static void main(String[] argv) {<br /> try {<br /> /**<br /> * 让一个命令行参数指定名称，我们将查找的数据源。<br /> */<br /> String jndiName = argv[0];</p> <p> /**<br /> * 创建InitialContext的，和查找惯常做法的DataSource。 我们使用的是没有的的InitialContext的构造参数版本，因此通过jndi.properties的文件，<br /> * 系统属性，或通过其他手段，JNDI环境，必须先设置。<br /> */<br /> InitialContext ctx = new InitialContext();</p> <p> /**<br /> * 获取数据源...这是唯一的C3P0的特定代码在这里<br /> */<br /> DataSource ds = (DataSource) ctx.lookup(jndiName);</p> <p> /**<br /> * 掌握了这样一个连接东西，通常的方式<br /> */<br /> Connection con = null;<br /> Statement stmt = null;<br /> ResultSet rs = null;<br /> try {<br /> con = ds.getConnection();<br /> stmt = con.createStatement();<br /> rs = stmt.executeQuery("SELECT * FROM LESOGO_USER");<br /> while (rs.next())<br /> System.out.println(rs.getString(1));<br /> } finally {<br /> /**<br /> * 我试图约在资源管理，`神经质显式关闭每个资源，但如果你只收盘家长资源的习惯（如连接）， 让他们接近自己的孩子，都C3P0的数据源一定会妥善处理。<br /> */<br /> attemptClose(rs);<br /> attemptClose(stmt);<br /> attemptClose(con);<br /> }<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> static void attemptClose(ResultSet o) {<br /> try {<br /> if (o != null)<br /> o.close();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> static void attemptClose(Statement o) {<br /> try {<br /> if (o != null)<br /> o.close();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> static void attemptClose(Connection o) {<br /> try {<br /> if (o != null)<br /> o.close();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> private UseJndiDataSource() {<br /> }<br /> }<br />
/**<br /> * 此示例演示如何以编程方式，直接使用数据库连接池中的数据源<br /> */<br /> public final class UsePoolBackedDataSource {</p> <p> public static void main(String[] argv) {<br /> try {<br /> //<br /> // 收购之前，您的数据源！</p> <p> // 获取数据源...这是唯一的C3P0的特定代码在这里<br /> DataSource unpooled = DataSources.unpooledDataSource(<br /> "jdbc:mysql://127.0.0.1:3306/lesogo_game2?user=root&password=123456&useUnicode=true", "root",<br /> "123456");<br /> DataSource pooled = DataSources.pooledDataSource(unpooled);</p> <p> Connection con = null;<br /> Statement stmt = null;<br /> ResultSet rs = null;<br /> try {<br /> con = pooled.getConnection();<br /> stmt = con.createStatement();<br /> rs = stmt.executeQuery("SELECT * FROM LESOGO_USER");<br /> while (rs.next())<br /> System.out.println(rs.getString(1));<br /> } finally {<br /> attemptClose(rs);<br /> attemptClose(stmt);<br /> attemptClose(con);<br /> }<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> static void attemptClose(ResultSet o) {<br /> try {<br /> if (o != null)<br /> o.close();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> static void attemptClose(Statement o) {<br /> try {<br /> if (o != null)<br /> o.close();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> static void attemptClose(Connection o) {<br /> try {<br /> if (o != null)<br /> o.close();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> private UsePoolBackedDataSource() {<br /> }<br /> }
抱歉!评论已关闭.