JDBC笔记

JDBC

1. JDBC概述
- 1.1 JDBC本质
- 1.2 JDBC好处
2. JDBC编写步骤
3. API详解
- 3.1 DriverManager
- 3.2 Connection
- 3.3 Statement
- 3.4 ResultSet
- 3.5 PreparedStatement

1. JDBC概述

在开发中我们使用的是java语言，那么势必要通过java语言操作数据库中的数据。这就是接下来要学习的JDBC。

1.1 JDBC本质

官方（sun公司）定义的一套操作所有关系型数据库的规则，即接口
各个数据库厂商去实现这套接口，提供数据库驱动jar包
我们可以使用这套接口（JDBC）编程，真正执行的代码是驱动jar包中的实现类

1.2 JDBC好处

各数据库厂商使用相同的接口，Java代码不需要针对不同数据库分别开发
可随时替换底层数据库，访问数据库的Java代码基本不变

以后编写操作数据库的代码只需要面向JDBC（接口），操作哪个关系型数据库就需要导入该数据库的驱动包，如需要操作MySQL数据库，就需要再项目中导入MySQL数据库的驱动包

2. JDBC编写步骤

创建工程，导入驱动jar包

注册驱动

Class.forName("com.mysql.jdbc.Driver");

获取连接
```
Connection conn = DriverManager.getConnection(url, username, password);
```
Java代码需要发送SQL给MySQL服务端，就需要先建立连接
定义SQL语句
```
String sql =  “update…” ;
```
获取执行SQL对象

执行SQL语句需要SQL执行对象，而这个执行对象就是PreparedStatement 对象
```
PreparedStatement psmt = conn.prepareStatement(sql);
```
设置参数值

上面的sql语句中参数使用 ? 进行占位，在之前要设置这些 ? 的值
```
psmt.setString(1,"B19030122");
psmt.setString(2,"'' or '1' = '1'");
```
执行SQL
```
ResultSet rs = psmt.executeQuery();
```
处理返回结果
释放资源

案例：

package JDBC;

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


public class connect {
    public static void main(String[] args) throws Exception {
        //1.注册驱动
        Class.forName("com.mysql.jdbc.Driver");

        //2.获取连接
        String url = "jdbc:mysql://localhost:3306/test";
        String username = "root";
        String password = "123456";
        Connection conn = DriverManager.getConnection(url,username,password);

        //3.定义sql
        String sql = "update admin_login_k set admin_id = 'B19030122' where admin_id = 'B19030121'";

        //4.获得执行sql语句对象
        Statement stmt = conn.createStatement();

        //5.执行sql，返回影响行数
        int count = stmt.executeUpdate(sql);

        //6.处理结果
        System.out.println(count);

        //7.释放资源
        stmt.close();
        conn.close();
    }
}

3. API详解 3.1 DriverManager

DriverManager（驱动管理类）作用：

注册驱动
获取数据库连接

3.1.1.注册驱动

static void registerDriver(Driver driver);

registerDriver方法是用于注册驱动的，之前做的入门案例并不是这样写的。而是如下实现

Class.forName("com.mysql.jdbc.Driver");

我们查询MySQL提供的Driver类，看它是如何实现的，源码如下：

在该类中的静态代码块中已经执行了 DriverManager 对象的 registerDriver() 方法进行驱动的注册了，那么我们只需要加载 Driver 类，该静态代码块就会执行。而 Class.forName("com.mysql.jdbc.Driver"); 就可以加载 Driver 类。

提示：

MySQL 5之后的驱动包，可以省略注册驱动的步骤
自动加载jar包中META-INF/services/java.sql.Driver文件中的驱动类

3.1.2.获取数据库连接

参数说明：

url ：连接路径
语法：jdbc:mysql://ip地址(域名):端口号/数据库名称?参数键值对1&参数键值对2…

示例：jdbc:mysql://127.0.0.1:3306/db1

细节：
- 如果连接的是本机mysql服务器，并且mysql服务默认端口是3306，则url可以简写为：jdbc:mysql:///数据库名称?参数键值对
- 配置 useSSL=false 参数，禁用安全连接方式，解决警告提示
user ：用户名
poassword ：密码

3.2 Connection

Connection（数据库连接对象）作用：

获取执行 SQL 的对象
管理事务

3.2.1.获取执行 SQL 的对象

普通执行SQL对象
```
Statement createStatement()
```
预编译SQL的执行SQL对象：防止SQL注入
```
PreparedStatement  prepareStatement(sql)
```

3.2.2.管理事务

MySQL事务管理的操作：

开启事务： BEGIN; 或者 START TRANSACTION;
提交事务： COMMIT;
回滚事务： ROLLBACK;

MySQL默认是自动提交事务

JDBC事务管理的方法

Connection几口中定义了3个对应的方法：

开启事务

conn.setAutoCommit(false);

参与autoCommit 表示是否自动提交事务，true表示自动提交事务，false表示手动提交事务。而开启事务需要将该参数设为为false

