NIFI-14345 Update QuestDB to 8.3.1 and adjusting client usage

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes apache#9947.

Author: simonbence

nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/pom.xml

@@ -35,7 +35,7 @@
         <dependency>
             <groupId>org.questdb</groupId>
             <artifactId>questdb</artifactId>
-            <version>8.1.4</version>
+            <version>8.3.1</version>
         </dependency>
         <dependency>
             <groupId>org.springframework</groupId>

nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedClient.java

@@ -54,10 +54,9 @@ final class EmbeddedClient implements Client {
     public void execute(final String query) throws DatabaseException {
         checkConnectionState();
 
-        try (final SqlCompiler compiler = getCompiler()) {
-            final CompiledQuery compile = compiler.compile(query, getSqlExecutionContext());
-            compile.execute(new SCSequence(new TimeoutBlockingWaitStrategy(5, TimeUnit.SECONDS)));
-        } catch (final SqlException | CairoError e) {
+        try {
+            engine.get().execute(query, getSqlExecutionContext(), new SCSequence(new TimeoutBlockingWaitStrategy(5, TimeUnit.SECONDS)));
+        } catch (SqlException e) {
             throw new DatabaseException(e);
         }
     }

nifi-framework-bundle/nifi-framework-extensions/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java

@@ -25,6 +25,8 @@
 import org.apache.nifi.questdb.Client;
 import org.apache.nifi.questdb.DatabaseException;
 import org.apache.nifi.questdb.DatabaseManager;
+import org.apache.nifi.questdb.QueryResultProcessor;
+import org.apache.nifi.questdb.QueryRowContext;
 import org.apache.nifi.util.file.FileUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -183,7 +185,17 @@ private void ensureTablesAreInPlaceAndHealthy() throws CorruptedDatabaseExceptio
                         metadata.close();
                     }
 
-                    client.execute(String.format("SELECT * FROM %S LIMIT 1", tableDefinition.getName()));
+                    client.query(String.format("SELECT * FROM %S LIMIT 1", tableDefinition.getName()), new QueryResultProcessor<>() {
+                        @Override
+                        public void processRow(final QueryRowContext context) {
+                            // Nothing to do, checking for successful execution
+                        }
+
+                        @Override
+                        public Object getResult() {
+                            return null;
+                        }
+                    });
                 } catch (final Exception e) {
                     throw new CorruptedDatabaseException(e);
                 }