您现在的位置是:首页 > 正文

Java中JDBC的数据库连接池

2024-02-01 02:14:27阅读 2
数据库连接池
池参数(所有池参数都有默认值):

初始大小:10个

最小空闲连接数:3个

增量:一次创建的最小单位(5个)

最大空闲连接数:12个

最大连接数:20个

最大的等待时间:1000毫秒

四大连接参数

连接池也是使用四大连接参数来完成创建连接对象!

实现的接口

连接池必须实现:javax.sql.DataSource接口!

连接池返回的Connection对象,它的close()方法与众不同!调用它的close()不是关闭,而是把连接归还给池!代表该链接不被占用了。

数据库连接池
连接池的概念

用池来管理Connection,这可以重复使用Connection。有了池,所以我们就不用自己来创建Connection,而是通过池来获取Connection对象。当使用完Connection后,调用Connection的close()方法也不会真的关闭Connection,而是把Connection“归还”给池。池就可以再利用这个Connection对象了。

JDBC数据库连接池接口(DataSource)

Java为数据库连接池提供了公共的接口:javax.sql.DataSource,各个厂商可以让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池!

自定义连接池(CloudPool)

分析:CloudPool需要有一个List,用来保存连接对象。在CloudPool的构造器中创建5个连接对象放到List中!当用人调用了CloudPool的getConnection()时,那么就从List拿出一个返回。当List中没有连接可用时,抛出异常。

我们需要对Connection的close()方法进行增强,所以我们需要自定义CloudConnection类,对Connection进行装饰!即对close()方法进行增强。因为需要在调用close()方法时把连接“归还”给池,所以CloudPool类需要拥有池对象的引用,并且池类还要提供“归还”的方法。

CloudPool.java
public class CloudPool implements DataSource {

    private static Properties props = new Properties();

    private List<Connection> list = new ArrayList<Connection>();

    static {

       InputStream in = CloudPool.class.getClassLoader()

              .getResourceAsStream("dbconfig.properties");

       try {

           props.load(in);

           Class.forName(props.getProperty("driverClassName"));

       } catch (Exception e) {

           throw new RuntimeException(e);

       }

    }

 

    public CloudPool () throws SQLException {

       for (int i = 0; i < 5; i++) {

           Connection con = DriverManager.getConnection(

                  props.getProperty("url"), props.getProperty("username"),

                  props.getProperty("password"));

           CloudPool conWapper = new CloudConnection(con, this);

           list.add(conWapper);

       }

    }

   

    public void add(Connection con) {

       list.add(con);

    }

 

    public Connection getConnection() throws SQLException {

       if(list.size() > 0) {

           return list.remove(0);

       }

       throw new SQLException("没连接了");

    }}
CloudConnection.java
 public class CloudConnection extends ConnectionWrapper {

    private ItcastPool pool;

   

    public CloudConnection(Connection con, CloudPool pool) {

       super(con);

       this.pool = pool;

    }

 

    @Override

    public void close() throws SQLException {

       pool.add(this);

    }

}
C3P0连接池
C3P0简介

C3P0也是开源免费的连接池,现在做的大部分项目都是使用C3P0连接池。

C3P0的使用

C3P0中池类是:ComboPooledDataSource。

