javaweb學習總結——使用JDBC處理MySQL大數(shù)據(jù)
更新時間：2016年11月01日 16:32:53 作者：孤傲蒼狼
本篇文章主要介紹了JDBC處理MySQL大數(shù)據(jù)，有時是需要用程序把大文本或二進制數(shù)據(jù)直接保存到數(shù)據(jù)庫中進行儲存的，非常具有實用價值，需要的朋友可以參考下。
BLOB (binary large object)，二進制大對象，是一個可以存儲二進制文件的容器。在計算機中，BLOB常常是數(shù)據(jù)庫中用來存儲二進制文件的字段類型，BLOB是一個大文件，典型的BLOB是一張圖片或一個聲音文件，由于它們的尺寸，必須使用特殊的方式來處理（例如：上傳、下載或者存放到一個數(shù)據(jù)庫）。
一、基本概念
在實際開發(fā)中，有時是需要用程序把大文本或二進制數(shù)據(jù)直接保存到數(shù)據(jù)庫中進行儲存的。
對MySQL而言只有blob，而沒有clob，mysql存儲大文本采用的是Text，Text和blob分別又分為：
TINYTEXT、TEXT、MEDIUMTEXT和LONGTEXT
TINYBLOB、BLOB、MEDIUMBLOB和LONGBLOB
二、搭建測試環(huán)境
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文件中的數(shù)據(jù)庫連接信息
InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
Properties prop = new Properties();
prop.load(in);
//獲取數(shù)據(jù)庫連接驅動
driver = prop.getProperty("driver");
//獲取數(shù)據(jù)庫連接URL地址
url = prop.getProperty("url");
//獲取數(shù)據(jù)庫連接用戶名
username = prop.getProperty("username");
//獲取數(shù)據(jù)庫連接密碼
password = prop.getProperty("password");
//加載數(shù)據(jù)庫驅動
Class.forName(driver);
}catch (Exception e) {
throw new ExceptionInInitializerError(e);
}
}
/**
* @Method: getConnection
* @Description: 獲取數(shù)據(jù)庫連接對象
* @Anthor:孤傲蒼狼
*
* @return Connection數(shù)據(jù)庫連接對象
* @throws SQLException
*/
public static Connection getConnection() throws SQLException{
return DriverManager.getConnection(url, username,password);
}
/**
* @Method: release
* @Description: 釋放資源，
* 要釋放的資源包括Connection數(shù)據(jù)庫連接對象，負責執(zhí)行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{
//關閉負責執(zhí)行SQL命令的Statement對象
st.close();
}catch (Exception e) {
e.printStackTrace();
}
}
if(conn!=null){
try{
//關閉Connection數(shù)據(jù)庫連接對象
conn.close();
}catch (Exception e) {
e.printStackTrace();
}
}
}
}
三、使用JDBC處理MySQL的大文本
對于MySQL中的Text類型，可調(diào)用如下方法設置
PreparedStatement.setCharacterStream(index, reader, length);//注意length長度須設置，并且設置為int型
對MySQL中的Text類型，可調(diào)用如下方法獲取
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:向數(shù)據(jù)庫中插入大文本數(shù)據(jù)
* @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: 讀取數(shù)據(jù)庫中的大文本數(shù)據(jù)
* @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("字段名")獲取大文本數(shù)據(jù)的內(nèi)容
content = rs.getString("resume");
//使用resultSet.getCharacterStream("字段名")獲取大文本數(shù)據(jù)的內(nèi)容
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的二進制數(shù)據(jù)
對于MySQL中的BLOB類型，可調(diào)用如下方法設置：
PreparedStatement. setBinaryStream(i, inputStream, length);
對MySQL中的BLOB類型，可調(diào)用如下方法獲?。?br />
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的二進制數(shù)據(jù)(例如圖像、聲音、二進制文)
* @author: 孤傲蒼狼
* @date: 2014-9-19 下午10:10:04
*
*/
public class JdbcOperaBlob {
/**
* @Method: add
* @Description:向數(shù)據(jù)庫中插入二進制數(shù)據(jù)
* @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: 讀取數(shù)據(jù)庫中的二進制數(shù)據(jù)
* @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);
}
}
}
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
您可能感興趣的文章:
相關文章
這篇文章主要介紹了SpringBoot+Vue項目打包部署的相關資料,包括Vue項目的打包設置、SpringBoot的配置修改、跨域問題處理、使用Nginx配置反向代理以及最終的項目啟動,教程假定開發(fā)者已具備完整的前后端分離項目和配置好環(huán)境的服務器,需要的朋友可以參考下2024-10-10
springboot集成spring cache緩存示例代碼
本篇文章主要介紹了springboot集成spring cache示例代碼，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-05-05
這篇文章主要介紹了SpringBoot測試junit遇到的坑及解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-01-01
在Java中，工具類定義了一組公共方法，這篇文章將介紹Java中使用工具類來獲取一個wav文件的時間長度，感興趣的同學繼續(xù)往下閱讀吧2021-10-10
這篇文章主要介紹了Java的Hibernate框架中的緩存和延遲加載機制,Hibernate是注明的Java下SSH三大web開發(fā)框架之一,需要的朋友可以參考下2015-11-11
Hibernate環(huán)境搭建與配置方法(Hello world配置文件版)
這篇文章主要介紹了Hibernate環(huán)境搭建與配置方法,這里演示Hello world配置文件版的具體實現(xiàn)步驟與相關代碼,需要的朋友可以參考下2016-03-03
這篇文章主要介紹了Java并發(fā)編程中構建自定義同步工具,本文講解了可阻塞狀態(tài)依賴操作的結構、有界緩存實現(xiàn)基類示例、阻塞實現(xiàn)方式一：拋異常給調(diào)用者、阻塞實現(xiàn)方式二：通過輪詢和休眠、阻塞實現(xiàn)方式三：條件隊列等內(nèi)容,需要的朋友可以參考下2015-04-04
這篇文章主要為大家詳細介紹了SpringBoot JPA實現(xiàn)查詢多值，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-08-08
這篇文章主要介紹了springboot如何實現(xiàn)自動裝配源碼賞析,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-12-12
這篇文章主要介紹了Java中Druid連接池連接超時獲取不到連接的解決，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-11-11