3

MySQL の COMPRESS 関数で返された値を解凍しようとしています。

SQLQuery query = session
            .createSQLQuery("SELECT ID, COMPRESS(TEXT_COL) AS TEXT_COL FROM TABLE WHERE ID IN (1,2,3,...);")
            .addScalar("ID", Hibernate.INTEGER)
            .addScalar("TEXT_COL", Hibernate.TEXT);
List<Object[]> list = query.list();
for (Object[] result : list) {
   String text = decompress(((String) result[1]).getBytes());
}

(...)
private String decompress(byte[] bs) {
    InputStream in = new InflaterInputStream(new ByteArrayInputStream(bs));
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    try {
        byte[] buffer = new byte[8192];
        int len;
        while((len = in.read(buffer))>0)
            baos.write(buffer, 0, len);
        return new String(baos.toByteArray(), "UTF-8");
    } catch (IOException e) {
        throw new AssertionError(e);
    }
}

そして、私は java.lang.AssertionError: java.util.zip.ZipException: wrong header checkを取得しています

そのようなmysqlの結果を解凍する方法は何ですか、または私のコードの何が問題なのですか?

前もってありがとう、ディエゴ。

編集: 提案をしてくれたジョニに感謝し、最終的にコードを次のように変更しました

SQLQuery query = session
            .createSQLQuery("SELECT ID, COMPRESS(TEXT_COL) AS TEXT_COL FROM TABLE WHERE ID IN (1,2,3,...);")
            .addScalar("ID", Hibernate.INTEGER)
            .addScalar("TEXT_COL", Hibernate.BINARY);
List<Object[]> list = query.list();
for (Object[] result : list) {
   String text = decompress(((byte[]) result[1]));
}

(...)
private String decompress(byte[] bs) {
    InputStream in = new InflaterInputStream(new ByteArrayInputStream(bs, 4, bs.length-4));
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    try {
        byte[] buffer = new byte[8192];
        int len;
        while((len = in.read(buffer))>0)
            baos.write(buffer, 0, len);
        return new String(baos.toByteArray(), "UTF-8");
    } catch (IOException e) {
        throw new AssertionError(e);
    }
}
4

1 に答える 1