JDBC之大數(shù)據(jù)內(nèi)容的傳輸_數(shù)據(jù)分析師

JDBC之 大數(shù)據(jù)內(nèi)容的傳輸

什么是大數(shù)據(jù)內(nèi)容？

      在數(shù)據(jù)庫中，有一條一條的記錄，記錄中很多字段都是幾個字符就夠的，假如現(xiàn)在要把一部小說存入數(shù)據(jù)庫，這本小說當(dāng)然不是幾個字符組成，而是由幾萬字組成，這本小說的數(shù)據(jù)我們就可以說是大數(shù)據(jù)，生活中當(dāng)然有各種各樣的大數(shù)據(jù)：電影，音樂，圖片等等。。。

大字符數(shù)據(jù)內(nèi)容操作

      大字符內(nèi)容：通常是指很長的字符類型的文件，例如小說，故事等等，內(nèi)容有字符組成。

      下面說明一下MySQL與Oracle中的大數(shù)據(jù)類型

1.把大字符數(shù)據(jù)存進(jìn)數(shù)據(jù)庫(把一個文本的數(shù)據(jù)存進(jìn)MySQL中的text類型字段)

@Test public void writeInDB() throws Exception { //獲取連接 connection = sqlUtil.getconnection(); //獲取對象 PreparedStatement preparedStatement = connection.prepareStatement("insert into book values(?)"); //準(zhǔn)備一個Reader用于讀取本地文件 Reader reader = new FileReader(new File("e:/test.txt")); //設(shè)置大數(shù)據(jù)參數(shù) preparedStatement.setClob(1, reader); //執(zhí)行SQL語句  preparedStatement.executeUpdate(); //關(guān)閉資源  reader.close();
    sqlUtil.close(preparedStatement, connection);
} 

2.從數(shù)據(jù)庫把大字符文件讀入到本地

@Test public void readFromDB() throws Exception
{ //獲取連接 connection = sqlUtil.getconnection(); //創(chuàng)建對象 PreparedStatement preparedStatement = connection.prepareStatement("SELECT content FROM book"); //設(shè)置參數(shù)//preparedStatement.setObject(1, "book");//獲得結(jié)果 ResultSet res = preparedStatement.executeQuery(); //以String的形式獲得大字符內(nèi)容 while(res.next())
    {
String content = res.getString("content");
System.out.println(content);
    } //關(guān)閉資源  sqlUtil.close(preparedStatement, connection);
}

      獲得結(jié)果后還有第二種方法：

@Test public void readFromDB() throws Exception
{ //獲取連接 connection = sqlUtil.getconnection(); //創(chuàng)建對象 PreparedStatement preparedStatement = connection.prepareStatement("SELECT content FROM book"); //設(shè)置參數(shù)//preparedStatement.setObject(1, "book");//獲得結(jié)果 ResultSet res = preparedStatement.executeQuery();  FileWriter fileWriter = new FileWriter(new File("d:/11021.txt")); //利用Clob對象 if(res.next())
{
Clob clob = res.getClob("content");
Reader reader = clob.getCharacterStream(); //然后把Reader寫入到本地文件中 char[] cr = new char[1024]; int len = 0; while((len = reader.read(cr))!=-1)
{
fileWriter.write(cr, 0, len);
}
reader.close();
} //關(guān)閉資源 fileWriter.close();
sqlUtil.close(preparedStatement, connection);
}

      以上就是對大字符文件的讀入與寫出~下面我們示范來對大字節(jié)文件的操作~

4.把大字節(jié)文件寫入數(shù)據(jù)庫

 @Test public void writeInDB() throws Exception { //獲取連接 connection = sqlUtil.getconnection(); //獲取對象 PreparedStatement preparedStatement = connection.prepareStatement("insert into book values(?,?)"); //準(zhǔn)備一個InputStream用于讀取本地文件 InputStream in = new FileInputStream(new File("f:/computer.jpg")); //設(shè)置大數(shù)據(jù)參數(shù) preparedStatement.setObject(1, 1);
preparedStatement.setBlob(2, in); //也可以使用這個//preparedStatement.setBinaryStream(2, in);//執(zhí)行SQL語句 preparedStatement.executeUpdate(); //關(guān)閉資源 in.close();
sqlUtil.close(preparedStatement, connection);
    }

5.從數(shù)據(jù)庫把大字節(jié)文件讀取到本地

@Test public void readFromDB() throws Exception
{ //獲取連接 connection = sqlUtil.getconnection(); //創(chuàng)建對象 PreparedStatement preparedStatement = connection.prepareStatement("SELECT content FROM book where id=?"); //設(shè)置參數(shù) preparedStatement.setInt(1, 1); //獲得結(jié)果 ResultSet res = preparedStatement.executeQuery();

FileOutputStream out = new FileOutputStream(new File("d:/999.jpg")); //利用Blob對象 if(res.next())
{ //Blob blob = res.getBlob("content");//InputStream in =  blob.getBinaryStream();//這樣也行  InputStream in = res.getBinaryStream("content"); //然后把Reader寫入到本地文件中 byte[] buf = new byte[1024]; int len = 0; while((len = in.read(buf))!=-1)
{ out.write(buf, 0, len);
} in.close(); out.close();
} //關(guān)閉資源  sqlUtil.close(preparedStatement, connection);
}