jdbc 与 mysql 连接 - Blod及批量数据处理

2024-02-19 15:58

本文主要是介绍jdbc 与 mysql 连接 - Blod及批量数据处理,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Blob 类型的数据操作

package com.atguigu5.blob;import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;import org.junit.Test;import com.atguigu3.bean.Customer;
import com.atguigu3.util.JDBCUtils;/*** 测试使用 PreparedStatement 操作 Blob 类型的数据* */
public class BlobTest {// 向数据表 customers 中插入 Blob 类型的字段@Testpublic void testInsert1() throws Exception {Connection conn = JDBCUtils.getConnection();String sql = "insert into customers(name,email,birth,photo)values(?,?,?,?)";PreparedStatement ps = conn.prepareStatement(sql);ps.setObject(1, "李阿豪");ps.setObject(2,"li@qq.com");ps.setObject(3, "1992-09-08");// 操纵 Blob 类型的变量FileInputStream is = new FileInputStream(new File("壁纸3.jpg"));ps.setBlob(4, is);ps.execute();is.close();JDBCUtils.closeResource(conn, ps);}// 向数据表 customers 中插入 Blob 类型的字段@Testpublic void testInsert2() throws Exception {Connection conn = JDBCUtils.getConnection();String sql = "insert into customers(name,email,birth,photo)values(?,?,?,?)";PreparedStatement ps = conn.prepareStatement(sql);ps.setObject(1, "元昊");ps.setObject(2,"yuanhao@qq.com");ps.setObject(3, "1992-09-08");// 操纵 Blob 类型的变量FileInputStream is = new FileInputStream(new File("壁纸5.jpg"));ps.setBlob(4, is);ps.execute();is.close();JDBCUtils.closeResource(conn, ps);// 在 mysql 下的 my.ini 文件尾添加: max_allowed_packet=16M// 完成后,"此电脑" - "管理" - "服务和应用程序" - "服务" - "MySQL" - "重新启动"// 完成操作后,就可以上传大于 1M 的图片到 MySQL 了。}// 向数据表 customers 中修改 Blob 类型的字段 @Testpublic void testUpdate() throws Exception {Connection conn = JDBCUtils.getConnection();String sql = "update customers set photo = ? where id = ?";PreparedStatement ps = conn.prepareStatement(sql);// 填充占位符// 操纵 Blob 类型的变量FileInputStream is = new FileInputStream(new File("壁纸1.jpeg"));ps.setBlob(1, is);// 23 : 要修改 id 号ps.setInt(2,23);ps.execute();is.close();JDBCUtils.closeResource(conn, ps);}// 查询数据表 customers 中 Blob 类型的字段@Testpublic void testQuery() {Connection conn = null;PreparedStatement ps = null;InputStream is = null;FileOutputStream fos = null;ResultSet rs = null;try {conn = JDBCUtils.getConnection();String sql = "select id,name,email,birth,photo from customers where id = ?";ps = conn.prepareStatement(sql);ps.setInt(1, 23);rs = ps.executeQuery();if(rs.next()) {// 方式一:通过顺序的方式 类似于 ArrayList
//			int id = rs.getInt(1);
//			String name = rs.getString(2);
//			String email = rs.getString(3);
//			Date birth = rs.getDate(4);// 方式二:通过别名的方式int id = rs.getInt("id");String name = rs.getString("name");String email = rs.getString("email");Date birth = rs.getDate("birth");Customer cust = new Customer(id,name,email,birth);System.out.println(cust);// 将 Blob 类型的字段下载下来,以文件的方式保存在本地Blob photo = rs.getBlob("photo");// photo 是一个比较大的数据,这时需要用 流 的方式获取is = photo.getBinaryStream();fos = new FileOutputStream("zhangyuhao.jpg");byte[] buffer = new byte[1024];int len;while((len = is.read(buffer)) != -1) {fos.write(buffer,0,len);}}} catch (Exception e) {e.printStackTrace();} finally {try {if(is != null)is.close();} catch (IOException e) {e.printStackTrace();}try {if(fos != null)fos.close();} catch (IOException e) {e.printStackTrace();}JDBCUtils.closeResource(conn, ps, rs);}}
}

让 mysql 开启批处理的支持 :

?rewriteBatchedStatements = true 写在配置文件的 url 后面

user=root
password=123456
url=jdbc:mysql://localhost:3306/test?rewriteBatchedStatements = true
driverClass=com.mysql.cj.jdbc.Driver
package com.atguigu5.blob;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;import org.junit.Test;import com.atguigu3.util.JDBCUtils;/*** 使用 PreparedStatement 实现批量数据的操作** update、delete 本身就具有批量操作的效果。* 此时的批量操作,主要指的时批量插入。使用 PreparedStatement 如何实现更高效的批量插入?* * 题目:向 goods 表中插入 20000 条数据*   CREATE TABLE goods(*       id INT PRIMARY KEY AUTO_INCREMENT,*       NAME VARCHAR(25)*   );* * 方式一:使用 Statement*    Connection  conn = JDBCUtils.getConnection();*    Statement st = conn.createStatement();*    for(int i = 1; i <= 20000; i++){*    		String sql = "insert into goods(name) values('name_" + i + "')";*    		st.execute(sql);*    }* */
public class InsertTest {// 批量插入的方式二:使用 PreparedStatement@Testpublic void testInsert1() {Connection conn = null;PreparedStatement ps = null;try {long start = System.currentTimeMillis();conn = JDBCUtils.getConnection();String sql = "insert into goods(name)values(?)";ps = conn.prepareStatement(sql);for(int i = 1; i <= 20000; i++) {ps.setObject(1, "name_" + i);ps.execute();}long end = System.currentTimeMillis();System.out.println("花费的时间为: " + (end - start));// 20000:76229 } catch (Exception e) {e.printStackTrace();} finally {JDBCUtils.closeResource(conn, ps);}}/**  批量插入的方式三*  		1.addBatch()、executeBatch()、clearBatch()*  		2.mysql 服务器默认是关闭此处理的,我们需要通过一个参数,让 mysql 开启批处理的支持。*  	   		    ?rewriteBatchedStatements = true 写在配置文件的 url 后面*  		3.使用更新的 mysql 驱动:mysql-connector-java-5.1.37-bin.jar*  */@Testpublic void testInsert2() {Connection conn = null;PreparedStatement ps = null;try {long start = System.currentTimeMillis();conn = JDBCUtils.getConnection();String sql = "insert into goods(name)values(?)";ps = conn.prepareStatement(sql);for(int i = 1; i <= 1000000; i++) {ps.setObject(1, "name_" + i);// 1."攒" sqlps.addBatch();if(i % 500 == 0) {// 2.执行 batchps.executeBatch();// 3.清空 batchps.clearBatch();}}long end = System.currentTimeMillis();System.out.println("花费的时间为: " + (end - start));// 20000:76229 -- 1525// 1000000:18780 -- 		} catch (Exception e) {e.printStackTrace();} finally {JDBCUtils.closeResource(conn, ps);}}/**  批量插入的方式四: 设置连接不允许自动提交数据		*  */@Testpublic void testInsert3() {Connection conn = null;PreparedStatement ps = null;try {long start = System.currentTimeMillis();conn = JDBCUtils.getConnection();// 设置不允许自动提交数据(为了提高插入速度,缩短插入时间)conn.setAutoCommit(false);String sql = "insert into goods(name)values(?)";ps = conn.prepareStatement(sql);for(int i = 1; i <= 1000000; i++) {ps.setObject(1, "name_" + i);// 1."攒" sqlps.addBatch();if(i % 500 == 0) {// 2.执行 batchps.executeBatch();// 3.清空 batchps.clearBatch();}}// 提交数据conn.commit();long end = System.currentTimeMillis();System.out.println("花费的时间为: " + (end - start));// 20000:76229 -- 1525// 1000000:18780 -- 9939		} catch (Exception e) {e.printStackTrace();} finally {JDBCUtils.closeResource(conn, ps);}}
}

