Method RowIter

server/node/revoke.go:98–140

RowIter implements the interface sql.ExecSourceRel.

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

// RowIter implements the interface sql.ExecSourceRel.
func (r *Revoke) RowIter(ctx *sql.Context, _ sql.Row) (sql.RowIter, error) {
	if r.Cascade {
		return nil, errors.New("REVOKE does not yet support CASCADE")
	}

	var err error
	auth.LockWrite(func() {
		switch {
		case r.RevokeTable != nil:
			if err = r.revokeTable(ctx); err != nil {
				return
			}
		case r.RevokeSchema != nil:
			if err = r.revokeSchema(ctx); err != nil {
				return
			}
		case r.RevokeDatabase != nil:
			if err = r.revokeDatabase(ctx); err != nil {
				return
			}
		case r.RevokeSequence != nil:
			if err = r.revokeSequence(ctx); err != nil {
				return
			}
		case r.RevokeRoutine != nil:
			if err = r.revokeRoutine(ctx); err != nil {
				return
			}
		case r.RevokeRole != nil:
			if err = r.revokeRole(ctx); err != nil {
				return
			}
		default:
			err = errors.Errorf("REVOKE statement is not yet supported")
			return
		}
		err = auth.PersistChanges()
	})
	if err != nil {
		return nil, err
	}
	return sql.RowsToRowIter(), nil
}

// Schema implements the interface sql.ExecSourceRel.
func (r *Revoke) Schema(ctx *sql.Context) sql.Schema {