如何使用 Helidon MP REST 服务将文件作为 Blob/Clob 上传到 Oracle DB

Question

我是 Helidon MP 的新手，想知道是否可以通过使用 Helidon MP 创建的 REST 服务将文件上传到 Oracle DB（Blob/Clob 列）。

我可以使用下面的代码在 SpringBoot 中实现相同的要求，接受文件参数作为 MultiPart，我们如何使用 Helidon MP 来实现这一点

@PostMapping("/upload")
      public ResponseEntity<ResponseMessage> uploadFile(@RequestParam("file") MultipartFile file) {
        String message = "";
        try {
          storageService.store(file);

          message = "Uploaded the file successfully: " + file.getOriginalFilename();
          return ResponseEntity.status(HttpStatus.OK).body(new ResponseMessage(message));
        } catch (Exception e) {
          message = "Could not upload the file: " + file.getOriginalFilename() + "!";
          return ResponseEntity.status(HttpStatus.EXPECTATION_FAILED).body(new ResponseMessage(message));
        }
      }    

Answer 1

Helidon 通过 MP 和 SE 提供对 multi-part 数据的支持（带有缓冲和流式 API SE) 口味的版本。

实现依赖于 Jersey 与 MIME MultiPart 消息的集成（与任何 JAX-RS 提供程序非常相似）。

允许上传文件的控制器端点方法的实现很简单，如下所示：

import import javax.ws.rs.*;
import org.glassfish.jersey.media.multipart.*;

@POST
@Path("/upload")
@Consumes(MediaType.MULTIPART_FORM_DATA)
public Response upload(MultiPart multiPart) throws IOException {

    multiPart.getBodyParts().stream()
            .filter(part -> /* retrieve your file part here, should be based on the `Content-Disposition` name parameter */ )
            .map(filePart -> {
                String fileName  = pfilePartart.getContentDisposition().getFileName();
                InputStream is = filePart.getEntityAs(BodyPartEntity.class).getInputStream();
                // use the injected `storageService` to somehow store the input stream
                this.storageService.store(fileName, is);
            });
    
}

请注意，JAX-RS 多部分功能默认未激活，因此应使用 JAX-RS 提供程序激活：

import javax.ws.rs.core.*;
import javax.ws.rs.ext.Provider;

@Provider
public class MultiPartFeatureProvider implements Feature {

    @Override
    public boolean configure(FeatureContext context) {
        return new MultiPartFeature().configure(context);
    }
}