当前位置： 移动技术网 > IT编程>开发语言>Java > java 自己实现DataSource实现实例

java 自己实现DataSource实现实例

2019年07月22日  | 移动技术网IT编程  | 我要评论

碧生源常润茶副作用,厦门房子网,瑜伽冥想课程

java 自己实现datasource实现代码

  datasource 对象所表示的物理数据源的连接。作为 drivermanager 工具的替代项。datasource能提供最高性能的对数据库的并发访问,数据源技术是java操作数据库的一个很关键技术，流行的持久化框架都离不开数据源的应用。

         数据源提供了一种简单获取数据库连接的方式，并能在内部通过一个池的机制来复用数据库连接，这样就大大减少了创建数据库连接的次数，提高了系统性能。下面，我们自己动手实现个精简的数据源，代码如下：

public class mydatasource { 
  private linkedlist<connection> connectionpool = new linkedlist<connection>(); 
 
  public mydatasource() { 
    for (int i = 0; i < 10; i++) { 
      connectionpool.add(new myconnection(creatconnection(),this)); 
    } 
  } 
  private connection creatconnection() { 
    try { 
      return drivermanager.getconnection( 
          "jdbc:mysql://localhost:3306/test", "root", "root"); 
    } catch (sqlexception e) { 
      // todo auto-generated catch block 
      throw new exceptionininitializererror(); 
    } 
  } 
   
  public connection getconnection(){ 
    system.out.println(connectionpool.size()); 
    return connectionpool.removefirst(); 
  } 
   
  public void freeconnection(connection conn){ 
    system.out.println("datasource close connection"); 
    connectionpool.addlast(conn); 
  } 
}

java代码 

public class myconnection implements connection{ 
  private connection connection; 
  private mydatasource datasource; 
  public connection getconnection() { 
    return connection; 
  } 
 
  public void setconnection(connection connection) { 
    this.connection = connection; 
  } 
 
  public myconnection(connection realconnection,mydatasource datasource){ 
    this.connection=realconnection; 
    this.datasource=datasource; 
  } 
   
  @override 
  public void close() throws sqlexception { 
    // todo auto-generated method stub 
    system.out.println("myconnection close"); 
    datasource.freeconnection(this); 
  } 
  ... 
}

        我们通过datasource获得的connection是经过包裹后的对象，这里应用到了代理模式。下面我们使用jdk的动态代理来改写mydatasource：

java代码

public class mydatasource { 
  private linkedlist<connection> connectionpool = new linkedlist<connection>(); 
 
  public mydatasource() { 
    for (int i = 0; i < 10; i++) { 
      connectionpool.add(getproxy(creatconnection())); 
    } 
  } 
 
  private connection getproxy(final connection connection) { 
    // todo auto-generated method stub 
    return (connection)proxy.newproxyinstance(this.getclass().getclassloader(), new class[]{connection.class}, new invocationhandler(){ 
      @override 
      public object invoke(object proxy, method method, object[] args) 
          throws throwable { 
        // todo auto-generated method stub 
        object value; 
        if(method.getname().equalsignorecase("close")){ 
          connectionpool.addlast((connection)proxy); 
          system.out.println(connectionpool.size()); 
          return null; 
        }else{ 
          value=method.invoke(connection, args); 
        } 
        system.out.println(connectionpool.size()); 
        return value; 
      } 
       
    }); 
     
  } 
 
  private connection creatconnection() { 
    try { 
      return drivermanager.getconnection( 
          "jdbc:mysql://localhost:3306/test", "root", "root"); 
    } catch (sqlexception e) { 
      // todo auto-generated catch block 
      throw new exceptionininitializererror(); 
    } 
  } 
   
  public connection getconnection(){ 
    system.out.println(connectionpool.size()); 
    return connectionpool.removefirst(); 
  } 
   
  public void freeconnection(connection conn){ 
    system.out.println("datasource close connection"); 
    connectionpool.addlast(conn); 
  } 
}

       通过这种方式获得的connection是通过jdk的动态代理生成的一个代理对象，该代理对象实现了connection接口。

       以上两种方式实现了我们自己的datasource，在我们通过datasource获得的connection对象的close方法都已经被改写过了。在connection对象调用close方法时，会将该connection对象放入到缓存池中，而不是关闭对象。

       感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网