Update gateway-ha/src/main/java/io/trino/gateway/ha/router/TrinoQueryProperties.java

Co-authored-by: Jaeho Yoo <[email protected]>

Author: vishalya

gateway-ha/src/main/java/io/trino/gateway/ha/router/TrinoQueryProperties.java

@@ -243,11 +243,10 @@ else if (statement instanceof ExecuteImmediate executeImmediate) {
 
     private void processRequestBody(ContainerRequestContext requestContext)
     {
-        InputStream entityStream = requestContext.getEntityStream();
-        if (entityStream == null ||
-                !requestContext.hasEntity() || requestContext.getMediaType() == null ||
-                !requestContext.getMediaType().getParameters().containsKey("charset") ||
-                !StandardCharsets.UTF_8.name().equalsIgnoreCase(requestContext.getMediaType().getParameters().get("charset"))) {
+    if (!shouldProcessBody(requestContext)) {
+        return;
+    }
+
             return;
         }
         InputStreamReader entityReader = new InputStreamReader(entityStream, StandardCharsets.UTF_8);