0

我需要创建一个JButton从 oracle 数据库下载 BLOB 文件。这是我的JButton代码：

JButton btnsave = new JButton("Save");
btnsave.setBounds(478, 542, 120, 23);
getContentPane().add(btnsave);
btnsave.addActionListener(new ActionListener() {

    public void actionPerformed(ActionEvent e) {


}
});

这个类已经连接到数据库，但这是我的代码的一部分：

Connection con;


String link="*******************************************";
       String u="user";
       String p="pw";
       Class.forName("oracle.jdbc.driver.OracleDriver");
       conn=DriverManager.getConnection(link,u,p);


Statement su=con.createStatement();

ActionListener那么我怎样才能下载我的 blob 文件JButton呢？我还需要创建另一个语句吗？

提前致谢！

4

2 回答 2

4

您可以使用此代码（但我目前无法尝试）。query是查询，子句index中的索引列SELECT，file是输出文件。

// take the result of the query
ResultSet rs = su.executeQuery(query);
while(rs.next()) { // for each row
   // take the blob
   Blob blob = rs.getBlob(index);
   BufferedInputStream is = new BufferedInputStream(blob.getBinaryStream());
   FileOutputStream fos = new FileOutputStream(file);
   // you can set the size of the buffer
   byte[] buffer = new byte[2048];
   int r = 0;
   while((r = is.read(buffer))!=-1) {
      fos.write(buffer, 0, r);
   }
   fos.flush();
   fos.close();
   is.close();
   blob.free();
}
su.close();

同样，我目前无法尝试此代码。在确保它像你想要的那样工作之前对其进行测试。

于 2013-05-23T09:31:28.933 回答
0

不建议在 ActionListener 中执行长操作。试试这个方法：

  • 实现回调以通知您的 blob 已加载
  • 实现执行 SQL 操作的线程（加载 blob）
  • 创建从 prev 开始线程的 ActionListener。步

这是一个例子：

private JButton button = new JButton(new ClickListener());
private LoaderListener blobLoaderListener = new BlobLoaderListener();
private byte[] blob;
private Connection con; // connection code is ommited

private class ClickListener extends AbstractAction {
    @Override
    public void actionPerformed(ActionEvent e) {
        new SQLLoader(blobLoaderListener).start();
    }
}

private class SQLLoader extends Thread {
    private final LoaderListener listener;

    public SQLLoader(LoaderListener listener) {
        this.listener = listener;
    }

    public void run() {
        byte[] blob = null;
        try {
            // create another statement here 
            Statement su = con.createStatement();

            // perform you SQL query, get your 'blog'
            // once you have done, notify listener
            listener.onLoad(blob);
        } catch (Exception e) {
            // TODO: handle exception
            listener.onError();
        }
    }
}

private interface LoaderListener {
    void onLoad(byte[] blob);

    void onError();
}

private class BlobLoaderListener implements LoaderListener {
    @Override
    public void onLoad(byte[] blob) {
        BlobLoader.this.blob = blob;
        // notify UI about changes
    }

    @Override
    public void onError() {
        // TODO 
    }
}
于 2013-05-23T09:33:56.767 回答