7
7
*
8
8
*
9
9
* IDENTIFICATION
10
- * $Header: /cvsroot/pgsql/src/backend/catalog/pg_operator.c,v 1.47 2000/01/10 17:14:31 momjian Exp $
10
+ * $Header: /cvsroot/pgsql/src/backend/catalog/pg_operator.c,v 1.48 2000/01/17 23:57:43 tgl Exp $
11
11
*
12
12
* NOTES
13
13
* these routines moved here from commands/define.c and somewhat cleaned up.
@@ -775,6 +775,9 @@ OperatorDef(char *operatorName,
775
775
opKey [1 ].sk_argument = ObjectIdGetDatum (leftTypeId );
776
776
opKey [2 ].sk_argument = ObjectIdGetDatum (rightTypeId );
777
777
778
+ /* Make sure we can see the shell even if it is new in current cmd */
779
+ CommandCounterIncrement ();
780
+
778
781
pg_operator_scan = heap_beginscan (pg_operator_desc ,
779
782
0 ,
780
783
SnapshotSelf ,/* no cache? */
@@ -790,9 +793,7 @@ OperatorDef(char *operatorName,
790
793
nulls ,
791
794
replaces );
792
795
793
- setheapoverride (true);
794
796
heap_update (pg_operator_desc ,& tup -> t_self ,tup ,NULL );
795
- setheapoverride (false);
796
797
}
797
798
else
798
799
elog (ERROR ,"OperatorDef: no operator %u" ,operatorObjectId );
@@ -875,7 +876,13 @@ OperatorUpd(Oid baseId, Oid commId, Oid negId)
875
876
876
877
pg_operator_desc = heap_openr (OperatorRelationName ,RowExclusiveLock );
877
878
878
- /* check and update the commutator, if necessary */
879
+ /*
880
+ * check and update the commutator & negator, if necessary
881
+ *
882
+ * First make sure we can see them...
883
+ */
884
+ CommandCounterIncrement ();
885
+
879
886
opKey [0 ].sk_argument = ObjectIdGetDatum (commId );
880
887
881
888
pg_operator_scan = heap_beginscan (pg_operator_desc ,
@@ -920,9 +927,7 @@ OperatorUpd(Oid baseId, Oid commId, Oid negId)
920
927
nulls ,
921
928
replaces );
922
929
923
- setheapoverride (true);
924
930
heap_update (pg_operator_desc ,& tup -> t_self ,tup ,NULL );
925
- setheapoverride (false);
926
931
927
932
if (RelationGetForm (pg_operator_desc )-> relhasindex )
928
933
{
@@ -954,9 +959,7 @@ OperatorUpd(Oid baseId, Oid commId, Oid negId)
954
959
nulls ,
955
960
replaces );
956
961
957
- setheapoverride (true);
958
962
heap_update (pg_operator_desc ,& tup -> t_self ,tup ,NULL );
959
- setheapoverride (false);
960
963
961
964
if (RelationGetForm (pg_operator_desc )-> relhasindex )
962
965
{
@@ -994,9 +997,7 @@ OperatorUpd(Oid baseId, Oid commId, Oid negId)
994
997
nulls ,
995
998
replaces );
996
999
997
- setheapoverride (true);
998
1000
heap_update (pg_operator_desc ,& tup -> t_self ,tup ,NULL );
999
- setheapoverride (false);
1000
1001
1001
1002
if (RelationGetForm (pg_operator_desc )-> relhasindex )
1002
1003
{