javaweb学习总结——使用JDBC处理MySQL大数据

更新时间：2016年11月01日 16:32:53 作者：孤傲苍狼

本篇文章主要介绍了JDBC处理MySQL大数据，有时是需要用程序把大文本或二进制数据直接保存到数据库中进行储存的，非常具有实用价值，需要的朋友可以参考下。

BLOB (binary large object)，二进制大对象，是一个可以存储二进制文件的容器。在计算机中，BLOB常常是数据库中用来存储二进制文件的字段类型，BLOB是一个大文件，典型的BLOB是一张图片或一个声音文件，由于它们的尺寸，必须使用特殊的方式来处理（例如：上传、下载或者存放到一个数据库）。

一、基本概念

在实际开发中，有时是需要用程序把大文本或二进制数据直接保存到数据库中进行储存的。

对MySQL而言只有blob，而没有clob，mysql存储大文本采用的是Text，Text和blob分别又分为：

TINYTEXT、TEXT、MEDIUMTEXT和LONGTEXT

TINYBLOB、BLOB、MEDIUMBLOB和LONGBLOB

二、搭建测试环境

2.1、搭建的测试项目架构

如图：

2.2、编写db.properties配置文件

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcStudy
username=root
password=XDP

2.3、编写JdbcUtils工具类

package me.gacl.utils;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class JdbcUtils {

  private static String driver = null;
  private static String url = null;
  private static String username = null;
  private static String password = null;
  
  static{
    try{
      //读取db.properties文件中的数据库连接信息
      InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
      Properties prop = new Properties();
      prop.load(in);
      
      //获取数据库连接驱动
      driver = prop.getProperty("driver");
      //获取数据库连接URL地址
      url = prop.getProperty("url");
      //获取数据库连接用户名
      username = prop.getProperty("username");
      //获取数据库连接密码
      password = prop.getProperty("password");
      
      //加载数据库驱动
      Class.forName(driver);
      
    }catch (Exception e) {
      throw new ExceptionInInitializerError(e);
    }
  }
  
  /**
  * @Method: getConnection
  * @Description: 获取数据库连接对象
  * @Anthor:孤傲苍狼
  *
  * @return Connection数据库连接对象
  * @throws SQLException
  */ 
  public static Connection getConnection() throws SQLException{
    return DriverManager.getConnection(url, username,password);
  }
  
  /**
  * @Method: release
  * @Description: 释放资源，
  *   要释放的资源包括Connection数据库连接对象，负责执行SQL命令的Statement对象，存储查询结果的ResultSet对象
  * @Anthor:孤傲苍狼
  *
  * @param conn
  * @param st
  * @param rs
  */ 
  public static void release(Connection conn,Statement st,ResultSet rs){
    if(rs!=null){
      try{
        //关闭存储查询结果的ResultSet对象
        rs.close();
      }catch (Exception e) {
        e.printStackTrace();
      }
      rs = null;
    }
    if(st!=null){
      try{
        //关闭负责执行SQL命令的Statement对象
        st.close();
      }catch (Exception e) {
        e.printStackTrace();
      }
    }
    
    if(conn!=null){
      try{
        //关闭Connection数据库连接对象
        conn.close();
      }catch (Exception e) {
        e.printStackTrace();
      }
    }
  }
}

三、使用JDBC处理MySQL的大文本

对于MySQL中的Text类型，可调用如下方法设置

PreparedStatement.setCharacterStream(index, reader, length);//注意length长度须设置，并且设置为int型

对MySQL中的Text类型，可调用如下方法获取

reader = resultSet. getCharacterStream(String columnLabel);2 string s = resultSet.getString(String columnLabel);

3.1、测试范例

1、编写SQL测试脚本

create database jdbcstudy;
use jdbcstudy;
create table testclob
(
     id int primary key auto_increment,
     resume text
);

2、编写测试代码如下：

package me.gacl.demo;

import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.Reader;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import me.gacl.utils.JdbcUtils;
import org.junit.Test;

