Method BuildRowIter

server/node/drop_table.go:57–88

BuildRowIter implements the interface sql.ExecBuilderNode.

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

// BuildRowIter implements the interface sql.ExecBuilderNode.
func (c *DropTable) BuildRowIter(ctx *sql.Context, b sql.NodeExecBuilder, r sql.Row) (sql.RowIter, error) {
	dropTableIter, err := b.Build(ctx, c.gmsDropTable, r)
	if err != nil {
		return nil, err
	}

	for _, table := range c.gmsDropTable.Tables {
		var dbName string
		var schemaName string
		var tableName string
		switch table := table.(type) {
		case *plan.ResolvedTable:
			schemaName, err = core.GetSchemaName(ctx, table.Database(), "")
			if err != nil {
				return nil, err
			}
			tableName = table.Name()
			dbName = table.Database().Name()
		default:
			return nil, errors.Errorf("encountered unexpected table type `%T` during DROP TABLE", table)
		}

		tableID := id.NewTable(schemaName, tableName).AsId()
		if err = id.ValidateOperation(ctx, id.Section_Table, id.Operation_Delete, dbName, tableID, id.Null); err != nil {
			return nil, err
		}
		if err = id.PerformOperation(ctx, id.Section_Table, id.Operation_Delete, dbName, tableID, id.Null); err != nil {
			return nil, err
		}
	}
	return dropTableIter, err
}

// Schema implements the interface sql.ExecBuilderNode.
func (c *DropTable) Schema(ctx *sql.Context) sql.Schema {