一、得到mysql的連接

這里封裝成一個方法，方便后面使用。

public Connection getConnection() throws Exception{

String url = "jdbc:mysql://localhost:3306/dbfortest";

String user = "root";

String password = "root";

Class.forName("com.mysql.jdbc.Driver");

Connection conn = DriverManager.getConnection(url, user, password);

return conn;

}

二、將數據存入數據庫

/**

*

* @param file? 需要傳入數據庫的文件

* @throws Exception

*/

public void save(File file) throws Exception{

Connection conn = getConnection();

String sql = "insert into tb_blob (name,myfile) values(?,?)";

PreparedStatement prest = conn.prepareStatement(sql);

String filename=file.getName();

prest.setString(1, filename);//根據文件名稱來保存

FileInputStream fis = new FileInputStream(file);

prest.setBlob(2, fis,file.length());//第二個參數需要一個InputStream

prest.execute();?? //執行

}

三、將數據取出，同時寫入文件。

/**

*

* @param filename? 列的值，同時是文件名

* @throws Exception

*/

public void getMp3(String filename) throws Exception{

Connection conn = getConnection();

String sql = "select * from tb_blob where name= ?";

PreparedStatement prest = conn.prepareStatement(sql);

prest.setString(1, filename);

ResultSet rs = prest.executeQuery();

while(rs.next()){

Blob? bl = rs.getBlob("myfile");//數據保存在"myfile"，這里則是取出這里保存的數據。

InputStream is = bl.getBinaryStream();? //查看blob,可以通過流的形式取出來。

BufferedInputStream buffis = new BufferedInputStream(is);

//保存到buffout，就工程目錄下的filename的文件

BufferedOutputStream buffout = new BufferedOutputStream(new FileOutputStream(filename));

byte[] buf= new byte[1024];

int len = buffis.read(buf, 0, 1024);

while(len>0){

buffout.write(buf);

len=buffis.read(buf, 0, 1024);

}

buffout.flush();

buffout.close();

buffis.close();

}

}

總結

以上是生活随笔為你收集整理的mysql数据库blob换行_mysql Blob存取的一个简单例子的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。