如何使用 Vert.x 将 Blob 插入到 oracle 数据库 11g 中?
how to insert Blob into oracle database 11g using Vert.x?
我正在尝试使用 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");
}
});
我正在尝试使用 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");
}
});