jdbc链接接数据库之开启事务

上篇简单介绍了jdbc链接数据库 本篇就说一下自定义连接池以及增删改查的测试  自定义链接池的原因:

    JDBC连接中用到Connection   在每次对数据进行增删查改 都要 开启  、关闭  ,在开发项目中 ,浪费了很大的资源 ,所以我们自己定义了一个连接池,用池来管理Connection,这样可以重复使用Connection,有了池,我们就不用自己来创建Connection,而是通过池来获取Connection对象,当使用完Connection后,调用Connection的close()方法也不会真的关闭Connection,而是把Connection“归还”给池,池也就可以再利用这个Connection对象。

 

  创建自定义连接池的步骤:

1 创建连接池实现(数据源),并实现接口javax.sql.DataSource.

2 提供一个集合,用于存放连接,因为移除/添加操作过多,所以选用LinkedList较好

3 为连接池初始化连接

4 程序如果需要连接,调用实现类的getConnection(),本方法将从连接池(容器List)获取连接,为了保证当前连接只是停工给一个线程使用,我们需要将连接先从连接池中移除。

5 当用户使用完连接,释放资源时,不执行close()方法,而是将连接添加到连接池中

  自定义连接池的代码:

 

1 package com.baidu.database.tools; 2 3 import java.io.PrintWriter; 4 import java.lang.reflect.InvocationHandler; 5 import java.lang.reflect.Method; 6 import java.lang.reflect.Proxy; 7 import java.sql.Connection; 8 import java.sql.SQLException; 9 import java.sql.SQLFeatureNotSupportedException; 10 import java.util.LinkedList; 11 import java.util.logging.Logger; 12 13 import javax.sql.DataSource; 14 15 /** 16 * 自定义连接池 17 * 18 * @author Admin 19 * 20 */ 21 public class MyDatabasePool implements DataSource { 22 23 /** 24 * 创建集合存放连接 25 */ 26 public LinkedList<Connection> list = new LinkedList<>(); 27 28 // 使用构造方法初始化连接池 29 public MyDatabasePool() throws Exception { 30 // 创建最小连接数个数据库连接对象以备使用 31 for (int i = 1; i < 21; i++) { 32 // 将创建好的数据库连接对象添加到Linkedlist集合中 33 list.add(JdbcUtils.getConnection()); 34 } 35 } 36 37 @Override 38 public void setLogWriter(PrintWriter out) throws SQLException { 39 // TODO Auto-generated method stub 40 41 } 42 43 @Override 44 public void setLoginTimeout(int seconds) throws SQLException { 45 // TODO Auto-generated method stub 46 47 } 48 49 @Override 50 public int getLoginTimeout() throws SQLException { 51 // TODO Auto-generated method stub 52 return 0; 53 } 54 55 @Override 56 public Logger getParentLogger() throws SQLFeatureNotSupportedException { 57 // TODO Auto-generated method stub 58 return null; 59 } 60 61 @Override 62 public <T> T unwrap(Class<T> iface) throws SQLException { 63 // TODO Auto-generated method stub 64 return null; 65 } 66 67 @Override 68 public boolean isWrapperFor(Class<?> iface) throws SQLException { 69 // TODO Auto-generated method stub 70 return false; 71 } 72 73 /** 74 * 获取链接 通过动态代理(Proxy)实现的数据库连接池的创建连接与归还链接的操作 75 */ 76 @Override 77 public Connection getConnection() throws SQLException { 78 Connection connection = list.removeLast(); 79 //创建代理对象 80 Connection proxyConnection = (Connection) Proxy.newProxyInstance( 81 //类加载器 82 connection.getClass().getClassLoader(), 83 //目标接口对象 84 new Class[] { Connection.class }, 85 //当调用connction对象的时候自动触发事务处理器 86 new InvocationHandler() { 87 @Override 88 public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { 89 //判断执行close()就把连接放入连接池 90 if ("close".equals(method.getName())) { 91 //连接放入连接池 92 list.addLast(connection); 93 return null; 94 } else { 95 //调用目标方法对象 96 return method.invoke(connection, args); 97 } 98 99 } 100 }); 101 return proxyConnection; 102 103 } 104 105 @Override 106 public Connection getConnection(String username, String password) throws SQLException { 107 // TODO Auto-generated method stub 108 return null; 109 } 110 111 @Override 112 public PrintWriter getLogWriter() throws SQLException { 113 // TODO Auto-generated method stub 114 return null; 115 } 116 117 }
          JdbcUtils地址

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wpypsx.html