Method executeDML

backend/executor.go:221–269

(ctx *sql.Context, n sql.Node, conn *stdsql.Conn)

// isStandaloneVectorConversion routes SELECT STRING_TO_VECTOR(...) without a
// data table through DuckDB's guarded UDF. The selected GMS version panics when
// its own scalar evaluator encodes an empty vector.
func isStandaloneVectorConversion(ctx *sql.Context, n sql.Node) bool {
	c := &tableAndFuncCollector{ctx: ctx}
	transform.Walk(c, n)

	for _, table := range c.tables {
		if !plan.IsDualTable(table.UnderlyingTable()) {
			return false
		}
	}

	found := false
	for _, fn := range c.functions {
		if _, ok := fn.(*vectorfn.StringToVector); !ok {
			return false
		}
		found = true
	}
	return found
}

func (b *DuckBuilder) executeExpressioner(ctx *sql.Context, n sql.Expressioner, conn *stdsql.Conn) (sql.RowIter, error) {
	node := n.(sql.Node)
	switch n := n.(type) {
	case *plan.InsertInto:
		if n.Returning != nil {
			return b.executeQuery(ctx, node, conn)
		}
		return b.executeDML(ctx, node, conn)
	case *plan.Update:
		if n.Returning == nil {
			n.Child = withMySQLOkResultSchema(n.Child)
		}
		return b.executeDML(ctx, node, conn)
	default:
		return b.executeQuery(ctx, node, conn)
	}
}

func (b *DuckBuilder) executeQuery(ctx *sql.Context, n sql.Node, conn *stdsql.Conn) (sql.RowIter, error) {
	ctx.GetLogger().Trace("Executing Query...")

	var (
		duckSQL string
		err     error
	)

	// Translate the MySQL query to a DuckDB query
	switch n := n.(type) {
	case *plan.ShowTables:
		duckSQL = ctx.Query()
	case *plan.ResolvedTable: