美文网首页
自定义JBDCUtils工具类

自定义JBDCUtils工具类

作者: mark_x | 来源:发表于2019-09-26 17:10 被阅读0次

使用java进行数据库操作时, 读表前后的步骤繁杂, 在读表前要进行注册驱动, 获得Connection对象等步骤, 在读表之后要进行资源的释放, 而且通用性不强, 为了简化步骤可以定义工具类, 通过调用静态方法简化代码。这里定义了JDBCUtils工具类, 功能主要有在静态代码块中加载读取配置文件, 注册驱动; 使用JBDCUtils.getConnection()方法获得Connection对象; 使用两个重载的close()方法进行资源释放。

注意: 一定要注意数据库加载地址的格式
最开始写成了下面这样:

 url = jdbc:mysql///db3

报错

java.sql.SQLException: No suitable driver found for url = jdbc:mysql///db3

mysql后面的冒号<:>丢了...
正确的写法:

 url = jdbc:mysql:///db3
// 或者完整格式
jdbc:mysql://localhost:3306/db3

测试用例

package cn.itcast.jdbc.demo4JDBCUtils;

import cn.itcast.utils.JDBCUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class UtilsDemo {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;

        try {
            conn = JDBCUtils.getConnection();
            stmt = conn.createStatement();
            // sql语句
            String sql_query = "SELECT * FROM account";
            rs = stmt.executeQuery(sql_query);

            int id = 0;
            String name = null;
            double salary = 0.0;

            while (rs.next()) {  // 依次读取每一行
                id = rs.getInt(1);  // 使用列索引
                name = rs.getString(2);
                salary = rs.getDouble(3);

                System.out.println(id + "--" + name + "--" + salary);
            }


        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtils.close(rs, stmt, conn);
        }
    }
}

JBDCUtils工具类

package cn.itcast.utils;

import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.sql.*;
import java.util.Properties;

/*
        作用:
            1. 注册驱动
                * 注册驱动整个程序运行阶段只需要执行一次, 不需要每次创建连接对象都执行
                  因此放在静态代码块中, 在JVM加载该工具类的时候执行一次
                * 配置文件读取也是只需要一次, 因此也放在静态代码块中
            2. 创建连接对象
            3. 释放资源
 */
public class JDBCUtils {
    // 静态变量域
    // 之所以设置全局变量是因为在静态代码块中读取文件, 在getConnection()中使用, 这样就不需要参数传递了
    // 设置成静态变量是因为getConnection是静态方法
    private static String url;
    private static String user;
    private static String password;
    private static String driver;

    static{
        try {
            // 获取配置文件
            // 创建Properties对象
            Properties pro = new Properties();

            // 加载配置文件
            // 找到配置文件
            ClassLoader classLoader = JDBCUtils.class.getClassLoader();
            // 通过类加载器查找配置文件, 得到路径
            String path = classLoader.getResource("pro.properties").getPath();
            // 注意load的参数是字节流或字符流, 使用路径创建字符流
            pro.load(new FileReader(path));

            url = pro.getProperty("url");  // // url = jdbc:mysql///db3
            user = pro.getProperty("user");
            password = pro.getProperty("password");
            driver = pro.getProperty("driver");

            // 注册驱动
            //Class.forName(driver);
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }


    public static Connection getConnection() throws SQLException {
        // 返回连接对象
        return DriverManager.getConnection(url, user, password);
    }

    // 释放资源
    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();
            }
        }
    }


    // 释放资源  重载没有ResultSet的情况
    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();
            }
        }
    }


}


配置文件pro.properties


url = jdbc:mysql://localhost:3306/db3
user = root
password = root
driver = com.mysql.jdbc.Driver

相关文章

网友评论

      本文标题:自定义JBDCUtils工具类

      本文链接:https://www.haomeiwen.com/subject/rrnructx.html