JDBC05----事务与批处理

一. 事务的基本概念

1. 什么是事务

事务是不可分割的操作，每条sql语句都是一个事务；事务只对DML语句有效，对DQL无效。

2. 事务的ACID

• 原子性（Atomicity）
• 一致性（Consistency）
• 隔离性（Isolation）
• 持久性（Durability）

3. 假设这里有一个需求体现了事务

二. 批处理

1. 什么是批处理

一次性执行多条sql语句，允许多条语句一次性提交给数据库批量处理，比单独提交处理效率搞。

2. 批处理方法

addBatch(String)：添加需要批处理的SQL语句；

executeBatch()：执行批处理

3. 举例

（1）新建立一个类BatchTest

package com.test.jdbctest.dao.test;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;


import com.test.jdbctest.util.JDBCUtil;

public class BatchTest {
    public static void main(String args[]) {
        Connection connection=JDBCUtil.getConnection();
        String sql="insert into table1(name,age) values(?,?)";
        PreparedStatement ps;
        try {
            ps = connection.prepareStatement(sql);
            long begin=System.currentTimeMillis();
            for(int i=0;i<1000;i++) {
                ps.setString(1,"zs" );
                ps.setInt(2, 10);
                ps.executeUpdate();
            }
            long end=System.currentTimeMillis();
            long time=end-begin;
            System.out.println(time);
            JDBCUtil.close(connection, ps, null);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }

}

4481

倘若使用批处理：

note:需要在url中添加一个参数：

public static String url="jdbc:mysql://localhost:3306/test?rewriteBatchedStatements=true";

package com.test.jdbctest.dao.test;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;


import com.test.jdbctest.util.JDBCUtil;

public class BatchTest {
    public static void main(String args[]) {
        Connection connection=JDBCUtil.getConnection();
        String sql="insert into table1(name,age) values(?,?)";
        PreparedStatement ps;
        try {
            ps = connection.prepareStatement(sql);
            long begin=System.currentTimeMillis();
            for(int i=0;i<1000;i++) {
                ps.setString(1,"zs" );
                ps.setInt(2, 10);
                //添加到批处理
                ps.addBatch();
            }
            //执行批处理
            ps.executeBatch();
            long end=System.currentTimeMillis();
            long time=end-begin;
            System.out.println(time);
            JDBCUtil.close(connection, ps, null);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }

}

42

 

参考文献

https://ke.qq.com/course/339214