提交事务

conn.commit();

回滚事务

conn.rollback();

案例：使用try-catch语句，抛出异常则回滚

package JDBC;

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


public class connect_transaction {
    public static void main(String[] args)  throws  Exception{
        Class.forName("com.mysql.jdbc.Driver");

        String url = "jdbc:mysql://localhost:3306/test";
        String username = "root";
        String password = "123456";
        Connection conn = DriverManager.getConnection(url,username,password);

        String sql = "update admin_login_k set admin_id = 'B19030122' where admin_id = 'B19030121'";

        Statement stmt = conn.createStatement();

        //开启事务
        conn.setAutoCommit(false);
        try {
            int count = stmt.executeUpdate(sql);

            //增加异常
            int i = 3/0;

            //提交事务
            conn.commit();
        } catch (Exception throwables) {
        //回滚事务
            conn.rollback();

            throwables.printStackTrace();
        }

        stmt.close();
        conn.close();
    }
}

3.3 Statement

Statement对象的作用就是用来执行SQL语句！而针对不同类型的SQL语句使用的方法也不一样

执行DDL、DML语句

//执行DML,返回影响的行数
//执行DDL，执行成果也可能返回0
int count = stmt.executeUpdate(sql);

//1. 注册驱动
    //Class.forName("com.mysql.jdbc.Driver");
    //2. 获取连接：如果连接的是本机mysql并且端口是默认的 3306 可以简化书写
    String url = "jdbc:mysql:///db1?useSSL=false";
    String username = "root";
    String password = "1234";
    Connection conn = DriverManager.getConnection(url, username, password);
    //3. 定义sql
    String sql = "update account set money = 3000 where id = 1";
    //4. 获取执行sql的对象 Statement
    Statement stmt = conn.createStatement();
    //5. 执行sql
    int count = stmt.executeUpdate(sql);//执行完DML语句，受影响的行数
    //6. 处理结果
    //System.out.println(count);
    if(count > 0){
        System.out.println("修改成功~");
    }else{
        System.out.println("修改失败~");
    }
    //7. 释放资源
    stmt.close();
    conn.close();

执行DQL语句

//返回：ResultSet结果集对象
Result executeQuery(sql)

//1. 注册驱动
    //Class.forName("com.mysql.jdbc.Driver");
    //2. 获取连接：如果连接的是本机mysql并且端口是默认的 3306 可以简化书写
    String url = "jdbc:mysql:///db1?useSSL=false";
    String username = "root";
    String password = "1234";
    Connection conn = DriverManager.getConnection(url, username, password);
    //3. 定义sql
    String sql = "drop database db2";
    //4. 获取执行sql的对象 Statement
    Statement stmt = conn.createStatement();
    //5. 执行sql
    int count = stmt.executeUpdate(sql);//执行完DDL语句，可能是0
    //6. 处理结果
    System.out.println(count);

    //7. 释放资源
    stmt.close();
    conn.close();

3.4 ResultSet

ResultSet（结果集对象）作用：

封装了SQL查询语句的结果。

而执行了DQL语句后就会返回该对象，对应执行DQL语句的方法如下：

ResultSet  executeQuery(sql)：执行DQL 语句，返回 ResultSet 对象

那么我们就需要从 ResultSet 对象中获取我们想要的数据。ResultSet 对象提供了操作查询结果数据的方法，如下：

boolean next()

将光标从当前位置向前移动一行
判断当前行是否为有效行

方法返回值说明：

true ：有效航，当前行有数据
false ：无效行，当前行没有数据

xxx getXxx(参数)：获取数据

xxx : 数据类型；如： int getInt(参数) ；String getString(参数)
参数
int类型的参数：列的编号，从1开始
String类型的参数：列的名称

package JDBC;

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


public class StatementDML {
    public static void main(String[] args) throws Exception{
        //1.注册驱动
        Class.forName("com.mysql.jdbc.Driver");

        //2.获取连接
        String url = "jdbc:mysql://localhost:3306/test";
        String username = "root";
        String password = "123456";
        Connection conn = DriverManager.getConnection(url,username,password);

        //3.写SQL对象
        String sql = "select * from student";

        //4.获取执行sql对象
        Statement stmt = conn.createStatement();

        //5.执行sql，返回结果集
        ResultSet rs = stmt.executeQuery(sql);

        //6.处理结果
        //光标移动
        while(rs.next()){
            //获取数据
            System.out.print(rs.getString(1)+" ");
            System.out.print(rs.getString(2)+" ");
            System.out.print(rs.getString(3)+" ");
            System.out.println();
        }

        System.out.println("---------------------");
        //重新获取数据集，因为光标已经到最低部
       rs = stmt.executeQuery(sql);
        //光标移动
        while(rs.next()){
            //获取数据
            System.out.print(rs.getString("id")+" ");
            System.out.print(rs.getString("name")+" ");
            System.out.print(rs.getString("grade")+" ");
            System.out.println();
        }

        //7.关闭资源
        stmt.close();
        conn.close();
    }
}

