【Java数据库】CLOB BLOB 在数据库中存入/取出大量文本数据、二进制文件（图片）

CLOB（Character Large Object）

– 用于存储大量的文本数据
– 大字段有些特殊，不同数据库处理的方式不一样，大字段的操作常常是以流的
方式来处理的。而非一般的字段，一次即可读出数据。

• Mysql中相关类型：

– TINYTEXT最大长度为255(2^[8]–1)字符的TEXT列。
– TEXT[(M)]最大长度为65,535(2^[16]–1)字符的TEXT列。
– MEDIUMTEXT最大长度为16,777,215(2^[24]–1)字符的TEXT列。
– LONGTEXT最大长度为4,294,967,295或4GB(2^[32]–1)字符的TEXT列

BLOB（Binary Large Object）

– 用于存储大量的二进制数据
– 大字段有些特殊，不同数据库处理的方式不一样，大字段的操作常常是以流的
方式来处理的。而非一般的字段，一次即可读出数据。

• Mysql中相关类型：
– TINYBLOB最大长度为255(2^[8]–1)字节的BLOB列。
– BLOB[(M)]最大长度为65,535(2^[16]–1)字节的BLOB列。
– MEDIUMBLOB最大长度为16,777,215(2^[24]–1)字节的BLOB列。
– LONGBLOB最大长度为4,294,967,295或4GB(2^[32]–1)字节的BLOB列。

CLOB

从本地读取txt文件/字符串，将内容写入数据库

package cn.hanquan.jdbcTest;import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;public class JDBCTest {public static void main(String[] args) throws SQLException {Connection conn = null;PreparedStatement ps = null;ResultSet rs = null;try {// 加载驱动类Class.forName("com.mysql.cj.jdbc.Driver");conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc?serverTimezone=UTC", "root","123456");String sql = "insert into user (id,blog) values (?,?)";ps = conn.prepareStatement(sql);ps.setString(1, "高淇");// ps.setClob(2, new BufferedReader(new InputStreamReader(new ByteArrayInputStream("这是一个字符串".getBytes()))));// 为了把字符串转换成流的方式ps.setClob(2, new FileReader(new File("c:/picture/test.txt")));ps.executeUpdate();} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();} catch (FileNotFoundException e) {e.printStackTrace();} finally {try {if (ps != null) {ps.close();}} catch (SQLException e) {e.printStackTrace();}try {if (conn != null) {conn.close();}} catch (SQLException e) {e.printStackTrace();}}}
}

从数据库中取出字符串

package cn.hanquan.jdbcTest;import java.io.IOException;
import java.io.Reader;
import java.sql.Clob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;public class JDBCTest {public static void main(String[] args) throws SQLException {Connection conn = null;PreparedStatement ps = null;ResultSet rs = null;try {// 加载驱动类Class.forName("com.mysql.cj.jdbc.Driver");conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc?serverTimezone=UTC", "root", "666666");String sql = "select * from user where id = ?";ps = conn.prepareStatement(sql);ps.setString(1, "高淇");rs = ps.executeQuery();while (rs.next()) {Clob c = rs.getClob("blog");Reader r = c.getCharacterStream();int temp = 0;// 输出取出结果while ((temp = r.read()) != -1) {System.out.print((char) temp);}}} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {try {if (ps != null) {ps.close();}} catch (SQLException e) {e.printStackTrace();}try {if (conn != null) {conn.close();}} catch (SQLException e) {e.printStackTrace();}}}
}

输出

这是一个字符串

BLOB

虽然数据库提供了存放二进制文件的功能，但是在实际的开发过程中，大的视频、数据一般会放在文件服务器上，而不是放在数据库中。

代码示例：取出数据库中的Blob

package cn.hanquan.jdbcTest;import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class JDBCTest {public static void main(String[] args) throws FileNotFoundException {Connection conn = null;PreparedStatement ps = null;ResultSet rs = null;InputStream is = null;OutputStream os = null;try {// 加载驱动类Class.forName("com.mysql.cj.jdbc.Driver");conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc?serverTimezone=UTC", "root", "123456");// 执行SQLString sql = "select * from user where id=?";ps = conn.prepareStatement(sql);ps.setString(1, "sxt");rs = ps.executeQuery();// 接收结果并存储到jpg文件while (rs.next()) {Blob b = rs.getBlob("headImg");is = b.getBinaryStream();os = new FileOutputStream("getimg.jpg");int temp = 0;while ((temp = is.read()) != -1) {os.write(temp);}}} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {// 关闭流try {if (os != null) {os.close();}if (is != null) {is.close();}} catch (IOException e) {e.printStackTrace();}try {if (ps != null) {ps.close();}} catch (SQLException e) {e.printStackTrace();}try {if (conn != null) {conn.close();}} catch (SQLException e) {e.printStackTrace();}}}
}

运行结果：成功保存jpg文件

以上只是在本地运行的例子。以后在服务器端的时候，还可以通过流向客户输出。