JDBC

• 今日内容
• • JDBC
  • 抽取JDBC工具类 ：JDBCUtils
  • JDBC控制事务

今日内容

1. JDBC基本概念
2. 快速入门
3. 对JDBC中各个接口和类的详解

JDBC

1. 概念：Java DataBase Connectivity java数据库连接，java语言操作数据库
   * JDBC本质：其实是官方(sun公司)定义的一套操作所有关系型数据库的规则，既接口。哥哥数据库厂商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口JDBC编程，真正执行的代码是jar包中的实现类

2. 快速入门：
    * 步骤：
        1. 导入jar：mysql-connector-java-8.0.25.jar
           1. 复制mysql-connector-java-8.0.25.jar到lib下
           2. 右键-->add as Library
        2. 注册驱动
            Class.forName("com.mysql.jc.jdbc.Driver"); 
        3. 获取数据库连接对象Connection
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/DataBaseName?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC","root","1234"); 
        4. 定义SQL
            String sql = "update accout set balance = 500 where id = 1"; 
        5. 获取执行sql对象Statement
            Statement stmt = conn.createStatement();
        6. 执行sql ，接受返回的对象
            int count = stmt.executeUpdate(sql); 
        7. 处理结果
            System.out.println(count);
        8. 释放资源 
            stmt.close();
            conn.close();

3. 详解各个对象
    1. DriverManager: 驱动管理对象
        * 功能：
            1. 注册驱动：
                static void registerDriver(Driver driver):注册与给定的驱动程序
                写代码时：Class.forName("com.mysql.cj.jdbc.Driver");
                通过查看源码：发现在com.mysql.cj.jdbc.Driver类中有静态代码块：
                    static {
                        try {
                            java.sql.DriverManager.registerDriver(new Driver());
                        } catch (SQLException E) {
                            throw new RuntimeException("Can't register driver!");
                        }
                    }
                **注意**：mysql5之后注册驱动可以省略
            2. 获取数据库连接  
                * 方法：static Connection getConnection(String url,String user,String password)
               * 参数：
                   * url：指定连接的路径
                       * 语法：jdbc:mysql://ip地址(域名):端口号/数据库名称
                       * 例如：jdbc:mysql://localhost:3306/DataBaseName?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC
                       * 细节：如果连接的是本地mysql数据库，且默认端口为3306，则url可以写为：jdbc:mysql:///数据库名称
                   * user：用户名
                   * password：密码 
    2. Connection:  数据库连接对象
        1. 功能：
            1. 获取执行sql的对象
                * Statement createStatement()
                * PrepareStatement prepareStatement(String sql)  
            2. 管理事务：
                * 开启事务：void setAutoCommit(boolean autoCommit):该方法设置参数为false，即开启事务
                * 提交事务：commit()
                * 回滚事务: rollback()
    3. Statement:  执行sql的对象
       1. 执行sql
            1. boolean execute(String sql): 可以执行任意的SQL语句
            2. int executeUpdate(String sql): 执行DML(insert，update，delete)语句，DDL(create,alter,drop)语句
                * 返回值：影响的行数  
            3. ResultSet executeQuery(String sql): 执行DQL(select)语句 
        2. 练习：
            1. accout表 添加一条记录
            2. account表 修改记录
            3. account表 删除一条记录  
    4. ResultSet：结果集对象，封装查询结果
       1. boolean next(): 右边向下移动一行，判读当前行是否是最后一行末尾，是否有数据，是false，不是true
       2.  getXxx(): 获取数据
            * Xxx代表数据类型   如：int getInt()  String  getString() 
                * int :代表列的编号，从1开始
                * String：代表列名称 
        * **注意**：
            * 使用步骤：
                1. 游标向下移动一行
                2. 判断是否有数据
                3. 获取数据  
    5. PreparedStatement：执行sql的对象   
        1. sql注入问题: 在拼接sql时有一些sql的特使关键字参与字符串的拼接，会造成安全问题
           1. 输入任意用户与密码 
           2. sql：select * from user where username = 'sss' and password = 'adsa' or 'a' = 'a' 
        2. 解决：使用PreparedStatement对象  
        3. 预编译sql：参数？做占位符 
           1. 步骤：
              1. 导入jar：mysql-connector-java-8.0.25.jar
              2. 注册驱动
              3. 获取数据库连接对象Connection
              4. 定义SQL
                * 注意：sql参数？做占位符 
                * 如：select * from user where username = ? and password = ?; 
              5. 获取执行sql对象PreparedStatement
                * 调用：Connevtion.prepareStatement(String sql)
              6. 给？赋值：
                 1. 方法：setXxx(参数1，参数2)
                    * 参数1：？的位置标号，从一开始
                    * 参数2：？的值   
              7. 执行sql ，接受返回的对象
              8. 处理结果
              9. 释放资源
            5. 注意：后期都用prepareStatement

