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

Add querystring column to pg_ivm_immv.

Browse source
This commit is contained in:
Adam Guo 2025-03-26 17:07:26 +00:00
parent 3f33229efe
commit d6f32e7b77
5 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
Makefile
View file

@ -18,7 +18,7 @@ DATA = pg_ivm--1.0.sql \
pg_ivm--1.3--1.4.sql pg_ivm--1.4--1.5.sql pg_ivm--1.5--1.6.sql \ pg_ivm--1.3--1.4.sql pg_ivm--1.4--1.5.sql pg_ivm--1.5--1.6.sql \
pg_ivm--1.6--1.7.sql pg_ivm--1.7--1.8.sql pg_ivm--1.8--1.9.sql \ pg_ivm--1.6--1.7.sql pg_ivm--1.7--1.8.sql pg_ivm--1.8--1.9.sql \
pg_ivm--1.9--1.10.sql \ pg_ivm--1.9--1.10.sql \
pg_ivm--1.10.sql pg_ivm--1.10.sql pg_ivm--1.10--1.11.sql
REGRESS = pg_ivm create_immv refresh_immv REGRESS = pg_ivm create_immv refresh_immv

1
createas.c
View file

@ -1719,6 +1719,7 @@ StoreImmvQuery(Oid viewOid, Query *viewQuery)
memset(values, 0, sizeof(values)); memset(values, 0, sizeof(values));
memset(isNulls, false, sizeof(isNulls)); memset(isNulls, false, sizeof(isNulls));
isNulls[Anum_pg_ivm_immv_querystring - 1] = true;
values[Anum_pg_ivm_immv_immvrelid -1 ] = ObjectIdGetDatum(viewOid); values[Anum_pg_ivm_immv_immvrelid -1 ] = ObjectIdGetDatum(viewOid);
values[Anum_pg_ivm_immv_ispopulated -1 ] = BoolGetDatum(false); values[Anum_pg_ivm_immv_ispopulated -1 ] = BoolGetDatum(false);

1
pg_ivm--1.10--1.11.sql Normal file
View file

@ -0,0 +1 @@
ALTER TABLE pgivm.pg_ivm_immv ADD COLUMN querystring text;

2
pg_ivm.control
View file

@ -1,6 +1,6 @@
# incremental view maintenance extension_ # incremental view maintenance extension_
comment = 'incremental view maintenance on PostgreSQL' comment = 'incremental view maintenance on PostgreSQL'
default_version = '1.10' default_version = '1.11'
module_pathname = '$libdir/pg_ivm' module_pathname = '$libdir/pg_ivm'
relocatable = false relocatable = false
schema = pg_catalog schema = pg_catalog

3
pg_ivm.h
View file

@ -20,12 +20,13 @@
#include "tcop/dest.h" #include "tcop/dest.h"
#include "utils/queryenvironment.h" #include "utils/queryenvironment.h"
#define Natts_pg_ivm_immv 4 #define Natts_pg_ivm_immv 5
#define Anum_pg_ivm_immv_immvrelid 1 #define Anum_pg_ivm_immv_immvrelid 1
#define Anum_pg_ivm_immv_viewdef 2 #define Anum_pg_ivm_immv_viewdef 2
#define Anum_pg_ivm_immv_ispopulated 3 #define Anum_pg_ivm_immv_ispopulated 3
#define Anum_pg_ivm_immv_lastivmupdate 4 #define Anum_pg_ivm_immv_lastivmupdate 4
#define Anum_pg_ivm_immv_querystring 5
/* pg_ivm.c */ /* pg_ivm.c */