Skip to content

Commit 47b33cb

Browse files
committed
added clusterAllReplicas
1 parent e7cf09c commit 47b33cb

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -309,7 +309,7 @@ public void setAndGetClientInfoTest(String clientName) throws SQLException {
309309
stmt.execute("SYSTEM FLUSH LOGS");
310310

311311
final String logQuery ="SELECT http_user_agent " +
312-
" FROM system.query_log WHERE query = '" + testQuery.replaceAll("'", "\\\\'") + "'";
312+
" FROM clusterAllReplicas('default', system.query_log) WHERE query = '" + testQuery.replaceAll("'", "\\\\'") + "'";
313313
try (ResultSet rs = stmt.executeQuery(logQuery)) {
314314
Assert.assertTrue(rs.next());
315315
String userAgent = rs.getString("http_user_agent");

0 commit comments

Comments
 (0)