展开全部

package admit.action;/*用JAVA读取各种计算机文件系统的文件列表 当你安装了jdk，在32313133353236313431303231363533e78988e69d8331333332613732jdk的类库里，有一个标准的File类，通过该类，可以很方便的实现浏览各种文件系统的功能。

File类：

java.lang.Object

|

+--java.io.File

File类扩展了Object对象，实现了Serializable, Comparable定义的接口，可以通过File的一个实例对jvm上的文件系统进行各种操作，下面我编写了一个FileViewer类，该类通过Iterator类将一个文件列表实现对列表的迭代操作

FileViewer.java */import java.io.File;

import java.util.ArrayList;

import java.util.Date;

import java.util.Iterator;

import java.util.Vector;public class ReadPath {

File myDir; File[] contents; Vector vectorList; Iterator currentFileView; File currentFile; String path; public ReadPath() {

path = new String("");

vectorList = new Vector();

} public ReadPath(String path) {

this.path = path;

vectorList = new Vector();

} /**

* 设置浏览的路径

*/

public void setPath(String path) {

this.path = path;

} /***************************************************************************

* 返回当前目录路径

*/

public String getDirectory() {

return myDir.getPath();

} /**

* 刷新列表

*/

public void refreshList() { if (this.path.equals(""))

path = "c:\\";

myDir = new File(path); vectorList.clear();

contents = myDir.listFiles();

// 重新装入路径下文件

for (int i = 0; i < contents.length; i++) {

vectorList.add(contents[i]);

}

currentFileView = vectorList.iterator();

} /**

* 移动当前文件集合的指针指到下一个条目

*

* @return 成功返回true,否则false

*/

public boolean nextFile() {

while (currentFileView.hasNext()) {

currentFile = (File) currentFileView.next();

return true;

}

return false;

} /**

* 返回当前指向的文件对象的文件名称

*/

public String getFileName() {

return currentFile.getName();

} /**

* 返回当前指向的文件对象的文件尺寸

*/

public String getFileSize() {

return new Long(currentFile.length()).toString();

} /**

* 返回当前指向的文件对象的最后修改日期

*/

public String getFileTimeStamp() {

return new Date(currentFile.lastModified()).toString();

} /**

* 返回当前指向的文件对象是否是一个文件目录

*/

public boolean getFileType() {

return currentFile.isDirectory();

} /*

* 通过setPath()方法设定要浏览的目录(注意如果操作系统为微软操作系统，每个路径分隔符应写成两个斜杠\)，nextFile()方法用来移动列表记录，可以通过getFileName()得到文件或文件夹名称，通过getFileSize()得到文件尺寸，通过getFileTimeStamp()得到文件的最后修改时间，通过getFileType()判断是否是一个文件目录。

* 编写一个test例子测试这个FileViewer类

*/ public ArrayList okpath(){

ReadPath f = new ReadPath();

f.setPath("c:\\aaa\\");

f.refreshList();

ArrayList list = new ArrayList();

while (f.nextFile()) {

list.add(f.path+f.getFileName());

}

return list;

}

/* public static void main(String[] args) {

ReadPath f = new ReadPath();

ArrayList list1 = f.okpath();

for(int j=0;j

System.out.println(list1.get(j));

}

}*/ }

package admit.action;

import java.sql.*;

import java.util.ArrayList;

import java.io.*;

import oracle.sql.*;

public class WriteBlob { public static void main(String[] args) {

try {

DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());

Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.100:1521:adminsys","admit","wuyue");

conn.setAutoCommit(false);

ReadPath readPath=new ReadPath();

ArrayList list = readPath.okpath();

/* String ff[]=new String[2];

String fileName = "c://tupian.gif"; */

for(int i=0;i

System.out.println("路径名="+list.get(i).toString());

File f = new File(list.get(i).toString());

FileInputStream fin = new FileInputStream(f);

BLOB blob = null; PreparedStatement pstmt = conn.prepareStatement("insert into javatest(name,context) values(?,empty_blob())");

pstmt.setString(1,""+list.get(i).toString()+"");

pstmt.executeUpdate();

pstmt.close(); pstmt = conn.prepareStatement("select context from javatest where name= ? for update");

pstmt.setString(1,""+list.get(i).toString()+"");

ResultSet rset = pstmt.executeQuery();

if (rset.next()) blob = (BLOB) rset.getBlob(1); pstmt = conn.prepareStatement("update javatest set context=? where name=?"); OutputStream out = blob.getBinaryOutputStream(); int count = -1, total = 0;

byte[] data = new byte[(int)fin.available()];

fin.read(data);

out.write(data);

/*

byte[] data = new byte[blob.getBufferSize()]; 另一种实现方法,节省内存

while ((count = fin.read(data)) != -1) {

total += count;

out.write(data, 0, count);

}

*/

fin.close();

out.close(); pstmt.setBlob(1,blob);

pstmt.setString(2,""+list.get(i).toString()+"");

pstmt.executeUpdate();

pstmt.close();

System.out.println("插入成功！！！");

}

conn.commit();

conn.close();

} catch (SQLException e) {

System.err.println(e.getMessage());

e.printStackTrace();

} catch (IOException e) {

System.err.println(e.getMessage());

}

}

}

已赞过

已踩过<

你对这个回答的评价是？

评论

收起