-1

我在从数据库中正确检索我自己的类“BallotPaper”的特定对象时遇到问题。它可以正确保存，但在创建 ObjectInputStream 时会引发异常。

当然，我在这里阅读了许多类似的问题和答案，但仍然无法处理。

在数据库中，我有一个包含 bytea 类型列（它是 postgreSQL）的表，我在其中保存我的对象。

下面是几行代码：

//Saving the object 'paper' of the class 'BallotPaper'
    PreparedStatement st = connection.prepareStatement(query);
    ByteArrayOutputStream byos = new ByteArrayOutputStream();
    ObjectOutputStream oos = new ObjectOutputStream(byos);
    oos.writeObject(paper);
    byte[] bytePaper = byos.toByteArray();
    st.setBytes(1, bytePaper);
    st.executeUpdate();

    byos.close();
    oos.close();
    st.close(); 

//Trying to retrieve the object:
    String query2 = "SELECT paper FROM voters WHERE id="+_id+";";
    Statement s = connection.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
    ResultSet r = s.executeQuery(query2);
    r.first();
    bytePaper = r.getBytes(1);
    ByteArrayInputStream b = new ByteArrayInputStream(bytePaper);
    ObjectInputStream o = new ObjectInputStream(b); // *
    BallotPaper ba = (BallotPaper)o.readObject();

异常在最后一行抛出，标有 * 。

它看起来像这样：

java.io.StreamCorruptedException: invalid stream header: BB656430
at java.io.ObjectInputStream.readStreamHeader(Unknown Source)
at java.io.ObjectInputStream.<init>(Unknown Source)
at slave.VotersDB.saveFilledPaper(VotersDB.java:162)
at slave.ClientThread.prepareResponse(ClientThread.java:50)
at slave.ClientThread.run(ClientThread.java:72)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)

感谢您的所有回答。

4

2 回答 2

0

添加一个flush()：

oos.writeObject(paper);
oos.flush();
byte[] bytePaper = byos.toByteArray();

ObjectOutputStream允许缓冲其输出。您也可以调用close()而不是调用flush()，这至少可以清楚地表明您不应该再次使用流。

于 2012-12-28T19:13:09.090 回答
0

我终于设法解决了这个问题。结果证明不适合使用 setBytes() 方法保存二进制数据。相反，应该使用 setBinaryStream()。

使用第一种方法，序列化对象的字节与原来的完全不同。有人知道为什么吗？

这是正确的代码：

PreparedStatement st = connection.prepareStatement(query);    

ByteArrayOutputStream baos = new ByteArrayOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(baos);
oos.writeObject(paper); 
byte[] bytePaper = baos.toByteArray();

PipedInputStream pis = new PipedInputStream();
PipedOutputStream pos = new PipedOutputStream(pis);
pos.write(bytePaper);   
pos.flush();

st.setBinaryStream(1, pis,bytePaper.length);

检索方式没有改变。

于 2012-12-29T10:00:40.810 回答