Package com.alibaba.cloud.ai.node

Class SqlExecuteNode

java.lang.Object

com.alibaba.cloud.ai.node.AbstractPlanBasedNode

com.alibaba.cloud.ai.node.SqlExecuteNode

All Implemented Interfaces:

NodeAction

public class SqlExecuteNode
extends AbstractPlanBasedNode

SQL execution node that executes SQL queries against the database. This node is responsible for: - Executing SQL queries generated by previous nodes - Handling query results and errors - Providing streaming feedback to users during execution - Managing step-by-step result accumulation

Author:

zhangshenghang

Constructor Summary

Constructors

Constructor	Description
SqlExecuteNode(Accessor dbAccessor, DatasourceService datasourceService)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	apply(OverAllState state)

Methods inherited from class com.alibaba.cloud.ai.node.AbstractPlanBasedNode

getCurrentExecutionStep, getCurrentStepNumber, getPlan, logNodeEntry, logNodeOutput

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SqlExecuteNode

public SqlExecuteNode(Accessor dbAccessor,
 DatasourceService datasourceService)

Method Details

apply

public Map<String,Object> apply(OverAllState state)
                         throws Exception

Throws:

Exception