抽取JDBC工具类 ：JDBCUtils

* 目的：简化书写
* 分析：
    1. 注册驱动也抽取
    2. 抽取一个方法获取连接对象
        1. 需求：不想传递参数，还要保证工具类的通用性
        2. 解决：配置文件
            jdbc.properties 
                url=
                user=
                password=
    3. 抽取一个方法去释放资源

代码实现

        static {
        //读取资源文件
        try {
            //1.创建Properties集合类
            Properties pro = new Properties();
            //获取src下路径文件的方式 Classloader
            ClassLoader classLoader = JdbcUtils.class.getClassLoader();
            URL res =  classLoader.getResource("jdbc.properties");
            assert res != null;
            String path = res.getPath();
            System.out.println(path);
            //2.加载文件
            pro.load(new FileReader(path));
            //3.获取数据，赋值
            url = pro.getProperty("url");
            user = pro.getProperty("user");
            password = pro.getProperty("password");
            driver = pro.getProperty("driver");
            //4.注册驱动
            Class.forName(driver);
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

* 练习：
    * 需求：
        1. 通过键盘录入用户名和密码
        2. 判断用户是否登入成功
    * 步骤：
        1. 创建表 user
            CREATE table USER(
                id INT PRIMARY KEY AUTO_INCREMENT ,
                username VARCHAR (32),
                PASSWORD VARCHAR (32)
            ); 
            INSERT INTO user VALUES (NULL ,'zhangsan',"123");
            INSERT INTO user VALUES (NULL ,'lisi',"234");

代码

    public boolean login2(String username,String password){
        if (username == null && password == null){
            return false;
        }
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        //连接数据库来判断是否成功
        try {
            conn = JdbcUtils.getConnection();
            //定义SQL
            String sql = "select * from user where username = ? and PASSWORD = ?";
            //获取执行sql对象PreparedStatement
            pstmt = conn.prepareStatement(sql);
            //给？赋值
            pstmt.setString(1,username);
            pstmt.setString(2,password);
            //执行sql ，接受返回的对象
            rs = pstmt.executeQuery();
            //处理结果
            return rs.next();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            //释放资源
            JdbcUtils.close(rs,pstmt,conn);
        }
        return false;
    }
}

JDBC控制事务

1. 事务：一个包含多个步骤的业务操作。如果这个事务操作被事务管理，则这些步骤要么同时成功，要么同时失败
2. 操作：
   1. 开启事务
   2. 提交事务
   3. 回滚事务
3. 使用Connection对象来管理事务
   1. 开启事务：setAutoCommit(boolean autoCommit):调用该方法设置参数为false及开启事务
        * 在sql之前开启事务
   2. 提交事务：commit() :
        * 当所有sql都执行完提交事务 
   3. 回滚事务: rollback()
        * 在catch中回滚事务 

代码

    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt1 = null;
        PreparedStatement pstmt2 = null;
        ResultSet rs = null;
        try {
            //获取连接
            conn = JdbcUtils.getConnection();
            //开起事务
            conn.setAutoCommit(false);
            //定义SQL
            String sql1 = "update account set balance = balance - ? where id = ?";
            String sql2 = "update account set balance = balance + ? where id = ?";
            assert false;
            //获取执行sql对象PreparedStatement
            pstmt1 = conn.prepareStatement(sql1);
            pstmt2 = conn.prepareStatement(sql2);
            //给？赋值
            pstmt1.setDouble(1, 500);
            pstmt1.setInt(2, 1);
            pstmt2.setDouble(1, 500);
            pstmt2.setInt(2, 2);
            //执行sql ，接受返回的对象
            pstmt1.executeUpdate();
            pstmt2.executeUpdate();
            //提交事务
            conn.commit();
        }catch (Exception e){
            //回滚事务
            try {
                if (conn != null){
                    conn.rollback();
                }
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }finally {
            JdbcUtils.close(null,pstmt1,conn);
            JdbcUtils.close(null,pstmt2,null);
        }
    }