added clusterAllReplicas for reading query_log

Author: chernser

client-v2/src/test/java/com/clickhouse/client/HttpTransportTests.java

@@ -806,7 +806,7 @@ public void testUserAgentHasCompleteProductName(String clientName, Pattern userA
             client.execute("SYSTEM FLUSH LOGS").get().close();
 
             List<GenericRecord> logRecords = client.queryAll("SELECT http_user_agent, http_referer, " +
-                    " forwarded_for  FROM system.query_log WHERE query_id = '" + q1Id + "'");
+                    " forwarded_for  FROM clusterAllReplicas('default', system.query_log) WHERE query_id = '" + q1Id + "'");
             Assert.assertFalse(logRecords.isEmpty(), "No records found in query log");
 
             for (GenericRecord record : logRecords) {
@@ -864,7 +864,7 @@ public void testClientName(String clientName, boolean setWithUpdate, String user
             client.execute("SYSTEM FLUSH LOGS").get().close();
 
             List<GenericRecord> logRecords = client.queryAll("SELECT query_id, client_name, http_user_agent, http_referer " +
-                    " FROM system.query_log WHERE query_id = '" + settings.getQueryId() + "'");
+                    " FROM clusterAllReplicas('default', system.query_log) WHERE query_id = '" + settings.getQueryId() + "'");
             Assert.assertEquals(logRecords.get(0).getString("query_id"), settings.getQueryId());
             final String logUserAgent = logRecords.get(0).getString("http_user_agent");
             Assert.assertTrue(logUserAgent.startsWith(expectedClientNameStartsWith),
@@ -905,7 +905,7 @@ public void testClientNameThruRawOptions(String property, String value, boolean
             client.execute("SYSTEM FLUSH LOGS").get().close();
 
             List<GenericRecord> logRecords = client.queryAll("SELECT query_id, client_name, http_user_agent, http_referer " +
-                    " FROM system.query_log WHERE query_id = '" + settings.getQueryId() + "'");
+                    " FROM clusterAllReplicas('default', system.query_log) WHERE query_id = '" + settings.getQueryId() + "'");
             Assert.assertEquals(logRecords.get(0).getString("query_id"), settings.getQueryId());
             final String logUserAgent = logRecords.get(0).getString("http_user_agent");
             Assert.assertTrue(logUserAgent.startsWith(value),

jdbc-v2/src/test/java/com/clickhouse/jdbc/ConnectionTest.java

@@ -311,7 +311,7 @@ public void setAndGetClientInfoTest(String clientName) throws SQLException {
             stmt.execute("SYSTEM FLUSH LOGS");
 
 
-            final String logQuery ="SELECT http_user_agent FROM system.query_log WHERE query_id = " +  stmt.enquoteLiteral(queryId);
+            final String logQuery ="SELECT http_user_agent FROM clusterAllReplicas('default', system.query_log) WHERE query_id = " +  stmt.enquoteLiteral(queryId);
             try (ResultSet rs = stmt.executeQuery(logQuery)) {
                 Assert.assertTrue(rs.next());
                 String userAgent = rs.getString("http_user_agent");
@@ -346,7 +346,7 @@ private void influenceUserAgentTest(String clientName, String urlParam) throws S
             stmt.execute("SYSTEM FLUSH LOGS");
 
             final String logQuery ="SELECT http_user_agent " +
-                    " FROM system.query_log WHERE query = '" + testQuery.replaceAll("'", "\\\\'") + "'";
+                    " FROM clusterAllReplicas('default', system.query_log) WHERE query = '" + testQuery.replaceAll("'", "\\\\'") + "'";
             try (ResultSet rs = stmt.executeQuery(logQuery)) {
                 Assert.assertTrue(rs.next());
                 String userAgent = rs.getString("http_user_agent");