policy.c File Reference

#include "postgres.h"
#include "access/genam.h"
#include "access/htup.h"
#include "access/htup_details.h"
#include "access/relation.h"
#include "access/table.h"
#include "access/xact.h"
#include "catalog/catalog.h"
#include "catalog/dependency.h"
#include "catalog/indexing.h"
#include "catalog/namespace.h"
#include "catalog/objectaccess.h"
#include "catalog/pg_authid.h"
#include "catalog/pg_policy.h"
#include "catalog/pg_type.h"
#include "commands/policy.h"
#include "miscadmin.h"
#include "nodes/pg_list.h"
#include "parser/parse_clause.h"
#include "parser/parse_collate.h"
#include "parser/parse_node.h"
#include "parser/parse_relation.h"
#include "rewrite/rewriteManip.h"
#include "rewrite/rowsecurity.h"
#include "utils/acl.h"
#include "utils/array.h"
#include "utils/builtins.h"
#include "utils/fmgroids.h"
#include "utils/inval.h"
#include "utils/lsyscache.h"
#include "utils/memutils.h"
#include "utils/rel.h"
#include "utils/syscache.h"

Include dependency graph for policy.c:

Go to the source code of this file.

Functions
static void	RangeVarCallbackForPolicy (const RangeVar *rv, Oid relid, Oid oldrelid, void *arg)
static char	parse_policy_command (const char *cmd_name)
static Datum *	policy_role_list_to_array (List *roles, int *num_roles)
void	RelationBuildRowSecurity (Relation relation)
void	RemovePolicyById (Oid policy_id)
bool	RemoveRoleFromObjectPolicy (Oid roleid, Oid classid, Oid policy_id)
ObjectAddress	CreatePolicy (CreatePolicyStmt *stmt)
ObjectAddress	AlterPolicy (AlterPolicyStmt *stmt)
ObjectAddress	rename_policy (RenameStmt *stmt)
Oid	get_relation_policy_oid (Oid relid, const char *policy_name, bool missing_ok)
bool	relation_has_policies (Relation rel)

Function Documentation

AlterPolicy()

ObjectAddress AlterPolicy

(

AlterPolicyStmt *

stmt

)

Definition at line 780 of file policy.c.

{
    Relation    pg_policy_rel;
    Oid         policy_id;
    Relation    target_table;
    Oid         table_id;
    Datum      *role_oids = NULL;
    int         nitems = 0;
    ArrayType  *role_ids = NULL;
    List       *qual_parse_rtable = NIL;
    List       *with_check_parse_rtable = NIL;
    Node       *qual = NULL;
    Node       *with_check_qual = NULL;
    ScanKeyData skey[2];
    SysScanDesc sscan;
    HeapTuple   policy_tuple;
    HeapTuple   new_tuple;
    Datum       values[Natts_pg_policy];
    bool        isnull[Natts_pg_policy];
    bool        replaces[Natts_pg_policy];
    ObjectAddress target;
    ObjectAddress myself;
    Datum       polcmd_datum;
    char        polcmd;
    bool        polcmd_isnull;
    int         i;
 
    /* Parse role_ids */
    if (stmt->roles != NULL)
    {
        role_oids = policy_role_list_to_array(stmt->roles, &nitems);
        role_ids = construct_array_builtin(role_oids, nitems, OIDOID);
    }
 
    /* Get id of table.  Also handles permissions checks. */
    table_id = RangeVarGetRelidExtended(stmt->table, AccessExclusiveLock,
                                        0,
                                        RangeVarCallbackForPolicy,
                                        stmt);
 
    target_table = relation_open(table_id, NoLock);
 
    /* Parse the using policy clause */
    if (stmt->qual)
    {
        ParseNamespaceItem *nsitem;
        ParseState *qual_pstate = make_parsestate(NULL);
 
        nsitem = addRangeTableEntryForRelation(qual_pstate, target_table,
                                               AccessShareLock,
                                               NULL, false, false);
 
        addNSItemToQuery(qual_pstate, nsitem, false, true, true);
 
        qual = transformWhereClause(qual_pstate, stmt->qual,
                                    EXPR_KIND_POLICY,
                                    "POLICY");
 
        /* Fix up collation information */
        assign_expr_collations(qual_pstate, qual);
 
        qual_parse_rtable = qual_pstate->p_rtable;
        free_parsestate(qual_pstate);
    }
 
    /* Parse the with-check policy clause */
    if (stmt->with_check)
    {
        ParseNamespaceItem *nsitem;
        ParseState *with_check_pstate = make_parsestate(NULL);
 
        nsitem = addRangeTableEntryForRelation(with_check_pstate, target_table,
                                               AccessShareLock,
                                               NULL, false, false);
 
        addNSItemToQuery(with_check_pstate, nsitem, false, true, true);
 
        with_check_qual = transformWhereClause(with_check_pstate,
                                               stmt->with_check,
                                               EXPR_KIND_POLICY,
                                               "POLICY");
 
        /* Fix up collation information */
        assign_expr_collations(with_check_pstate, with_check_qual);
 
        with_check_parse_rtable = with_check_pstate->p_rtable;
        free_parsestate(with_check_pstate);
    }
 
    /* zero-clear */
    memset(values, 0, sizeof(values));
    memset(replaces, 0, sizeof(replaces));
    memset(isnull, 0, sizeof(isnull));
 
    /* Find policy to update. */
    pg_policy_rel = table_open(PolicyRelationId, RowExclusiveLock);
 
    /* Set key - policy's relation id. */
    ScanKeyInit(&skey[0],
                Anum_pg_policy_polrelid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(table_id));
 
    /* Set key - policy's name. */
    ScanKeyInit(&skey[1],
                Anum_pg_policy_polname,
                BTEqualStrategyNumber, F_NAMEEQ,
                CStringGetDatum(stmt->policy_name));
 
    sscan = systable_beginscan(pg_policy_rel,
                               PolicyPolrelidPolnameIndexId, true, NULL, 2,
                               skey);
 
    policy_tuple = systable_getnext(sscan);
 
    /* Check that the policy is found, raise an error if not. */
    if (!HeapTupleIsValid(policy_tuple))
        ereport(ERROR,
                (errcode(ERRCODE_UNDEFINED_OBJECT),
                 errmsg("policy \"%s\" for table \"%s\" does not exist",
                        stmt->policy_name,
                        RelationGetRelationName(target_table))));
 
    /* Get policy command */
    polcmd_datum = heap_getattr(policy_tuple, Anum_pg_policy_polcmd,
                                RelationGetDescr(pg_policy_rel),
                                &polcmd_isnull);
    Assert(!polcmd_isnull);
    polcmd = DatumGetChar(polcmd_datum);
 
    /*
     * If the command is SELECT or DELETE then WITH CHECK should be NULL.
     */
    if ((polcmd == ACL_SELECT_CHR || polcmd == ACL_DELETE_CHR)
        && stmt->with_check != NULL)
        ereport(ERROR,
                (errcode(ERRCODE_SYNTAX_ERROR),
                 errmsg("only USING expression allowed for SELECT, DELETE")));
 
    /*
     * If the command is INSERT then WITH CHECK should be the only expression
     * provided.
     */
    if ((polcmd == ACL_INSERT_CHR)
        && stmt->qual != NULL)
        ereport(ERROR,
                (errcode(ERRCODE_SYNTAX_ERROR),
                 errmsg("only WITH CHECK expression allowed for INSERT")));
 
    policy_id = ((Form_pg_policy) GETSTRUCT(policy_tuple))->oid;
 
    if (role_ids != NULL)
    {
        replaces[Anum_pg_policy_polroles - 1] = true;
        values[Anum_pg_policy_polroles - 1] = PointerGetDatum(role_ids);
    }
    else
    {
        Oid        *roles;
        Datum       roles_datum;
        bool        attr_isnull;
        ArrayType  *policy_roles;
 
        /*
         * We need to pull the set of roles this policy applies to from what's
         * in the catalog, so that we can recreate the dependencies correctly
         * for the policy.
         */
 
        roles_datum = heap_getattr(policy_tuple, Anum_pg_policy_polroles,
                                   RelationGetDescr(pg_policy_rel),
                                   &attr_isnull);
        Assert(!attr_isnull);
 
        policy_roles = DatumGetArrayTypePCopy(roles_datum);
 
        roles = (Oid *) ARR_DATA_PTR(policy_roles);
 
        nitems = ARR_DIMS(policy_roles)[0];
 
        role_oids = palloc_array(Datum, nitems);
 
        for (i = 0; i < nitems; i++)
            role_oids[i] = ObjectIdGetDatum(roles[i]);
    }
 
    if (qual != NULL)
    {
        replaces[Anum_pg_policy_polqual - 1] = true;
        values[Anum_pg_policy_polqual - 1]
            = CStringGetTextDatum(nodeToString(qual));
    }
    else
    {
        Datum       value_datum;
        bool        attr_isnull;
 
        /*
         * We need to pull the USING expression and build the range table for
         * the policy from what's in the catalog, so that we can recreate the
         * dependencies correctly for the policy.
         */
 
        /* Check if the policy has a USING expr */
        value_datum = heap_getattr(policy_tuple, Anum_pg_policy_polqual,
                                   RelationGetDescr(pg_policy_rel),
                                   &attr_isnull);
        if (!attr_isnull)
        {
            char       *qual_value;
            ParseState *qual_pstate;
 
            /* parsestate is built just to build the range table */
            qual_pstate = make_parsestate(NULL);
 
            qual_value = TextDatumGetCString(value_datum);
            qual = stringToNode(qual_value);
 
            /* Add this rel to the parsestate's rangetable, for dependencies */
            (void) addRangeTableEntryForRelation(qual_pstate, target_table,
                                                 AccessShareLock,
                                                 NULL, false, false);
 
            qual_parse_rtable = qual_pstate->p_rtable;
            free_parsestate(qual_pstate);
        }
    }
 
    if (with_check_qual != NULL)
    {
        replaces[Anum_pg_policy_polwithcheck - 1] = true;
        values[Anum_pg_policy_polwithcheck - 1]
            = CStringGetTextDatum(nodeToString(with_check_qual));
    }
    else
    {
        Datum       value_datum;
        bool        attr_isnull;
 
        /*
         * We need to pull the WITH CHECK expression and build the range table
         * for the policy from what's in the catalog, so that we can recreate
         * the dependencies correctly for the policy.
         */
 
        /* Check if the policy has a WITH CHECK expr */
        value_datum = heap_getattr(policy_tuple, Anum_pg_policy_polwithcheck,
                                   RelationGetDescr(pg_policy_rel),
                                   &attr_isnull);
        if (!attr_isnull)
        {
            char       *with_check_value;
            ParseState *with_check_pstate;
 
            /* parsestate is built just to build the range table */
            with_check_pstate = make_parsestate(NULL);
 
            with_check_value = TextDatumGetCString(value_datum);
            with_check_qual = stringToNode(with_check_value);
 
            /* Add this rel to the parsestate's rangetable, for dependencies */
            (void) addRangeTableEntryForRelation(with_check_pstate,
                                                 target_table,
                                                 AccessShareLock,
                                                 NULL, false, false);
 
            with_check_parse_rtable = with_check_pstate->p_rtable;
            free_parsestate(with_check_pstate);
        }
    }
 
    new_tuple = heap_modify_tuple(policy_tuple,
                                  RelationGetDescr(pg_policy_rel),
                                  values, isnull, replaces);
    CatalogTupleUpdate(pg_policy_rel, &new_tuple->t_self, new_tuple);
 
    /* Update Dependencies. */
    deleteDependencyRecordsFor(PolicyRelationId, policy_id, false);
 
    /* Record Dependencies */
    target.classId = RelationRelationId;
    target.objectId = table_id;
    target.objectSubId = 0;
 
    myself.classId = PolicyRelationId;
    myself.objectId = policy_id;
    myself.objectSubId = 0;
 
    recordDependencyOn(&myself, &target, DEPENDENCY_AUTO);
 
    recordDependencyOnExpr(&myself, qual, qual_parse_rtable, DEPENDENCY_NORMAL);
 
    recordDependencyOnExpr(&myself, with_check_qual, with_check_parse_rtable,
                           DEPENDENCY_NORMAL);
 
    /* Register role dependencies */
    deleteSharedDependencyRecordsFor(PolicyRelationId, policy_id, 0);
    target.classId = AuthIdRelationId;
    target.objectSubId = 0;
    for (i = 0; i < nitems; i++)
    {
        target.objectId = DatumGetObjectId(role_oids[i]);
        /* no dependency if public */
        if (target.objectId != ACL_ID_PUBLIC)
            recordSharedDependencyOn(&myself, &target,
                                     SHARED_DEPENDENCY_POLICY);
    }
 
    InvokeObjectPostAlterHook(PolicyRelationId, policy_id, 0);
 
    heap_freetuple(new_tuple);
 
    /* Invalidate Relation Cache */
    CacheInvalidateRelcache(target_table);
 
    /* Clean up. */
    systable_endscan(sscan);
    relation_close(target_table, NoLock);
    table_close(pg_policy_rel, RowExclusiveLock);
 
    return myself;
}

References AccessExclusiveLock, AccessShareLock, ACL_DELETE_CHR, ACL_ID_PUBLIC, ACL_INSERT_CHR, ACL_SELECT_CHR, addNSItemToQuery(), addRangeTableEntryForRelation(), ARR_DATA_PTR, ARR_DIMS, Assert, assign_expr_collations(), BTEqualStrategyNumber, CacheInvalidateRelcache(), CatalogTupleUpdate(), ObjectAddress::classId, construct_array_builtin(), CStringGetDatum(), CStringGetTextDatum, DatumGetArrayTypePCopy, DatumGetChar(), DatumGetObjectId(), deleteDependencyRecordsFor(), deleteSharedDependencyRecordsFor(), DEPENDENCY_AUTO, DEPENDENCY_NORMAL, ereport, errcode(), errmsg, ERROR, EXPR_KIND_POLICY, fb(), Form_pg_policy, free_parsestate(), GETSTRUCT(), heap_freetuple(), heap_getattr(), heap_modify_tuple(), HeapTupleIsValid, i, InvokeObjectPostAlterHook, make_parsestate(), NIL, nitems, nodeToString(), NoLock, ObjectAddress::objectId, ObjectIdGetDatum(), ObjectAddress::objectSubId, palloc_array, PointerGetDatum, policy_role_list_to_array(), RangeVarCallbackForPolicy(), RangeVarGetRelidExtended(), recordDependencyOn(), recordDependencyOnExpr(), recordSharedDependencyOn(), relation_close(), relation_open(), RelationGetDescr, RelationGetRelationName, RowExclusiveLock, ScanKeyInit(), SHARED_DEPENDENCY_POLICY, stmt, stringToNode(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), table_open(), TextDatumGetCString, transformWhereClause(), and values.

Referenced by ProcessUtilitySlow().

CreatePolicy()

ObjectAddress CreatePolicy

(

CreatePolicyStmt *

stmt

)

Definition at line 581 of file policy.c.

{
    Relation    pg_policy_rel;
    Oid         policy_id;
    Relation    target_table;
    Oid         table_id;
    char        polcmd;
    Datum      *role_oids;
    int         nitems = 0;
    ArrayType  *role_ids;
    ParseState *qual_pstate;
    ParseState *with_check_pstate;
    ParseNamespaceItem *nsitem;
    Node       *qual;
    Node       *with_check_qual;
    ScanKeyData skey[2];
    SysScanDesc sscan;
    HeapTuple   policy_tuple;
    Datum       values[Natts_pg_policy];
    bool        isnull[Natts_pg_policy];
    ObjectAddress target;
    ObjectAddress myself;
    int         i;
 
    /* Parse command */
    polcmd = parse_policy_command(stmt->cmd_name);
 
    /*
     * If the command is SELECT or DELETE then WITH CHECK should be NULL.
     */
    if ((polcmd == ACL_SELECT_CHR || polcmd == ACL_DELETE_CHR)
        && stmt->with_check != NULL)
        ereport(ERROR,
                (errcode(ERRCODE_SYNTAX_ERROR),
                 errmsg("WITH CHECK cannot be applied to SELECT or DELETE")));
 
    /*
     * If the command is INSERT then WITH CHECK should be the only expression
     * provided.
     */
    if (polcmd == ACL_INSERT_CHR && stmt->qual != NULL)
        ereport(ERROR,
                (errcode(ERRCODE_SYNTAX_ERROR),
                 errmsg("only WITH CHECK expression allowed for INSERT")));
 
    /* Collect role ids */
    role_oids = policy_role_list_to_array(stmt->roles, &nitems);
    role_ids = construct_array_builtin(role_oids, nitems, OIDOID);
 
    /* Parse the supplied clause */
    qual_pstate = make_parsestate(NULL);
    with_check_pstate = make_parsestate(NULL);
 
    /* zero-clear */
    memset(values, 0, sizeof(values));
    memset(isnull, 0, sizeof(isnull));
 
    /* Get id of table.  Also handles permissions checks. */
    table_id = RangeVarGetRelidExtended(stmt->table, AccessExclusiveLock,
                                        0,
                                        RangeVarCallbackForPolicy,
                                        stmt);
 
    /* Open target_table to build quals. No additional lock is necessary. */
    target_table = relation_open(table_id, NoLock);
 
    /* Add for the regular security quals */
    nsitem = addRangeTableEntryForRelation(qual_pstate, target_table,
                                           AccessShareLock,
                                           NULL, false, false);
    addNSItemToQuery(qual_pstate, nsitem, false, true, true);
 
    /* Add for the with-check quals */
    nsitem = addRangeTableEntryForRelation(with_check_pstate, target_table,
                                           AccessShareLock,
                                           NULL, false, false);
    addNSItemToQuery(with_check_pstate, nsitem, false, true, true);
 
    qual = transformWhereClause(qual_pstate,
                                stmt->qual,
                                EXPR_KIND_POLICY,
                                "POLICY");
 
    with_check_qual = transformWhereClause(with_check_pstate,
                                           stmt->with_check,
                                           EXPR_KIND_POLICY,
                                           "POLICY");
 
    /* Fix up collation information */
    assign_expr_collations(qual_pstate, qual);
    assign_expr_collations(with_check_pstate, with_check_qual);
 
    /* Open pg_policy catalog */
    pg_policy_rel = table_open(PolicyRelationId, RowExclusiveLock);
 
    /* Set key - policy's relation id. */
    ScanKeyInit(&skey[0],
                Anum_pg_policy_polrelid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(table_id));
 
    /* Set key - policy's name. */
    ScanKeyInit(&skey[1],
                Anum_pg_policy_polname,
                BTEqualStrategyNumber, F_NAMEEQ,
                CStringGetDatum(stmt->policy_name));
 
    sscan = systable_beginscan(pg_policy_rel,
                               PolicyPolrelidPolnameIndexId, true, NULL, 2,
                               skey);
 
    policy_tuple = systable_getnext(sscan);
 
    /* Complain if the policy name already exists for the table */
    if (HeapTupleIsValid(policy_tuple))
        ereport(ERROR,
                (errcode(ERRCODE_DUPLICATE_OBJECT),
                 errmsg("policy \"%s\" for table \"%s\" already exists",
                        stmt->policy_name, RelationGetRelationName(target_table))));
 
    policy_id = GetNewOidWithIndex(pg_policy_rel, PolicyOidIndexId,
                                   Anum_pg_policy_oid);
    values[Anum_pg_policy_oid - 1] = ObjectIdGetDatum(policy_id);
    values[Anum_pg_policy_polrelid - 1] = ObjectIdGetDatum(table_id);
    values[Anum_pg_policy_polname - 1] = DirectFunctionCall1(namein,
                                                             CStringGetDatum(stmt->policy_name));
    values[Anum_pg_policy_polcmd - 1] = CharGetDatum(polcmd);
    values[Anum_pg_policy_polpermissive - 1] = BoolGetDatum(stmt->permissive);
    values[Anum_pg_policy_polroles - 1] = PointerGetDatum(role_ids);
 
    /* Add qual if present. */
    if (qual)
        values[Anum_pg_policy_polqual - 1] = CStringGetTextDatum(nodeToString(qual));
    else
        isnull[Anum_pg_policy_polqual - 1] = true;
 
    /* Add WITH CHECK qual if present */
    if (with_check_qual)
        values[Anum_pg_policy_polwithcheck - 1] = CStringGetTextDatum(nodeToString(with_check_qual));
    else
        isnull[Anum_pg_policy_polwithcheck - 1] = true;
 
    policy_tuple = heap_form_tuple(RelationGetDescr(pg_policy_rel), values,
                                   isnull);
 
    CatalogTupleInsert(pg_policy_rel, policy_tuple);
 
    /* Record Dependencies */
    target.classId = RelationRelationId;
    target.objectId = table_id;
    target.objectSubId = 0;
 
    myself.classId = PolicyRelationId;
    myself.objectId = policy_id;
    myself.objectSubId = 0;
 
    recordDependencyOn(&myself, &target, DEPENDENCY_AUTO);
 
    recordDependencyOnExpr(&myself, qual, qual_pstate->p_rtable,
                           DEPENDENCY_NORMAL);
 
    recordDependencyOnExpr(&myself, with_check_qual,
                           with_check_pstate->p_rtable, DEPENDENCY_NORMAL);
 
    /* Register role dependencies */
    target.classId = AuthIdRelationId;
    target.objectSubId = 0;
    for (i = 0; i < nitems; i++)
    {
        target.objectId = DatumGetObjectId(role_oids[i]);
        /* no dependency if public */
        if (target.objectId != ACL_ID_PUBLIC)
            recordSharedDependencyOn(&myself, &target,
                                     SHARED_DEPENDENCY_POLICY);
    }
 
    InvokeObjectPostCreateHook(PolicyRelationId, policy_id, 0);
 
    /* Invalidate Relation Cache */
    CacheInvalidateRelcache(target_table);
 
    /* Clean up. */
    heap_freetuple(policy_tuple);
    free_parsestate(qual_pstate);
    free_parsestate(with_check_pstate);
    systable_endscan(sscan);
    relation_close(target_table, NoLock);
    table_close(pg_policy_rel, RowExclusiveLock);
 
    return myself;
}

References AccessExclusiveLock, AccessShareLock, ACL_DELETE_CHR, ACL_ID_PUBLIC, ACL_INSERT_CHR, ACL_SELECT_CHR, addNSItemToQuery(), addRangeTableEntryForRelation(), assign_expr_collations(), BoolGetDatum(), BTEqualStrategyNumber, CacheInvalidateRelcache(), CatalogTupleInsert(), CharGetDatum(), ObjectAddress::classId, construct_array_builtin(), CStringGetDatum(), CStringGetTextDatum, DatumGetObjectId(), DEPENDENCY_AUTO, DEPENDENCY_NORMAL, DirectFunctionCall1, ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errmsg, ERROR, EXPR_KIND_POLICY, fb(), free_parsestate(), GetNewOidWithIndex(), heap_form_tuple(), heap_freetuple(), HeapTupleIsValid, i, InvokeObjectPostCreateHook, make_parsestate(), namein(), nitems, nodeToString(), NoLock, ObjectAddress::objectId, ObjectIdGetDatum(), ObjectAddress::objectSubId, parse_policy_command(), PointerGetDatum, policy_role_list_to_array(), RangeVarCallbackForPolicy(), RangeVarGetRelidExtended(), recordDependencyOn(), recordDependencyOnExpr(), recordSharedDependencyOn(), relation_close(), relation_open(), RelationGetDescr, RelationGetRelationName, RowExclusiveLock, ScanKeyInit(), SHARED_DEPENDENCY_POLICY, stmt, systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), table_open(), transformWhereClause(), and values.

Referenced by ProcessUtilitySlow().

get_relation_policy_oid()

Oid get_relation_policy_oid	(	Oid	relid,
		const char *	policy_name,
		bool	missing_ok
	)

Definition at line 1216 of file policy.c.

{
    Relation    pg_policy_rel;
    ScanKeyData skey[2];
    SysScanDesc sscan;
    HeapTuple   policy_tuple;
    Oid         policy_oid;
 
    pg_policy_rel = table_open(PolicyRelationId, AccessShareLock);
 
    /* Add key - policy's relation id. */
    ScanKeyInit(&skey[0],
                Anum_pg_policy_polrelid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(relid));
 
    /* Add key - policy's name. */
    ScanKeyInit(&skey[1],
                Anum_pg_policy_polname,
                BTEqualStrategyNumber, F_NAMEEQ,
                CStringGetDatum(policy_name));
 
    sscan = systable_beginscan(pg_policy_rel,
                               PolicyPolrelidPolnameIndexId, true, NULL, 2,
                               skey);
 
    policy_tuple = systable_getnext(sscan);
 
    if (!HeapTupleIsValid(policy_tuple))
    {
        if (!missing_ok)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_OBJECT),
                     errmsg("policy \"%s\" for table \"%s\" does not exist",
                            policy_name, get_rel_name(relid))));
 
        policy_oid = InvalidOid;
    }
    else
        policy_oid = ((Form_pg_policy) GETSTRUCT(policy_tuple))->oid;
 
    /* Clean up. */
    systable_endscan(sscan);
    table_close(pg_policy_rel, AccessShareLock);
 
    return policy_oid;
}

References AccessShareLock, BTEqualStrategyNumber, CStringGetDatum(), ereport, errcode(), errmsg, ERROR, fb(), Form_pg_policy, get_rel_name(), GETSTRUCT(), HeapTupleIsValid, InvalidOid, ObjectIdGetDatum(), ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().

Referenced by get_object_address_relobject().

parse_policy_command()

static char parse_policy_command ( const char *  cmd_name )

static

Definition at line 120 of file policy.c.

{
    char        polcmd;
 
    if (!cmd_name)
        elog(ERROR, "unrecognized policy command");
 
    if (strcmp(cmd_name, "all") == 0)
        polcmd = '*';
    else if (strcmp(cmd_name, "select") == 0)
        polcmd = ACL_SELECT_CHR;
    else if (strcmp(cmd_name, "insert") == 0)
        polcmd = ACL_INSERT_CHR;
    else if (strcmp(cmd_name, "update") == 0)
        polcmd = ACL_UPDATE_CHR;
    else if (strcmp(cmd_name, "delete") == 0)
        polcmd = ACL_DELETE_CHR;
    else
        elog(ERROR, "unrecognized policy command");
 
    return polcmd;
}

References ACL_DELETE_CHR, ACL_INSERT_CHR, ACL_SELECT_CHR, ACL_UPDATE_CHR, elog, ERROR, and fb().

Referenced by CreatePolicy().

policy_role_list_to_array()

static Datum * policy_role_list_to_array ( List *  roles, int *  num_roles  )

static

Definition at line 149 of file policy.c.

{
    Datum      *role_oids;
    ListCell   *cell;
    int         i = 0;
 
    /* Handle no roles being passed in as being for public */
    if (roles == NIL)
    {
        *num_roles = 1;
        role_oids = palloc_array(Datum, *num_roles);
        role_oids[0] = ObjectIdGetDatum(ACL_ID_PUBLIC);
 
        return role_oids;
    }
 
    *num_roles = list_length(roles);
    role_oids = (Datum *) palloc(*num_roles * sizeof(Datum));
 
    foreach(cell, roles)
    {
        RoleSpec   *spec = lfirst(cell);
 
        /*
         * PUBLIC covers all roles, so it only makes sense alone.
         */
        if (spec->roletype == ROLESPEC_PUBLIC)
        {
            if (*num_roles != 1)
            {
                ereport(WARNING,
                        (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                         errmsg("ignoring specified roles other than PUBLIC"),
                         errhint("All roles are members of the PUBLIC role.")));
                *num_roles = 1;
            }
            role_oids[0] = ObjectIdGetDatum(ACL_ID_PUBLIC);
 
            return role_oids;
        }
        else
            role_oids[i++] =
                ObjectIdGetDatum(get_rolespec_oid(spec, false));
    }
 
    return role_oids;
}

References ACL_ID_PUBLIC, ereport, errcode(), errhint(), errmsg, fb(), get_rolespec_oid(), i, lfirst, list_length(), NIL, ObjectIdGetDatum(), palloc(), palloc_array, ROLESPEC_PUBLIC, and WARNING.

Referenced by AlterPolicy(), and CreatePolicy().

RangeVarCallbackForPolicy()

static void RangeVarCallbackForPolicy ( const RangeVar *  rv, Oid  relid, Oid  oldrelid, void *  arg  )

static

Definition at line 64 of file policy.c.

{
    HeapTuple   tuple;
    Form_pg_class classform;
    char        relkind;
 
    tuple = SearchSysCache1(RELOID, ObjectIdGetDatum(relid));
    if (!HeapTupleIsValid(tuple))
        return;
 
    classform = (Form_pg_class) GETSTRUCT(tuple);
    relkind = classform->relkind;
 
    /* Must own relation. */
    if (!object_ownercheck(RelationRelationId, relid, GetUserId()))
        aclcheck_error(ACLCHECK_NOT_OWNER, get_relkind_objtype(get_rel_relkind(relid)), rv->relname);
 
    /*
     * Conflict log tables are used internally for logical replication
     * conflict logging and should not be modified directly, as it could
     * disrupt conflict logging.
     */
    if (IsConflictLogTableClass(classform))
        ereport(ERROR,
                (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                 errmsg("cannot create policy on conflict log table \"%s\"",
                        rv->relname),
                 errdetail("Conflict log tables are system-managed tables for logical replication conflicts.")));
 
    /* No system table modifications unless explicitly allowed. */
    if (!allowSystemTableMods && IsSystemClass(relid, classform))
        ereport(ERROR,
                (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                 errmsg("permission denied: \"%s\" is a system catalog",
                        rv->relname)));
 
    /* Relation type MUST be a table. */
    if (relkind != RELKIND_RELATION && relkind != RELKIND_PARTITIONED_TABLE)
        ereport(ERROR,
                (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                 errmsg("\"%s\" is not a table", rv->relname)));
 
    ReleaseSysCache(tuple);
}

References aclcheck_error(), ACLCHECK_NOT_OWNER, allowSystemTableMods, ereport, errcode(), errdetail(), errmsg, ERROR, fb(), get_rel_relkind(), get_relkind_objtype(), GETSTRUCT(), GetUserId(), HeapTupleIsValid, IsConflictLogTableClass(), IsSystemClass(), object_ownercheck(), ObjectIdGetDatum(), ReleaseSysCache(), RangeVar::relname, and SearchSysCache1().

Referenced by AlterPolicy(), CreatePolicy(), and rename_policy().

relation_has_policies()

bool relation_has_policies

(

Relation

rel

)

Definition at line 1268 of file policy.c.

{
    Relation    catalog;
    ScanKeyData skey;
    SysScanDesc sscan;
    HeapTuple   policy_tuple;
    bool        ret = false;
 
    catalog = table_open(PolicyRelationId, AccessShareLock);
    ScanKeyInit(&skey,
                Anum_pg_policy_polrelid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(RelationGetRelid(rel)));
    sscan = systable_beginscan(catalog, PolicyPolrelidPolnameIndexId, true,
                               NULL, 1, &skey);
    policy_tuple = systable_getnext(sscan);
    if (HeapTupleIsValid(policy_tuple))
        ret = true;
 
    systable_endscan(sscan);
    table_close(catalog, AccessShareLock);
 
    return ret;
}

