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

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

2019-04-16 583

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

微信关注我们

原文链接：https://yq.aliyun.com/articles/698703

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

MyBatis 映射器

ps 一个用于生成MyBatis配置文件的插件 mybatis-generator使用方法呢, 是加入maven插件中然后执行相关命令可以实现自动生成MyBatis配置文件自动映射首先编写无参的javabean package com.ming.MyBatis.POJO; /** * @author ming */ public class Role { private int id; private String roleName; private String note; public Role(){ } /** * @param id */ public void setId(int id) { this.id = id; } /** * @param roleName */ public void setRole_name(String roleName) { this.roleName = roleName; } /** * @param note */ public void setNote(String note) { this.note = note; } /**...

2019-04-17

566

上个月，学习群里的 S 同学问了个题目，大意可理解为列表降维，例子如下： oldlist = [[1, 2, 3], [4, 5]] # 想得到结果： newlist = [1, 2, 3, 4, 5] 原始数据是一个二维列表，目的是获取该列表中所有元素的具体值。从抽象一点的角度来理解，也可看作是列表解压或者列表降维。这个问题并不难，但是，怎么写才比较优雅呢？ # 方法一，粗暴拼接法： newlist = oldlist[0] + oldlist[1] 这种方法简单粗暴，需要拼接什么内容，就取出来直接拼接。然而，如果原列表有很多子列表，则这个方法就会变得繁琐了。我们把原问题升级一下：一个二维列表包含 n 个一维列表元素，如何优雅地把这些子列表拼成一个新的一维列表？方法一的做法需要写 n 个对象，以及 n - 1 次拼接操作。当然不可行。下面看看方法二： # 方法二，列表推导式： newlist = [i for j in range(len(oldlist)) for i in oldlist[j]] 这个表达式中出现了两个 for 语句，在第一个 for 语句中，我们先取出原...

2019-04-17

509

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。