|
9 | 9 | import com.clickhouse.client.ClickHouseResponse; |
10 | 10 | import com.clickhouse.client.ClickHouseSocketFactory; |
11 | 11 | import com.clickhouse.client.config.ClickHouseClientOption; |
| 12 | +import com.clickhouse.client.config.ClickHouseDefaults; |
12 | 13 | import com.clickhouse.client.config.ClickHouseProxyType; |
13 | 14 | import com.clickhouse.client.http.config.ClickHouseHttpOption; |
14 | 15 | import com.clickhouse.client.http.config.HttpConnectionProvider; |
|
42 | 43 | import com.github.tomakehurst.wiremock.stubbing.StubMapping; |
43 | 44 | import org.apache.hc.client5.http.socket.PlainConnectionSocketFactory; |
44 | 45 | import org.apache.hc.core5.http.HttpStatus; |
| 46 | +import org.apache.hc.core5.net.URIBuilder; |
45 | 47 | import org.testcontainers.shaded.org.checkerframework.checker.units.qual.A; |
46 | 48 | import org.testng.Assert; |
47 | 49 | import org.testng.annotations.DataProvider; |
@@ -293,13 +295,17 @@ public void testConnectionTTL(Map<ClickHouseOption, Serializable> options, int o |
293 | 295 | .networkTrafficListener(connectionCounter) |
294 | 296 | .notifier(new Slf4jNotifier(true))); |
295 | 297 | proxy.start(); |
| 298 | + URIBuilder targetURI = new URIBuilder(server.getBaseUri()) |
| 299 | + .setPath(""); |
296 | 300 | proxy.addStubMapping(WireMock.post(WireMock.anyUrl()) |
297 | | - .willReturn(WireMock.aResponse().proxiedFrom("http://localhost:" + server.getPort())).build()); |
| 301 | + .willReturn(WireMock.aResponse().proxiedFrom(targetURI.build().toString())).build()); |
298 | 302 |
|
299 | 303 | Map<ClickHouseOption, Serializable> baseOptions = new HashMap<>(); |
300 | 304 | baseOptions.put(ClickHouseClientOption.PROXY_PORT, proxyPort); |
301 | 305 | baseOptions.put(ClickHouseClientOption.PROXY_HOST, "localhost"); |
302 | 306 | baseOptions.put(ClickHouseClientOption.PROXY_TYPE, ClickHouseProxyType.HTTP); |
| 307 | + baseOptions.put(ClickHouseDefaults.PASSWORD, getPassword()); |
| 308 | + baseOptions.put(ClickHouseDefaults.USER, "default"); |
303 | 309 | baseOptions.putAll(options); |
304 | 310 |
|
305 | 311 | ClickHouseConfig config = new ClickHouseConfig(baseOptions); |
|
0 commit comments