References AccessShareLock, BTEqualStrategyNumber, fb(), HeapTupleIsValid, ObjectIdGetDatum(), RelationGetRelid, ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().

RelationBuildRowSecurity()

void RelationBuildRowSecurity

(

Relation

relation

)

Definition at line 205 of file policy.c.

{
    MemoryContext rscxt;
    MemoryContext oldcxt = CurrentMemoryContext;
    RowSecurityDesc *rsdesc;
    Relation    catalog;
    ScanKeyData skey;
    SysScanDesc sscan;
    HeapTuple   tuple;
 
    /*
     * Create a memory context to hold everything associated with this
     * relation's row security policy.  This makes it easy to clean up during
     * a relcache flush.  However, to cover the possibility of an error
     * partway through, we don't make the context long-lived till we're done.
     */
    rscxt = AllocSetContextCreate(CurrentMemoryContext,
                                  "row security descriptor",
                                  ALLOCSET_SMALL_SIZES);
    MemoryContextCopyAndSetIdentifier(rscxt,
                                      RelationGetRelationName(relation));
 
    rsdesc = MemoryContextAllocZero(rscxt, sizeof(RowSecurityDesc));
    rsdesc->rscxt = rscxt;
 
    /*
     * Now scan pg_policy for RLS policies associated with this relation.
     * Because we use the index on (polrelid, polname), we should consistently
     * visit the rel's policies in name order, at least when system indexes
     * aren't disabled.  This simplifies equalRSDesc().
     */
    catalog = table_open(PolicyRelationId, AccessShareLock);
 
    ScanKeyInit(&skey,
                Anum_pg_policy_polrelid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(RelationGetRelid(relation)));
 
    sscan = systable_beginscan(catalog, PolicyPolrelidPolnameIndexId, true,
                               NULL, 1, &skey);
 
    while (HeapTupleIsValid(tuple = systable_getnext(sscan)))
    {
        Form_pg_policy policy_form = (Form_pg_policy) GETSTRUCT(tuple);
        RowSecurityPolicy *policy;
        Datum       datum;
        bool        isnull;
        char       *str_value;
 
        policy = MemoryContextAllocZero(rscxt, sizeof(RowSecurityPolicy));
 
        /*
         * Note: we must be sure that pass-by-reference data gets copied into
         * rscxt.  We avoid making that context current over wider spans than
         * we have to, though.
         */
 
        /* Get policy command */
        policy->polcmd = policy_form->polcmd;
 
        /* Get policy, permissive or restrictive */
        policy->permissive = policy_form->polpermissive;
 
        /* Get policy name */
        policy->policy_name =
            MemoryContextStrdup(rscxt, NameStr(policy_form->polname));
 
        /* Get policy roles */
        datum = heap_getattr(tuple, Anum_pg_policy_polroles,
                             RelationGetDescr(catalog), &isnull);
        /* shouldn't be null, but let's check for luck */
        if (isnull)
            elog(ERROR, "unexpected null value in pg_policy.polroles");
        MemoryContextSwitchTo(rscxt);
        policy->roles = DatumGetArrayTypePCopy(datum);
        MemoryContextSwitchTo(oldcxt);
 
        /* Get policy qual */
        datum = heap_getattr(tuple, Anum_pg_policy_polqual,
                             RelationGetDescr(catalog), &isnull);
        if (!isnull)
        {
            str_value = TextDatumGetCString(datum);
            MemoryContextSwitchTo(rscxt);
            policy->qual = (Expr *) stringToNode(str_value);
            MemoryContextSwitchTo(oldcxt);
            pfree(str_value);
        }
        else
            policy->qual = NULL;
 
        /* Get WITH CHECK qual */
        datum = heap_getattr(tuple, Anum_pg_policy_polwithcheck,
                             RelationGetDescr(catalog), &isnull);
        if (!isnull)
        {
            str_value = TextDatumGetCString(datum);
            MemoryContextSwitchTo(rscxt);
            policy->with_check_qual = (Expr *) stringToNode(str_value);
            MemoryContextSwitchTo(oldcxt);
            pfree(str_value);
        }
        else
            policy->with_check_qual = NULL;
 
        /* We want to cache whether there are SubLinks in these expressions */
        policy->hassublinks = checkExprHasSubLink((Node *) policy->qual) ||
            checkExprHasSubLink((Node *) policy->with_check_qual);
 
        /*
         * Add this object to list.  For historical reasons, the list is built
         * in reverse order.
         */
        MemoryContextSwitchTo(rscxt);
        rsdesc->policies = lcons(policy, rsdesc->policies);
        MemoryContextSwitchTo(oldcxt);
    }
 
    systable_endscan(sscan);
    table_close(catalog, AccessShareLock);
 
    /*
     * Success.  Reparent the descriptor's memory context under
     * CacheMemoryContext so that it will live indefinitely, then attach the
     * policy descriptor to the relcache entry.
     */
    MemoryContextSetParent(rscxt, CacheMemoryContext);
 
    relation->rd_rsdesc = rsdesc;
}

References AccessShareLock, ALLOCSET_SMALL_SIZES, AllocSetContextCreate, BTEqualStrategyNumber, CacheMemoryContext, checkExprHasSubLink(), CurrentMemoryContext, DatumGetArrayTypePCopy, elog, ERROR, fb(), Form_pg_policy, GETSTRUCT(), heap_getattr(), HeapTupleIsValid, lcons(), MemoryContextAllocZero(), MemoryContextCopyAndSetIdentifier, MemoryContextSetParent(), MemoryContextStrdup(), MemoryContextSwitchTo(), NameStr, ObjectIdGetDatum(), pfree(), RelationData::rd_rsdesc, RelationGetDescr, RelationGetRelationName, RelationGetRelid, ScanKeyInit(), stringToNode(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), table_open(), and TextDatumGetCString.

Referenced by RelationBuildDesc(), and RelationCacheInitializePhase3().

RemovePolicyById()

void RemovePolicyById

(

Oid

policy_id

)

Definition at line 344 of file policy.c.

{
    Relation    pg_policy_rel;
    SysScanDesc sscan;
    ScanKeyData skey[1];
    HeapTuple   tuple;
    Oid         relid;
    Relation    rel;
 
    pg_policy_rel = table_open(PolicyRelationId, RowExclusiveLock);
 
    /*
     * Find the policy to delete.
     */
    ScanKeyInit(&skey[0],
                Anum_pg_policy_oid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(policy_id));
 
    sscan = systable_beginscan(pg_policy_rel, PolicyOidIndexId, true,
                               NULL, 1, skey);
 
    tuple = systable_getnext(sscan);
 
    /* If the policy exists, then remove it, otherwise raise an error. */
    if (!HeapTupleIsValid(tuple))
        elog(ERROR, "could not find tuple for policy %u", policy_id);
 
    /*
     * Open and exclusive-lock the relation the policy belongs to.  (We need
     * exclusive lock to lock out queries that might otherwise depend on the
     * set of policies the rel has; furthermore we've got to hold the lock
     * till commit.)
     */
    relid = ((Form_pg_policy) GETSTRUCT(tuple))->polrelid;
 
    rel = table_open(relid, AccessExclusiveLock);
    if (rel->rd_rel->relkind != RELKIND_RELATION &&
        rel->rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
        ereport(ERROR,
                (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                 errmsg("\"%s\" is not a table",
                        RelationGetRelationName(rel))));
 
    if (!allowSystemTableMods && IsSystemRelation(rel))
        ereport(ERROR,
                (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                 errmsg("permission denied: \"%s\" is a system catalog",
                        RelationGetRelationName(rel))));
 
    CatalogTupleDelete(pg_policy_rel, &tuple->t_self);
 
    systable_endscan(sscan);
 
    /*
     * Note that, unlike some of the other flags in pg_class, relrowsecurity
     * is not just an indication of if policies exist.  When relrowsecurity is
     * set by a user, then all access to the relation must be through a
     * policy.  If no policy is defined for the relation then a default-deny
     * policy is created and all records are filtered (except for queries from
     * the owner).
     */
    CacheInvalidateRelcache(rel);
 
    table_close(rel, NoLock);
 
    /* Clean up */
    table_close(pg_policy_rel, RowExclusiveLock);
}

References AccessExclusiveLock, allowSystemTableMods, BTEqualStrategyNumber, CacheInvalidateRelcache(), CatalogTupleDelete(), elog, ereport, errcode(), errmsg, ERROR, fb(), Form_pg_policy, GETSTRUCT(), HeapTupleIsValid, IsSystemRelation(), NoLock, ObjectIdGetDatum(), RelationData::rd_rel, RelationGetRelationName, RowExclusiveLock, ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), HeapTupleData::t_self, table_close(), and table_open().

Referenced by doDeletion().

RemoveRoleFromObjectPolicy()

bool RemoveRoleFromObjectPolicy	(	Oid	roleid,
		Oid	classid,
		Oid	policy_id
	)

Definition at line 428 of file policy.c.

{
    Relation    pg_policy_rel;
    SysScanDesc sscan;
    ScanKeyData skey[1];
    HeapTuple   tuple;
    Oid         relid;
    ArrayType  *policy_roles;
    Datum       roles_datum;
    Oid        *roles;
    int         num_roles;
    Datum      *role_oids;
    bool        attr_isnull;
    bool        keep_policy = true;
    int         i,
                j;
 
    Assert(classid == PolicyRelationId);
 
    pg_policy_rel = table_open(PolicyRelationId, RowExclusiveLock);
 
    /*
     * Find the policy to update.
     */
    ScanKeyInit(&skey[0],
                Anum_pg_policy_oid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(policy_id));
 
    sscan = systable_beginscan(pg_policy_rel, PolicyOidIndexId, true,
                               NULL, 1, skey);
 
    tuple = systable_getnext(sscan);
 
    /* Raise an error if we don't find the policy. */
    if (!HeapTupleIsValid(tuple))
        elog(ERROR, "could not find tuple for policy %u", policy_id);
 
    /* Identify rel the policy belongs to */
    relid = ((Form_pg_policy) GETSTRUCT(tuple))->polrelid;
 
    /* Get the current set of roles */
    roles_datum = heap_getattr(tuple,
                               Anum_pg_policy_polroles,
                               RelationGetDescr(pg_policy_rel),
                               &attr_isnull);
 
    Assert(!attr_isnull);
 
    policy_roles = DatumGetArrayTypePCopy(roles_datum);
    roles = (Oid *) ARR_DATA_PTR(policy_roles);
    num_roles = ARR_DIMS(policy_roles)[0];
 
    /*
     * Rebuild the polroles array, without any mentions of the target role.
     * Ordinarily there'd be exactly one, but we must cope with duplicate
     * mentions, since CREATE/ALTER POLICY historically have allowed that.
     */
    role_oids = palloc_array(Datum, num_roles);
    for (i = 0, j = 0; i < num_roles; i++)
    {
        if (roles[i] != roleid)
            role_oids[j++] = ObjectIdGetDatum(roles[i]);
    }
    num_roles = j;
 
    /* If any roles remain, update the policy entry. */
    if (num_roles > 0)
    {
        ArrayType  *role_ids;
        Datum       values[Natts_pg_policy];
        bool        isnull[Natts_pg_policy];
        bool        replaces[Natts_pg_policy];
        HeapTuple   new_tuple;
        HeapTuple   reltup;
        ObjectAddress target;
        ObjectAddress myself;
 
        /* zero-clear */
        memset(values, 0, sizeof(values));
        memset(replaces, 0, sizeof(replaces));
        memset(isnull, 0, sizeof(isnull));
 
        /* This is the array for the new tuple */
        role_ids = construct_array_builtin(role_oids, num_roles, OIDOID);
 
        replaces[Anum_pg_policy_polroles - 1] = true;
        values[Anum_pg_policy_polroles - 1] = PointerGetDatum(role_ids);
 
        new_tuple = heap_modify_tuple(tuple,
                                      RelationGetDescr(pg_policy_rel),
                                      values, isnull, replaces);
        CatalogTupleUpdate(pg_policy_rel, &new_tuple->t_self, new_tuple);
 
        /* Remove all the old shared dependencies (roles) */
        deleteSharedDependencyRecordsFor(PolicyRelationId, policy_id, 0);
 
        /* Record the new shared dependencies (roles) */
        myself.classId = PolicyRelationId;
        myself.objectId = policy_id;
        myself.objectSubId = 0;
 
        target.classId = AuthIdRelationId;
        target.objectSubId = 0;
        for (i = 0; i < num_roles; i++)
        {
            target.objectId = DatumGetObjectId(role_oids[i]);
            /* no need for dependency on the public role */
            if (target.objectId != ACL_ID_PUBLIC)
                recordSharedDependencyOn(&myself, &target,
                                         SHARED_DEPENDENCY_POLICY);
        }
 
        InvokeObjectPostAlterHook(PolicyRelationId, policy_id, 0);
 
        heap_freetuple(new_tuple);
 
        /* Make updates visible */
        CommandCounterIncrement();
 
        /*
         * Invalidate relcache entry for rel the policy belongs to, to force
         * redoing any dependent plans.  In case of a race condition where the
         * rel was just dropped, we need do nothing.
         */
        reltup = SearchSysCache1(RELOID, ObjectIdGetDatum(relid));
        if (HeapTupleIsValid(reltup))
        {
            CacheInvalidateRelcacheByTuple(reltup);
            ReleaseSysCache(reltup);
        }
    }
    else
    {
        /* No roles would remain, so drop the policy instead. */
        keep_policy = false;
    }
 
    /* Clean up. */
    systable_endscan(sscan);
 
    table_close(pg_policy_rel, RowExclusiveLock);
 
    return keep_policy;
}

