]> granicus.if.org Git - postgresql/blobdiff - src/backend/utils/adt/regproc.c
Implement types regprocedure, regoper, regoperator, regclass, regtype
[postgresql] / src / backend / utils / adt / regproc.c
index d15c7a4393020af57cc6288da37e46d359fa622f..89be1bac96b3e70ecc84c1cf6c3ea78c3cd09eb4 100644 (file)
- /*-------------------------------------------------------------------------
+/*-------------------------------------------------------------------------
  *
  * regproc.c
- *       Functions for the built-in type "RegProcedure".
+ *       Functions for the built-in types regproc, regclass, regtype, etc.
  *
- * Copyright (c) 1994, Regents of the University of California
+ * These types are all binary-compatible with type Oid, and rely on Oid
+ * for comparison and so forth.  Their only interesting behavior is in
+ * special I/O conversion routines.
+ *
+ *
+ * Portions Copyright (c) 1996-2001, PostgreSQL Global Development Group
+ * Portions Copyright (c) 1994, Regents of the University of California
  *
  *
  * IDENTIFICATION
- *       $Header: /cvsroot/pgsql/src/backend/utils/adt/regproc.c,v 1.48 2000/01/10 16:13:14 momjian Exp $
+ *       $Header: /cvsroot/pgsql/src/backend/utils/adt/regproc.c,v 1.66 2002/04/25 02:56:55 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
 #include "postgres.h"
 
+#include <ctype.h>
+
 #include "access/genam.h"
 #include "access/heapam.h"
 #include "catalog/catname.h"
 #include "catalog/indexing.h"
+#include "catalog/namespace.h"
+#include "catalog/pg_operator.h"
 #include "catalog/pg_proc.h"
 #include "catalog/pg_type.h"
+#include "lib/stringinfo.h"
 #include "miscadmin.h"
+#include "parser/parse_type.h"
 #include "utils/builtins.h"
+#include "utils/fmgroids.h"
+#include "utils/lsyscache.h"
 #include "utils/syscache.h"
 
+
+static List *stringToQualifiedNameList(const char *string, const char *caller);
+static void parseNameAndArgTypes(const char *string, const char *caller,
+                                                                bool allow_none,
+                                                                List **names, int *nargs, Oid *argtypes);
+
+
 /*****************************************************************************
  *      USER I/O ROUTINES                                                                                                               *
  *****************************************************************************/
 
 /*
- *             regprocin               - converts "proname" or "proid" to proid
+ * regprocin           - converts "proname" to proc OID
  *
- *             proid of '-' signifies unknown, for consistency with regprocout
+ * We also accept a numeric OID, mostly for historical reasons.
+ *
+ * '-' signifies unknown (OID 0).  In all other cases, the input must
+ * match an existing pg_proc entry.
  */
