您当前的位置： 首页 > 慢生活 > 程序人生 网站首页程序人生

7_数据库连接池_druid_工具类(8_数据库连接池_druid_工具类测试)

发布时间：2022-07-21 22:36:21编辑：雪饮阅读（）

 

Druid虽然强大，但是也仅仅只是连接池的一种实现，具体要获取数据库连接，还是要自己装载配置文件，然后写一些代码才能。

这些繁琐的过程同样也是可以再次封装的，那么基于上篇druid工具类封装如：

DuidUtils.java：

package day6;

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 DuidUtils {
    //1.定义成员变量 DataSource
    private static DataSource ds ;

    static{
        try {
            //1.加载配置文件
            Properties pro = new Properties();
            pro.load(DuidUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
            //2.获取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){
        close(null,stmt,conn);
    }

    //两种close，根据业务情况有时候是需要有不同的重载方式，这种设计思路还是挺不错的
    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 getDataSource(){
        return  ds;
    }
}

然后具体的使用在预处理sql以insert的方式操作下数据的测试如：

PoolTest.java:

package day6;
 
 import com.alibaba.druid.pool.DruidDataSourceFactory;
 import com.mchange.v2.c3p0.ComboPooledDataSource;
 
 import javax.sql.DataSource;
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 import java.util.Properties;
 
 public class PoolTest {
     public static void main(String args[]) throws Exception {
         /*
          * 完成添加操作：给user表添加一条记录
          */
         Connection conn = null;
         PreparedStatement pstmt = null;
         try {
             //1.获取连接
             conn = DuidUtils.getConnection();
             //2.定义sql
             String sql = "insert into user(user,pwd,balance) values(null,?,?)";
             //3.获取pstmt对象
             pstmt = conn.prepareStatement(sql);
             //4.给？赋值
             pstmt.setString(1,"kasumi220807");
             pstmt.setDouble(2,220807);
             //5.执行sql
             int count = pstmt.executeUpdate();
             System.out.println(count);
         } catch (SQLException e) {
             e.printStackTrace();
         }finally {
             //6. 释放资源
             DuidUtils.close(pstmt,conn);
         }
     }
 }