Execute SQL Node

E

Data/DataFusion/Tools

Execute a SQL query and return results as formatted text. Ideal for agent-driven data exploration.

df_execute_sqldata

Inputs4

Outputs4

Security exposure8/10

Packagedata

Ratings

Scores range from 0 to 10. Higher values mean more impact, exposure, or operational weight.

SecurityAttack surface and exposure impact.

8/10High

PrivacyPotential sensitivity of processed data.

10/10High

PerformanceRuntime or resource pressure.

7/10High

GovernancePolicy, audit, or compliance impact.

8/10High

ReliabilityOperational stability considerations.

8/10High

CostExternal or compute cost impact.

10/10High

Input Pins

4

Input

Execution

exec_in

Trigger execution

Session

Struct

session

DataFusion session to query

SchemaDataFusionSessionDataFusionSessionDataFusionSession1 fields

cache_keystringrequired

Query

String

query

SQL query to execute. Use $placeholders for values that come from the flow (SELECT * FROM users WHERE id = $user_id) — each one adds an input pin to wire the value into. Placeholders stand for values only; table and column names cannot be parameterized.

Default SELECT * FROM data LIMIT 10

Params

Struct

params

Values for the query's $placeholders, as an object keyed by placeholder name without the $ (e.g. {"customer_id": 42}). Only needed when the query itself comes from a wire — a literal query derives one pin per placeholder instead. Where both supply the same name, the derived pin wins unless it is empty.

Default {}

Output Pins

4

Done

Execution

exec_out

Execution completed

Result

String

result

Query results formatted as markdown table

Table

Struct

table

Query results as CSVTable for further processing

SchemaCSVTableCSVTableCSVTable6 fields

namestring | null

Optional name/identifier for this table

titlestring | null

Optional title text found above the table in the source sheet

rangestring | null

Optional A1 range the table was extracted from (e.g. "A3:F42")

headersArray<string>required

itemsstringarray item

rowsArray<Array<Cell>>required

itemsArray<Cell>array item

itemsCellarray item

variant 1nullvariant

variant 2booleanvariant

variant 3integer:int64variant

format int64

variant 4number:doublevariant

format double

variant 5stringvariant

+1 more fields

sourceanyOf (2)

variant 1FlowPathvariant

pathstringrequired

store_refstringrequired

cache_store_refstring | null

variant 2nullvariant

Row Count

Integer

row_count

Number of rows returned

Node Info

Internal name

df_execute_sql

Category

Data/DataFusion/Tools