列 "file" 是 oid 类型，但 expression 是 byte 类型

Question

我正在尝试使用 JSF 2.3 实现文件上传：

@Inject
@Push
private PushContext uploadProgress;

private static final Logger logger = Logger.getLogger(NewProcedure.class.getName());
private Part file;

public Part getFile()
{
    return file;
}

public void setFile(Part file)
{
    this.file = file;
}

public void upload() throws SQLException
{
    if (file != null)
    {
        try (InputStream inputStream = file.getInputStream();
            //FileOutputStream outputStream = new FileOutputStream(path)
            )
        {

            long lastTimestamp = System.currentTimeMillis();
            int pushInterval = 1000;
            long totalRead = 0;
            long size = file.getSize();

            int bytesRead = 0;
            final byte[] chunck = new byte[1024];
            while ((bytesRead = inputStream.read(chunck)) != -1)
            {
//                    outputStream.write(chunck, 0, bytesRead);
                totalRead += bytesRead;

                if (System.currentTimeMillis() > lastTimestamp + pushInterval)
                {
                    lastTimestamp = System.currentTimeMillis();
                    uploadProgress.send(100.0 * totalRead / size); // Make sure this isn't sent more often than once per second.
                }
            }

            Connection conn = ds.getConnection();
            // insert into database file
            PreparedStatement ps = null;
            boolean committed = false;
            try
            {
                conn.setAutoCommit(false);

                ps = conn.prepareStatement("INSERT INTO PROCEDURE_FILES (ID, PROCEDURE_ID, FILE_NAME, FILE) "
                    + " VALUES (?, ?, ?, ?)");
                ps.setInt(1, obj.number);
                ps.setInt(2, obj.number);
                ps.setString(3, "tests");
                ps.setBinaryStream(4, inputStream);

                ps.executeUpdate();
                ps.close();

                conn.commit();
                committed = true;
            }
            catch (SQLException e)
            {
                e.printStackTrace();
            }

            finally
            {
                if (!committed)
                {
                    conn.rollback();
                }

                if (ps != null)
                {
                    ps.close();
                }
                conn.close();
            }

            FacesContext.getCurrentInstance().addMessage(null, new FacesMessage("Upload successfully ended!"));
        }
        catch (IOException e)
        {
            FacesContext.getCurrentInstance().addMessage(null, new FacesMessage("Upload failed!"));
        }
    }
}

我想将文件直接插入数据库，但出现错误：

org.postgresql.util.PSQLException: ERROR: column "file" is of type oid but expression is of type bytea
  Hint: You will need to rewrite or cast the expression.

将文件插入数据库的正确方法是什么？可能我需要使用其他 Java 对象来存储文件？

P.S 我试过这个：

public static byte[] getBytesFromInputStream(InputStream is) throws IOException
    {
        try (ByteArrayOutputStream os = new ByteArrayOutputStream();)
        {
            byte[] buffer = new byte[0xFFFF];

            for (int len; (len = is.read(buffer)) != -1;)
                os.write(buffer, 0, len);

            os.flush();

            return os.toByteArray();
        }
    }

    public void upload() throws SQLException
    {
        if (file != null)
        {
            try
            {
                InputStream inputStream = file.getInputStream();

                byte[] bytesFromInputStream = getBytesFromInputStream(inputStream);
                ByteArrayInputStream input = new ByteArrayInputStream(bytesFromInputStream);


                long lastTimestamp = System.currentTimeMillis();
                int pushInterval = 1000;
                long totalRead = 0;
                long size = file.getSize();

                int bytesRead = 0;
                final byte[] chunck = new byte[1024];
                while ((bytesRead = inputStream.read(chunck)) != -1)
                {
//                    outputStream.write(chunck, 0, bytesRead);
                    totalRead += bytesRead;

                    if (System.currentTimeMillis() > lastTimestamp + pushInterval)
                    {
                        lastTimestamp = System.currentTimeMillis();
                        uploadProgress.send(100.0 * totalRead / size); // Make sure this isn't sent more often than once per second.
                    }
                }

                Connection conn = ds.getConnection();
                // insert into database file
                PreparedStatement ps = null;
                boolean committed = false;
                try
                {
                    conn.setAutoCommit(false);

                    ps = conn.prepareStatement("INSERT INTO PROCEDURE_FILES (ID, PROCEDURE_ID, FILE_NAME, FILE) "
                        + " VALUES (?, ?, ?, ?)");
                    ps.setInt(1, obj.number);
                    ps.setInt(2, obj.number);
                    ps.setString(3, file.getSubmittedFileName());
                    ps.setBinaryStream(4, input, input.available());

                    ps.executeUpdate();
                    ps.close();

                    conn.commit();
                    committed = true;
                }
                catch (SQLException e)
                {
                    e.printStackTrace();
                }
                finally
                {}
            }
            catch (IOException e)
            {}
        }
    }

Answer 1

删除 while-loop 读取 inputStream。

通过设置file列的二进制输入流进行读取。

这需要另一种进度指示。

现在的情况是inputStream读到最后，prepared statement只能读到0字节

public void upload() throws SQLException {
    if (file != null) {
        try (InputStream inputStream = file.getInputStream()) {

            long lastTimestamp = System.currentTimeMillis();
            int pushInterval = 1000;
            long totalRead = 0;
            long size = file.getSize();

            Connection conn = ds.getConnection();
            // insert into database file
            boolean committed = false;
            try {
                conn.setAutoCommit(false);

                try (PreparedStatement ps =
                        conn.prepareStatement("INSERT INTO PROCEDURE_FILES"
                                + " (ID, PROCEDURE_ID, FILE_NAME, FILE) "
                                + " VALUES (?, ?, ?, ?)")) {
                    ps.setInt(1, obj.number);
                    ps.setInt(2, obj.number);
                    ps.setString(3, "tests");
                    ps.setBinaryStream(4, inputStream);

                    ps.executeUpdate();
                }

                conn.commit();
                committed = true;
            }
            catch (SQLException e) {
                e.printStackTrace();
            }
            finally {
                if (!committed) {
                    conn.rollback();
                }
                conn.close();
            }

            FacesContext.getCurrentInstance().addMessage(null,
                    new FacesMessage("Upload successfully ended!"));
        }
        catch (IOException e) {
            FacesContext.getCurrentInstance().addMessage(null,
                    new FacesMessage("Upload failed!"));
        }
    }
}

列 "file" 是 oid 类型，但 expression 是 byte 类型

Column "file" is of type oid but expression is of type byte

java

sql

postgresql-9.2

postgresql-9.3