Execute SQL Node

E

Data/DataFusion/Tools

Execute a read-only SQL query and return results as formatted text. Ideal for agent-driven data exploration; writing statements are rejected.

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.

Schemaobjectobjectobject0 fields

No named fields in this schema.

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