/**
* @ClassName: JdbcOperaClob
* @Description: 使用JDBC操作MySQL的大文本
* @author: 孤傲苍狼
* @date: 2014-9-19 下午10:10:04
*
*/ 
public class JdbcOperaClob {

  /**
  * @Method: add
  * @Description:向数据库中插入大文本数据
  * @Anthor:孤傲苍狼
  *
  */ 
  @Test
  public void add(){
    Connection conn = null;
    PreparedStatement st = null;
    ResultSet rs = null;
    Reader reader = null;
    try{
      conn = JdbcUtils.getConnection();
      String sql = "insert into testclob(resume) values(?)";
      st = conn.prepareStatement(sql);
      //这种方式获取的路径，其中的空格会被使用“%20”代替
      String path = JdbcOperaClob.class.getClassLoader().getResource("data.txt").getPath();
      //将“%20”替换回空格
      path = path.replaceAll("%20", " ");
      File file = new File(path);
      reader = new FileReader(file);
      st.setCharacterStream(1, reader,(int) file.length());
      int num = st.executeUpdate();
      if(num>0){
        System.out.println("插入成功！！");
      }
      //关闭流
      reader.close();
    }catch (Exception e) {
      e.printStackTrace();
    }finally{
      JdbcUtils.release(conn, st, rs);
    }
  }
  
  /**
  * @Method: read
  * @Description: 读取数据库中的大文本数据
  * @Anthor:孤傲苍狼
  *
  */ 
  @Test
  public void read(){
    Connection conn = null;
    PreparedStatement st = null;
    ResultSet rs = null;
    try{
      conn = JdbcUtils.getConnection();
      String sql = "select resume from testclob where id=2";
      st = conn.prepareStatement(sql);
      rs = st.executeQuery();
      
      String contentStr ="";
      String content = "";
      if(rs.next()){
        //使用resultSet.getString("字段名")获取大文本数据的内容
        content = rs.getString("resume");
        //使用resultSet.getCharacterStream("字段名")获取大文本数据的内容
        Reader reader = rs.getCharacterStream("resume");
        char buffer[] = new char[1024];
        int len = 0;
        FileWriter out = new FileWriter("D:\\1.txt");
        while((len=reader.read(buffer))>0){
          contentStr += new String(buffer);
          out.write(buffer, 0, len);
        }
        out.close();
        reader.close();
      }
      System.out.println(content);
      System.out.println("-----------------------------------------------");
      System.out.println(contentStr);
    }catch (Exception e) {
      e.printStackTrace();
    }finally{
      JdbcUtils.release(conn, st, rs);
    }
  }
}

四、使用JDBC处理MySQL的二进制数据

对于MySQL中的BLOB类型，可调用如下方法设置：

PreparedStatement. setBinaryStream(i, inputStream, length);

对MySQL中的BLOB类型，可调用如下方法获取：

InputStream in = resultSet.getBinaryStream(String columnLabel);
InputStream in = resultSet.getBlob(String columnLabel).getBinaryStream();

4.1、测试范例

1、编写SQL测试脚本

create table testblob
(
   id int primary key auto_increment,
   image longblob
 );

2、编写测试代码如下：

package me.gacl.demo;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import me.gacl.utils.JdbcUtils;
import org.junit.Test;

/**
* @ClassName: JdbcOperaClob
* @Description: 使用JDBC操作MySQL的二进制数据(例如图像、声音、二进制文)
* @author: 孤傲苍狼
* @date: 2014-9-19 下午10:10:04
*
*/ 
public class JdbcOperaBlob {

