Java 程序连接数据库服务端程序的助手类

username = 用户名
password = 密码
jdbcURL = jdbc:mysql://IP地址:端口号/数据库名?useUnicode=true&useSSL=false&amp&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true
jdbcDriver = com.mysql.cj.jdbc.Driver

import lombok.extern.slf4j.Slf4j;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

/**
 * Java 程序与数据库服务端程序的连接句柄
 *
 * @作者 hapday
 * @author hapday
 * @时间 2023-04-13
 * @time 2023-04-13
 * @起始于 0.1.0
 * @since 0.1.0
 */
@Slf4j
public class JavaDatabaseConnectivityHandle {

    /**
     * 获取 Java 程序与数据库服务端程序的连接
     * @return 【Java 程序与数据库服务端程序的连接】对象
     *
     * <note>
     *     前置条件：在【类路径（classpath）】目录中增加 jdbc.properties 配置文件。
     * </note>
     *
     * @作者 hapday
     * @author hapday
     * @时间 2023-04-13
     * @time 2023-04-13
     * @起始于 0.1.0
     * @since 0.1.0
     */
    public Connection getDatabaseConnection () {
        InputStream databaseConfigInputStream = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties") ; // 从【类路径】中获取配置文件
        Properties databaseConfigProperties = new Properties();
        try {
            databaseConfigProperties.load(databaseConfigInputStream);   // 加载【数据库】配置文件
        } catch (IOException e) {
            log.error("加载【数据库配置文件】失败！", e);

            return null;
        }

        String username = databaseConfigProperties.getProperty("username");
        String password = databaseConfigProperties.getProperty("password");
        String jdbcURL = databaseConfigProperties.getProperty("jdbcURL");
        String jdbcDriver = databaseConfigProperties.getProperty("jdbcDriver");

        /**
         * 第一步：注册驱动
         */
        try {
            Class.forName(jdbcDriver);
        } catch (ClassNotFoundException e) {
            log.error("没有找到数据库的驱动！", e);

            return null;
        }

        /**
         * 第二步：获取连接
         */
        Connection connection = null;
        try {
            connection = DriverManager.getConnection(jdbcURL, username, password);
        } catch (SQLException e) {
            log.error("获取 Java 程序与数据库服务端程序的连接对象 - 失败！", e);

            return null;
        }

        return connection;
    } ;

    /**
     * 关闭 Java 程序与数据库服务端程序的连接
     * @param connection 【Java 程序与数据库服务端程序的连接】对象
     * @return 成功返回真，失败返回假。
     *
     * @作者 hapday
     * @author hapday
     * @时间 2023-04-13
     * @time 2023-04-13
     * @起始于 0.1.0
     * @since 0.1.0
     */
    public boolean closeDatabaseConnection ( Connection connection ) {
        if (null == connection)
            return false;

        try {
            if (connection.isClosed())
                return true;
        } catch (SQLException e) {
            log.error("判断 Java 程序与数据库服务端程序的连接是否已关闭 - 失败！", e);

            return false;
        }

        try {
            connection.close();
        } catch (SQLException e) {
            log.error("关闭 Java 程序与数据库服务端程序的连接 - 失败！", e);

            return false;
        }

        return true ;
    }

}