@Test
public void testResultSet2() throws  Exception {
    //1. 注册驱动
    //Class.forName("com.mysql.jdbc.Driver");
    //2. 获取连接：如果连接的是本机mysql并且端口是默认的 3306 可以简化书写
    String url = "jdbc:mysql:///db1?useSSL=false";
    String username = "root";
    String password = "1234";
    Connection conn = DriverManager.getConnection(url, username, password);

    //3. 定义sql
    String sql = "select * from account";

    //4. 获取statement对象
    Statement stmt = conn.createStatement();

    //5. 执行sql
    ResultSet rs = stmt.executeQuery(sql);

    // 创建集合
    List list = new ArrayList<>();
   
    // 6.1 光标向下移动一行，并且判断当前行是否有数据
    while (rs.next()){
        Account account = new Account();

        //6.2 获取数据  getXxx()
        int id = rs.getInt("id");
        String name = rs.getString("name");
        double money = rs.getDouble("money");

        //赋值
        account.setId(id);
        account.setName(name);
        account.setMoney(money);

        // 存入集合
        list.add(account);
    }

    System.out.println(list);

    //7. 释放资源
    rs.close();
    stmt.close();
    conn.close();
}

3.5 PreparedStatement

PreparedStatement作用：

预编译SQL语句并执行：预防SQL注入问题

3.5.1 SQL注入

SQL注入是通过操作输入来修改事先定义好的SQL语句，用以达到执行代码对服务器进行攻击的方法。

3.5.2 代码模拟SQL注入问题

@Test
public void testLogin() throws  Exception {
    //2. 获取连接：如果连接的是本机mysql并且端口是默认的 3306 可以简化书写
    String url = "jdbc:mysql:///db1?useSSL=false";
    String username = "root";
    String password = "1234";
    Connection conn = DriverManager.getConnection(url, username, password);

    // 接收用户输入 用户名和密码
    String name = "sjdljfld";
    String pwd = "' or '1' = '1";
    String sql = "select * from tb_user where username = '"+name+"' and password = '"+pwd+"'";
    // 获取stmt对象
    Statement stmt = conn.createStatement();
    // 执行sql
    ResultSet rs = stmt.executeQuery(sql);
    // 判断登录是否成功
    if(rs.next()){
        System.out.println("登录成功~");
    }else{
        System.out.println("登录失败~");
    }

    //7. 释放资源
    rs.close();
    stmt.close();
    conn.close();
}

上面代码是将用户名和密码拼接到sql语句中，拼接后的sql语句如下

select * from tb_user where username = 'sjdljfld' and password = ''or '1' = '1'

从上面语句可以看出条件 username = 'sjdljfld' and password = '' 不管是否满足，而 or 后面的 '1' = '1' 是始终满足的，最终条件是成立的，就可以正常的进行登陆了

3.5.3 PreparedStatement用法

解决SQL注意问题：

 @Test
public void testPreparedStatement() throws  Exception {
    //2. 获取连接：如果连接的是本机mysql并且端口是默认的 3306 可以简化书写
    String url = "jdbc:mysql:///db1?useSSL=false";
    String username = "root";
    String password = "1234";
    Connection conn = DriverManager.getConnection(url, username, password);

    // 接收用户输入 用户名和密码
    String name = "zhangsan";
    String pwd = "' or '1' = '1";

    // 定义sql
    String sql = "select * from tb_user where username = ? and password = ?";
    // 获取pstmt对象
    PreparedStatement pstmt = conn.prepareStatement(sql);
    // 设置？的值
    pstmt.setString(1,name);
    pstmt.setString(2,pwd);
    // 执行sql
    ResultSet rs = pstmt.executeQuery();
    // 判断登录是否成功
    if(rs.next()){
        System.out.println("登录成功~");
    }else{
        System.out.println("登录失败~");
    }
    //7. 释放资源
    rs.close();
    pstmt.close();
    conn.close();
}

3.5.4 PreparedStatement优势

PreparedStatement 好处：

预编译SQL，性能更高
防止SQL注入：将敏感字符进行转义

Java代码操作数据库流程如图所示：

将sql语句发送到MySQL服务器端
MySQL服务端会对sql语句进行如下操作
- 检查SQL语句
  
  检查SQL语句的语法是否正确。
- 编译SQL语句。将SQL语句编译成可执行的函数。
  
  检查SQL和编译SQL花费的时间比执行SQL的时间还要长。如果我们只是重新设置参数，那么检查SQL语句和编译SQL语句将不需要重复执行。这样就提高了性能。
- 执行SQL语句
在获取PreparedStatement对象时，将sql语句发送给mysql服务器进行检查，编译（这些步骤很耗时）
执行时就不用再进行这些步骤了，速度更快
如果sql模板一样，则只需要进行一次检查、编译

JDBC笔记

Java相关栏目本月热门文章