|
15 | 15 | import com.clickhouse.client.http.config.HttpConnectionProvider; |
16 | 16 | import com.clickhouse.config.ClickHouseOption; |
17 | 17 | import com.clickhouse.data.ClickHouseUtils; |
18 | | - |
19 | | -import java.io.IOException; |
20 | | -import java.io.Serializable; |
21 | | -import java.net.ConnectException; |
22 | | -import java.net.Socket; |
23 | | -import java.nio.ByteBuffer; |
24 | | -import java.util.Collections; |
25 | | -import java.util.HashMap; |
26 | | -import java.util.List; |
27 | | -import java.util.Map; |
28 | | -import java.util.Random; |
29 | | -import java.util.TreeMap; |
30 | | -import java.util.concurrent.atomic.AtomicBoolean; |
31 | | -import java.util.concurrent.atomic.AtomicInteger; |
32 | | - |
33 | 18 | import com.github.tomakehurst.wiremock.WireMockServer; |
34 | 19 | import com.github.tomakehurst.wiremock.client.WireMock; |
35 | | -import com.github.tomakehurst.wiremock.client.WireMockBuilder; |
36 | 20 | import com.github.tomakehurst.wiremock.common.Slf4jNotifier; |
37 | 21 | import com.github.tomakehurst.wiremock.core.WireMockConfiguration; |
38 | 22 | import com.github.tomakehurst.wiremock.http.Fault; |
39 | | -import com.github.tomakehurst.wiremock.http.trafficlistener.CollectingNetworkTrafficListener; |
40 | 23 | import com.github.tomakehurst.wiremock.http.trafficlistener.WiremockNetworkTrafficListener; |
41 | 24 | import com.github.tomakehurst.wiremock.stubbing.Scenario; |
42 | | -import com.github.tomakehurst.wiremock.stubbing.ServeEvent; |
43 | 25 | import com.github.tomakehurst.wiremock.stubbing.StubMapping; |
44 | 26 | import org.apache.hc.client5.http.socket.PlainConnectionSocketFactory; |
45 | 27 | import org.apache.hc.core5.http.HttpStatus; |
46 | 28 | import org.apache.hc.core5.net.URIBuilder; |
47 | | -import org.testcontainers.shaded.org.checkerframework.checker.units.qual.A; |
48 | 29 | import org.testng.Assert; |
49 | 30 | import org.testng.annotations.DataProvider; |
50 | 31 | import org.testng.annotations.Ignore; |
51 | 32 | import org.testng.annotations.Test; |
52 | | -import org.testng.collections.Maps; |
| 33 | + |
| 34 | +import java.io.IOException; |
| 35 | +import java.io.Serializable; |
| 36 | +import java.net.ConnectException; |
| 37 | +import java.net.Socket; |
| 38 | +import java.nio.ByteBuffer; |
| 39 | +import java.util.Collections; |
| 40 | +import java.util.HashMap; |
| 41 | +import java.util.List; |
| 42 | +import java.util.Map; |
| 43 | +import java.util.Random; |
| 44 | +import java.util.TreeMap; |
| 45 | +import java.util.concurrent.atomic.AtomicBoolean; |
| 46 | +import java.util.concurrent.atomic.AtomicInteger; |
53 | 47 |
|
54 | 48 | public class ApacheHttpConnectionImplTest extends ClickHouseHttpClientTest { |
55 | 49 | public static class CustomSocketFactory implements ClickHouseSocketFactory { |
@@ -284,7 +278,12 @@ public static Object[] validationTimeoutProvider() { |
284 | 278 | } |
285 | 279 |
|
286 | 280 | @Test(groups = {"integration"},dataProvider = "testConnectionTTLProvider") |
| 281 | + @SuppressWarnings("java:S2925") |
287 | 282 | public void testConnectionTTL(Map<ClickHouseOption, Serializable> options, int openSockets) throws Exception { |
| 283 | + if (isCloud()) { |
| 284 | + // skip for cloud because wiremock proxy need extra configuration. TODO: need to fix it |
| 285 | + return; |
| 286 | + } |
288 | 287 | ClickHouseNode server = getServer(ClickHouseProtocol.HTTP); |
289 | 288 |
|
290 | 289 | int proxyPort = new Random().nextInt(1000) + 10000; |
@@ -361,12 +360,12 @@ public void opened(Socket socket) { |
361 | 360 |
|
362 | 361 | @Override |
363 | 362 | public void incoming(Socket socket, ByteBuffer bytes) { |
364 | | - |
| 363 | + // ignore |
365 | 364 | } |
366 | 365 |
|
367 | 366 | @Override |
368 | 367 | public void outgoing(Socket socket, ByteBuffer bytes) { |
369 | | - |
| 368 | + // ignore |
370 | 369 | } |
371 | 370 |
|
372 | 371 | @Override |
|
0 commit comments