AI 助理
备案控制台
开发者社区 数据库 文章 正文

JDBC之自定义数据库资源连接池并封装到数据库工具类

2019-04-17 2341
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
云数据库 RDS MySQL，高可用系列 2核4GB
简介： JDBC之自定义数据库资源连接池并封装到数据库工具类。代码完整。

Java为连接池实现提供了一个规范(接口),规范的写法,我们需要实现DataSource接口!

1.定义数据库的资源连接池 MyDbPool 

package com.scc.utils;

import javax.sql.DataSource;
import java.io.InputStream;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.SQLFeatureNotSupportedException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Properties;
import java.util.logging.Logger;

/**
 * scc
 */
public class MyDbPool implements DataSource {
    private static String driverClass = null;
    private static String url = null;
    private static String user = null;
    private static String password = null;

    private static List<Connection> connections;
    static {
        connections= Collections.synchronizedList(new ArrayList<>());

        try {
            //加载属性文件
            InputStream is = MyDbPool.class.getClassLoader().getResourceAsStream("db.properties");
            //创建一个集合
            Properties properties = new Properties();
            //从流中加载
            properties.load(is);
            //获取相应的属性值
            driverClass = properties.getProperty("driverClass");
            url = properties.getProperty("url");
            user = properties.getProperty("user");
            password = properties.getProperty("password");
            System.out.println(driverClass+"  "+url+"..."+user+"..."+password);
            //注册驱动
            Class.forName(driverClass);

            for (int i = 0; i < 20; i++) {
                connections.add(DriverManager.getConnection(url, user, password));
            }
            System.out.println("数据库连接池初始化完成");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    @Override
    public Connection getConnection() throws SQLException {
       synchronized (connections){
           if(connections.size()>0){
               Connection connection = connections.remove(0);
               System.out.println("使用了:"+connection.toString());
               return connection;
           }
       }
        return null;
    }

//释放资源
    public static void release(Connection conn){
        System.out.println("归还了:"+conn.toString());
        connections.add(conn);
    }

    @Override
    public Connection getConnection(String username, String password) throws SQLException {
        return null;
    }

    @Override
    public <T> T unwrap(Class<T> iface) throws SQLException {
        return null;
    }

    @Override
    public boolean isWrapperFor(Class<?> iface) throws SQLException {
        return false;
    }

    @Override
    public PrintWriter getLogWriter() throws SQLException {
        return null;
    }

    @Override
    public void setLogWriter(PrintWriter out) throws SQLException {

    }

    @Override
    public void setLoginTimeout(int seconds) throws SQLException {

    }

    @Override
    public int getLoginTimeout() throws SQLException {
        return 0;
    }

    @Override
    public Logger getParentLogger() throws SQLFeatureNotSupportedException {
        return null;
    }
}

2.封装DButils工具类

package com.scc.utils;

import java.beans.PropertyDescriptor;
import java.lang.reflect.Method;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;

/**
 * scc

 * 1.注册驱动
 * 2.获取连接
 * 3.释放资源
 * 4.执行增删改
 * 5.查
 */
public class DBUtils {

    private static MyDbPool  mypool;

    //注册
    static {
       mypool=new MyDbPool();
    }

    //数据库连接
    public static Connection getConnection() {
        try {
            return mypool.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("连接失败");
        }
        return null;
    }

    //关流
    public static void closeAll(PreparedStatement pstat, Connection conn, ResultSet res) {
        try {
            if (res != null) {
                res.close();
            }
            if (pstat != null) {
                pstat.close();
            }
            if (conn != null) {
               mypool.release(conn);//归还连接
            }
        } catch (SQLException e) {
            e.printStackTrace();
            System.out.println("没有开流，不用关");
        }
    }

    //增删改操作
    public static int executeUpdate(String sql, Object[] params) {
        Connection conn = null;
        PreparedStatement pstat = null;
        if (sql != null) {
            try {
                //获取连接
                conn = getConnection();
                //创建命令
                pstat = conn.prepareStatement(sql);
                //遍历参数并赋值
                if (params != null) {
                    for (int i = 0; i < params.length; i++) {
                        pstat.setObject(i + 1, params[i]);
                    }
                }
                //执行方法
                return pstat.executeUpdate(); //返回值为int类型
            } catch (SQLException e) {
                e.printStackTrace();
            } finally {
                closeAll(pstat, conn, null);
            }
        }
        return -1;
    }
    //获取单条数据  参数可以变化
    public static <T> T findSingle(String sql, Object[] params, Class<T> clazz) {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            conn = getConnection();
            ps = conn.prepareStatement(sql);
            if (params != null) {
                for (int i = 0; i < params.length; i++) {
                    ps.setObject(i + 1, params[i]);
                }
            }
            rs = ps.executeQuery();

            T obj = clazz.newInstance();//创建实体类的实例对象

            if (rs.next()) {
                ResultSetMetaData metaData = rs.getMetaData();//获取ResultSet的返回值对象的元数据集合
                System.out.println("列数：" + metaData.getColumnCount());
                for (int i = 0; i < metaData.getColumnCount(); i++) {
                    String columnName = metaData.getColumnName(i + 1);
                    PropertyDescriptor pd = new PropertyDescriptor(columnName, clazz);//返回的是一个对象

                    System.out.println("PropertyDescriptor的对象，pd:" + pd);
                    if (pd != null) {
                        Method writeMethod = pd.getWriteMethod();
                        writeMethod.invoke(obj, rs.getObject(columnName));
                    }
                }
            }
            return obj;
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("查询异常");
        } finally {
            closeAll(ps, conn, rs);
        }

        return null;
    }

    //查找 多条数据
    public static <T> List<T> findAll(String sql, Object[] params, Class<T> clazz) {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        List<T> list = new ArrayList<>();
        try {
            conn = getConnection();
            ps = conn.prepareStatement(sql);
            if (params != null) {
                for (int i = 0; i < params.length; i++) {
                    ps.setObject(i + 1, params[i]);
                }
            }
            rs = ps.executeQuery();
//            T obj = clazz.newInstance();//这句话不能放在外面，因为要把对象的地址放到list集合里，集合里的所有数据都单独对应一个地址

            ResultSetMetaData metaData = rs.getMetaData();//这个是获取SQL语句中要查询的列名对象，放在while里面和外卖都行
            while (rs.next()) {
                T obj = clazz.newInstance();//没创建一个对象，就把相应的地址引用方法list集合里
                for (int i = 0; i < metaData.getColumnCount(); i++) {
                    String columnName = metaData.getColumnName(i + 1);
                    Object value = rs.getObject(columnName);
                    PropertyDescriptor pd = new PropertyDescriptor(columnName, clazz);
                    Method writeMethod = pd.getWriteMethod();
                    writeMethod.invoke(obj, value);
                }

                list.add(obj);
            }
            return list;
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("查询异常");
        } finally {
            closeAll(ps, conn, rs);
        }
        return null;
    }


}

3.测试类

package com.scc.demo;

import com.scc.utils.DBUtils;

import java.sql.Connection;

/**
 * scc
 */
public class PoolTest {
    public static void main(String[] args) {
        for (int i = 0; i < 20; i++) {
            Connection conn = DBUtils.getConnection();
            System.out.println("获取连接："+conn.toString());
            DBUtils.closeAll(null, conn, null);

        }
    }
}

运行结果

"C:\Program Files\Java\jdk1.8.0_152\bin\java.exe" "-javaagent:D:\Program Files\JetBrains\IntelliJ IDEA 2018.3.3\lib\idea_rt.jar=65478:D:\Program Files\JetBrains\IntelliJ IDEA 2018.3.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Program Files\Java\jdk1.8.0_152\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_152\jre\lib\rt.jar;E:\IdeaWorkplace\JDBC2\out\production\JDBC2;E:\IdeaWorkplace\JDBC2\lib\mysql-connector-java-5.1.41-bin.jar;E:\Software02\repository\junit\junit\4.12\junit-4.12.jar;E:\Software02\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar" com.scc.demo.PoolTest
com.mysql.jdbc.Driver  jdbc:mysql://localhost:3306/student...root...123456
数据库连接池初始化完成
使用了:com.mysql.jdbc.JDBC4Connection@4ccabbaa
获取连接：com.mysql.jdbc.JDBC4Connection@4ccabbaa
归还了:com.mysql.jdbc.JDBC4Connection@4ccabbaa
使用了:com.mysql.jdbc.JDBC4Connection@4bf558aa
获取连接：com.mysql.jdbc.JDBC4Connection@4bf558aa
归还了:com.mysql.jdbc.JDBC4Connection@4bf558aa
使用了:com.mysql.jdbc.JDBC4Connection@2d38eb89
获取连接：com.mysql.jdbc.JDBC4Connection@2d38eb89
归还了:com.mysql.jdbc.JDBC4Connection@2d38eb89
使用了:com.mysql.jdbc.JDBC4Connection@5fa7e7ff
获取连接：com.mysql.jdbc.JDBC4Connection@5fa7e7ff
归还了:com.mysql.jdbc.JDBC4Connection@5fa7e7ff
使用了:com.mysql.jdbc.JDBC4Connection@4629104a
获取连接：com.mysql.jdbc.JDBC4Connection@4629104a
归还了:com.mysql.jdbc.JDBC4Connection@4629104a
使用了:com.mysql.jdbc.JDBC4Connection@27f8302d
获取连接：com.mysql.jdbc.JDBC4Connection@27f8302d
归还了:com.mysql.jdbc.JDBC4Connection@27f8302d
使用了:com.mysql.jdbc.JDBC4Connection@4d76f3f8
获取连接：com.mysql.jdbc.JDBC4Connection@4d76f3f8
归还了:com.mysql.jdbc.JDBC4Connection@4d76f3f8
使用了:com.mysql.jdbc.JDBC4Connection@2d8e6db6
获取连接：com.mysql.jdbc.JDBC4Connection@2d8e6db6
归还了:com.mysql.jdbc.JDBC4Connection@2d8e6db6
使用了:com.mysql.jdbc.JDBC4Connection@23ab930d
获取连接：com.mysql.jdbc.JDBC4Connection@23ab930d
归还了:com.mysql.jdbc.JDBC4Connection@23ab930d
使用了:com.mysql.jdbc.JDBC4Connection@4534b60d
获取连接：com.mysql.jdbc.JDBC4Connection@4534b60d
归还了:com.mysql.jdbc.JDBC4Connection@4534b60d
使用了:com.mysql.jdbc.JDBC4Connection@3fa77460
获取连接：com.mysql.jdbc.JDBC4Connection@3fa77460
归还了:com.mysql.jdbc.JDBC4Connection@3fa77460
使用了:com.mysql.jdbc.JDBC4Connection@619a5dff
获取连接：com.mysql.jdbc.JDBC4Connection@619a5dff
归还了:com.mysql.jdbc.JDBC4Connection@619a5dff
使用了:com.mysql.jdbc.JDBC4Connection@1ed6993a
获取连接：com.mysql.jdbc.JDBC4Connection@1ed6993a
归还了:com.mysql.jdbc.JDBC4Connection@1ed6993a
使用了:com.mysql.jdbc.JDBC4Connection@7e32c033
获取连接：com.mysql.jdbc.JDBC4Connection@7e32c033
归还了:com.mysql.jdbc.JDBC4Connection@7e32c033
使用了:com.mysql.jdbc.JDBC4Connection@7ab2bfe1
获取连接：com.mysql.jdbc.JDBC4Connection@7ab2bfe1
归还了:com.mysql.jdbc.JDBC4Connection@7ab2bfe1
使用了:com.mysql.jdbc.JDBC4Connection@497470ed
获取连接：com.mysql.jdbc.JDBC4Connection@497470ed
归还了:com.mysql.jdbc.JDBC4Connection@497470ed
使用了:com.mysql.jdbc.JDBC4Connection@63c12fb0
获取连接：com.mysql.jdbc.JDBC4Connection@63c12fb0
归还了:com.mysql.jdbc.JDBC4Connection@63c12fb0
使用了:com.mysql.jdbc.JDBC4Connection@b1a58a3
获取连接：com.mysql.jdbc.JDBC4Connection@b1a58a3
归还了:com.mysql.jdbc.JDBC4Connection@b1a58a3
使用了:com.mysql.jdbc.JDBC4Connection@6438a396
获取连接：com.mysql.jdbc.JDBC4Connection@6438a396
归还了:com.mysql.jdbc.JDBC4Connection@6438a396
使用了:com.mysql.jdbc.JDBC4Connection@e2144e4
获取连接：com.mysql.jdbc.JDBC4Connection@e2144e4
归还了:com.mysql.jdbc.JDBC4Connection@e2144e4

Process finished with exit code 0
文章标签：
云数据库 RDS MySQL 版
超级计算集群
Java
数据库
SQL
关系型数据库
数据库连接
关键词：
数据库工具类
jdbc数据库工具类
jdbc工具类
数据库自定义
jdbc连接池
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
sun小太阳
目录
相关文章
众所周知
|
2天前
|
Java 数据库连接 数据库
优化之路：Java连接池技术助力数据库性能飞跃
在Java应用开发中，数据库操作常成为性能瓶颈。频繁的数据库连接建立和断开增加了系统开销，导致性能下降。本文通过问题解答形式，深入探讨Java连接池技术如何通过复用数据库连接，显著减少连接开销，提升系统性能。文章详细介绍了连接池的优势、选择标准、使用方法及优化策略，帮助开发者实现数据库性能的飞跃。
众所周知
14 4
龙大吉
|
2天前
|
SQL Java 数据库连接
打破瓶颈：利用Java连接池技术提升数据库访问效率
在Java应用中，数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接，避免了频繁的连接建立和断开，显著提升了数据库访问效率。常见的连接池库包括HikariCP、C3P0和DBCP，它们提供了丰富的配置选项和强大的功能，帮助优化应用性能。
龙大吉
16 2
Codelinghu
|
21天前
|
SQL druid Java
JDBC和数据库连接池-两个工具类-JDBCUtilsByDruid和BasicDAO
JDBC和数据库连接池-两个工具类-JDBCUtilsByDruid和BasicDAO
Codelinghu
19 0
游客j4mujezz7vm7y
|
2月前
|
存储 SQL 监控
5-6|jdbc连接池
5-6|jdbc连接池
游客j4mujezz7vm7y
30 0
众所周知
|
3月前
|
SQL Java 数据库连接
Hibernate 是一款开源 ORM（对象关系映射）框架，封装了 JDBC，允许以面向对象的方式操作数据库，简化了数据访问层的开发。
Hibernate 是一款开源 ORM（对象关系映射）框架，封装了 JDBC，允许以面向对象的方式操作数据库，简化了数据访问层的开发。通过映射机制，它可以自动处理对象与数据库表之间的转换，支持主流数据库，提高了代码的可移植性和可维护性。其核心接口包括 SessionFactory、Session 和 Transaction 等，通过它们可以执行数据库的 CRUD 操作。配置方面，需在项目中引入 Hibernate 及数据库驱动依赖，并创建 `hibernate.cfg.xml` 配置文件来设置数据库连接和 Hibernate 行为参数。
众所周知
43 1
土木林森
|
3月前
|
JSON 数据格式 Java
化繁为简的魔法：Struts 2 与 JSON 联手打造超流畅数据交换体验，让应用飞起来！
【8月更文挑战第31天】在现代 Web 开发中，JSON 成为数据交换的主流格式，以其轻量、易读和易解析的特点受到青睐。Struts 2 内置对 JSON 的支持，结合 Jackson 库可便捷实现数据传输。本文通过具体示例展示了如何在 Struts 2 中进行 JSON 数据的序列化与反序列化，并结合 AJAX 技术提升 Web 应用的响应速度和用户体验。
土木林森
97 0
广州爱奇迪-伍华聪
|
4月前
|
开发框架 前端开发 JavaScript
基于SqlSugar的数据库访问处理的封装，支持.net FrameWork和.net core的项目调用
基于SqlSugar的数据库访问处理的封装，支持.net FrameWork和.net core的项目调用
广州爱奇迪-伍华聪
348 5
广州爱奇迪-伍华聪
|
4月前
|
开发框架 缓存 NoSQL
基于SqlSugar的数据库访问处理的封装，在.net6框架的Web API上开发应用
基于SqlSugar的数据库访问处理的封装，在.net6框架的Web API上开发应用
广州爱奇迪-伍华聪
67 3
广州爱奇迪-伍华聪
|
4月前
|
SQL 开发框架 关系型数据库
基于SqlSugar的数据库访问处理的封装，支持多数据库并使之适应于实际业务开发中
基于SqlSugar的数据库访问处理的封装，支持多数据库并使之适应于实际业务开发中
广州爱奇迪-伍华聪
377 1
广州爱奇迪-伍华聪
|
4月前
|
开发框架 前端开发 测试技术
基于SqlSugar的数据库访问处理的封装，支持多数据库并使之适应于实际业务开发中(2)
基于SqlSugar的数据库访问处理的封装，支持多数据库并使之适应于实际业务开发中(2)
广州爱奇迪-伍华聪
72 0

热门文章

最新文章

