chore: Restructure test directory names

Signed-off-by: Edmund Miller <[email protected]>

Author: edmundmiller

plugins/nf-sqldb/src/testResources/test-h2/nextflow.config

@@ -0,0 +1,22 @@
+/*
+ * Configuration file for the SQL execution example script
+ */
+
+// Enable the SQL DB plugin
+plugins {
+    id '[email protected]'
+}
+
+// Define a file-based H2 database for the example
+sql {
+    db {
+        demo {
+            url = 'jdbc:h2:./demo'
+            driver = 'org.h2.Driver'
+        }
+    }
+}
+
+// Silence unnecessary Nextflow logs
+process.echo = false
+dag.enabled = false 

plugins/nf-sqldb/src/testResources/test-h2/test_sql_db.nf

@@ -0,0 +1,122 @@
+#!/usr/bin/env nextflow
+
+/*
+ * Example script demonstrating how to use the SQL sqlExecute function
+ */
+
+include { sqlExecute } from 'plugin/nf-sqldb'
+include { fromQuery } from 'plugin/nf-sqldb'
+
+// Define database configuration in nextflow.config file
+// sql.db.demo = [url: 'jdbc:h2:mem:demo', driver: 'org.h2.Driver']
+
+workflow {
+    log.info """
+    =========================================
+    SQL Execution Function Example
+    =========================================
+    """
+
+    // Step 1: Create a table (DDL operation returns null)
+    log.info "Creating a sample table..."
+    def createResult = sqlExecute(
+        db: 'demo',
+        statement: '''
+            CREATE TABLE IF NOT EXISTS TEST_TABLE (
+                ID INTEGER PRIMARY KEY,
+                NAME VARCHAR(100),
+                VALUE DOUBLE
+            )
+        '''
+    )
+    log.info "Create table result: $createResult"
+
+    // Step 2: Insert some data (DML operation returns affected row count)
+    log.info "Inserting data..."
+    def insertCount = sqlExecute(
+        db: 'demo',
+        statement: '''
+            INSERT INTO TEST_TABLE (ID, NAME, VALUE) VALUES
+            (1, 'alpha', 10.5),
+            (2, 'beta', 20.7),
+            (3, 'gamma', 30.2),
+            (4, 'delta', 40.9);
+        '''
+    )
+    log.info "Inserted $insertCount rows"
+
+    // Step 3: Update some data (DML operation returns affected row count)
+    log.info "Updating data..."
+    def updateCount = sqlExecute(
+        db: 'demo',
+        statement: '''
+            UPDATE TEST_TABLE
+            SET VALUE = VALUE * 2
+            WHERE ID = 2;
+        '''
+    )
+    log.info "Updated $updateCount rows"
+
+    // Step 4: Delete some data (DML operation returns affected row count)
+    log.info "Deleting data..."
+    def deleteCount = sqlExecute(
+        db: 'demo',
+        statement: '''
+            DELETE FROM TEST_TABLE
+            WHERE ID = 4;
+        '''
+    )
+    log.info "Deleted $deleteCount rows"
+
+    // Step 5: Query results
+    log.info "Querying results..."
+    channel
+        .fromQuery("SELECT * FROM TEST_TABLE ORDER BY ID", db: 'demo')
+        .view { row -> "ID: ${row[0]}, Name: ${row[1]}, Value: ${row[2]}" }
+}
+
+workflow example {
+    // Setup: create table (DDL operation)
+    def createResult = sqlExecute(
+        db: 'foo',
+        statement: '''
+            CREATE TABLE IF NOT EXISTS testing (
+                id INTEGER PRIMARY KEY,
+                name VARCHAR(100),
+                value DOUBLE
+            )
+        '''
+    )
+    println "Create table success: ${createResult.success}" // Should be true
+
+    // Handle potential failure
+    if (!createResult.success) {
+        println "Failed to create table: ${createResult.error}"
+        return
+    }
+
+    // Insert data using sqlInsert
+    Channel
+        .of([1, 'alpha', 10.5], [2, 'beta', 20.5])
+        .sqlInsert(
+            db: 'foo',
+            into: 'sample_table',
+            columns: 'id, name, value'
+        )
+
+    // Query data using fromQuery
+    fromQuery('SELECT * FROM sample_table', db: 'foo')
+        .view()
+
+    // Update data using sqlExecute (DML operation returns affected row count in result field)
+    def updateResult = sqlExecute(
+        db: 'foo',
+        statement: "UPDATE sample_table SET value = 30.5 WHERE name = 'beta'"
+    )
+
+    if (updateResult.success) {
+        println "Updated ${updateResult.result} row(s)"
+    } else {
+        println "Update failed: ${updateResult.error}"
+    }
+}