Line data Source code
1 : /*-------------------------------------------------------------------------
2 : * relation_stats.c
3 : *
4 : * PostgreSQL relation statistics manipulation
5 : *
6 : * Code supporting the direct import of relation statistics, similar to
7 : * what is done by the ANALYZE command.
8 : *
9 : * Portions Copyright (c) 1996-2025, PostgreSQL Global Development Group
10 : * Portions Copyright (c) 1994, Regents of the University of California
11 : *
12 : * IDENTIFICATION
13 : * src/backend/statistics/relation_stats.c
14 : *
15 : *-------------------------------------------------------------------------
16 : */
17 :
18 : #include "postgres.h"
19 :
20 : #include "access/heapam.h"
21 : #include "catalog/indexing.h"
22 : #include "catalog/namespace.h"
23 : #include "statistics/stat_utils.h"
24 : #include "utils/builtins.h"
25 : #include "utils/fmgroids.h"
26 : #include "utils/fmgrprotos.h"
27 : #include "utils/lsyscache.h"
28 : #include "utils/syscache.h"
29 :
30 :
31 : /*
32 : * Positional argument numbers, names, and types for
33 : * relation_statistics_update().
34 : */
35 :
36 : enum relation_stats_argnum
37 : {
38 : RELSCHEMA_ARG = 0,
39 : RELNAME_ARG,
40 : RELPAGES_ARG,
41 : RELTUPLES_ARG,
42 : RELALLVISIBLE_ARG,
43 : RELALLFROZEN_ARG,
44 : NUM_RELATION_STATS_ARGS
45 : };
46 :
47 : static struct StatsArgInfo relarginfo[] =
48 : {
49 : [RELSCHEMA_ARG] = {"schemaname", TEXTOID},
50 : [RELNAME_ARG] = {"relname", TEXTOID},
51 : [RELPAGES_ARG] = {"relpages", INT4OID},
52 : [RELTUPLES_ARG] = {"reltuples", FLOAT4OID},
53 : [RELALLVISIBLE_ARG] = {"relallvisible", INT4OID},
54 : [RELALLFROZEN_ARG] = {"relallfrozen", INT4OID},
55 : [NUM_RELATION_STATS_ARGS] = {0}
56 : };
57 :
58 : static bool relation_statistics_update(FunctionCallInfo fcinfo);
59 :
60 : /*
61 : * Internal function for modifying statistics for a relation.
62 : */
63 : static bool
64 4220 : relation_statistics_update(FunctionCallInfo fcinfo)
65 : {
66 4220 : bool result = true;
67 : char *nspname;
68 : char *relname;
69 : Oid reloid;
70 : Relation crel;
71 4220 : BlockNumber relpages = 0;
72 4220 : bool update_relpages = false;
73 4220 : float reltuples = 0;
74 4220 : bool update_reltuples = false;
75 4220 : BlockNumber relallvisible = 0;
76 4220 : bool update_relallvisible = false;
77 4220 : BlockNumber relallfrozen = 0;
78 4220 : bool update_relallfrozen = false;
79 : HeapTuple ctup;
80 : Form_pg_class pgcform;
81 4220 : int replaces[4] = {0};
82 4220 : Datum values[4] = {0};
83 4220 : bool nulls[4] = {0};
84 4220 : int nreplaces = 0;
85 :
86 4220 : stats_check_required_arg(fcinfo, relarginfo, RELSCHEMA_ARG);
87 4208 : stats_check_required_arg(fcinfo, relarginfo, RELNAME_ARG);
88 :
89 4196 : nspname = TextDatumGetCString(PG_GETARG_DATUM(RELSCHEMA_ARG));
90 4196 : relname = TextDatumGetCString(PG_GETARG_DATUM(RELNAME_ARG));
91 :
92 4196 : reloid = stats_lookup_relid(nspname, relname);
93 :
94 4190 : if (RecoveryInProgress())
95 0 : ereport(ERROR,
96 : (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
97 : errmsg("recovery is in progress"),
98 : errhint("Statistics cannot be modified during recovery.")));
99 :
100 4190 : stats_lock_check_privileges(reloid);
101 :
102 4172 : if (!PG_ARGISNULL(RELPAGES_ARG))
103 : {
104 4148 : relpages = PG_GETARG_UINT32(RELPAGES_ARG);
105 4148 : update_relpages = true;
106 : }
107 :
108 4172 : if (!PG_ARGISNULL(RELTUPLES_ARG))
109 : {
110 4136 : reltuples = PG_GETARG_FLOAT4(RELTUPLES_ARG);
111 4136 : if (reltuples < -1.0)
112 : {
113 0 : ereport(WARNING,
114 : (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
115 : errmsg("reltuples cannot be < -1.0")));
116 0 : result = false;
117 : }
118 : else
119 4136 : update_reltuples = true;
120 : }
121 :
122 4172 : if (!PG_ARGISNULL(RELALLVISIBLE_ARG))
123 : {
124 4136 : relallvisible = PG_GETARG_UINT32(RELALLVISIBLE_ARG);
125 4136 : update_relallvisible = true;
126 : }
127 :
128 4172 : if (!PG_ARGISNULL(RELALLFROZEN_ARG))
129 : {
130 4136 : relallfrozen = PG_GETARG_UINT32(RELALLFROZEN_ARG);
131 4136 : update_relallfrozen = true;
132 : }
133 :
134 : /*
135 : * Take RowExclusiveLock on pg_class, consistent with
136 : * vac_update_relstats().
137 : */
138 4172 : crel = table_open(RelationRelationId, RowExclusiveLock);
139 :
140 4172 : ctup = SearchSysCache1(RELOID, ObjectIdGetDatum(reloid));
141 4172 : if (!HeapTupleIsValid(ctup))
142 0 : elog(ERROR, "pg_class entry for relid %u not found", reloid);
143 :
144 4172 : pgcform = (Form_pg_class) GETSTRUCT(ctup);
145 :
146 4172 : if (update_relpages && relpages != pgcform->relpages)
147 : {
148 1838 : replaces[nreplaces] = Anum_pg_class_relpages;
149 1838 : values[nreplaces] = UInt32GetDatum(relpages);
150 1838 : nreplaces++;
151 : }
152 :
153 4172 : if (update_reltuples && reltuples != pgcform->reltuples)
154 : {
155 1840 : replaces[nreplaces] = Anum_pg_class_reltuples;
156 1840 : values[nreplaces] = Float4GetDatum(reltuples);
157 1840 : nreplaces++;
158 : }
159 :
160 4172 : if (update_relallvisible && relallvisible != pgcform->relallvisible)
161 : {
162 462 : replaces[nreplaces] = Anum_pg_class_relallvisible;
163 462 : values[nreplaces] = UInt32GetDatum(relallvisible);
164 462 : nreplaces++;
165 : }
166 :
167 4172 : if (update_relallfrozen && relallfrozen != pgcform->relallfrozen)
168 : {
169 88 : replaces[nreplaces] = Anum_pg_class_relallfrozen;
170 88 : values[nreplaces] = UInt32GetDatum(relallfrozen);
171 88 : nreplaces++;
172 : }
173 :
174 4172 : if (nreplaces > 0)
175 : {
176 2130 : TupleDesc tupdesc = RelationGetDescr(crel);
177 : HeapTuple newtup;
178 :
179 2130 : newtup = heap_modify_tuple_by_cols(ctup, tupdesc, nreplaces,
180 : replaces, values, nulls);
181 2130 : CatalogTupleUpdate(crel, &newtup->t_self, newtup);
182 2130 : heap_freetuple(newtup);
183 : }
184 :
185 4172 : ReleaseSysCache(ctup);
186 :
187 : /* release the lock, consistent with vac_update_relstats() */
188 4172 : table_close(crel, RowExclusiveLock);
189 :
190 4172 : CommandCounterIncrement();
191 :
192 4172 : return result;
193 : }
194 :
195 : /*
196 : * Clear statistics for a given pg_class entry; that is, set back to initial
197 : * stats for a newly-created table.
198 : */
199 : Datum
200 24 : pg_clear_relation_stats(PG_FUNCTION_ARGS)
201 : {
202 24 : LOCAL_FCINFO(newfcinfo, 6);
203 :
204 24 : InitFunctionCallInfoData(*newfcinfo, NULL, 6, InvalidOid, NULL, NULL);
205 :
206 24 : newfcinfo->args[0].value = PG_GETARG_DATUM(0);
207 24 : newfcinfo->args[0].isnull = PG_ARGISNULL(0);
208 24 : newfcinfo->args[1].value = PG_GETARG_DATUM(1);
209 24 : newfcinfo->args[1].isnull = PG_ARGISNULL(1);
210 24 : newfcinfo->args[2].value = UInt32GetDatum(0);
211 24 : newfcinfo->args[2].isnull = false;
212 24 : newfcinfo->args[3].value = Float4GetDatum(-1.0);
213 24 : newfcinfo->args[3].isnull = false;
214 24 : newfcinfo->args[4].value = UInt32GetDatum(0);
215 24 : newfcinfo->args[4].isnull = false;
216 24 : newfcinfo->args[5].value = UInt32GetDatum(0);
217 24 : newfcinfo->args[5].isnull = false;
218 :
219 24 : relation_statistics_update(newfcinfo);
220 12 : PG_RETURN_VOID();
221 : }
222 :
223 : Datum
224 4208 : pg_restore_relation_stats(PG_FUNCTION_ARGS)
225 : {
226 4208 : LOCAL_FCINFO(positional_fcinfo, NUM_RELATION_STATS_ARGS);
227 4208 : bool result = true;
228 :
229 4208 : InitFunctionCallInfoData(*positional_fcinfo, NULL,
230 : NUM_RELATION_STATS_ARGS,
231 : InvalidOid, NULL, NULL);
232 :
233 4208 : if (!stats_fill_fcinfo_from_arg_pairs(fcinfo, positional_fcinfo,
234 : relarginfo))
235 24 : result = false;
236 :
237 4196 : if (!relation_statistics_update(positional_fcinfo))
238 0 : result = false;
239 :
240 4160 : PG_RETURN_BOOL(result);
241 : }
|