-int32
-regprocin(char *pro_name_or_oid)
+Datum
+regprocin(PG_FUNCTION_ARGS)
 {
-       HeapTuple       proctup = NULL;
-       HeapTupleData tuple;
+       char       *pro_name_or_oid = PG_GETARG_CSTRING(0);
        RegProcedure result = InvalidOid;
+       List       *names;
+       FuncCandidateList clist;
+
+       /* '-' ? */
+       if (strcmp(pro_name_or_oid, "-") == 0)
+               PG_RETURN_OID(InvalidOid);
+
+       /* Numeric OID? */
+       if (pro_name_or_oid[0] >= '0' &&
+               pro_name_or_oid[0] <= '9' &&
+               strspn(pro_name_or_oid, "0123456789") == strlen(pro_name_or_oid))
+       {
+               Oid                     searchOid;
+
+               searchOid = DatumGetObjectId(DirectFunctionCall1(oidin,
+                                                                         CStringGetDatum(pro_name_or_oid)));
+               result = (RegProcedure) GetSysCacheOid(PROCOID,
+                                                                                        ObjectIdGetDatum(searchOid),
+                                                                                          0, 0, 0);
+               if (!RegProcedureIsValid(result))
+                       elog(ERROR, "No procedure with oid %s", pro_name_or_oid);
+               PG_RETURN_OID(result);
+       }
 
-       if (pro_name_or_oid == NULL)
-               return InvalidOid;
-       if (pro_name_or_oid[0] == '-' && pro_name_or_oid[1] == '\0')
-               return InvalidOid;
+       /* Else it's a name, possibly schema-qualified */
 
-       if (!IsBootstrapProcessingMode())
+       /*
+        * In bootstrap mode we assume the given name is not schema-qualified,
+        * and just search pg_proc for a unique match.  This is needed for
+        * initializing other system catalogs (pg_namespace may not exist yet,
+        * and certainly there are no schemas other than pg_catalog).
+        */
+       if (IsBootstrapProcessingMode())
        {
+               int                     matches = 0;
+               Relation        hdesc;
+               ScanKeyData skey[1];
+               SysScanDesc     sysscan;
+               HeapTuple       tuple;
+
+               ScanKeyEntryInitialize(&skey[0], 0x0,
+                                                          (AttrNumber) Anum_pg_proc_proname,
+                                                          (RegProcedure) F_NAMEEQ,
+                                                          CStringGetDatum(pro_name_or_oid));
+
+               hdesc = heap_openr(ProcedureRelationName, AccessShareLock);
+               sysscan = systable_beginscan(hdesc, ProcedureNameNspIndex, true,
+                                                                        SnapshotNow, 1, skey);
+
+               while (HeapTupleIsValid(tuple = systable_getnext(sysscan)))
+               {
+                       result = (RegProcedure) tuple->t_data->t_oid;
+                       if (++matches > 1)
+                               break;
+               }
+
+               systable_endscan(sysscan);
+               heap_close(hdesc, AccessShareLock);
+
+               if (matches == 0)
+                       elog(ERROR, "No procedure with name %s", pro_name_or_oid);
+               else if (matches > 1)
+                       elog(ERROR, "There is more than one procedure named %s",
+                                pro_name_or_oid);
+               PG_RETURN_OID(result);
+       }
+
+       /*
+        * Normal case: parse the name into components and see if it
+        * matches any pg_proc entries in the current search path.
+        */
+       names = stringToQualifiedNameList(pro_name_or_oid, "regprocin");
+       clist = FuncnameGetCandidates(names, -1);
+
+       if (clist == NULL)
+               elog(ERROR, "No procedure with name %s", pro_name_or_oid);
+       else if (clist->next != NULL)
+               elog(ERROR, "There is more than one procedure named %s",
+                        pro_name_or_oid);
+
+       result = clist->oid;
+
+       PG_RETURN_OID(result);
+}
+
+/*
+ * regprocout          - converts proc OID to "pro_name"
+ */
+Datum
+regprocout(PG_FUNCTION_ARGS)
+{
+       RegProcedure proid = PG_GETARG_OID(0);
+       char       *result;
+       HeapTuple       proctup;
+
+       if (proid == InvalidOid)
+       {
+               result = pstrdup("-");
+               PG_RETURN_CSTRING(result);
+       }
+
+       proctup = SearchSysCache(PROCOID,
+                                                        ObjectIdGetDatum(proid),
+                                                        0, 0, 0);
+
+       if (HeapTupleIsValid(proctup))
+       {
+               Form_pg_proc procform = (Form_pg_proc) GETSTRUCT(proctup);
+               char       *proname = NameStr(procform->proname);
 
                /*
-                * we need to use the oid because there can be multiple entries
-                * with the same name.  We accept int4eq_1323 and 1323.
+                * In bootstrap mode, skip the fancy namespace stuff and just
+                * return the proc name.  (This path is only needed for debugging
+                * output anyway.)
                 */
-               if (pro_name_or_oid[0] >= '0' &&
-                       pro_name_or_oid[0] <= '9')
+               if (IsBootstrapProcessingMode())
                {
-                       proctup = SearchSysCacheTuple(PROCOID,
-                                                               ObjectIdGetDatum(oidin(pro_name_or_oid)),
-                                                                                 0, 0, 0);
-                       if (HeapTupleIsValid(proctup))
-                               result = (RegProcedure) proctup->t_data->t_oid;
-                       else
-                               elog(ERROR, "No procedure with oid %s", pro_name_or_oid);
+                       result = pstrdup(proname);
                }
                else
                {
-                       Relation        hdesc;
-                       Relation        idesc;
-                       IndexScanDesc sd;
-                       ScanKeyData skey[1];
-                       RetrieveIndexResult indexRes;
-                       Buffer          buffer;
-                       int                     matches = 0;
-
-                       ScanKeyEntryInitialize(&skey[0],
-                                                                  (bits16) 0x0,
-                                                                  (AttrNumber) 1,
-                                                                  (RegProcedure) F_NAMEEQ,
-                                                                  PointerGetDatum(pro_name_or_oid));
-
-                       hdesc = heap_openr(ProcedureRelationName, AccessShareLock);
-                       idesc = index_openr(ProcedureNameIndex);
-
-                       sd = index_beginscan(idesc, false, 1, skey);
-                       while ((indexRes = index_getnext(sd, ForwardScanDirection)))
-                       {
-                               tuple.t_datamcxt = NULL;
-                               tuple.t_data = NULL;
-                               tuple.t_self = indexRes->heap_iptr;
-                               heap_fetch(hdesc, SnapshotNow,
-                                                  &tuple,
-                                                  &buffer);
-                               pfree(indexRes);
-                               if (tuple.t_data != NULL)
-                               {
-                                       result = (RegProcedure) tuple.t_data->t_oid;
-                                       ReleaseBuffer(buffer);
+                       char       *nspname;
+                       FuncCandidateList clist;
 
-                                       if (++matches > 1)
-                                               break;
-                               }
-                       }
+                       /*
+                        * Would this proc be found (uniquely!) by regprocin?
+                        * If not, qualify it.
+                        */
+                       clist = FuncnameGetCandidates(makeList1(makeString(proname)), -1);
+                       if (clist != NULL && clist->next == NULL &&
+                               clist->oid == proid)
+                               nspname = NULL;
+                       else
+                               nspname = get_namespace_name(procform->pronamespace);
+
+                       result = quote_qualified_identifier(nspname, proname);
+               }
+
+               ReleaseSysCache(proctup);
+       }
+       else
+       {
+               /* If OID doesn't match any pg_proc entry, return it numerically */
+               result = (char *) palloc(NAMEDATALEN);
+               snprintf(result, NAMEDATALEN, "%u", proid);
+       }
+
+       PG_RETURN_CSTRING(result);
+}
+
+
+/*
+ * regprocedurein              - converts "proname(args)" to proc OID
+ *
+ * We also accept a numeric OID, mostly for historical reasons.
+ *
+ * '-' signifies unknown (OID 0).  In all other cases, the input must
+ * match an existing pg_proc entry.
+ */
+Datum
+regprocedurein(PG_FUNCTION_ARGS)
+{
+       char       *pro_name_or_oid = PG_GETARG_CSTRING(0);
+       RegProcedure result = InvalidOid;
+       List       *names;
+       int                     nargs;
+       Oid                     argtypes[FUNC_MAX_ARGS];
+       FuncCandidateList clist;
+
+       /* '-' ? */
+       if (strcmp(pro_name_or_oid, "-") == 0)
+               PG_RETURN_OID(InvalidOid);
+
+       /* Numeric OID? */
+       if (pro_name_or_oid[0] >= '0' &&
+               pro_name_or_oid[0] <= '9' &&
+               strspn(pro_name_or_oid, "0123456789") == strlen(pro_name_or_oid))
+       {
+               Oid                     searchOid;
+
+               searchOid = DatumGetObjectId(DirectFunctionCall1(oidin,
+                                                                         CStringGetDatum(pro_name_or_oid)));
+               result = (RegProcedure) GetSysCacheOid(PROCOID,
+                                                                                        ObjectIdGetDatum(searchOid),
+                                                                                          0, 0, 0);
+               if (!RegProcedureIsValid(result))
+                       elog(ERROR, "No procedure with oid %s", pro_name_or_oid);
+               PG_RETURN_OID(result);
+       }
+
+       /*
+        * Else it's a name and arguments.  Parse the name and arguments,
+        * look up potential matches in the current namespace search list,
+        * and scan to see which one exactly matches the given argument
+        * types.  (There will not be more than one match.)
+        *
+        * XXX at present, this code will not work in bootstrap mode, hence this
+        * datatype cannot be used for any system column that needs to receive
+        * data during bootstrap.
+        */
+       parseNameAndArgTypes(pro_name_or_oid, "regprocedurein", false,
+                                                &names, &nargs, argtypes);
+
+       clist = FuncnameGetCandidates(names, nargs);
+
+       for (; clist; clist = clist->next)
+       {
+               if (memcmp(clist->args, argtypes, nargs * sizeof(Oid)) == 0)
+                       break;
+       }
+
+       if (clist == NULL)
+               elog(ERROR, "No procedure with name %s", pro_name_or_oid);
+
+       result = clist->oid;
+
+       PG_RETURN_OID(result);
+}
+
+/*
+ * regprocedureout             - converts proc OID to "pro_name(args)"
+ */
+Datum
+regprocedureout(PG_FUNCTION_ARGS)
+{
+       RegProcedure proid = PG_GETARG_OID(0);
+       char       *result;
+       HeapTuple       proctup;
+
+       if (proid == InvalidOid)
+       {
+               result = pstrdup("-");
+               PG_RETURN_CSTRING(result);
+       }
 
-                       index_endscan(sd);
-                       index_close(idesc);
-                       heap_close(hdesc, AccessShareLock);
+       proctup = SearchSysCache(PROCOID,
+                                                        ObjectIdGetDatum(proid),
+                                                        0, 0, 0);
 
-                       if (matches > 1)
-                               elog(ERROR, "There is more than one procedure named %s.\n\tSupply the pg_proc oid inside single quotes.", pro_name_or_oid);
-                       else if (matches == 0)
-                               elog(ERROR, "No procedure with name %s", pro_name_or_oid);
+       if (HeapTupleIsValid(proctup))
+       {
+               Form_pg_proc procform = (Form_pg_proc) GETSTRUCT(proctup);
+               char       *proname = NameStr(procform->proname);
+               int                     nargs = procform->pronargs;
+               int                     i;
+               char       *nspname;
+               FuncCandidateList clist;
+               StringInfoData buf;
+
+               /* XXX no support here for bootstrap mode */
+
+               /*
+                * Would this proc be found (given the right args) by regprocedurein?
+                * If not, we need to qualify it.
+                */
+               clist = FuncnameGetCandidates(makeList1(makeString(proname)), nargs);
+
+               for (; clist; clist = clist->next)
+               {
+                       if (memcmp(clist->args, procform->proargtypes,
+                                          nargs * sizeof(Oid)) == 0)
+                               break;
+               }
+
+               if (clist != NULL && clist->oid == proid)
+                       nspname = NULL;
+               else
+                       nspname = get_namespace_name(procform->pronamespace);
+
+               initStringInfo(&buf);
+
+               appendStringInfo(&buf, "%s(",
+                                                quote_qualified_identifier(nspname, proname));
+               for (i = 0; i < nargs; i++)
+               {
+                       appendStringInfo(&buf, "%s%s",
+                                                        (i > 0) ? "," : "",
+                                                        format_type_be(procform->proargtypes[i]));
                }
+
+               appendStringInfo(&buf, ")");
+
+               result = buf.data;
+
+               ReleaseSysCache(proctup);
        }
        else
        {
-               Relation        proc;
-               HeapScanDesc procscan;
-               ScanKeyData key;
-               bool            isnull;
+               /* If OID doesn't match any pg_proc entry, return it numerically */
+               result = (char *) palloc(NAMEDATALEN);
+               snprintf(result, NAMEDATALEN, "%u", proid);
+       }
 
-               proc = heap_openr(ProcedureRelationName, AccessShareLock);
-               ScanKeyEntryInitialize(&key,
-                                                          (bits16) 0,
-                                                          (AttrNumber) 1,
+       PG_RETURN_CSTRING(result);
+}
+
+
+/*
+ * regoperin           - converts "oprname" to operator OID
+ *
+ * We also accept a numeric OID, mostly for historical reasons.
+ *
+ * '0' signifies unknown (OID 0).  In all other cases, the input must
+ * match an existing pg_operator entry.
+ */
+Datum
+regoperin(PG_FUNCTION_ARGS)
+{
+       char       *opr_name_or_oid = PG_GETARG_CSTRING(0);
+       Oid                     result = InvalidOid;
+       List       *names;
+       FuncCandidateList clist;
+
+       /* '0' ? */
+       if (strcmp(opr_name_or_oid, "0") == 0)
+               PG_RETURN_OID(InvalidOid);
+
+       /* Numeric OID? */
+       if (opr_name_or_oid[0] >= '0' &&
+               opr_name_or_oid[0] <= '9' &&
+               strspn(opr_name_or_oid, "0123456789") == strlen(opr_name_or_oid))
+       {
+               Oid                     searchOid;
+
+               searchOid = DatumGetObjectId(DirectFunctionCall1(oidin,
+                                                                         CStringGetDatum(opr_name_or_oid)));
+               result = GetSysCacheOid(OPEROID,
+                                                               ObjectIdGetDatum(searchOid),
+                                                               0, 0, 0);
+               if (!OidIsValid(result))
+                       elog(ERROR, "No operator with oid %s", opr_name_or_oid);
+               PG_RETURN_OID(result);
+       }
+
+       /* Else it's a name, possibly schema-qualified */
+
+       /*
+        * In bootstrap mode we assume the given name is not schema-qualified,
+        * and just search pg_operator for a unique match.  This is needed for
+        * initializing other system catalogs (pg_namespace may not exist yet,
+        * and certainly there are no schemas other than pg_catalog).
+        */
+       if (IsBootstrapProcessingMode())
+       {
+               int                     matches = 0;
+               Relation        hdesc;
+               ScanKeyData skey[1];
+               SysScanDesc     sysscan;
+               HeapTuple       tuple;
+
+               ScanKeyEntryInitialize(&skey[0], 0x0,
+                                                          (AttrNumber) Anum_pg_operator_oprname,
                                                           (RegProcedure) F_NAMEEQ,
-                                                          (Datum) pro_name_or_oid);
+                                                          CStringGetDatum(opr_name_or_oid));
+
+               hdesc = heap_openr(OperatorRelationName, AccessShareLock);
+               sysscan = systable_beginscan(hdesc, OperatorNameNspIndex, true,
+                                                                        SnapshotNow, 1, skey);
 
-               procscan = heap_beginscan(proc, 0, SnapshotNow, 1, &key);
-               if (!HeapScanIsValid(procscan))
+               while (HeapTupleIsValid(tuple = systable_getnext(sysscan)))
                {
-                       heap_close(proc, AccessShareLock);
-                       elog(ERROR, "regprocin: could not begin scan of %s",
-                                ProcedureRelationName);
-                       return 0;
+                       result = tuple->t_data->t_oid;
+                       if (++matches > 1)
+                               break;
                }
-               proctup = heap_getnext(procscan, 0);
-               if (HeapTupleIsValid(proctup))
+
+               systable_endscan(sysscan);
+               heap_close(hdesc, AccessShareLock);
+
+               if (matches == 0)
+                       elog(ERROR, "No operator with name %s", opr_name_or_oid);
+               else if (matches > 1)
+                       elog(ERROR, "There is more than one operator named %s",
+                                opr_name_or_oid);
+               PG_RETURN_OID(result);
+       }
+
+       /*
+        * Normal case: parse the name into components and see if it
+        * matches any pg_operator entries in the current search path.
+        */
+       names = stringToQualifiedNameList(opr_name_or_oid, "regoperin");
+       clist = OpernameGetCandidates(names, '\0');
+
+       if (clist == NULL)
+               elog(ERROR, "No operator with name %s", opr_name_or_oid);
+       else if (clist->next != NULL)
+               elog(ERROR, "There is more than one operator named %s",
+                        opr_name_or_oid);
+
+       result = clist->oid;
+
+       PG_RETURN_OID(result);
+}
+
+/*
+ * regoperout          - converts operator OID to "opr_name"
+ */
+Datum
+regoperout(PG_FUNCTION_ARGS)
+{
+       Oid                     oprid = PG_GETARG_OID(0);
+       char       *result;
+       HeapTuple       opertup;
+
+       if (oprid == InvalidOid)
+       {
+               result = pstrdup("0");
+               PG_RETURN_CSTRING(result);
+       }
+
+       opertup = SearchSysCache(OPEROID,
+                                                        ObjectIdGetDatum(oprid),
+                                                        0, 0, 0);
+
+       if (HeapTupleIsValid(opertup))
+       {
+               Form_pg_operator operform = (Form_pg_operator) GETSTRUCT(opertup);
+               char       *oprname = NameStr(operform->oprname);
+
+               /*
+                * In bootstrap mode, skip the fancy namespace stuff and just
+                * return the oper name.  (This path is only needed for debugging
+                * output anyway.)
+                */
+               if (IsBootstrapProcessingMode())
                {
-                       result = (RegProcedure) heap_getattr(proctup,
-                                                                                                ObjectIdAttributeNumber,
-                                                                                                RelationGetDescr(proc),
-                                                                                                &isnull);
-                       if (isnull)
-                               elog(FATAL, "regprocin: null procedure %s", pro_name_or_oid);
+                       result = pstrdup(oprname);
                }
                else
-                       result = (RegProcedure) 0;
+               {
+                       FuncCandidateList clist;
+
+                       /*
+                        * Would this oper be found (uniquely!) by regoperin?
+                        * If not, qualify it.
+                        */
+                       clist = OpernameGetCandidates(makeList1(makeString(oprname)),
+                                                                                 '\0');
+                       if (clist != NULL && clist->next == NULL &&
+                               clist->oid == oprid)
+                               result = pstrdup(oprname);
+                       else
+                       {
+                               const char *nspname;
+
+                               nspname = get_namespace_name(operform->oprnamespace);
+                               nspname = quote_identifier(nspname);
+                               result = (char *) palloc(strlen(nspname)+strlen(oprname)+2);
+                               sprintf(result, "%s.%s", nspname, oprname);
+                       }
+               }
 
-               heap_endscan(procscan);
-               heap_close(proc, AccessShareLock);
+               ReleaseSysCache(opertup);
+       }
+       else
+       {
+               /* If OID doesn't match any pg_operator entry, return it numerically */
+               result = (char *) palloc(NAMEDATALEN);
+               snprintf(result, NAMEDATALEN, "%u", oprid);
        }
 
-       return (int32) result;
+       PG_RETURN_CSTRING(result);
 }
 