这篇关于jdbc 与 mysql 连接 - Blod及批量数据处理的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/725153

相关文章

MySQL查询JSON数组字段包含特定字符串的方法

《MySQL查询JSON数组字段包含特定字符串的方法》在MySQL数据库中,当某个字段存储的是JSON数组,需要查询数组中包含特定字符串的记录时传统的LIKE语句无法直接使用,下面小编就为大家介绍两种... 目录问题背景解决方案对比1. 精确匹配方案(推荐)2. 模糊匹配方案参数化查询示例使用场景建议性能优

mysql表操作与查询功能详解

《mysql表操作与查询功能详解》本文系统讲解MySQL表操作与查询,涵盖创建、修改、复制表语法,基本查询结构及WHERE、GROUPBY等子句,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随... 目录01.表的操作1.1表操作概览1.2创建表1.3修改表1.4复制表02.基本查询操作2.1 SE

MySQL中的锁机制详解之全局锁,表级锁,行级锁

《MySQL中的锁机制详解之全局锁,表级锁,行级锁》MySQL锁机制通过全局、表级、行级锁控制并发,保障数据一致性与隔离性,全局锁适用于全库备份,表级锁适合读多写少场景,行级锁(InnoDB)实现高并... 目录一、锁机制基础:从并发问题到锁分类1.1 并发访问的三大问题1.2 锁的核心作用1.3 锁粒度分

MySQL数据库中ENUM的用法是什么详解

《MySQL数据库中ENUM的用法是什么详解》ENUM是一个字符串对象,用于指定一组预定义的值,并可在创建表时使用,下面:本文主要介绍MySQL数据库中ENUM的用法是什么的相关资料,文中通过代码... 目录mysql 中 ENUM 的用法一、ENUM 的定义与语法二、ENUM 的特点三、ENUM 的用法1

MySQL count()聚合函数详解

《MySQLcount()聚合函数详解》MySQL中的COUNT()函数,它是SQL中最常用的聚合函数之一,用于计算表中符合特定条件的行数,本文给大家介绍MySQLcount()聚合函数,感兴趣的朋... 目录核心功能语法形式重要特性与行为如何选择使用哪种形式?总结深入剖析一下 mysql 中的 COUNT

mysql中的服务器架构详解

《mysql中的服务器架构详解》:本文主要介绍mysql中的服务器架构,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、mysql服务器架构解释3、总结1、背景简单理解一下mysqphpl的服务器架构。2、mysjsql服务器架构解释mysql的架

MySQL之InnoDB存储引擎中的索引用法及说明

《MySQL之InnoDB存储引擎中的索引用法及说明》:本文主要介绍MySQL之InnoDB存储引擎中的索引用法及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录1、背景2、准备3、正篇【1】存储用户记录的数据页【2】存储目录项记录的数据页【3】聚簇索引【4】二

mysql中的数据目录用法及说明

《mysql中的数据目录用法及说明》:本文主要介绍mysql中的数据目录用法及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、版本3、数据目录4、总结1、背景安装mysql之后,在安装目录下会有一个data目录,我们创建的数据库、创建的表、插入的

MySQL中的InnoDB单表访问过程

《MySQL中的InnoDB单表访问过程》:本文主要介绍MySQL中的InnoDB单表访问过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、环境3、访问类型【1】const【2】ref【3】ref_or_null【4】range【5】index【6】

MySQL 中 ROW_NUMBER() 函数最佳实践

《MySQL中ROW_NUMBER()函数最佳实践》MySQL中ROW_NUMBER()函数,作为窗口函数为每行分配唯一连续序号,区别于RANK()和DENSE_RANK(),特别适合分页、去重... 目录mysql 中 ROW_NUMBER() 函数详解一、基础语法二、核心特点三、典型应用场景1. 数据分