|
2 | 2 |
|
3 | 3 | import com.clickhouse.client.ClickHouseNode; |
4 | 4 | import com.clickhouse.client.ClickHouseSslContextProvider; |
5 | | -import com.clickhouse.client.api.Client; |
6 | | -import com.clickhouse.client.api.ClientConfigProperties; |
7 | | -import com.clickhouse.client.api.ClientException; |
8 | | -import com.clickhouse.client.api.ClientFaultCause; |
9 | | -import com.clickhouse.client.api.ClientMisconfigurationException; |
10 | | -import com.clickhouse.client.api.ConnectionInitiationException; |
| 5 | +import com.clickhouse.client.api.*; |
11 | 6 | import com.clickhouse.client.api.ConnectionReuseStrategy; |
12 | | -import com.clickhouse.client.api.ServerException; |
13 | 7 | import com.clickhouse.client.api.data_formats.internal.SerializerUtils; |
14 | 8 | import com.clickhouse.client.api.enums.ProxyType; |
15 | 9 | import com.clickhouse.client.api.http.ClickHouseHttpProto; |
|
31 | 25 | import org.apache.hc.client5.http.socket.LayeredConnectionSocketFactory; |
32 | 26 | import org.apache.hc.client5.http.socket.PlainConnectionSocketFactory; |
33 | 27 | import org.apache.hc.client5.http.ssl.SSLConnectionSocketFactory; |
34 | | -import org.apache.hc.core5.http.ClassicHttpResponse; |
35 | | -import org.apache.hc.core5.http.ConnectionRequestTimeoutException; |
36 | | -import org.apache.hc.core5.http.ContentType; |
37 | | -import org.apache.hc.core5.http.Header; |
38 | | -import org.apache.hc.core5.http.HttpEntity; |
39 | | -import org.apache.hc.core5.http.HttpHeaders; |
40 | | -import org.apache.hc.core5.http.HttpHost; |
41 | | -import org.apache.hc.core5.http.HttpRequest; |
42 | | -import org.apache.hc.core5.http.HttpStatus; |
43 | | -import org.apache.hc.core5.http.NoHttpResponseException; |
| 28 | +import org.apache.hc.core5.http.*; |
44 | 29 | import org.apache.hc.core5.http.config.CharCodingConfig; |
45 | 30 | import org.apache.hc.core5.http.config.Http1Config; |
46 | 31 | import org.apache.hc.core5.http.config.RegistryBuilder; |
|
58 | 43 | import org.slf4j.Logger; |
59 | 44 | import org.slf4j.LoggerFactory; |
60 | 45 |
|
61 | | -import javax.net.ssl.KeyManager; |
62 | 46 | import javax.net.ssl.SSLContext; |
63 | 47 | import javax.net.ssl.SSLException; |
64 | | -import javax.net.ssl.TrustManager; |
65 | 48 | import javax.net.ssl.X509TrustManager; |
66 | 49 | import java.io.IOException; |
67 | 50 | import java.io.InputStream; |
68 | 51 | import java.io.OutputStream; |
69 | 52 | import java.lang.reflect.Method; |
70 | | -import java.net.ConnectException; |
71 | | -import java.net.InetSocketAddress; |
72 | | -import java.net.NoRouteToHostException; |
73 | | -import java.net.Socket; |
74 | | -import java.net.SocketTimeoutException; |
75 | | -import java.net.URI; |
76 | | -import java.net.URISyntaxException; |
77 | | -import java.net.URL; |
78 | | -import java.net.UnknownHostException; |
| 53 | +import java.net.*; |
79 | 54 | import java.nio.charset.StandardCharsets; |
80 | | -import java.security.KeyManagementException; |
81 | 55 | import java.security.NoSuchAlgorithmException; |
82 | | -import java.security.SecureRandom; |
83 | 56 | import java.security.cert.X509Certificate; |
84 | | -import java.util.Base64; |
85 | | -import java.util.Collection; |
86 | | -import java.util.Collections; |
87 | | -import java.util.HashMap; |
88 | | -import java.util.Map; |
89 | | -import java.util.Objects; |
90 | | -import java.util.Properties; |
91 | | -import java.util.Set; |
| 57 | +import java.util.*; |
92 | 58 | import java.util.concurrent.ConcurrentLinkedQueue; |
93 | 59 | import java.util.concurrent.TimeUnit; |
94 | 60 | import java.util.concurrent.atomic.AtomicLong; |
@@ -834,22 +800,4 @@ public long getTime() { |
834 | 800 | return count > 0 ? runningAverage / count : 0; |
835 | 801 | } |
836 | 802 | } |
837 | | - |
838 | | - private static final class TrustAllManager implements X509TrustManager { |
839 | | - |
840 | | - @Override |
841 | | - public void checkClientTrusted(X509Certificate[] chain, String authType) { |
842 | | - // ignore |
843 | | - } |
844 | | - |
845 | | - @Override |
846 | | - public void checkServerTrusted(X509Certificate[] chain, String authType) { |
847 | | - // ignore |
848 | | - } |
849 | | - |
850 | | - @Override |
851 | | - public X509Certificate[] getAcceptedIssuers() { |
852 | | - return new X509Certificate[0]; |
853 | | - } |
854 | | - } |
855 | 803 | } |
0 commit comments