java 自己实现DataSource实现实例

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对象放入到缓存池中，而不是关闭对象。

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

# java  # DataSource  # DataSource自己实现  # Springboot mybatis plus druid多数据源解决方案 dynamic-data  # Spring Boot 自定义数据源DruidDataSource代码  # 详解spring cloud config实现datasource的热部署  # 浅谈利用Spring的AbstractRoutingDataSource解决多数据源的问题  # 详解利用Spring的AbstractRoutingDataSource解决多数据源的问题  # Spring(AbstractRoutingDataSource)实现动态数据源切换示例  # 使用Spring的AbstractRoutingDataSource实现多数据源切换示例  # 如何在MyBatis中实现DataSource  # 自己的  # 实现了  # 过了  # 两种  # 希望能  # 谢谢大家  # 并能  # 将该  # 自己动手  # 池中  # 复用  # 在内部  # 而不是  # 提高了  # 减少了  # return  # creatConnection  # jdbc  # getConnection  # int 

相关文章： 网站制作多少钱一个,建一个论坛网站大约需要多少钱？  广州网站制作的公司,现在专门做网站的公司有没有哪几家是比较好的，性价比高，模板也多的？  如何快速搭建高效WAP手机网站吸引移动用户？  广州建站公司哪家好？十大优质服务商推荐  建站OpenVZ教程与优化策略：配置指南与性能提升  招商网站制作流程,网站招商广告语？  建站之星如何修改网站生成路径？  深圳网站制作案例,网页的相关名词有哪些？  网站视频制作书签怎么做,ie浏览器怎么将网站固定在书签工具栏？  建站DNS解析失败？如何正确配置域名服务器？  制作证书网站有哪些,全国城建培训中心证书查询官网？  模具网站制作流程,如何找模具客户？  Swift中switch语句区间和元组模式匹配  如何快速建站并高效导出源代码？  交易网站制作流程,我想开通一个网站，注册一个交易网址，需要那些手续？  如何在云服务器上快速搭建个人网站？  ,有什么在线背英语单词效率比较高的网站？  高配服务器限时抢购：企业级配置与回收服务一站式优惠方案  上海网站制作开发公司,上海买房比较好的网站有哪些？  简单实现Android文件上传  如何用低价快速搭建高质量网站？  建设网站制作价格,怎样建立自己的公司网站？  高性能网站服务器部署指南：稳定运行与安全配置优化方案  如何在IIS7上新建站点并设置安全权限？  如何通过wdcp面板快速创建网站？  营销式网站制作方案,销售哪个网站招聘效果最好？  昆明高端网站制作公司,昆明公租房申请网上登录入口？  定制建站是什么？如何实现个性化需求？  建站之星各版本价格是多少？  存储型VPS适合搭建中小型网站吗？  贸易公司网站制作流程,出口贸易网站设计怎么做？  如何快速生成橙子建站落地页链接？  岳西云建站教程与模板下载_一站式快速建站系统操作指南  如何在云主机上快速搭建多站点网站？  矢量图网站制作软件,用千图网的一张矢量图做公司app首页，该网站并未说明版权等问题，这样做算不算侵权？应该如何解决？  如何处理“XML格式不正确”错误 常见XML well-formed问题解决方法  建站主机选购指南：核心配置与性价比推荐解析  如何在Mac上搭建Golang开发环境_使用Homebrew安装和管理Go版本  网站设计制作书签怎么做,怎样将网页添加到书签/主页书签/桌面？  建站ABC备案流程中有哪些关键注意事项？  如何在腾讯云服务器快速搭建个人网站？  简易网站制作视频教程,使用记事本编写一个简单的网页html文件？  如何实现建站之星域名转发设置？  建站之星代理如何获取技术支持？  如何用PHP工具快速搭建高效网站？  如何快速生成凡客建站的专业级图册？  如何在云指建站中生成FTP站点？  如何生成腾讯云建站专用兑换码？  建站上传速度慢？如何优化加速网站加载效率？  单页制作网站有哪些,朋友给我发了一个单页网站，我应该怎么修改才能把他变成自己的呢，请求高手指点迷津？