Method executeQuery

backend/executor.go:183–219

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

func (b *DuckBuilder) executeExpressioner(ctx *sql.Context, n sql.Expressioner, conn *stdsql.Conn) (sql.RowIter, error) {
	node := n.(sql.Node)
	switch n.(type) {
	case *plan.InsertInto:
		return b.executeDML(ctx, node, conn)
	case *plan.Update:
		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:
		// SQLGlot cannot translate MySQL's `TABLE t` into DuckDB's `FROM t` - it produces `"table" AS t` instead.
		duckSQL = `FROM ` + catalog.ConnectIdentifiersANSI(n.Database().Name(), n.Name())
	default:
		duckSQL, err = transpiler.TranslateWithSQLGlot(queryForTranslation(ctx))
	}
	if err != nil {
		return nil, catalog.ErrTranspiler.New(err)
	}
	duckSQL = QueryForJSONScan(duckSQL, n.Schema())

	if log := ctx.GetLogger(); log.Logger.IsLevelEnabled(logrus.TraceLevel) {
		log.WithFields(logrus.Fields{
			"Query":   ctx.Query(),
			"DuckSQL": duckSQL,
		}).Trace("Executing Query...")
	}