Java异常错误 - Sqlite preparedStatement.setBlob

Question

我正在将一张图片存入数据库，可以是MYSQL数据库（服务器）或者是SQLITE数据库（平板电脑用于在路上）。Java应用程序每天与服务器同步，上传新数据并下载任何新数据。这部分已经很好地工作了。然而，要求它也能够处理图像。

我们选择使用数据库中的BLOB，而不是实现一个依赖于在每个端点上复制图像到文件系统的全新系统。真正需要帮助的是当我尝试写入BLOB时，在分派中出现异常。

我们从数据库构建输入表单，因为整个应用程序被用于不同的目的，取决于数据库。输入表单允许您将图像附加到记录中，我们将其存储为base64字符串。然后将其解码为byte[]。

我的测试程序可以轻松地在字符串和byte数组之间以及最终的图像之间进行转换。所以我相当确信问题在于设置准备语句中的BLOB，但我可能错了。

异常发生在点击保存按钮之后。

Exception occurred during event dispatching:
java.lang.AbstractMethodError: org.sqlite.PrepStmt.setBlob(ILjava/io/InputStream;J)V
    at tabletapp.database.DB.prepareStatement(DB.java:641)
    at tabletapp.database.DB.save(DB.java:743)
    at tabletapp.FormPanel.saveData(FormPanel.java:546)

有问题的代码块。

public void prepareStatement(String table, String sql, LinkedHashMap<String, String> data) {
    try {
        String typeID = "";
        PreparedStatement ps = connection.prepareStatement(sql);
        log.debug("Preparing SQL: " + sql.replace("\n", ""));
        int parameterIndex = 1;

        //for (String columnName : getColumnNames(table)) {
        for (String columnName : data.keySet()) {
            typeID = getColumnType(table, columnName);

            if (data.containsKey(columnName)) {
                String value = data.get(columnName);
                if (value == null || "".equals(value)) {
                    //log.debug(columnName+":"+parameterIndex+" set to null");
                    ps.setNull(parameterIndex, Types.NULL);
                } else {
                    //log.debug(columnName+":"+parameterIndex+" set to "+value);
                    switch (getColumnTypeId(table, columnName)) {
                        case Types.VARCHAR:
                        case Types.CHAR:
                            ps.setString(parameterIndex, value);
                            break;

                        case Types.TIMESTAMP:
                            DateFormat timestampFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                            java.util.Date timstamp = new java.util.Date();
                            ps.setString(parameterIndex, timestampFormat.format(timstamp));
                            break;

                        case Types.DATE:
                            DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
                            java.util.Date date = new java.util.Date();
                            ps.setString(parameterIndex, dateFormat.format(date));
                            break;

                        case Types.SMALLINT:
                        case Types.INTEGER:
                        case Types.NUMERIC:
                            ps.setInt(parameterIndex, new Integer(value));
                            break;

                        case Types.FLOAT:
                            ps.setFloat(parameterIndex, new Float(value));
                            break;

                        case Types.BLOB:
                            // convert string to byte array to blob
                            byte[] bData = null;
                            try {
                               bData = new BASE64Decoder().decodeBuffer(value);
                               log.info("I have Bytes[]");
                            }
                            catch (Exception e){
                                log.info("Something went Horribly, Horribly Wrong");
                            }

                            // Note tried the follwowing
                            //Blob blob=connection.createBlob();
                            // blob.setBytes(bData.length, bData);
                            // ps.setBlob(parameterIndex,blob);

                            ByteArrayInputStream bais = new ByteArrayInputStream(bData);
                            ps.setBlob(parameterIndex, bais,bData.length);


                            break;

                        case Types.BOOLEAN:
                        case Types.BIT:
                            //log.debug(table + "." + columnName + " (boolean) = " + value);
                            if ("1".equals(value) || "true".equals(value)) {
                                ps.setBoolean(parameterIndex, true);
                            } else {
                                ps.setBoolean(parameterIndex, false);
                            }
                            break;
                    }
                }
                parameterIndex++;
            }
        }
        ps.executeUpdate();
        connection.commit();
    } catch (SQLException e) {
        log.error("Error in sql: " + sql);
        e.printStackTrace();
    }

}

非常感谢您的帮助。

- Peter

Answer 1

根据Xerial group最新的一篇文章，sqlite-jdbc中没有实现setBlob方法。对于我来说，建议的替代方法 如果您的二进制数据足够小且可以作为字节数组加载到内存中，则运行良好。

- Sven

---

救了我一命！我只有5分钟的时间来解决问题，而这就是它！ - Peter Perháč

Answer 2

尝试使用“count”字段获取你的ByteArrayInputStream对象bais的长度，而不是解码后字符串的长度。

- AmbrosiaDevelopments

---

不确定是否可能，因为count是在ByteArrayInputStream内受保护的，那么我该如何访问它呢？其次，我认为流一次只有一个字节？我仍然在努力理解这个过程，所以我可能离轨了。 - Peter