美文网首页
自定义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