JDBC（五）批处理操作、大数据类型、自动获取主键

1.批处理操作

批量操作(batch):

当需要成批插入或者更新记录时。可以采用Java的批量更新机制.
这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率.
JDBC的批量处理语句包括下面两个方法：

addBatch(String sql)：添加需要批量处理的SQL语句或是参数；
executeBatch（）；执行批量处理语句；

通常我们会遇到两种批量执行SQL语句的情况：

• 1.多条SQL语句的批量处理； :Statement
• 2.一个SQL语句的批量传参； :PreparedStatement

需求:同时向t_student表,插入1000条数据。在JDBC中,MySQL不支持批量操作。

public class BatchTest extends TestCase {

    // 耗时：1022
    public void testInsertByStatementBatch() throws Exception {
        Connection conn = JdbcUtil.getConn();
        Statement st = conn.createStatement();
        long begin = System.currentTimeMillis();
        for (int i = 0; i < 1000; i++) {
            String sql = "INSERT INTO t_student (NAME, age) VALUES ('name" + i + "'," + i + ");";

            st.addBatch(sql);
            if (i % 200 == 0) {
                System.out.println("sql:" + sql);
                st.executeBatch();// 执行批量处理
                st.clearBatch();// 清除批量处理中的信息
            }
        }
        System.out.println("耗时：" + (System.currentTimeMillis() - begin));
        JdbcUtil.close(conn, st, null);
    }

    // 耗时：1045
    public void testInsertByPrepareStatementBatch() throws Exception {
        Connection conn = JdbcUtil.getConn();
        String sql = "INSERT INTO t_student (NAME, age) VALUES ('?',?);";
        PreparedStatement ps = conn.prepareStatement(sql);
        long begin = System.currentTimeMillis();
        for (int i = 0; i < 1000; i++) {
            ps.setString(1, "name" + i);
            ps.setInt(2, i);
            ps.addBatch();
            if (i % 200 == 0) {
                System.out.println("sql:" + sql);
                ps.executeBatch(); // 执行批量处理
                ps.clearBatch(); // 清除批量处理中的信息
                ps.clearParameters();// 清除批量处理中的参数
            }
        }
        System.out.println("耗时：" + (System.currentTimeMillis() - begin));
        JdbcUtil.close(conn, ps, null);
    }

}

---

Statement 批处理： 一次性可以执行多条sql语句，需要编译多次。

应用场景：系统初始化 (创建表，创建数据等)
添加sql语句，st.addBatch(sql) --添加sql语句
批量处理sql语句，int[] st.executeBatch()
清除缓存： st.clearBatch();

---

PreparedStatement 批处理： 执行一条sql语句，编译一次，执行sql语句的参数不同。

应用场景：表数据初始化
添加批量参数：psmt.addBatch() --添加实际参数，执行之前，需要执行psmt.setXxx()设置实际参数
执行批处理：int[] psmt.executeBatch()
清除缓存：pstm.clearBatch();

2.大数据类型操作

大数据类型1.png 大数据类型2.png

BLOB系列是大的二进制类型,允许存储(255个字节到4G).二进制类型存储二进制数据(图像,音频,视频等);
在开发中,对于图片,音频,视频,我们往往是不会直接存储到数据库中的.我们把图片,音频,视频存储到服务端磁盘中,然后在数据库表中存储其存储的位置.

id          name        age          headImg
--------------------------------------------------------
1           萧峰        30           /upload/qiao.png
2           阿朱        18           /upload/az.png

存储图片.png

TEXT系列,是大的VARCHAR类型.
一般的,存储文字过多的博客,书籍内容等.
TEXT系列的类型和VARCHAR仅仅只是在MySQL中数据类型不一样,在Java代码中都对应着String数据类型。

3.获取自动生成的主键

为什么需要获取主键: 分析一个案例:

在线注册案例:
1:进入注册页面
2:处理注册功能:在数据库表中插入一条数据.
3:进入信息完善页面.
4:处理完善个人信息:在数据库表中更新一条数据.

获取自动生成的主键案例.png

---

如何在JDBC中保存数据的时候获取自动生成的主键呢?

• Statement方式:

1.执行SQL:

int executeUpdate(String sql,int autoGeneratedKeys)
//参数:autoGeneratedKeys,是否需要返回自动生成的主键.常量值:Statement.RETURN_GENERATED_KEYS.

2.getGeneratedKeys

ResultSet getGeneratedKeys():获取自动生成的主键

• PreparedStatement方式:

PreparedStatement prepareStatement(String sql, int autoGeneratedKeys)  :
//创建PreparedStatement对象,病指定是否需要返回生成的主键. 常量值:Statement.RETURN_GENERATED_KEYS

单据和单据明细:

Hibernate中可以自动返回

public class GeneratedKeysTest extends TestCase {

    
    public void testInsertByStatemen() throws Exception {
        String sql = "INSERT INTO t_student (NAME, age) VALUES ('jarry',20)";
        Connection conn = JdbcUtil.getConn();
        Statement st = conn.createStatement();
        st.executeUpdate(sql, Statement.RETURN_GENERATED_KEYS);
        ResultSet rs=st.getGeneratedKeys();
        if(rs.next()){
            Long id=rs.getLong(1);
            System.out.println(id);
        }
        JdbcUtil.close(conn, st, rs);
    }

    
    public void testInsertByPrepareStatement() throws Exception {
        Connection conn = JdbcUtil.getConn();
        String sql = "INSERT INTO t_student (NAME, age) VALUES ('?',?);";
        PreparedStatement ps = conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
        ps.setString(1, "xiaohua");
        ps.setInt(2, 80);
        ps.executeUpdate();
        ResultSet rs=ps.getGeneratedKeys();
        if(rs.next()){
            Long id=rs.getLong(1);
            System.out.println(id);
        }
        JdbcUtil.close(conn, ps, rs);
    }

}