Druid数据库连接池基本使用

小程序：扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序

一、导入Druid的jar包和数据库驱动jar包

二、定义配置文件

与c3p0不同，Druid的配置文件是properties形式的。而且Druid不像c3p0那样可以自动加载配置文件，Druid需要手动去指定配置文件，所以Druid的配置文件可以叫任意名称，并且可以放置在任意目录下。

# druid.properties文件的配置

driverClassName=com.mysql.jdbc.Driver

url=jdbc:mysql://127.0.0.1:3307/test_db

username=root

password=root

# 初始化连接数量

initialSize=5

# 最大连接数

maxActive=10

# 最大超时时间

maxWait=3000

目录结构如下：

三、使用Druid连接池

package cn.xj.datasource.druid;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;

import java.io.IOException;

import java.io.InputStream;

import java.sql.Connection;

import java.util.Properties;

public class Druid_demo {

    public static void main(String[] args) throws Exception {

        //加载配置文件

        Properties pro = new Properties();

        InputStream is = Druid_demo.class.getClassLoader().getResourceAsStream("druid.properties");

        pro.load(is);

        //获取连接池对象

        DataSource ds = DruidDataSourceFactory.createDataSource(pro);

        //获取连接

        Connection conn = ds.getConnection();

        System.out.println(conn);

    }

}

四、定义工具类

步骤：

1.定义一个类JDBCUtils

*类里边提供静态代码块加载配置文件，初始化连接池对象

*类里边要提供这些方法：

（1）获取连接方法：通过数据库连接池获取连接

（2）释放资源

（3）获取连接池的方法

package cn.xj.datasource.utils;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;

import java.io.IOException;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Properties;

public class JDBCUtils {

    //定义成员变量

    private static DataSource ds;

    static {

        try {

            //加载配置文件

            Properties pro = new Properties();

            pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));

            //获取连接池对象DataSource

            ds = DruidDataSourceFactory.createDataSource(pro);

        } catch (IOException e) {

            e.printStackTrace();

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

    //获取链接

    public static Connection getConnection() throws SQLException {

        return ds.getConnection();

    }

    //释放资源

    public static void close(Statement stmt,Connection conn){

        if (stmt != null){

            try {

                stmt.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if (conn != null){

            try {

                conn.close();  //归还连接

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

    public static void close(ResultSet rs,Statement stmt, Connection conn){

        if (rs != null){

            try {

                rs.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if (stmt != null){

            try {

                stmt.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if (conn != null){

            try {

                conn.close();  //归还连接

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

    //获取连接池方法

    public static DataSource getDateSource(){

        return ds;

    }

}

五、使用工具类

package cn.xj.datasource.druid;

import cn.xj.datasource.utils.JDBCUtils;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

public class Druid_demo02 {

    public static void main(String[] args) {

        Connection conn = null;

        PreparedStatement pstmt = null;

        try {

            //获取连接

            conn = JDBCUtils.getConnection();

            //定义sql语句

            String sql = "insert into account value(null,?,?)";

            //获取PreparedStatement对象

            pstmt = conn.prepareStatement(sql);

            //给占位符（？）赋值

            pstmt.setString(1,"王五");

            pstmt.setDouble(2,3000);

            //执行sql语句

            int count = pstmt.executeUpdate();

            System.out.println(count);

        } catch (SQLException e) {

            e.printStackTrace();

        }finally {

            //释放资源

            JDBCUtils.close(pstmt,conn);

        }

    }

}