Line data    Source code

       1              : /*-------------------------------------------------------------------------
       2              :  *
       3              :  * pg_range.c
       4              :  *    routines to support manipulation of the pg_range relation
       5              :  *
       6              :  * Portions Copyright (c) 1996-2026, PostgreSQL Global Development Group
       7              :  * Portions Copyright (c) 1994, Regents of the University of California
       8              :  *
       9              :  *
      10              :  * IDENTIFICATION
      11              :  *    src/backend/catalog/pg_range.c
      12              :  *
      13              :  *-------------------------------------------------------------------------
      14              :  */
      15              : #include "postgres.h"
      16              : 
      17              : #include "access/genam.h"
      18              : #include "access/htup_details.h"
      19              : #include "access/table.h"
      20              : #include "catalog/dependency.h"
      21              : #include "catalog/indexing.h"
      22              : #include "catalog/pg_collation.h"
      23              : #include "catalog/pg_opclass.h"
      24              : #include "catalog/pg_proc.h"
      25              : #include "catalog/pg_range.h"
      26              : #include "catalog/pg_type.h"
      27              : #include "utils/fmgroids.h"
      28              : #include "utils/rel.h"
      29              : 
      30              : 
      31              : /*
      32              :  * RangeCreate
      33              :  *      Create an entry in pg_range.
      34              :  */
      35              : void
      36           80 : RangeCreate(Oid rangeTypeOid, Oid rangeSubType, Oid rangeCollation,
      37              :             Oid rangeSubOpclass, RegProcedure rangeCanonical,
      38              :             RegProcedure rangeSubDiff, Oid multirangeTypeOid,
      39              :             RegProcedure rangeConstruct2, RegProcedure rangeConstruct3,
      40              :             RegProcedure mltrngConstruct0, RegProcedure mltrngConstruct1, RegProcedure mltrngConstruct2)
      41              : {
      42              :     Relation    pg_range;
      43              :     Datum       values[Natts_pg_range];
      44              :     bool        nulls[Natts_pg_range];
      45              :     HeapTuple   tup;
      46              :     ObjectAddress myself;
      47              :     ObjectAddress referenced;
      48              :     ObjectAddress referencing;
      49              :     ObjectAddresses *addrs;
      50              : 
      51           80 :     pg_range = table_open(RangeRelationId, RowExclusiveLock);
      52              : 
      53           80 :     memset(nulls, 0, sizeof(nulls));
      54              : 
      55           80 :     values[Anum_pg_range_rngtypid - 1] = ObjectIdGetDatum(rangeTypeOid);
      56           80 :     values[Anum_pg_range_rngsubtype - 1] = ObjectIdGetDatum(rangeSubType);
      57           80 :     values[Anum_pg_range_rngcollation - 1] = ObjectIdGetDatum(rangeCollation);
      58           80 :     values[Anum_pg_range_rngsubopc - 1] = ObjectIdGetDatum(rangeSubOpclass);
      59           80 :     values[Anum_pg_range_rngcanonical - 1] = ObjectIdGetDatum(rangeCanonical);
      60           80 :     values[Anum_pg_range_rngsubdiff - 1] = ObjectIdGetDatum(rangeSubDiff);
      61           80 :     values[Anum_pg_range_rngmultitypid - 1] = ObjectIdGetDatum(multirangeTypeOid);
      62           80 :     values[Anum_pg_range_rngconstruct2 - 1] = ObjectIdGetDatum(rangeConstruct2);
      63           80 :     values[Anum_pg_range_rngconstruct3 - 1] = ObjectIdGetDatum(rangeConstruct3);
      64           80 :     values[Anum_pg_range_rngmltconstruct0 - 1] = ObjectIdGetDatum(mltrngConstruct0);
      65           80 :     values[Anum_pg_range_rngmltconstruct1 - 1] = ObjectIdGetDatum(mltrngConstruct1);
      66           80 :     values[Anum_pg_range_rngmltconstruct2 - 1] = ObjectIdGetDatum(mltrngConstruct2);
      67              : 
      68           80 :     tup = heap_form_tuple(RelationGetDescr(pg_range), values, nulls);
      69              : 
      70           80 :     CatalogTupleInsert(pg_range, tup);
      71           80 :     heap_freetuple(tup);
      72              : 
      73              :     /* record type's dependencies on range-related items */
      74           80 :     addrs = new_object_addresses();
      75              : 
      76           80 :     ObjectAddressSet(myself, TypeRelationId, rangeTypeOid);
      77              : 
      78           80 :     ObjectAddressSet(referenced, TypeRelationId, rangeSubType);
      79           80 :     add_exact_object_address(&referenced, addrs);
      80              : 
      81           80 :     ObjectAddressSet(referenced, OperatorClassRelationId, rangeSubOpclass);
      82           80 :     add_exact_object_address(&referenced, addrs);
      83              : 
      84           80 :     if (OidIsValid(rangeCollation))
      85              :     {
      86           36 :         ObjectAddressSet(referenced, CollationRelationId, rangeCollation);
      87           36 :         add_exact_object_address(&referenced, addrs);
      88              :     }
      89              : 
      90           80 :     if (OidIsValid(rangeCanonical))
      91              :     {
      92            0 :         ObjectAddressSet(referenced, ProcedureRelationId, rangeCanonical);
      93            0 :         add_exact_object_address(&referenced, addrs);
      94              :     }
      95              : 
      96           80 :     if (OidIsValid(rangeSubDiff))
      97              :     {
      98            4 :         ObjectAddressSet(referenced, ProcedureRelationId, rangeSubDiff);
      99            4 :         add_exact_object_address(&referenced, addrs);
     100              :     }
     101              : 
     102           80 :     record_object_address_dependencies(&myself, addrs, DEPENDENCY_NORMAL);
     103           80 :     free_object_addresses(addrs);
     104              : 
     105              :     /* record multirange type's dependency on the range type */
     106           80 :     referencing.classId = TypeRelationId;
     107           80 :     referencing.objectId = multirangeTypeOid;
     108           80 :     referencing.objectSubId = 0;
     109           80 :     recordDependencyOn(&referencing, &myself, DEPENDENCY_INTERNAL);
     110              : 
     111           80 :     table_close(pg_range, RowExclusiveLock);
     112           80 : }
     113              : 
     114              : 
     115              : /*
     116              :  * RangeDelete
     117              :  *      Remove the pg_range entry for the specified type.
     118              :  */
     119              : void
     120           52 : RangeDelete(Oid rangeTypeOid)
     121              : {
     122              :     Relation    pg_range;
     123              :     ScanKeyData key[1];
     124              :     SysScanDesc scan;
     125              :     HeapTuple   tup;
     126              : 
     127           52 :     pg_range = table_open(RangeRelationId, RowExclusiveLock);
     128              : 
     129           52 :     ScanKeyInit(&key[0],
     130              :                 Anum_pg_range_rngtypid,
     131              :                 BTEqualStrategyNumber, F_OIDEQ,
     132              :                 ObjectIdGetDatum(rangeTypeOid));
     133              : 
     134           52 :     scan = systable_beginscan(pg_range, RangeTypidIndexId, true,
     135              :                               NULL, 1, key);
     136              : 
     137          104 :     while (HeapTupleIsValid(tup = systable_getnext(scan)))
     138              :     {
     139           52 :         CatalogTupleDelete(pg_range, &tup->t_self);
     140              :     }
     141              : 
     142           52 :     systable_endscan(scan);
     143              : 
     144           52 :     table_close(pg_range, RowExclusiveLock);
     145           52 : }