代碼在前天做好了，但是一直都沒時(shí)間去修改，
偷下懶吧。
呵呵
放出來只是給大家一點(diǎn)參考。
我用的表示temp。中間有三個屬性time（存儲系統(tǒng)當(dāng)前時(shí)間），title（文件名稱），context（文件中文本內(nèi)容），
其中測試的是在E盤下的test文件夾下的文件，（文件采用問txt的）。
oracle是10 XE版本的。驅(qū)動是class12.
下面就是代碼了。
|
package PreparedTest;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
public class lsat {
static String driverClass = "oracle.jdbc.driver.OracleDriver";
static String URL = "jdbc:oracle:thin:@localhost:1521:XE";
static String USERNAME = "system";
static String PASSWORD = "duduli";
static Connection con = null;
static Statement stmt = null;
static ResultSet rs = null;
static String filePathName = null;
static String fileName = null;
public static String getFileName(File file){
String filename = "";
if (file != null){
filename = file.getName();
int i = filename.lastIndexOf('.');
if (i > 0 && i < filename.length()-1){
return filename.substring(0,i);
}
}
return filename;
}
public static void clobInsert(String filepath)throws Exception {
try {
File file = new File(filepath);
if (file.isDirectory()) {
//System.out.println("文件夾");
String[] filelist = file.list();
for (int i = 0; i < filelist.length; i++) {
Date dateNow = new Date(); // 取得當(dāng)前時(shí)間
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd-hh"); // 對時(shí)間進(jìn)行格式化
String dateNowStr = dateFormat.format(dateNow);
System.out.println(dateNowStr);
File readfile = new File(filepath + "\\" + filelist[i]);
//文件掃描
filePathName = readfile.getAbsolutePath();
if (!readfile.isDirectory()) {
fileName = getFileName(readfile);
System.out.print("一個文件!\t");
System.out.println("文件名："+fileName);
System.out.println("文件地址"+filePathName);
} else if (readfile.isDirectory()) {
fileName = getFileName(readfile);
System.out.print("一個文件夾！\t");
System.out.println("文件夾名："+fileName);
System.out.println("文件夾地址："+filePathName);
clobInsert(filepath + "\\" + filelist[i]);
}
boolean defaultCommit = con.getAutoCommit();
con.setAutoCommit(false);
try {
/* 插入一個空的CLOB對象 */
stmt.executeUpdate("INSERT INTO temp VALUES ('"+dateNowStr+"', '"+filePathName+"',EMPTY_CLOB())");
/* 查詢此CLOB對象并鎖定 */
ResultSet rs = stmt.executeQuery("SELECT context FROM temp WHERE title='"+filePathName+"' FOR UPDATE");
while (rs.next()) {
/* 取出此CLOB對象 */
oracle.sql.CLOB clob = (oracle.sql.CLOB)rs.getClob("context");
/* 向CLOB對象中寫入數(shù)據(jù) */
BufferedWriter out = new BufferedWriter(clob.getCharacterOutputStream());
BufferedReader in = new BufferedReader(new FileReader(fileName));
int c;
while ((c=in.read())!=-1) {
out.write(c);
}
in.close();
out.close();
}
/* 正式提交 */
con.commit();
} catch (Exception ex) {
/* 出錯回滾 */
con.rollback();
}
/* 恢復(fù)原提交狀態(tài) */
con.setAutoCommit(defaultCommit);
}
}
/* 設(shè)定不自動提交 */
}
catch (FileNotFoundException e) {
System.out.println("readfile() Exception:" + e.getMessage());
}
}
public static void main(String[] args) throws Exception
{
/* 裝載驅(qū)動,建立數(shù)據(jù)庫連接 */
Class.forName(driverClass);
con = DriverManager.getConnection(URL,USERNAME,PASSWORD);
stmt = con.createStatement();
clobInsert("e:/test");
try {
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (con != null) {
con.close();
}
} catch (Exception e) {
}
}
}
|
寫得很凌亂，大家就勉強(qiáng)看看吧。