diff --git a/gateway-ha/src/main/java/io/trino/gateway/proxyserver/MultiReadHttpServletRequest.java b/gateway-ha/src/main/java/io/trino/gateway/proxyserver/MultiReadHttpServletRequest.java index 35d8e6249..f706bf0e4 100644 --- a/gateway-ha/src/main/java/io/trino/gateway/proxyserver/MultiReadHttpServletRequest.java +++ b/gateway-ha/src/main/java/io/trino/gateway/proxyserver/MultiReadHttpServletRequest.java @@ -21,7 +21,7 @@ import java.io.BufferedReader; import java.io.ByteArrayInputStream; import java.io.IOException; -import java.io.StringReader; +import java.io.Reader; import java.nio.charset.StandardCharsets; public class MultiReadHttpServletRequest @@ -87,6 +87,6 @@ public int read(byte[] b) public BufferedReader getReader() throws IOException { - return new BufferedReader(new StringReader(new String(content, StandardCharsets.UTF_8))); + return new BufferedReader(Reader.of(new String(content, StandardCharsets.UTF_8))); } } diff --git a/gateway-ha/src/test/java/io/trino/gateway/ha/router/TestRoutingGroupSelector.java b/gateway-ha/src/test/java/io/trino/gateway/ha/router/TestRoutingGroupSelector.java index 0e2f47c1d..e1a92726b 100644 --- a/gateway-ha/src/test/java/io/trino/gateway/ha/router/TestRoutingGroupSelector.java +++ b/gateway-ha/src/test/java/io/trino/gateway/ha/router/TestRoutingGroupSelector.java @@ -34,7 +34,7 @@ import java.io.BufferedWriter; import java.io.File; import java.io.IOException; -import java.io.StringReader; +import java.io.Reader; import java.nio.file.Files; import java.nio.file.Path; import java.util.Arrays; @@ -526,7 +526,7 @@ uno as (SELECT c1 FROM dos) TrinoQueryProperties trinoQueryPropertiesWithDefaults = getTrinoQueryProps(mockRequestNoDefaults); Set tablesWithDefaults = trinoQueryPropertiesWithDefaults.getTables(); assertThat(tablesWithDefaults).containsExactly(QualifiedName.of("cat", "schem", "tbl1")); - when(mockRequestNoDefaults.getReader()).thenReturn(new BufferedReader(new StringReader(query))); + when(mockRequestNoDefaults.getReader()).thenReturn(new BufferedReader(Reader.of(query))); TrinoQueryProperties trinoQueryPropertiesNoDefaults = (TrinoQueryProperties) mockRequestNoDefaults.getAttribute(TRINO_QUERY_PROPERTIES); Set tablesNoDefaults = trinoQueryPropertiesNoDefaults.getTables(); diff --git a/gateway-ha/src/test/java/io/trino/gateway/ha/util/QueryRequestMock.java b/gateway-ha/src/test/java/io/trino/gateway/ha/util/QueryRequestMock.java index 3cc4a9231..f2bd14b9a 100644 --- a/gateway-ha/src/test/java/io/trino/gateway/ha/util/QueryRequestMock.java +++ b/gateway-ha/src/test/java/io/trino/gateway/ha/util/QueryRequestMock.java @@ -37,7 +37,7 @@ import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStream; -import java.io.StringReader; +import java.io.Reader; import java.net.URI; import java.net.URISyntaxException; import java.nio.charset.StandardCharsets; @@ -118,7 +118,7 @@ public int read() } }); - when(mockRequest.getReader()).thenReturn(new BufferedReader(new StringReader(query))); + when(mockRequest.getReader()).thenReturn(new BufferedReader(Reader.of(query))); when(mockRequest.getQueryString()).thenReturn(""); return this; } diff --git a/pom.xml b/pom.xml index 71dae8075..504ec4fc0 100644 --- a/pom.xml +++ b/pom.xml @@ -43,7 +43,7 @@ 25.0.0 true true - 8 + 25 clean verify -DskipTests @@ -101,6 +101,17 @@ + + org.gaul + modernizer-maven-plugin + + + + java/util/Optional.get:()Ljava/lang/Object; + + + + org.apache.maven.plugins maven-compiler-plugin