sqlquery

package

v0.5.0 Latest Latest Go to latest Published: Jul 25, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aijustin/agentflow-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Config
type Executor
- func NewExecutor(config Config) (*Executor, error)
- func (executor *Executor) Execute(ctx context.Context, call core.ToolCall) (core.ToolResult, error)
type Request
type Response

Constants ¶

View Source

const DefaultMaxRows = 100

View Source

const DefaultTimeout = 5 * time.Second

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	DB              *sql.DB
	AllowedQueries  map[string]string
	AllowAdHocQuery bool
	MaxRows         int
	Timeout         time.Duration
}

type Executor ¶

type Executor struct {
	// contains filtered or unexported fields
}

func NewExecutor ¶

func NewExecutor(config Config) (*Executor, error)

func (*Executor) Execute ¶

func (executor *Executor) Execute(ctx context.Context, call core.ToolCall) (core.ToolResult, error)

Execute runs a read-only (SELECT/WITH) query; mutating statements are rejected by validateReadOnlyQuery, so this executor performs no side effects and needs no idempotency handling itself. Custom SQL *write* tools built on this pattern must instead deduplicate by the framework-injected idempotency key (core.IdempotencyKeyFromContext): the key is stable across recovery replays of the same logical execution, so writes should use it as a UPSERT conflict key / INSERT IGNORE discriminator or a dedupe-table primary key rather than issuing a bare INSERT.

type Request ¶

type Request struct {
	QueryID string `json:"query_id,omitempty"`
	Query   string `json:"query,omitempty"`
	Args    []any  `json:"args,omitempty"`
}

type Response ¶

type Response struct {
	QueryID   string           `json:"query_id,omitempty"`
	Columns   []string         `json:"columns"`
	Rows      []map[string]any `json:"rows"`
	RowCount  int              `json:"row_count"`
	Truncated bool             `json:"truncated,omitempty"`
}

Source Files ¶

View all Source files

executor.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL