rewriteSupport.c File Reference

#include "postgres.h"
#include "access/htup_details.h"
#include "access/table.h"
#include "catalog/indexing.h"
#include "catalog/pg_class.h"
#include "catalog/pg_rewrite.h"
#include "rewrite/rewriteSupport.h"
#include "utils/inval.h"
#include "utils/lsyscache.h"
#include "utils/syscache.h"

Include dependency graph for rewriteSupport.c:

Go to the source code of this file.

Functions
bool	IsDefinedRewriteRule (Oid owningRel, const char *ruleName)
void	SetRelationRuleStatus (Oid relationId, bool relHasRules)
Oid	get_rewrite_oid (Oid relid, const char *rulename, bool missing_ok)

Function Documentation

get_rewrite_oid()

Oid get_rewrite_oid	(	Oid	relid,
		const char *	rulename,
		bool	missing_ok
	)

Definition at line 92 of file rewriteSupport.c.

{
    HeapTuple   tuple;
    Form_pg_rewrite ruleform;
    Oid         ruleoid;
 
    /* Find the rule's pg_rewrite tuple, get its OID */
    tuple = SearchSysCache2(RULERELNAME,
                            ObjectIdGetDatum(relid),
                            PointerGetDatum(rulename));
    if (!HeapTupleIsValid(tuple))
    {
        if (missing_ok)
            return InvalidOid;
        ereport(ERROR,
                (errcode(ERRCODE_UNDEFINED_OBJECT),
                 errmsg("rule \"%s\" for relation \"%s\" does not exist",
                        rulename, get_rel_name(relid))));
    }
    ruleform = (Form_pg_rewrite) GETSTRUCT(tuple);
    Assert(relid == ruleform->ev_class);
    ruleoid = ruleform->oid;
    ReleaseSysCache(tuple);
    return ruleoid;
}

References Assert(), ereport, errcode(), errmsg(), ERROR, get_rel_name(), GETSTRUCT(), HeapTupleIsValid, InvalidOid, ObjectIdGetDatum(), PointerGetDatum(), ReleaseSysCache(), and SearchSysCache2().

Referenced by get_object_address_relobject().

IsDefinedRewriteRule()

bool IsDefinedRewriteRule	(	Oid	owningRel,
		const char *	ruleName
	)

Definition at line 32 of file rewriteSupport.c.

{
    return SearchSysCacheExists2(RULERELNAME,
                                 ObjectIdGetDatum(owningRel),
                                 PointerGetDatum(ruleName));
}

References ObjectIdGetDatum(), PointerGetDatum(), and SearchSysCacheExists2.

Referenced by RenameRewriteRule().

SetRelationRuleStatus()

void SetRelationRuleStatus	(	Oid	relationId,
		bool	relHasRules
	)

Definition at line 53 of file rewriteSupport.c.

{
    Relation    relationRelation;
    HeapTuple   tuple;
    Form_pg_class classForm;
 
    /*
     * Find the tuple to update in pg_class, using syscache for the lookup.
     */
    relationRelation = table_open(RelationRelationId, RowExclusiveLock);
    tuple = SearchSysCacheCopy1(RELOID, ObjectIdGetDatum(relationId));
    if (!HeapTupleIsValid(tuple))
        elog(ERROR, "cache lookup failed for relation %u", relationId);
    classForm = (Form_pg_class) GETSTRUCT(tuple);
 
    if (classForm->relhasrules != relHasRules)
    {
        /* Do the update */
        classForm->relhasrules = relHasRules;
 
        CatalogTupleUpdate(relationRelation, &tuple->t_self, tuple);
    }
    else
    {
        /* no need to change tuple, but force relcache rebuild anyway */
        CacheInvalidateRelcacheByTuple(tuple);
    }
 
    heap_freetuple(tuple);
    table_close(relationRelation, RowExclusiveLock);
}

References CacheInvalidateRelcacheByTuple(), CatalogTupleUpdate(), elog, ERROR, GETSTRUCT(), heap_freetuple(), HeapTupleIsValid, ObjectIdGetDatum(), RowExclusiveLock, SearchSysCacheCopy1, HeapTupleData::t_self, table_close(), and table_open().

Referenced by DefineQueryRewrite().