0

在过去的两天里，我一直被这个问题困扰。我已经将 java 函数存储在 Oracle 系统中，该函数应该从本地驱动器复制图像做远程数据库并将其存储在 BLOB 中 - 它称为 CopyBLOB，如下所示：

  import java.sql.*;  
  import oracle.sql.*;
  import java.io.*;

public class CopyBLOB 
{
  static int id;
  static String  fileName = null;
  static Connection conn = null;  

  public CopyBLOB(int idz, String f) 
  {
    id       = idz;
    fileName   = f;
  }

   public static void copy(int ident, String path) throws SQLException, FileNotFoundException 
   {
       CopyBLOB cpB = new CopyBLOB(ident, path);
       cpB.getConnection();
       cpB.callUpdate(id, fileName);
   }

    public void getConnection() throws SQLException
    {    
     DriverManager.registerDriver (new oracle.jdbc.OracleDriver());
     try 
     {     
       conn = DriverManager.getConnection("jdbc:oracle:thin:@oraserv.ms.mff.cuni.cz:1521:db", "xxx", "xxx");
     } 
     catch (SQLException sqlex) 
     {
         System.out.println("SQLException while getting db connection: "+sqlex);
         if (conn != null)  conn.close();
     } 
     catch (Exception ex) 
     {
         System.out.println("Exception while getting db connection: "+ex);
         if (conn != null) conn.close();
     }
    }

    public void callUpdate(int id, String file ) throws SQLException, FileNotFoundException 
    {
      CallableStatement cs = null;
      try 
      {  
        conn.setAutoCommit(false);
        File f = new File(file);
        FileInputStream fin = new FileInputStream(f);
        cs = (CallableStatement) conn.prepareCall( "begin add_image(?,?); end;" );
        cs.setInt(1, id );
        cs.setBinaryStream(2, fin, (int) f.length());
        cs.execute();
        conn.setAutoCommit(true);        
      } 
      catch ( SQLException sqlex ) 
      {
            System.out.println("SQLException in callUpdateUsingStream method of given status : " + sqlex.getMessage() );
      } 
      catch ( FileNotFoundException fnex ) 
      {
            System.out.println("FileNotFoundException in callUpdateUsingStream method of given status : " + fnex.getMessage() );
      } 
      finally 
      {
          try 
          {          
            if (cs != null)  cs.close();
            if (conn != null) conn.close();
          } 
          catch ( Exception ex ) 
          {
            System.out.println("Some exception in callUpdateUsingStream method of given status : " + ex.getMessage(  ) );
          }
      }
    }
}

包装函数在包“MyPackage”中定义如下：

  procedure image_adder( id varchar2, path varchar2 )  
  AS
    language java name 'CopyBLOB.copy(java.lang.String, java.lang.String)';

而名为 image_add 的插入函数就这么简单：

procedure add_image( id numeric(10), pic blob)
  AS 

  BEGIN
    insert into pictures values (seq_pic.nextval, id, pic);
  END add_image;

现在的问题：当我输入

call MyPackage.image_adder(1, 'd:\samples\img.jpg');

我收到 ORA-29531 错误：CopyBLOB 类中没有方法复制。你能帮我吗？

4

1 回答 1

1

您类中的方法具有以下签名：

public static void copy(int ident, String path)

但是在您的 Java 存储过程中，您已经指定了这个签名：

'CopyBLOB.copy(java.lang.String, java.lang.String)'

我认为如果您将第一个论点更改为java,lang.Integer您的问题应该会自行解决。您可能还应该更改 IMAGE_ADDER() 过程中 ID 参数的数据类型。

编辑

“任何想法如何上传本地文件？”

并非没有道理，数据库只能与对其服务器可见的文件进行交互。通常，除非网络管理员映射了一些远程驱动器，否则这仅限于物理上位于同一盒子上的文件和目录。

将文件从本地 PC 驱动器传输到服务器实际上是客户端（即应用程序）问题，它不是数据库真正应该参与的事情。

我知道这不是你希望听到的。如果你真的想驱动从数据库上传文件，那么每当我们想通过网络传输文件时，机制都是一样的：FTP。Tim Hall 在他的 Oracle-Base 站点上发布了 FTP 的 PL/SQL 实现。 了解更多。

“只要文件小于 2000B（WTF？）”

这可疑地接近 BINARY CHAR 限制（2000 年）。在旧版本的 Oracle 中，我们必须使用两步过程：插入占位符，然后发出更新。像这样的东西：

  procedure add_image( id numeric(10), pic blob) 
  AS       
  BEGIN 
      insert into pictures 
          values (seq_pic.nextval, id, empty_blob()); 
      update pictures 
      set col_pic = pic
      where id = seq_pic.currval;
  END add_image;
于 2010-06-12T16:04:11.127 回答