db_exec

Execute a SQL INSERT, UPDATE, or DELETE statement against a database.

Parameters

Context Output

On successful execution:

• rows_affected -- Number of rows affected by the statement.
• db_exec_success -- Boolean true.

Example

local flow = Flow.new("sqlite_crud")

local db = "sqlite:/tmp/app.db?mode=rwc"

flow:step("create_table", nodes.db_exec({
    connection = db,
    query = "CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, active BOOLEAN)"
}))

flow:step("insert_user", nodes.db_exec({
    connection = db,
    query = "INSERT INTO users (name, active) VALUES (?, ?)",
    params = { "${ctx.user_name}", true }
})):depends_on("create_table")

flow:step("deactivate_user", nodes.db_exec({
    connection = db,
    query = "UPDATE users SET active = ? WHERE name = ?",
    params = { false, "${ctx.user_name}" }
})):depends_on("insert_user")

return flow

Notes

• The connection string follows the sqlx URL format. For SQLite, use sqlite:/path/to/file?mode=rwc.
• Query parameters use positional ? placeholders. The params array values are bound in order.
• String parameters support context interpolation (${ctx.key}), so you can dynamically construct statements based on upstream step outputs.
• Null values in params are bound as SQL NULL.
• Boolean values are bound as their native SQL type (e.g., INTEGER 0/1 for SQLite).
• This node is intended for write operations. For SELECT queries, use db_query.

See Also

• db_query -- Execute SELECT queries and return rows.