Method RowIter

server/node/show_schemas.go:58–94

RowIter implements the interface sql.ExecSourceRel.

(ctx *sql.Context, r sql.Row)

// RowIter implements the interface sql.ExecSourceRel.
func (s *ShowSchemas) RowIter(ctx *sql.Context, r sql.Row) (sql.RowIter, error) {
	database := s.database
	if database == "" {
		database = ctx.GetCurrentDatabase()
		if database == "" {
			return nil, errors.New("no database selected (this is a bug)")
		}
	}

	db, err := core.GetSqlDatabaseFromContext(ctx, database)
	if err != nil {
		return nil, err
	}

	if db == nil {
		return nil, errors.New("database not found: " + database)
	}

	sdb, ok := db.(sql.SchemaDatabase)
	if !ok {
		// This handles any database that doesn't support schemas (such as some system databases)
		// TODO: mirror the postgres behavior of returning, every database should have schemas
		return sql.RowsToRowIter(), nil
	}

	schemas, err := sdb.AllSchemas(ctx)
	if err != nil {
		return nil, err
	}

	rows := make([]sql.Row, len(schemas))
	for i, schema := range schemas {
		rows[i] = sql.Row{schema.SchemaName()}
	}

	return sql.RowsToRowIter(rows...), nil
}

// Schema implements the interface sql.ExecSourceRel.
func (s *ShowSchemas) Schema(ctx *sql.Context) sql.Schema {