qryflow (version 0.2.0)

qryflow_execute: Execute a parsed qryflow SQL workflow

Description

qryflow_execute() takes a parsed workflow object (as returned by qryflow_parse()), executes each chunk (e.g., @query, @exec), and collects the results and timing metadata.

This function is used internally by qryflow_run(), but can be called directly in concert with qryflow_parse() if you want to manually control parsing and execution.

Usage

qryflow_execute(con, x, ..., source = NULL)

Value

An object of class qryflow_result, containing executed chunks with results and a meta field that includes timing and source information.

Arguments

con

A database connection from DBI::dbConnect()

x

A parsed qryflow workflow object, typically created by qryflow_parse()

...

Reserved for future use.

source

Optional; a character string indicating the source SQL to include in metadata.

See Also

qryflow_run(), qryflow_parse()

Examples

con <- example_db_connect(mtcars)

filepath <- example_sql_path("mtcars.sql")

parsed <- qryflow_parse(filepath)

executed <- qryflow_execute(con, parsed, source = filepath)

DBI::dbDisconnect(con)