JDBC：处理二进制blob类型数据（字节流），存储mp3音乐文件到数据库，并从数据库中取出该mp3音乐文件

处理大文本blob类型数据
1.blob用于存储二进制数据，常常为图片或音频。
相关类型如下：

2.实现步骤
a.准备好mp3音乐文件
b.创建测试数据库并创建一个music表存储mp3音乐文件
c.连接数据库实现该mp3音乐文件的存取

3.核心知识

a.数据流的读取：
读数据：File file=new File("D:\\a_music.mp3");java.io.InputStream in=new FileInputStream(file);		
写数据：InputStream in=rs.getBinaryStream("music");OutputStream out=new FileOutputStream("src/音乐.mp3");		byte[] chs=new byte[100];int len=-1;while((len=in.read(chs))!=-1) {out.write(chs,0,len);}out.close();in.close();
b.pstmt.setBinaryStream()方法和getBinaryStream()方法pstmt.setBinaryStream(2, in,(int)file.length() );rs.getBinaryStream("music");

创建数据库test与数据表music

create database test;use test;create table music(id int primary key,music longblob
)select * from music;

连接数据库：JDBC_blob.java

package jdbc;import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.Reader;
import java.io.Writer;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class JDBC_blob {private static final String URL = "jdbc:mysql://127.0.0.1:3306/test";private static final String NAME = "root";private static final String PWD = "123abc";private static final String DRIVER="com.mysql.jdbc.Driver";//增加音乐private static void update() {Connection con=null;PreparedStatement pstmt=null;try {//1.加载驱动类Class.forName(DRIVER);//2.连接数据库con=DriverManager.getConnection(URL,NAME,PWD);//3.获取操作数据库对象String sql="insert into music values(?,?)";pstmt=con.prepareStatement(sql);pstmt.setInt(1, 1);//将音乐加入到music数据表中:setBinaryStream()//对文件流的操作File file=new File("D:\\a_music.mp3");java.io.InputStream in=new FileInputStream(file);		pstmt.setBinaryStream(2, in,(int)file.length() );//4.操作数据库pstmt.executeUpdate();System.out.println("操作成功！");} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();}catch (FileNotFoundException e) {e.printStackTrace();}finally {try {if(pstmt!=null) pstmt.close();if(con!=null) con.close();} catch (SQLException e) {e.printStackTrace();}}}//查找音乐:读数据，将音乐保存到src中的小说.music文件中private static void query() {Connection con=null;PreparedStatement pstmt=null;ResultSet rs=null;try {//1.加载驱动类Class.forName(DRIVER);//2.连接数据库con=DriverManager.getConnection(URL,NAME,PWD);//3.获取操作数据库对象String sql="select * from music where id=?";pstmt=con.prepareStatement(sql);pstmt.setInt(1, 1);//4.操作数据库rs=pstmt.executeQuery();//5.处理结果集if(rs.next()!=false) {InputStream in=rs.getBinaryStream("music");OutputStream out=new FileOutputStream("src/音乐.mp3");byte[] chs=new byte[100];int len=-1;while((len=in.read(chs))!=-1) {out.write(chs,0,len);}out.close();in.close();}System.out.println("操作成功！");} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();}catch (IOException e) {e.printStackTrace();}finally {try {if(pstmt!=null) pstmt.close();if(con!=null) con.close();} catch (SQLException e) {e.printStackTrace();}}}public static void main(String[] args) {//将数据存储到数据库//update();//将数据读取到src/音乐.mp3文件中query();}}

调用update()函数后，输出控制台与数据库的变化

调用query()函数后，刷新src目录查看其变化
然后将该音乐文件复制到桌面，看能否正常播放