oracle中实现ftp文件上传下载VIP

1、敲好最近有机会用到ftp发送接收文件，总结一下oracle里面ftp发送接收的方法。Java 中可以使用.ftp.FtpClient 实现简单的ftp操作，这是在oracle数据库中有提供 api 的。我个人觉得对于ftp的操作用java方式比较方便，代码简单容易懂而且广泛。不过oracle 中也有提供ftp访问的包UTL_TCP,通过这个包也可以很方便的实现 ftp操作。Java方式实现ftp客户端操作在oracle数据库中有提供 .即.FtpClient,所以可以直接使用该包完成简单的ftp操作在oracle数据库端。这里有个问题没有解决：ftp文件追加时候，发现没有提供FtpClient

2、.append() 函数，但是在一般的java程序中式可以使用，测试都是在jdk1.4版本上进行的。还是在 oracle里面这个功能不允许还是我没有找到append替代方法呢？createorreplaceandcompilejavasourcenamedremoteFtpClient ASpackage oracle.apps.zz.zzmes;importjava.io.BufferedReader; importjava.io.DataInputStream; importjava.io.File;importjava.io.IOException;importjava.io.Input

3、StreamReader; importjava.io.RandomAccessFile; importjava.io.FileInputStream; importjava.util.StringTokenizer; .TelnetInputStream; .TelnetOutputStream; .ftp.FtpClient; .*;.ftp.*;importorg.apache.*;.ftp.*;.ftp.FTP.*;.ftp.FTP.*;publicclass remoteFtpClientprivatestring host;privatestring username;privat

4、eStringpassword ;private FtpClientclient;public remoteFtpClient()public remoteFtpClient( String Host, String userName, StringpassWordthis.host=Host;/ip 地址this.username=userName;用户名this.password= passWord ;/ 密码this.client= new FtpClient();public voidsetHost( String Host)host=Host;public voidsetUserNa

5、me( String userName)username=userName;public voidsetPassword( String pwd)password =pwd;*获取和远程ftp服务器的连接 */publicboolean getFtpConnection() /client= new FtpClient();try client.openServer(host);client.login(username, password );client.ascii();client.binary();6000 );设置超时client.setConnectTimeout(System.o

6、ut.println(loginsucess);catch(IOExceptione) /TODO Auto -generated catch block e.printStackTrace();returnfalse ;returntrue ;/*关闭即连接*/public voidcloseConnection() if(client!= null ) try client.closeServer();catch(IOExceptione)/TODO Auto -generated catch blocke.printStackTrace();client= null ;/*实现即文件上传

7、parameters*fileName:文件名*sendcontent :要发送的内容*path :上传的路径，路径为空则取登录ftp后的默认路径*return:成功返回true ,失败返回false*/ publicboolean sendXml2Ftp( String fileName, String sendContent, String path)tryif(path!= null )client.cd(path); / 发现在数据库中不能使用 client.append(path);String lineSeparator=System.getProperty(line.separa

8、tor);TelnetOutputStreamos=client.put(fileName);/ 创建一个新的文件或者覆盖/client.rename(index,wip); 重新命名文件名称TelnetOutputStreamos=client.append(fileName);os.write(sendContent.getBytes(UTF-8);os.write(sendContent.getBytes(GB2312);String encoding=System.getProperty(file.encoding); os.write(sendContent.getBytes(enc

9、oding);os.close();client.rename(arg0,arg1)/client.sendServer(DELEwip.xml); / 删除文件catch(IOExceptione)System.out.println(insertarecordtoerrortable!);/TODO Auto -generated catch blocke.printStackTrace();returnfalse ;returntrue ;publicstaticString replaceAllString( String str, String pattern, String rep

10、laces) StringBuffer result = new StringBuffer();StringTokenizerstrToken= new StringTokenizer(str,pattern);while (strToken.hasMoreTokens()result.append( String )strToken.nextToken();result.append(replaces);return result.toString();/*实现即下载parameters:*fileName:文件名称*path:文件路径*return:ftp 文件内容*/publicStri

11、ng loadXml2Temp( String fileName, String path) TelnetInputStreamfget;String xmlString= null ;String encoding=System.getProperty(file.encoding);String temp;tryif(path!= null )client.cd(path);fget=client.get(fileName);否则在中文时候会有乱码/InputStreamReaders= new InputStreamReader(fget,GB2312);/接收的字符集需要和要下载的文件最

12、好字符集相同，InputStreamReaders= new InputStreamReader(fget,UTF-8);BufferedReader in = new BufferedReader(s);StringBuffersb= new StringBuffer();while (temp=in.readLine()!= null )sb.append(temp.trim();sb.append(n);xmlString=sb.toString();s.close();catch(IOExceptione)/TODO Auto -generated catch blocke.print

13、StackTrace();returnnull ; return xmlString;通过在另一个java存储过程调用以上的以上ftp存储过程，可以实现ftp文件的上传下载例如：createorreplaceandcompilejavasourcenamed ftpSendGetTest ASpackage oracle.apps.zz.zzmes;importjava.sql.Clob;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.sql.SQLException;importjava.util.Ha

14、shtable;importoracle.xml.sql.query.OracleXMLQuery;importjava.io.*;.ftp.FtpClient;importoracle.sql.*;importoracle.jdbc.OracleDriver;importjava.sql.Connection;publicclass ftpSendGetTest/实现ftp下载，并转换为xml文件格式并返回clobpublicstaticCLOB getXml( String host, String username, String pwd, String fileName, String

15、 path)String xml=;CLOBtempClob= null ;/ftp类构造remoteFtpClientfc= new remoteFtpClient(host,username,pwd);if(fc.getFtpConnection() / 连接ftpxml=fc.loadXml2Temp(fileName,path); / 调用下载函数if(xml!= null )try / 实现String 转换为 clobConnectionconn= new OracleDriver().defaultConnection();tempClob=CLOB.createTemporar

16、y(conn, true ,CLOB.DURATION_SESSION);tempClob.open(CLOB.MODE_READWRITE);WritertempClobWriter=tempClob.getCharacterOutputStream();tempClobWriter.write(xml);tempClobWriter.flush();tempClobWriter.close();tempClob.close();conn.close();catch(SQLExceptione)/TODO Auto -generated catch blocke.printStackTrac

17、e();catch(IOExceptione)/TODO Auto -generated catch blocke.printStackTrace();fc.closeConnection(); / 关闭 ftp 连接 return tempClob;/发送数据到ftppublicstaticString sendxml( String host, String username, String pwd, String fileName, Str ing path, String content) String b=N;remoteFtpClientfc= new remoteFtpClien

18、t(host,username,pwd);if(fc.getFtpConnection() / 连接ftpif(fc.sendXml2Ftp(fileName,content,path) / 发送文件b=Y fc.closeConnection(); / 关闭 ftp 连接return b;Pl/sql中实现ftp客户端操作在oracle中提供了数据库包 SYS.utl_tcp实现客户端操作。ftp操作详细的可以查看该package.举例一个简单的ftp上传下载程序。ftp连接FUNCTION login(p_host INVARCHAR2 ,p_port INVARCHAR2，/ftp 端口

19、 21p_user INVARCHAR2 , p_pass INVARCHAR2p_timeout INNUMBER := NULL )RETURN UTL_TCP.connection ISl_connUTL_TCP.connection;BEGINl_conn:=UTL_TCP.open_connection(p_host,p_port,tx_timeout=p_timeout);get_reply(l_conn);send_command(l_conn,USER |p_user);send_command(l_conn,PASS |p_pass);RETURN l_conn;END ;f

20、tp关闭连接PROCEDURE logout(p_conn INOUTNOCOPY UTL_TCP.connection,p_reply INBOOLEAN := TRUE)ASl_replyt_string_table:=t_string_table();BEGINsend_command(p_conn, QUIT ,l_reply);UTL_TCP.close_connection(p_conn);END ;ftp下载FUNCTION get_remote_data(p_conn INOUTNOCOPY UTL_TCP.connection,p_file INVARCHAR2 )RETUR

21、NCLOBISl_connUTL_TCP.connection;l_amount PLS_INTEGER;l_buffer VARCHAR2 (32767 );l_data CLOB ;BEGINDBMS_LOB.createtemporary(lob_loc=l_data,cache= TRUE,dur=DBMS_LOB.call);l_conn:=get_passive(p_conn);send_command(p_conn, RETR|p_file, TRUE);BEGINLOOPl_amount:=UTL_TCP.read_text(l_conn,l_buffer, 32767 );DBMS_LOB.writeappend(l_data,l_amount,l_buffer);ENDLOOP ;EXCEPTIONWHEN UTL_TCP.END_OF_INPUT THENNULL ;WHENOTHERSTHENNULL ;END ;UTL_TCP.close_connection(l_conn);RETURN l_data;EXCEPTIONWHEN