create table test_account(
		id int,
		name VARCHAR(15),
		money int
)
INSERT INTO test_account(id,name,money) values (1,'小明',100),(2,'小蓝',100);
select * from test_account;
BEGIN #开启事务
UPDATE test_account set money=money-500 where name='小明';
UPDATE test_account set money=money+500 where name='小蓝';
COMMIT #执行成功之后提交事务，使数据持久化
ROLLBACK  #回滚事务

2.JDBC简介

3.JDBC快速入门

A.基本步骤

B.代码

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

public class JDBCdemo {
    public static void main(String[] args) throws Exception {
       Class.forName("com.mysql.jdbc.Driver");
        String url= "jdbc:mysql://localhost:3306/atguigudb";
        String username = "root";
        String password = "root";
        Connection conn =
                DriverManager.getConnection(url, username,
                        password);
        String sql = "update test_account set money =2000 where id = 1";
        //4. 获取执行sql的对象 Statement
        Statement stmt = conn.createStatement();
        //5. 执行sq
        int count = stmt.executeUpdate(sql);//受影响的行数
        //6. 处理结果
        System.out.println(count);
        //7. 释放资源
        stmt.close();
        conn.close();

    }
}

图解：

4.连接数据库

5.事务管理

A.基本概念

B.实现代码:

/**
* JDBC API 详解：Connection
*/
public class JDBCDemo3_Connection {
   public static void main(String[] args) 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 sql1 = "update account set money =
3000 where id = 1";
       String sql2 = "update account set money =
3000 where id = 2";
       //4. 获取执行sql的对象 Statement
       Statement stmt = conn.createStatement();
       try {
           // ============开启事务==========
           conn.setAutoCommit(false);
           //5. 执行sql
            int count1 = stmt.executeUpdate(sql1);//
受影响的行数
           //6. 处理结果
           System.out.println(count1);
            int i = 3/0;
           //5. 执行sql
            int count2 = stmt.executeUpdate(sql2);//
受影响的行数
           //6. 处理结果
           System.out.println(count2);
           // ============提交事务==========
           //程序运行到此处，说明没有出现任何问题，则需求提
交事务
           conn.commit();
       } catch (Exception e) {
           // ============回滚事务==========
           //程序在出现异常时会执行到这个地方，此时就需要回
滚事务
           conn.rollback();
           e.printStackTrace();
       }
       //7. 释放资源
       stmt.close();
       conn.close();
  }
}

6.resultSet以及遍历数据库元素

A.基本概念

B. 代码：

/**
  * 执行DQL
  * @throws Exception
  */
@Test
public void testResultSet() 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);
    //6. 处理结果， 遍历rs中的所有数据
    /* // 6.1 光标向下移动一行，并且判断当前行是否有数据
        while (rs.next()){
            //6.2 获取数据 getXxx()
            int id = rs.getInt(1);
            String name = rs.getString(2);
            double money = rs.getDouble(3);
            System.out.println(id);
            System.out.println(name);
            System.out.println(money);
            System.out.println("--------------");
3.5 案例
需求：查询account账户表数据，封装为Account对象中，并且
存储到ArrayList集合中
代码实现
        }*/
    // 6.1 光标向下移动一行，并且判断当前行是否有数据
    while (rs.next()){
        //6.2 获取数据 getXxx()
        int id = rs.getInt("id");
        String name = rs.getString("name");
        double money = rs.getDouble("money");
        System.out.println(id);
        System.out.println(name);
        System.out.println(money);
        System.out.println("--------------");
   }
    //7. 释放资源
    rs.close();
    stmt.close();
    conn.close();
}

7.综合案例

/**
  * 查询account账户表数据，封装为Account对象中，并且存储
到ArrayList集合中
  * 1. 定义实体类Account
  * 2. 查询数据，封装到Account对象中
  * 3. 将Account对象存入ArrayList集合中
  */
@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<Account> list = new ArrayList<>();
  
    // 6.1 光标向下移动一行，并且判断当前行是否有数据
    while (rs.next()){
        Account account = new Account();
        //6.2 获取数据 getXxx()
3.6 PreparedStatement
PreparedStatement作用：
预编译SQL语句并执行：预防SQL注入问题
对上面的作用中SQL注入问题大家肯定不理解。那我们先对SQL注
入进行说明.
3.6.1 SQL注入
SQL注入是通过操作输入来修改事先定义好的SQL语句，用以达
到执行代码对服务器进行攻击的方法。
        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();
}

原文链接：https://blog.csdn.net/m0_68997646/article/details/128380850

THE END