  • 1
    数据库中的Schema和Database的区别
  • 2
    RDS入门——Excel文件转存到RDS数据库实践
  • 3
    【大数据干货】数据进入阿里云数加-分析型数据库AnalyticDB（原ADS）的N种方法
  • 4
    客户端、服务器、数据库之间的时区转换
  • 5
    分布式关系型数据库服务 DRDS 提供全新规格实例
  • 6
    DataAccess通用数据库访问类，简单易用，功能强悍
  • 7
    JBPM5.3入门及SQLServer2008数据库转移
  • 8
    CentOS6.4下Mysql数据库的安装与配置
  • 9
    2011寒假-数据库学习笔记
  • 10
    数据库厂商提供的 Providers for ASP.NET
  • 1
    开源一个教学型分库分表示例项目 shardingsphere-jdbc-demo
    87
  • 2
    jdbc解析excel文件，批量插入数据至库中
    51
  • 3
    jdbc实现批量给多个表中更新数据（解析Excel表数据插入到数据库中）
    190
  • 4
    com.microsoft.sqlserver.jdbc.SQLServerException: 索引 7 超出范围。
    43
  • 5
    性能工具之JMeter JDBC Request 基础
    303
  • 6
    【Mybatis】从 JDBC 到 MyBatis
    189
  • 7
    Flink Connector JDBC已经被移到了一个独立的仓库
    48
  • 8
    DataWorks常见问题之hive jdbc加载数据错误如何解决
    89
  • 9
    Java的JDBC编程
    120
  • 10
    使用Mybatis与直觉用jdbc相比，哪个更有优势？
    94

    • 相关课程

    更多
  • 数据库的前世今生
  • 数据库核心概念
  • JDBC数据库开发入门
  • 数据库及SQL/MySQL基础
  • JDBC数据库开发进阶
  • 高校精品课-西安交通大学 -数据库理论与技术

    • 相关电子书

    更多
  • DTCC 2022大会集锦《云原生一站式数据库技术与实践》
  • 阿里云瑶池数据库精要2022版
  • 2022 DTCC-阿里云一站式数据库上云最佳实践

    • 相关实验场景

    更多
  • 自建数据库迁移到云数据库
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 云原生HTAP数据库，让你的交易和分析一库搞定
  • 快速体验PolarDB开源数据库
  • SQLServer数据库的创建
  • 手把手教你把IoT传感器数据存储到数据库
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月