public void fun1() throws PropertyVetoException, SQLException {

ComboPooledDataSource ds = new ComboPooledDataSource();

ds.setJdbcUrl(“jdbc:mysql://localhost:3306/mydb1”);

ds.setUser(“root”);

ds.setPassword(“123”);

ds.setDriverClass(“com.mysql.jdbc.Driver”);

ds.setAcquireIncrement(5);

ds.setInitialPoolSize(20);

ds.setMinPoolSize(2);

ds.setMaxPoolSize(50);

Connection con = ds.getConnection();

System.out.println(con);

con.close();

}

配置文件要求:

l 文件名称:必须叫c3p0-config.xml

l 文件位置:必须在src下

c3p0也可以指定配置文件,而且配置文件可以是properties,也可骒xml的。当然xml的高级一些了。但是c3p0的配置文件名必须为c3p0-config.xml,并且必须放在类路径下。

<?xml version="1.0" encoding="UTF-8"?>

<c3p0-config>

    <default-config>

       <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb1</property>

       <property name="driverClass">com.mysql.jdbc.Driver</property>

       <property name="user">root</property>

       <property name="password">123</property>

       <property name="acquireIncrement">3</property>

       <property name="initialPoolSize">10</property>

       <property name="minPoolSize">2</property>

       <property name="maxPoolSize">10</property>

    </default-config>

    <named-config name="oracle-config">

       <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb1</property>

       <property name="driverClass">com.mysql.jdbc.Driver</property>

       <property name="user">root</property>

       <property name="password">123</property>

       <property name="acquireIncrement">3</property>

       <property name="initialPoolSize">10</property>

       <property name="minPoolSize">2</property>

       <property name="maxPoolSize">10</property>

    </named-config>

</c3p0-config>

c3p0的配置文件中可以配置多个连接信息,可以给每个配置起个名字,这样可以方便的通过配置名称来切换配置信息。上面文件中默认配置为mysql的配置,名为oracle-config的配置也是mysql的配置

  public void fun2() throws PropertyVetoException, SQLException {

       ComboPooledDataSource ds = new ComboPooledDataSource();

       Connection con = ds.getConnection();

       System.out.println(con);

       con.close();

    }

public void fun2() throws PropertyVetoException, SQLException {

       ComboPooledDataSource ds = new ComboPooledDataSource("orcale-config");

       Connection con = ds.getConnection();

       System.out.println(con);

       con.close();

    }
Tomcat配置连接池
Tomcat配置JNDI资源

JNDI(Java Naming and Directory Interface),Java命名和目录接口。JNDI的作用就是:在服务器上配置资源,然后通过统一的方式来获取配置的资源。

我们这里要配置的资源当然是连接池了,这样项目中就可以通过统一的方式来获取连接池对象了。

下图是Tomcat文档提供的:
在这里插入图片描述
配置JNDI资源需要到元素中配置子元素:

l name:指定资源的名称,这个名称可以随便给,在获取资源时需要这个名称;

l factory:用来创建资源的工厂,这个值基本上是固定的,不用修改;

l type:资源的类型,我们要给出的类型当然是我们连接池的类型了;

l bar:表示资源的属性,如果资源存在名为bar的属性,那么就配置bar的值。对于DBCP连接池而言,你需要配置的不是bar,因为它没有bar这个属性,而是应该去配置url、username等属性。

<Context> 

  <Resource name="mydbcp"

                            type="org.apache.tomcat.dbcp.dbcp.BasicDataSource"

                            factory="org.apache.naming.factory.BeanFactory"

                            username="root"

                            password="123"

                            driverClassName="com.mysql.jdbc.Driver"   

                            url="jdbc:mysql://127.0.0.1/mydb1"

                            maxIdle="3"

                            maxWait="5000"

                            maxActive="5"

                            initialSize="3"/>

</Context> 

<Context> 

  <Resource name="myc3p0"

                            type="com.mchange.v2.c3p0.ComboPooledDataSource"

                            factory="org.apache.naming.factory.BeanFactory"

                            user="root"

                            password="123"

                            classDriver="com.mysql.jdbc.Driver"   

                            jdbcUrl="jdbc:mysql://127.0.0.1/mydb1"

                            maxPoolSize="20"

                            minPoolSize ="5"

                            initialPoolSize="10"

                            acquireIncrement="2"/>

</Context> 
获取资源

配置资源的目的当然是为了获取资源了。只要你启动了Tomcat,那么就可以在项目中任何类中通过JNDI获取资源的方式来获取资源了。

下图是Tomcat文档提供的,与上面Tomcat文档提供的配置资源是对应的。
在这里插入图片描述
获取资源:

l Context:javax.naming.Context;

l InitialContext:javax.naming.InitialContext;

l lookup(String):获取资源的方法,其中”java:comp/env”是资源的入口(这是固定的名称),获取过来的还是一个Context,这说明需要在获取到的Context上进一步进行获取。”bean/MyBeanFactory”对应中配置的name值,这回获取的就是资源对象了。

Context cxt = new InitialContext();

DataSource ds = (DataSource)cxt.lookup("java:/comp/env/mydbcp");

 Connection con = ds.getConnection();

System.out.println(con);

con.close();

Context cxt = new InitialContext();

Context envCxt = (Context)cxt.lookup("java:/comp/env");

DataSource ds = (DataSource)env.lookup("mydbcp");

Connection con = ds.getConnection();

System.out.println(con);

con.close();

上面两种方式是相同的效果。

修改JdbcUtils

因为已经学习了连接池,那么JdbcUtils的获取连接对象的方法也要修改一下了。

JdbcUtils.java

public class JdbcUtils {

    private static DataSource dataSource = new ComboPooledDataSource();

 

    public static DataSource getDataSource() {

       return dataSource;

    }

 

    public static Connection getConnection() {

       try {

           return dataSource.getConnection();

       } catch (Exception e) {

           throw new RuntimeException(e);

       }

    }

}

网站文章

  • 学习 C/C++ 到底应该看哪些书或者视频?

    Hello,大家好,我是 Eg。初学 C/C++,不知道该看哪些书籍?学长说郝斌的视频好,学姐又说谭浩强的书好,大学老师却说把教材中的内容吃透就行。那到底谁说的是真的呢?今天我就以一个过来人的经验告诉...

    2024-02-01 02:13:56
  • Java面试总结。多达十万字的面试内容总结 简直yyds

    Java面试总结。多达十万字的面试内容总结 简直yyds

    基础篇1、Java语言有哪些特点2、面向对象和面向过程的区别3、八种基本数据类型的大小,以及他们的封装类4、标识符的命名规则。5、instanceof关键字的作用6、Java自动装箱与拆箱7、重载和重...

    2024-02-01 02:13:48
  • 服务器设置进系统密码,服务器系统设置密码

    服务器设置进系统密码,服务器系统设置密码

    服务器系统设置密码 内容精选换一换登录Windows操作系统的弹性云服务器时,需使用密码方式登录。因此,用户需先根据创建弹性云服务器时使用的密钥文件,获取该弹性云服务器初始安装时系统生成的管理员密码(...

    2024-02-01 02:13:40
  • 本人用uniapp做微信公众号开发易错点整理

    本人用uniapp做微信公众号开发易错点整理

    wxUpdateAppMessageShareData和updateTimelineShareData,即自定义“分享给朋友”及“分享到QQ”按钮的分享内容和自定义“分享到朋友圈”及“分享到QQ空间”...

    2024-02-01 02:13:12
  • Golang框架Gin入门实战--(4)HTML模板渲染以及模板语法 自定义模板函数 静态文件服务(下)

    Golang框架Gin入门实战--(4)HTML模板渲染以及模板语法 自定义模板函数 静态文件服务(下)

    Golang框架Gin入门实战--(4)HTML模板渲染以及模板语法 自定义模板函数 静态文件服务(下)

    2024-02-01 02:13:03
  • 分布式服务框架

    本博客转自git项目advancejavadubbo 工作原理• 第一层:service 层,接口层,给服务提供者和消费者来实现的• 第二层:config 层,配置层,主要是对 dubbo 进行各种配置的• 第三层:proxy 层,服务代理层,无论是 consumer 还是 provider,dubbo 都会给你生成代理,代理之间进行网络通信• 第四层:registry 层,服务注册层,...

    2024-02-01 02:12:59
  • 2021美团校招(一)

    2021美团校招(一)

    小美的送花路线 输入描述 输出第一行包含一个正整数n,即花店和客户的总数。(1&lt;=n&lt;=30000) 接下来有n-1行,每行有三个整数u,v,w,表示在u和v之间存在一条距离为w的道路。(...

    2024-02-01 02:12:32
  • Ubuntu如何设置或删除swap虚拟内存

    Ubuntu如何设置或删除swap虚拟内存

    什么是swap? swap 简单的说就是将硬盘当内存用,用于解决内存容量不足的情况。 1、如何设置swap? 1、查看当前系统是否设置了swap 在终端输入以下命令查看是否设置了swap free -...

    2024-02-01 02:12:04
  • runoob.com python3教程结构提要

    原站地址:http://www.runoob.com/python3/python3-tutorial.html 本文目的: 1. 提供更深层次的资料查询目录; 2. 快速复习python的简单知识 一、基础语法 1.编码:Python 3 源码文件以UTF-8编码,所有字符串都是 unicode 字符串。 2.标识符: 2.1 第一个字符必须是字母表中字母或下划线_ 2.2...

    2024-02-01 02:11:55
  • Spring @Transactional 事务以及事务间调用完整解析,保你看完,反手就一个赞!

    Spring @Transactional 事务以及事务间调用完整解析,保你看完,反手就一个赞!

    事物注解方式: @Transactional当标于类前时, 标示类中所有方法都进行事物处理 , 例子:@Transactional public class TestServiceBean imple...

    2024-02-01 02:11:27