0

我正在尝试使用在 blob 列后面的字段中找到的值从 blob 中提取文件。我的解决方案有效，但速度相当慢。

我在大约 1 小时内提取了 169MB（727 个不同的文件）。这大约是每分钟 12 个文件。大多数文件通常在 5KB 和 50KB 之间，但有时可能高达 2MB。我正在使用本地 Oracle 数据库。

我能做些什么来提高我的代码效率吗？如果不是，还有哪些其他因素可能会影响流程的速度？这是该方法的代码：

public void beginExtraction(String FileOutDir, String blobSQL,
        String fileSuffix, Connection conn) {

    if ((FileOutDir != null) && (blobSQL != null) && (conn != null)) {
        PreparedStatement selBlobs = null;
        FileOutputStream fos = null;

        if (conn != null) {
            if (blobSQL != null) {
                try {

                    selBlobs = conn.prepareStatement(blobSQL);
                    ResultSet rs = selBlobs.executeQuery();
                    int cols = rs.getMetaData().getColumnCount();

                    while (rs.next()) {

                        Blob blob = rs.getBlob(1);
                        InputStream is = blob.getBinaryStream();

                        String filepath = "";

                        filepath += FileOutDir + "/";

                        for (int c = 2; c <= cols; c++) {
                            filepath += rs.getObject(c).toString() + "_";
                        }

                        filepath = filepath.substring(0,
                                filepath.length() - 1);
                        filepath += fileSuffix;
                        fos = new FileOutputStream(filepath);

                        int b = 0;
                        while ((b = is.read()) != -1) {
                            fos.write(b);
                        }

                    }

                    selBlobs.close();
                    fos.close();

                } catch (Exception e) {
                    JOptionPane.showMessageDialog(gui, e.toString());
                }
            }
        }
    } else {
        if (conn == null) {
            JOptionPane.showMessageDialog(gui,
                    "You have not selected a database.");
        } else {
            if (FileOutDir == null) {
                JOptionPane.showMessageDialog(gui,
                        "You have not chosen a directory for your files.");
            } else {
                if (blobSQL == null) {
                    JOptionPane.showMessageDialog(gui,
                            "Please insert an SQL statement.");

                }
            }
        }
    }
}
4

1 回答 1

1

更改为缓冲输出使该过程成倍地加快。我能够在一分钟内导出 727 个文件。这里是新代码：

//...

                    while (rs.next()) {

                        blob = rs.getBlob(1);
                        is = blob.getBinaryStream();
                        filepath += "/";

                        for (int c = 2; c <= cols; c++) {
                            filepath += rs.getObject(c).toString() + "_";
                        }
                        filepath = filepath.substring(0,
                                filepath.length() - 1);
                        filepath += fileSuffix;

                        fos = new BufferedOutputStream(new FileOutputStream(filepath));

                        while ((b = is.read()) != -1) {
                            fos.write(b);
                        }

                        filepath = FileOutDir;
                        b = 0;
                    }

 //...
于 2013-10-30T13:55:55.987 回答