十年網(wǎng)站開發(fā)經(jīng)驗(yàn) + 多家企業(yè)客戶 + 靠譜的建站團(tuán)隊(duì)
量身定制 + 運(yùn)營(yíng)維護(hù)+專業(yè)推廣+無(wú)憂售后,網(wǎng)站問題一站解決
將開發(fā)過程中經(jīng)常用的一些內(nèi)容片段做個(gè)珍藏,下面資料是關(guān)于java大對(duì)象存取的簡(jiǎn)單實(shí)現(xiàn)的內(nèi)容。
創(chuàng)新互聯(lián)是專業(yè)的柳林網(wǎng)站建設(shè)公司,柳林接單;提供成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作,網(wǎng)頁(yè)設(shè)計(jì),網(wǎng)站設(shè)計(jì),建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行柳林網(wǎng)站開發(fā)網(wǎng)頁(yè)制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊(duì),希望更多企業(yè)前來(lái)合作!
package info.itlanguageexpress.LargeObject;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class MySQLLargeObjectAccess {
public static String DRIVER = "org.gjt.mm.mysql.Driver";
public static String USER = "root";
public static String PASSWORD = "your password";
public static void main(String[] args) throws Exception {
Connection conn = null;
try {
Class.forName(DRIVER);
conn = DriverManager.getConnection(URL, USER, PASSWORD);
insertWordFileToMySql(conn);
fetchWordFileFromMySql(conn);
} catch (Exception ex) {
ex.printStackTrace(System.out);
} finally {
try {
conn.close();
} catch (Exception ex) {
}
}
}
public static void insertWordFileToMySql(Connection conn)
throws SQLException, IOException {
PreparedStatement pstm = conn
.prepareStatement("insert into wordInputTest values (?,?)");
pstm.setString(1, "docx1");
InputStream in = new FileInputStream("F:" + File.separator
+ "test1.docx");
pstm.setBinaryStream(2, in, in.available());
pstm.executeUpdate();
pstm.close();
}
public static void fetchWordFileFromMySql(Connection conn)
throws SQLException, IOException {
PreparedStatement pstm = conn
pstm.setString(1, "docx1");
ResultSet rs = pstm.executeQuery();
int count = 1;
while(rs.next()) {
InputStream in = rs.getBinaryStream("file");
FileOutputStream out = new FileOutputStream("F:" + File.separator + "testcopy" + count + ".docx");
byte[] b = new byte[1024];
int len = 0;
while ((len = in.read(b)) != -1) {
out.write(b, 0, len);
out.flush();
}
out.close();
in.close();
count++;
}
rs.close();
pstm.close();
}
}