  /**
  * @Method: add
  * @Description:向数据库中插入二进制数据
  * @Anthor:孤傲苍狼
  *
  */ 
  @Test
  public void add(){
    Connection conn = null;
    PreparedStatement st = null;
    ResultSet rs = null;
    try{
      conn = JdbcUtils.getConnection();
      String sql = "insert into testblob(image) values(?)";
      st = conn.prepareStatement(sql);
      //这种方式获取的路径，其中的空格会被使用“%20”代替
      String path = JdbcOperaBlob.class.getClassLoader().getResource("01.jpg").getPath();
      //将“%20”替换会空格
      path = path.replaceAll("%20", " ");
      File file = new File(path);
      FileInputStream fis = new FileInputStream(file);//生成的流
      st.setBinaryStream(1, fis,(int) file.length());
      int num = st.executeUpdate();
      if(num>0){
        System.out.println("插入成功！！");
      }
      fis.close();
    }catch (Exception e) {
      e.printStackTrace();
    }finally{
      JdbcUtils.release(conn, st, rs);
    }
  }
  
  /**
  * @Method: read
  * @Description: 读取数据库中的二进制数据
  * @Anthor:孤傲苍狼
  *
  */ 
  @Test
  public void read() {
    Connection conn = null;
    PreparedStatement st = null;
    ResultSet rs = null;
    try {
      conn = JdbcUtils.getConnection();
      String sql = "select image from testblob where id=?";
      st = conn.prepareStatement(sql);
      st.setInt(1, 1);
      rs = st.executeQuery();
      if (rs.next()) {
        //InputStream in = rs.getBlob("image").getBinaryStream();//这种方法也可以
        InputStream in = rs.getBinaryStream("image");
        int len = 0;
        byte buffer[] = new byte[1024];
        
        FileOutputStream out = new FileOutputStream("D:\\1.jpg");
        while ((len = in.read(buffer)) > 0) {
          out.write(buffer, 0, len);
        }
        in.close();
        out.close();
      }
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      JdbcUtils.release(conn, st, rs);
    }
  }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

jdbc
mysql

SpringBoot+Vue项目打包部署完整步骤教程
这篇文章主要介绍了SpringBoot+Vue项目打包部署的相关资料,包括Vue项目的打包设置、SpringBoot的配置修改、跨域问题处理、使用Nginx配置反向代理以及最终的项目启动,教程假定开发者已具备完整的前后端分离项目和配置好环境的服务器,需要的朋友可以参考下
2024-10-10
springboot集成spring cache缓存示例代码
本篇文章主要介绍了springboot集成spring cache示例代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-05-05
SpringBoot测试junit遇到的坑及解决
这篇文章主要介绍了SpringBoot测试junit遇到的坑及解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-01-01
Java轻松使用工具类实现获取wav时间长度
在Java中，工具类定义了一组公共方法，这篇文章将介绍Java中使用工具类来获取一个wav文件的时间长度，感兴趣的同学继续往下阅读吧
2021-10-10
浅析Java的Hibernate框架中的缓存和延迟加载机制
这篇文章主要介绍了Java的Hibernate框架中的缓存和延迟加载机制,Hibernate是注明的Java下SSH三大web开发框架之一,需要的朋友可以参考下
2015-11-11
Hibernate环境搭建与配置方法(Hello world配置文件版)
这篇文章主要介绍了Hibernate环境搭建与配置方法,这里演示Hello world配置文件版的具体实现步骤与相关代码,需要的朋友可以参考下
2016-03-03
Java并发编程中构建自定义同步工具
这篇文章主要介绍了Java并发编程中构建自定义同步工具,本文讲解了可阻塞状态依赖操作的结构、有界缓存实现基类示例、阻塞实现方式一：抛异常给调用者、阻塞实现方式二：通过轮询和休眠、阻塞实现方式三：条件队列等内容,需要的朋友可以参考下
2015-04-04
SpringBoot JPA实现查询多值
这篇文章主要为大家详细介绍了SpringBoot JPA实现查询多值，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-08-08
springboot如何实现自动装配源码解读
这篇文章主要介绍了springboot如何实现自动装配源码赏析,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2020-12-12
Java中Druid连接池连接超时获取不到连接的解决
这篇文章主要介绍了Java中Druid连接池连接超时获取不到连接的解决，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-11-11

javaweb学习总结——使用JDBC处理MySQL大数据

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具