luciano/pg_ivm
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Emit warning

Browse source
This commit is contained in:
Adam Guo 2025-03-04 16:29:16 +00:00
parent 23e897c32e
commit 0757f1f97a
2 changed files with 35 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
pg_ivm.c
View file

@ -269,13 +269,19 @@ IVM_prevent_immv_change(PG_FUNCTION_ARGS)
TriggerData *trigdata = (TriggerData *) fcinfo->context; TriggerData *trigdata = (TriggerData *) fcinfo->context;
Relation rel = trigdata->tg_relation; Relation rel = trigdata->tg_relation;
if (!ImmvIncrementalMaintenanceIsEnabled()) if (ImmvIncrementalMaintenanceIsEnabled())
return PointerGetDatum(NULL);
/*
* If we are maintaining an IMMV, this warning would have been emitted by
* the IVM_immediate_* triggers, so there is no need to emit it again.
*/
warnIfPgIvmNotPreloaded();
ereport(ERROR, ereport(ERROR,
(errcode(ERRCODE_WRONG_OBJECT_TYPE), (errcode(ERRCODE_WRONG_OBJECT_TYPE),
errmsg("cannot change materialized view \"%s\"", errmsg("cannot change materialized view \"%s\"",
RelationGetRelationName(rel)))); RelationGetRelationName(rel))));
return PointerGetDatum(NULL);
} }
/* /*
@ -467,7 +473,7 @@ PgIvmFuncName(char *name)
* *
* Check if pg_ivm is in the shared_preload_libraries parameter. * Check if pg_ivm is in the shared_preload_libraries parameter.
*/ */
bool static bool
pgIvmIsInSharedPreloadLibraries() pgIvmIsInSharedPreloadLibraries()
{ {
return check_string_in_guc_list("pg_ivm", shared_preload_libraries_string, return check_string_in_guc_list("pg_ivm", shared_preload_libraries_string,
@ -479,13 +485,33 @@ pgIvmIsInSharedPreloadLibraries()
* *
* Check if pg_ivm is in the session_preload_libraries parameter. * Check if pg_ivm is in the session_preload_libraries parameter.
*/ */
bool static bool
pgIvmIsInSessionPreloadLibraries() pgIvmIsInSessionPreloadLibraries()
{ {
return check_string_in_guc_list("pg_ivm", session_preload_libraries_string, return check_string_in_guc_list("pg_ivm", session_preload_libraries_string,
"session_preload_libraries"); "session_preload_libraries");
} }
/*
* warnIfPgIvmNotPreloaded
*
* Emit a warning if pg_ivm is not in shared_preload_libraries or
* session_preload_libraries.
*/
void
warnIfPgIvmNotPreloaded()
{
if (!pgIvmIsInSharedPreloadLibraries() &&
!pgIvmIsInSessionPreloadLibraries())
ereport(WARNING,
(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
errmsg("pg_ivm is not loaded in shared_preload_libraries or "
"session_preload_libraries"),
errhint("Add pg_ivm to session_preload_libraries and restart "
"the session. Or, add pg_ivm to "
"shared_preload_libraries and restart Postgres.")));
}
/* /*
* check_string_in_guc_list * check_string_in_guc_list
* *

3
pg_ivm.h
View file

@ -34,8 +34,7 @@ extern Oid PgIvmImmvRelationId(void);
extern Oid PgIvmImmvPrimaryKeyIndexId(void); extern Oid PgIvmImmvPrimaryKeyIndexId(void);
extern bool isImmv(Oid immv_oid); extern bool isImmv(Oid immv_oid);
extern List *PgIvmFuncName(char *name); extern List *PgIvmFuncName(char *name);
extern bool pgIvmIsInSharedPreloadLibraries(void); extern void warnIfPgIvmNotPreloaded(void);
extern bool pgIvmIsInSessionPreloadLibraries(void);
/* createas.c */ /* createas.c */