+
 /*
- *             regprocout              - converts proid to "pro_name"
+ * regoperatorin               - converts "oprname(args)" to operator OID
+ *
+ * We also accept a numeric OID, mostly for historical reasons.
+ *
+ * '0' signifies unknown (OID 0).  In all other cases, the input must
+ * match an existing pg_operator entry.
  */
-char *
-regprocout(RegProcedure proid)
+Datum
+regoperatorin(PG_FUNCTION_ARGS)
 {
-       HeapTuple       proctup;
+       char       *opr_name_or_oid = PG_GETARG_CSTRING(0);
+       Oid                     result = InvalidOid;
+       List       *names;
+       int                     nargs;
+       Oid                     argtypes[FUNC_MAX_ARGS];
+       char            oprkind;
+       FuncCandidateList clist;
+
+       /* '0' ? */
+       if (strcmp(opr_name_or_oid, "0") == 0)
+               PG_RETURN_OID(InvalidOid);
+
+       /* Numeric OID? */
+       if (opr_name_or_oid[0] >= '0' &&
+               opr_name_or_oid[0] <= '9' &&
+               strspn(opr_name_or_oid, "0123456789") == strlen(opr_name_or_oid))
+       {
+               Oid                     searchOid;
+
+               searchOid = DatumGetObjectId(DirectFunctionCall1(oidin,
+                                                                         CStringGetDatum(opr_name_or_oid)));
+               result = GetSysCacheOid(OPEROID,
+                                                               ObjectIdGetDatum(searchOid),
+                                                               0, 0, 0);
+               if (!OidIsValid(result))
+                       elog(ERROR, "No operator with oid %s", opr_name_or_oid);
+               PG_RETURN_OID(result);
+       }
+
+       /*
+        * Else it's a name and arguments.  Parse the name and arguments,
+        * look up potential matches in the current namespace search list,
+        * and scan to see which one exactly matches the given argument
+        * types.  (There will not be more than one match.)
+        *
+        * XXX at present, this code will not work in bootstrap mode, hence this
+        * datatype cannot be used for any system column that needs to receive
+        * data during bootstrap.
+        */
+       parseNameAndArgTypes(opr_name_or_oid, "regoperatorin", true,
+                                                &names, &nargs, argtypes);
+       if (nargs == 1)
+               elog(ERROR, "regoperatorin: use NONE to denote the missing argument of a unary operator");
+       if (nargs != 2)
+               elog(ERROR, "regoperatorin: provide two argument types for operator");
+
+       if (argtypes[0] == InvalidOid)
+               oprkind = 'l';
+       else if (argtypes[1] == InvalidOid)
+               oprkind = 'r';
+       else
+               oprkind = 'b';
+
+       clist = OpernameGetCandidates(names, oprkind);
+
+       for (; clist; clist = clist->next)
+       {
+               if (memcmp(clist->args, argtypes, 2 * sizeof(Oid)) == 0)
+                       break;
+       }
+
+       if (clist == NULL)
+               elog(ERROR, "No operator with name %s", opr_name_or_oid);
+
+       result = clist->oid;
+
+       PG_RETURN_OID(result);
+}
+
+/*
+ * regoperatorout              - converts operator OID to "opr_name(args)"
+ */
+Datum
+regoperatorout(PG_FUNCTION_ARGS)
+{
+       Oid                     oprid = PG_GETARG_OID(0);
        char       *result;
+       HeapTuple       opertup;
 
-       result = (char *) palloc(NAMEDATALEN);
+       if (oprid == InvalidOid)
+       {
+               result = pstrdup("0");
+               PG_RETURN_CSTRING(result);
+       }
+
+       opertup = SearchSysCache(OPEROID,
+                                                        ObjectIdGetDatum(oprid),
+                                                        0, 0, 0);
 
-       if (!IsBootstrapProcessingMode())
+       if (HeapTupleIsValid(opertup))
        {
-               proctup = SearchSysCacheTuple(PROCOID,
-                                                                         ObjectIdGetDatum(proid),
-                                                                         0, 0, 0);
+               Form_pg_operator operform = (Form_pg_operator) GETSTRUCT(opertup);
+               char       *oprname = NameStr(operform->oprname);
+               char       *nspname;
+               FuncCandidateList clist;
+               StringInfoData buf;
 
-               if (HeapTupleIsValid(proctup))
-               {
-                       char       *s;
+               /* XXX no support here for bootstrap mode */
+
+               /*
+                * Would this oper be found (given the right args) by regoperatorin?
+                * If not, we need to qualify it.
+                */
+               clist = OpernameGetCandidates(makeList1(makeString(oprname)),
+                                                                         operform->oprkind);
 
-                       s = NameStr(((Form_pg_proc) GETSTRUCT(proctup))->proname);
-                       StrNCpy(result, s, NAMEDATALEN);
+               for (; clist; clist = clist->next)
+               {
+                       if (clist->args[0] == operform->oprleft &&
+                               clist->args[1] == operform->oprright)
+                               break;
                }
-               else
+
+               initStringInfo(&buf);
+
+               if (clist == NULL || clist->oid != oprid)
                {
-                       result[0] = '-';
-                       result[1] = '\0';
+                       nspname = get_namespace_name(operform->oprnamespace);
+                       appendStringInfo(&buf, "%s.",
+                                                        quote_identifier(nspname));
                }
+
+               appendStringInfo(&buf, "%s(", oprname);
+
+               if (operform->oprleft)
+                       appendStringInfo(&buf, "%s,",
+                                                        format_type_be(operform->oprleft));
+               else
+                       appendStringInfo(&buf, "NONE,");
+
+               if (operform->oprright)
+                       appendStringInfo(&buf, "%s)",
+                                                        format_type_be(operform->oprright));
+               else
+                       appendStringInfo(&buf, "NONE)");
+
+               result = buf.data;
+
+               ReleaseSysCache(opertup);
        }
        else
        {
-               Relation        proc;
-               HeapScanDesc procscan;
-               ScanKeyData key;
+               /* If OID doesn't match any pg_operator entry, return it numerically */
+               result = (char *) palloc(NAMEDATALEN);
+               snprintf(result, NAMEDATALEN, "%u", oprid);
+       }
+
+       PG_RETURN_CSTRING(result);
+}
+
 
-               proc = heap_openr(ProcedureRelationName, AccessShareLock);
-               ScanKeyEntryInitialize(&key,
-                                                          (bits16) 0,
-                                                          (AttrNumber) ObjectIdAttributeNumber,
-                                                          (RegProcedure) F_INT4EQ,
-                                                          (Datum) proid);
+/*
+ * regclassin          - converts "classname" to class OID
+ *
+ * We also accept a numeric OID, mostly for historical reasons.
+ *
+ * '-' signifies unknown (OID 0).  In all other cases, the input must
+ * match an existing pg_class entry.
+ */
+Datum
+regclassin(PG_FUNCTION_ARGS)
+{
+       char       *class_name_or_oid = PG_GETARG_CSTRING(0);
+       Oid                     result = InvalidOid;
+       List       *names;
+
+       /* '-' ? */
+       if (strcmp(class_name_or_oid, "-") == 0)
+               PG_RETURN_OID(InvalidOid);
+
+       /* Numeric OID? */
+       if (class_name_or_oid[0] >= '0' &&
+               class_name_or_oid[0] <= '9' &&
+               strspn(class_name_or_oid, "0123456789") == strlen(class_name_or_oid))
+       {
+               Oid                     searchOid;
+
+               searchOid = DatumGetObjectId(DirectFunctionCall1(oidin,
+                                                                         CStringGetDatum(class_name_or_oid)));
+               result = GetSysCacheOid(RELOID,
+                                                               ObjectIdGetDatum(searchOid),
+                                                               0, 0, 0);
+               if (!OidIsValid(result))
+                       elog(ERROR, "No class with oid %s", class_name_or_oid);
+               PG_RETURN_OID(result);
+       }
+
+       /* Else it's a name, possibly schema-qualified */
+
+       /*
+        * In bootstrap mode we assume the given name is not schema-qualified,
+        * and just search pg_class for a match.  This is needed for
+        * initializing other system catalogs (pg_namespace may not exist yet,
+        * and certainly there are no schemas other than pg_catalog).
+        */
+       if (IsBootstrapProcessingMode())
+       {
+               Relation        hdesc;
+               ScanKeyData skey[1];
+               SysScanDesc     sysscan;
+               HeapTuple       tuple;
+
+               ScanKeyEntryInitialize(&skey[0], 0x0,
+                                                          (AttrNumber) Anum_pg_class_relname,
+                                                          (RegProcedure) F_NAMEEQ,
+                                                          CStringGetDatum(class_name_or_oid));
 
-               procscan = heap_beginscan(proc, 0, SnapshotNow, 1, &key);
-               if (!HeapScanIsValid(procscan))
+               hdesc = heap_openr(RelationRelationName, AccessShareLock);
+               sysscan = systable_beginscan(hdesc, ClassNameNspIndex, true,
+                                                                        SnapshotNow, 1, skey);
+
+               if (HeapTupleIsValid(tuple = systable_getnext(sysscan)))
+                       result = tuple->t_data->t_oid;
+               else
+                       elog(ERROR, "No class with name %s", class_name_or_oid);
+
+               /* We assume there can be only one match */
+
+               systable_endscan(sysscan);
+               heap_close(hdesc, AccessShareLock);
+
+               PG_RETURN_OID(result);
+       }
+
+       /*
+        * Normal case: parse the name into components and see if it
+        * matches any pg_class entries in the current search path.
+        */
+       names = stringToQualifiedNameList(class_name_or_oid, "regclassin");
+
+       result = RangeVarGetRelid(makeRangeVarFromNameList(names), false);
+
+       PG_RETURN_OID(result);
+}
+
+/*
+ * regclassout         - converts class OID to "class_name"
+ */
+Datum
+regclassout(PG_FUNCTION_ARGS)
+{
+       Oid                     classid = PG_GETARG_OID(0);
+       char       *result;
+       HeapTuple       classtup;
+
+       if (classid == InvalidOid)
+       {
+               result = pstrdup("-");
+               PG_RETURN_CSTRING(result);
+       }
+
+       classtup = SearchSysCache(RELOID,
+                                                         ObjectIdGetDatum(classid),
+                                                         0, 0, 0);
+
+       if (HeapTupleIsValid(classtup))
+       {
+               Form_pg_class classform = (Form_pg_class) GETSTRUCT(classtup);
+               char       *classname = NameStr(classform->relname);
+
+               /*
+                * In bootstrap mode, skip the fancy namespace stuff and just
+                * return the class name.  (This path is only needed for debugging
+                * output anyway.)
+                */
+               if (IsBootstrapProcessingMode())
                {
-                       heap_close(proc, AccessShareLock);
-                       elog(ERROR, "regprocout: could not begin scan of %s",
-                                ProcedureRelationName);
-                       return 0;
+                       result = pstrdup(classname);
                }
-               proctup = heap_getnext(procscan, 0);
-               if (HeapTupleIsValid(proctup))
+               else
                {
-                       char       *s;
-                       bool            isnull;
+                       char       *nspname;
 
-                       s = (char *) heap_getattr(proctup, 1,
-                                                                         RelationGetDescr(proc), &isnull);
-                       if (!isnull)
-                               StrNCpy(result, s, NAMEDATALEN);
+                       /*
+                        * Would this class be found by regclassin?
+                        * If not, qualify it.
+                        */
+                       if (RelnameGetRelid(classname) == classid)
+                               nspname = NULL;
                        else
-                               elog(FATAL, "regprocout: null procedure %u", proid);
+                               nspname = get_namespace_name(classform->relnamespace);
+
+                       result = quote_qualified_identifier(nspname, classname);
                }
+
+               ReleaseSysCache(classtup);
+       }
+       else
+       {
+               /* If OID doesn't match any pg_class entry, return it numerically */
+               result = (char *) palloc(NAMEDATALEN);
+               snprintf(result, NAMEDATALEN, "%u", classid);
+       }
+
+       PG_RETURN_CSTRING(result);
+}
+
+
+/*
+ * regtypein           - converts "typename" to type OID
+ *
+ * We also accept a numeric OID, mostly for historical reasons.
+ *
+ * '-' signifies unknown (OID 0).  In all other cases, the input must
+ * match an existing pg_type entry.
+ *
+ * In bootstrap mode the name must just equal some existing name in pg_type.
+ * In normal mode the type name can be specified using the full type syntax
+ * recognized by the parser; for example, DOUBLE PRECISION and INTEGER[] will
+ * work and be translated to the correct type names.  (We ignore any typmod
+ * info generated by the parser, however.)
+ */
+Datum
+regtypein(PG_FUNCTION_ARGS)
+{
+       char       *typ_name_or_oid = PG_GETARG_CSTRING(0);
+       Oid                     result = InvalidOid;
+       int32           typmod;
+
+       /* '-' ? */
+       if (strcmp(typ_name_or_oid, "-") == 0)
+               PG_RETURN_OID(InvalidOid);
+
+       /* Numeric OID? */
+       if (typ_name_or_oid[0] >= '0' &&
+               typ_name_or_oid[0] <= '9' &&
+               strspn(typ_name_or_oid, "0123456789") == strlen(typ_name_or_oid))
+       {
+               Oid                     searchOid;
+
+               searchOid = DatumGetObjectId(DirectFunctionCall1(oidin,
+                                                                         CStringGetDatum(typ_name_or_oid)));
+               result = GetSysCacheOid(TYPEOID,
+                                                               ObjectIdGetDatum(searchOid),
+                                                               0, 0, 0);
+               if (!OidIsValid(result))
+                       elog(ERROR, "No type with oid %s", typ_name_or_oid);
+               PG_RETURN_OID(result);
+       }
+
+       /* Else it's a type name, possibly schema-qualified or decorated */
+
+       /*
+        * In bootstrap mode we assume the given name is not schema-qualified,
+        * and just search pg_type for a match.  This is needed for
+        * initializing other system catalogs (pg_namespace may not exist yet,
+        * and certainly there are no schemas other than pg_catalog).
+        */
+       if (IsBootstrapProcessingMode())
+       {
+               Relation        hdesc;
+               ScanKeyData skey[1];
+               SysScanDesc     sysscan;
+               HeapTuple       tuple;
+
+               ScanKeyEntryInitialize(&skey[0], 0x0,
+                                                          (AttrNumber) Anum_pg_type_typname,
+                                                          (RegProcedure) F_NAMEEQ,
+                                                          CStringGetDatum(typ_name_or_oid));
+
+               hdesc = heap_openr(TypeRelationName, AccessShareLock);
+               sysscan = systable_beginscan(hdesc, TypeNameNspIndex, true,
+                                                                        SnapshotNow, 1, skey);
+
+               if (HeapTupleIsValid(tuple = systable_getnext(sysscan)))
+                       result = tuple->t_data->t_oid;
                else
-               {
-                       result[0] = '-';
-                       result[1] = '\0';
-               }
-               heap_endscan(procscan);
-               heap_close(proc, AccessShareLock);
+                       elog(ERROR, "No type with name %s", typ_name_or_oid);
+
+               /* We assume there can be only one match */
+
+               systable_endscan(sysscan);
+               heap_close(hdesc, AccessShareLock);
+
+               PG_RETURN_OID(result);
        }
 
-       return result;
+       /*
+        * Normal case: invoke the full parser to deal with special cases
+        * such as array syntax.
+        */
+       parseTypeString(typ_name_or_oid, &result, &typmod);
+
+       PG_RETURN_OID(result);
 }
 
 /*
- *             int8typeout                     - converts int8 type oids to "typname" list
+ * regtypeout          - converts type OID to "typ_name"
  */
-text *
-oidvectortypes(Oid *oidArray)
+Datum
+regtypeout(PG_FUNCTION_ARGS)
 {
+       Oid                     typid = PG_GETARG_OID(0);
+       char       *result;
        HeapTuple       typetup;
-       text       *result;
-       int                     num;
-       Oid                *sp;
 
-       if (oidArray == NULL)
+       if (typid == InvalidOid)
        {
-               result = (text *) palloc(VARHDRSZ);
-               VARSIZE(result) = 0;
-               return result;
+               result = pstrdup("-");
+               PG_RETURN_CSTRING(result);
        }
 
-       result = (text *) palloc(NAMEDATALEN * 8 + 8 + VARHDRSZ);
-       *VARDATA(result) = '\0';
+       typetup = SearchSysCache(TYPEOID,
+                                                        ObjectIdGetDatum(typid),
+                                                        0, 0, 0);
 
-       sp = oidArray;
-       for (num = 8; num != 0; num--, sp++)
+       if (HeapTupleIsValid(typetup))
        {
-               if (*sp != InvalidOid)
+               Form_pg_type typeform = (Form_pg_type) GETSTRUCT(typetup);
+               char       *typname = NameStr(typeform->typname);
+
+               /*
+                * In bootstrap mode, skip the fancy namespace stuff and just
+                * return the type name.  (This path is only needed for debugging
+                * output anyway.)
+                */
+               if (IsBootstrapProcessingMode())
                {
-                       typetup = SearchSysCacheTuple(TYPEOID,
-                                                                                 ObjectIdGetDatum(*sp),
-                                                                                 0, 0, 0);
-                       if (HeapTupleIsValid(typetup))
-                       {
-                               char       *s;
+                       result = pstrdup(typname);
+               }
+               else
+               {
+                       char       *nspname;
 
-                               s = NameStr(((Form_pg_type) GETSTRUCT(typetup))->typname);
-                               StrNCpy(VARDATA(result) + strlen(VARDATA(result)), s,
-                                               NAMEDATALEN);
-                               strcat(VARDATA(result), " ");
-                       }
+                       /*
+                        * Would this type be found by regtypein?
+                        * If not, qualify it.
+                        *
+                        * XXX shouldn't we use format_type instead?
+                        */
+                       if (TypenameGetTypid(typname) == typid)
+                               nspname = NULL;
+                       else
+                               nspname = get_namespace_name(typeform->typnamespace);
+
+                       result = quote_qualified_identifier(nspname, typname);
                }
+
+               ReleaseSysCache(typetup);
        }
-       VARSIZE(result) = strlen(VARDATA(result)) + VARHDRSZ;
-       return result;
+       else
+       {
+               /* If OID doesn't match any pg_type entry, return it numerically */
+               result = (char *) palloc(NAMEDATALEN);
+               snprintf(result, NAMEDATALEN, "%u", typid);
+       }
+
+       PG_RETURN_CSTRING(result);
 }
 
 
 /*****************************************************************************
- *      PUBLIC ROUTINES                                                                                                                 *
+ *      SUPPORT ROUTINES                                                                                                                *
  *****************************************************************************/
 
-/* regproctooid()
- * Lowercase version of RegprocToOid() to allow case-insensitive SQL.
- * Define RegprocToOid() as a macro in builtins.h.
- * Referenced in pg_proc.h. - tgl 97/04/26
+/*
+ * Given a C string, parse it into a qualified-name list.
  */
-Oid
-regproctooid(RegProcedure rp)
+static List *
+stringToQualifiedNameList(const char *string, const char *caller)
 {
-       return (Oid) rp;
+       char       *rawname;
+       List       *result = NIL;
+       List       *namelist;
+       List       *l;
+
+       /* We need a modifiable copy of the input string. */
+       rawname = pstrdup(string);
+
+       if (!SplitIdentifierString(rawname, '.', &namelist))
+               elog(ERROR, "%s: invalid name syntax", caller);
+
+       if (namelist == NIL)
+               elog(ERROR, "%s: invalid name syntax", caller);
+
+       foreach(l, namelist)
+       {
+               char   *curname = (char *) lfirst(l);
+
+               result = lappend(result, makeString(pstrdup(curname)));
+       }
+
+       pfree(rawname);
+       freeList(namelist);
+
+       return result;
 }
 
-/* (see int.c for comparison/operation routines) */
+/*
+ * Given a C string, parse it into a qualified function or operator name
+ * followed by a parenthesized list of type names.  Reduce the
+ * type names to an array of OIDs (returned into *nargs and *argtypes;
+ * the argtypes array should be of size FUNC_MAX_ARGS).  The function or
+ * operator name is returned to *names as a List of Strings.
+ *
+ * NONE is accepted as a placeholder for OID 0 if allow_none is true.
+ */
+static void
+parseNameAndArgTypes(const char *string, const char *caller, bool allow_none,
+                                        List **names, int *nargs, Oid *argtypes)
+{
+       char       *rawname;
+       char       *ptr;
+       char       *ptr2;
+       char       *typename;
+       bool            in_quote;
+       bool            had_comma;
+       int                     paren_count;
+       Oid                     typeid;
+       int32           typmod;
+
+       /* We need a modifiable copy of the input string. */
+       rawname = pstrdup(string);
+
+       /* Scan to find the expected left paren; mustn't be quoted */
+       in_quote = false;
+       for (ptr = rawname; *ptr; ptr++)
+       {
+               if (*ptr == '"')
+                       in_quote = !in_quote;
+               else if (*ptr == '(' && !in_quote)
+                       break;
+       }
+       if (*ptr == '\0')
+               elog(ERROR, "%s: expected a left parenthesis", caller);
+
+       /* Separate the name and parse it into a list */
+       *ptr++ = '\0';
+       *names = stringToQualifiedNameList(rawname, caller);
+
+       /* Check for the trailing right parenthesis and remove it */
+       ptr2 = ptr + strlen(ptr);
+       while (--ptr2 > ptr)
+       {
+               if (!isspace((unsigned char) *ptr2))
+                       break;
+       }
+       if (*ptr2 != ')')
+               elog(ERROR, "%s: expected a right parenthesis", caller);
+       *ptr2 = '\0';
+
+       /* Separate the remaining string into comma-separated type names */
+       *nargs = 0;
+       had_comma = false;
+
+       for (;;)
+       {
+               /* allow leading whitespace */
+               while (isspace((unsigned char) *ptr))
+                       ptr++;
+               if (*ptr == '\0')
+               {
+                       /* End of string.  Okay unless we had a comma before. */
+                       if (had_comma)
+                               elog(ERROR, "%s: expected a type name", caller);
+                       break;
+               }
+               typename = ptr;
+               /* Find end of type name --- end of string or comma */
+               /* ... but not a quoted or parenthesized comma */
+               in_quote = false;
+               paren_count = 0;
+               for (; *ptr; ptr++)
+               {
+                       if (*ptr == '"')
+                               in_quote = !in_quote;
+                       else if (*ptr == ',' && !in_quote && paren_count == 0)
+                               break;
+                       else if (!in_quote)
+                       {
+                               switch (*ptr)
+                               {
+                                       case '(':
+                                       case '[':
+                                               paren_count++;
+                                               break;
+                                       case ')':
+                                       case ']':
+                                               paren_count--;
+                                               break;
+                               }
+                       }
+               }
+               if (in_quote || paren_count != 0)
+                       elog(ERROR, "%s: improper type name", caller);
+               ptr2 = ptr;
+               if (*ptr == ',')
+               {
+                       had_comma = true;
+                       *ptr++ = '\0';
+               }
+               else
+               {
+                       had_comma = false;
+                       Assert(*ptr == '\0');
+               }
+               /* Lop off trailing whitespace */
+               while (--ptr2 >= typename)
+               {
+                       if (!isspace((unsigned char) *ptr2))
+                               break;
+                       *ptr2 = '\0';
+               }
 
+               if (allow_none && strcasecmp(typename, "none") == 0)
+               {
+                       /* Report NONE as OID 0 */
+                       typeid = InvalidOid;
+                       typmod = -1;
+               }
+               else
+               {
+                       /* Use full parser to resolve the type name */
+                       parseTypeString(typename, &typeid, &typmod);
+               }
+               if (*nargs >= FUNC_MAX_ARGS)
+                       elog(ERROR, "%s: too many argument datatypes", caller);
+               argtypes[*nargs] = typeid;
+               (*nargs)++;
+       }
 
-/* ========== PRIVATE ROUTINES ========== */
+       pfree(rawname);
+}