Skip to content

Commit 36418f2

Browse files
docs: Update sqlExecute documentation on outputs
Co-authored-by: Paolo Di Tommaso <[email protected]> Signed-off-by: Edmund Miller <[email protected]>
1 parent 1d8072c commit 36418f2

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

README.md

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -132,14 +132,14 @@ This plugin provides the following function for executing SQL statements that do
132132

133133
### sqlExecute
134134

135-
The `sqlExecute` function executes a SQL statement that doesn't return a result set, such as `CREATE`, `ALTER`, `DROP`, `INSERT`, `UPDATE`, or `DELETE` statements. For DML statements (`INSERT`, `UPDATE`, `DELETE`), it returns the number of rows affected. For DDL statements (`CREATE`, `ALTER`, `DROP`), it returns `null`.
135+
The `sqlExecute` function executes a SQL statement that doesn't return a result set, such as `CREATE`, `ALTER`, `DROP`, `INSERT`, `UPDATE`, or `DELETE` statements. For DML statements (`INSERT`, `UPDATE`, `DELETE`), it returns a Map with `success: true` and `result` set to the number of rows affected. For DDL statements (`CREATE`, `ALTER`, `DROP`), it returns a Map with `success: true` and `result: null`.
136136

137137
For example:
138138

139139
```nextflow
140140
include { sqlExecute } from 'plugin/nf-sqldb'
141141
142-
// Create a table (returns null for DDL operations)
142+
// Create a table (returns Map with result: null for DDL operations)
143143
def createResult = sqlExecute(
144144
db: 'foo',
145145
statement: '''
@@ -150,28 +150,28 @@ def createResult = sqlExecute(
150150
)
151151
'''
152152
)
153-
println "Create result: $createResult" // null
153+
println "Create result: $createResult" // [success: true, result: null]
154154
155-
// Insert data (returns 1 for number of rows affected)
155+
// Insert data (returns Map with result: 1 for number of rows affected)
156156
def insertedRows = sqlExecute(
157157
db: 'foo',
158158
statement: "INSERT INTO sample_table (id, name, value) VALUES (1, 'alpha', 10.5)"
159159
)
160-
println "Inserted $insertedRows row(s)"
160+
println "Inserted $insertedRows.row(s)" // [success: true, result: 1]
161161
162-
// Update data (returns number of rows updated)
162+
// Update data (returns Map with result: number of rows updated)
163163
def updatedRows = sqlExecute(
164164
db: 'foo',
165165
statement: "UPDATE sample_table SET value = 30.5 WHERE name = 'alpha'"
166166
)
167-
println "Updated $updatedRows row(s)"
167+
println "Updated $updatedRows.row(s)" // [success: true, result: <number>]
168168
169-
// Delete data (returns number of rows deleted)
169+
// Delete data (returns Map with result: number of rows deleted)
170170
def deletedRows = sqlExecute(
171171
db: 'foo',
172172
statement: "DELETE FROM sample_table WHERE value > 25"
173173
)
174-
println "Deleted $deletedRows row(s)"
174+
println "Deleted $deletedRows.row(s)" // [success: true, result: <number>]
175175
```
176176

177177
The following options are available:

0 commit comments

Comments
 (0)