References ACL_ID_PUBLIC, ARR_DATA_PTR, ARR_DIMS, Assert, BTEqualStrategyNumber, CacheInvalidateRelcacheByTuple(), CatalogTupleUpdate(), ObjectAddress::classId, CommandCounterIncrement(), construct_array_builtin(), DatumGetArrayTypePCopy, DatumGetObjectId(), deleteSharedDependencyRecordsFor(), elog, ERROR, fb(), Form_pg_policy, GETSTRUCT(), heap_freetuple(), heap_getattr(), heap_modify_tuple(), HeapTupleIsValid, i, InvokeObjectPostAlterHook, j, ObjectAddress::objectId, ObjectIdGetDatum(), ObjectAddress::objectSubId, palloc_array, PointerGetDatum, recordSharedDependencyOn(), RelationGetDescr, ReleaseSysCache(), RowExclusiveLock, ScanKeyInit(), SearchSysCache1(), SHARED_DEPENDENCY_POLICY, systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), table_open(), and values.

Referenced by shdepDropOwned().

rename_policy()

ObjectAddress rename_policy

(

RenameStmt *

stmt

)

Definition at line 1108 of file policy.c.

{
    Relation    pg_policy_rel;
    Relation    target_table;
    Oid         table_id;
    Oid         opoloid;
    ScanKeyData skey[2];
    SysScanDesc sscan;
    HeapTuple   policy_tuple;
    ObjectAddress address;
 
    /* Get id of table.  Also handles permissions checks. */
    table_id = RangeVarGetRelidExtended(stmt->relation, AccessExclusiveLock,
                                        0,
                                        RangeVarCallbackForPolicy,
                                        stmt);
 
    target_table = relation_open(table_id, NoLock);
 
    pg_policy_rel = table_open(PolicyRelationId, RowExclusiveLock);
 
    /* First pass -- check for conflict */
 
    /* Add key - policy's relation id. */
    ScanKeyInit(&skey[0],
                Anum_pg_policy_polrelid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(table_id));
 
    /* Add key - policy's name. */
    ScanKeyInit(&skey[1],
                Anum_pg_policy_polname,
                BTEqualStrategyNumber, F_NAMEEQ,
                CStringGetDatum(stmt->newname));
 
    sscan = systable_beginscan(pg_policy_rel,
                               PolicyPolrelidPolnameIndexId, true, NULL, 2,
                               skey);
 
    if (HeapTupleIsValid(systable_getnext(sscan)))
        ereport(ERROR,
                (errcode(ERRCODE_DUPLICATE_OBJECT),
                 errmsg("policy \"%s\" for table \"%s\" already exists",
                        stmt->newname, RelationGetRelationName(target_table))));
 
    systable_endscan(sscan);
 
    /* Second pass -- find existing policy and update */
    /* Add key - policy's relation id. */
    ScanKeyInit(&skey[0],
                Anum_pg_policy_polrelid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(table_id));
 
    /* Add key - policy's name. */
    ScanKeyInit(&skey[1],
                Anum_pg_policy_polname,
                BTEqualStrategyNumber, F_NAMEEQ,
                CStringGetDatum(stmt->subname));
 
    sscan = systable_beginscan(pg_policy_rel,
                               PolicyPolrelidPolnameIndexId, true, NULL, 2,
                               skey);
 
    policy_tuple = systable_getnext(sscan);
 
    /* Complain if we did not find the policy */
    if (!HeapTupleIsValid(policy_tuple))
        ereport(ERROR,
                (errcode(ERRCODE_UNDEFINED_OBJECT),
                 errmsg("policy \"%s\" for table \"%s\" does not exist",
                        stmt->subname, RelationGetRelationName(target_table))));
 
    opoloid = ((Form_pg_policy) GETSTRUCT(policy_tuple))->oid;
 
    policy_tuple = heap_copytuple(policy_tuple);
 
    namestrcpy(&((Form_pg_policy) GETSTRUCT(policy_tuple))->polname,
               stmt->newname);
 
    CatalogTupleUpdate(pg_policy_rel, &policy_tuple->t_self, policy_tuple);
 
    InvokeObjectPostAlterHook(PolicyRelationId, opoloid, 0);
 
    ObjectAddressSet(address, PolicyRelationId, opoloid);
 
    /*
     * Invalidate relation's relcache entry so that other backends (and this
     * one too!) are sent SI message to make them rebuild relcache entries.
     * (Ideally this should happen automatically...)
     */
    CacheInvalidateRelcache(target_table);
 
    /* Clean up. */
    systable_endscan(sscan);
    table_close(pg_policy_rel, RowExclusiveLock);
    relation_close(target_table, NoLock);
 
    return address;
}

References AccessExclusiveLock, BTEqualStrategyNumber, CacheInvalidateRelcache(), CatalogTupleUpdate(), CStringGetDatum(), ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errmsg, ERROR, fb(), Form_pg_policy, GETSTRUCT(), heap_copytuple(), HeapTupleIsValid, InvokeObjectPostAlterHook, namestrcpy(), NoLock, ObjectAddressSet, ObjectIdGetDatum(), RangeVarCallbackForPolicy(), RangeVarGetRelidExtended(), relation_close(), relation_open(), RelationGetRelationName, RowExclusiveLock, ScanKeyInit(), stmt, systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().

Referenced by ExecRenameStmt().