File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed
client-v2/src/test/java/com/clickhouse/client Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -240,7 +240,7 @@ void testStringParams(String paramValue) throws Exception {
240240 "SELECT " + column + " FROM " + table + " WHERE " + column + "='" + paramValue + "'" ).get ();
241241 ClickHouseBinaryFormatReader reader = client .newBinaryFormatReader (r ))
242242 {
243- reader .next ();
243+ Assert . assertNotNull ( reader .next (), "No records were returned." );
244244 Assert .assertEquals (reader .getString (1 ), paramValue );
245245 }
246246 try (QueryResponse r = client .query (
Original file line number Diff line number Diff line change @@ -121,6 +121,9 @@ public void testCreateTableWithAllDataTypes() throws Exception {
121121 excludedTypes .add ("LowCardinality" ); // LowCardinality is a wrapper, not a base type
122122 excludedTypes .add ("Enum" ); // Enum is a base type, use Enum8 or Enum16 instead
123123 excludedTypes .add ("Object" ); // Deprecated and not used for while
124+ if (isCloud ()) {
125+ excludedTypes .add ("QBit" ); // Due to env specific
126+ }
124127
125128 // Build column definitions
126129 StringBuilder createTableSql = new StringBuilder ();
@@ -175,7 +178,7 @@ public void testCreateTableWithAllDataTypes() throws Exception {
175178 if (isVersionMatch ("[25.5,)" )) {
176179 commandSettings .serverSetting ("enable_time_time64_type" , "1" );
177180 }
178- if (isVersionMatch ("[25.10,)" )) {
181+ if (isVersionMatch ("[25.10,)" ) && ! isCloud () ) {
179182 commandSettings .serverSetting ("allow_experimental_qbit_type" , "1" );
180183 }
181184 } catch (Exception e ) {
You can’t perform that action at this time.
0 commit comments