问题描述
我正在尝试使用vert.x将BLOB插入Oracle数据库,我得到了上载文件
for (FileUpload f : routingContext.fileUploads()){ System.out.println("file name " + f.fileName()); System.out.println("size name " + f.size()); System.out.println("Uploaded File " + f.uploadedFileName()); }
我使用以下命令将FileUpload转换为字节数组:
Buffer fileUploaded = routingContext.vertx().fileSystem().readFileBlocking(f.uploadedFileName()); byte[] fileUploadedBytes = fileUploaded.getBytes();现在我想将其直接插入Oracle数据库,我已经尝试使用updateWithParams,但我不知道如何将Blob添加到查询参数中。 感谢您的帮助
推荐答案
这是我的实现来解决我的问题,现在我可以将文件BLOB插入到ORACLE数据库中,我希望这能在未来对某人有所帮助。
ByteArrayInputStream finalBis = bis; byte[] finalFileUploadedBytes = fileUploadedBytes; DB.getConnection(connection -> { if (connection.succeeded()) { CallableStatement stmt = null; try { stmt = connection.result().getConnection().prepareCall(SQL.INSERT_DOCS_QUERY); stmt.setBinaryStream(1, finalBis, finalFileUploadedBytes.length); stmt.setString(2,desiDoc); stmt.setString(3,sourDoc); logger.debug(stmt); stmt.execute(); finalBis.close(); } catch (SQLException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } else { System.out.println("nooot ok"); } });