github/repmgr
1
0
Fork 0
mirror of https://github.com/EnterpriseDB/repmgr.git synced 2026-03-26 08:36:30 +00:00
Code Issues Packages Projects Releases 1 Wiki Activity

Redefining repl_status view to improve performance, also add an

Browse Source 
index on repl_monitor to speed up even more the view.
This commit is contained in:
Jaime Casanova
2011-06-13 11:58:43 -05:00
parent 3f4ff5a862
commit 4d26e4d21e
2 changed files with 25 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
repmgr.c
View File

@@ -1911,16 +1911,16 @@ create_schema(PGconn *conn)
exit(ERR_BAD_CONFIG); exit(ERR_BAD_CONFIG);
} }
/* and the view */ /* a view */
sqlquery_snprintf(sqlquery, "CREATE VIEW %s.repl_status AS " sqlquery_snprintf(sqlquery, "CREATE VIEW %s.repl_status AS "
" WITH monitor_info AS (SELECT *, ROW_NUMBER() OVER (PARTITION BY primary_node, standby_node " " SELECT primary_node, standby_node, last_monitor_time, last_wal_primary_location, "
" ORDER BY last_monitor_time desc) " " last_wal_standby_location, pg_size_pretty(replication_lag) replication_lag, "
" FROM %s.repl_monitor) " " pg_size_pretty(apply_lag) apply_lag, "
" SELECT primary_node, standby_node, last_monitor_time, last_wal_primary_location, " " age(now(), last_monitor_time) AS time_lag "
" last_wal_standby_location, pg_size_pretty(replication_lag) replication_lag, " " FROM %s.repl_monitor "
" pg_size_pretty(apply_lag) apply_lag, age(now(), last_monitor_time) AS time_lag " " WHERE (standby_node, last_monitor_time) IN (SELECT standby_node, MAX(last_monitor_time) "
" FROM monitor_info a " " FROM %s.repl_monitor GROUP BY 1)",
" WHERE row_number = 1", repmgr_schema, repmgr_schema); repmgr_schema, repmgr_schema, repmgr_schema);
log_debug(_("master register: %s\n"), sqlquery); log_debug(_("master register: %s\n"), sqlquery);
if (!PQexec(conn, sqlquery)) if (!PQexec(conn, sqlquery))
{ {
@@ -1930,6 +1930,18 @@ create_schema(PGconn *conn)
exit(ERR_BAD_CONFIG); exit(ERR_BAD_CONFIG);
} }
/* an index to improve performance of the view */
sqlquery_snprintf(sqlquery, "CREATE INDEX idx_repl_status_sort "
" ON %s.repl_monitor (last_monitor_time, standby_node) ");
log_debug(_("master register: %s\n"), sqlquery);
if (!PQexec(conn, sqlquery))
{
log_err(_("Cannot indexing table %s.repl_monitor: %s\n"),
repmgr_schema, PQerrorMessage(conn));
PQfinish(conn);
exit(ERR_BAD_CONFIG);
}
/* XXX Here we MUST try to load the repmgr_function.sql not hardcode it here */ /* XXX Here we MUST try to load the repmgr_function.sql not hardcode it here */
sprintf(sqlquery, sprintf(sqlquery,
"CREATE OR REPLACE FUNCTION public.repmgr_update_standby_location(text) RETURNS boolean " "CREATE OR REPLACE FUNCTION public.repmgr_update_standby_location(text) RETURNS boolean "

9
repmgr.sql
View File

@@ -34,6 +34,7 @@ CREATE TABLE repl_monitor (
); );
ALTER TABLE repl_monitor OWNER TO repmgr; ALTER TABLE repl_monitor OWNER TO repmgr;
CREATE INDEX idx_repl_monitor_last_monitor_sort ON repl_monitor(last_monitor_time, standby_node);
/* /*
* This view shows the latest monitor info about every node. * This view shows the latest monitor info about every node.
@@ -46,14 +47,12 @@ ALTER TABLE repl_monitor OWNER TO repmgr;
* time_lag: how many seconds are we from being up-to-date with master * time_lag: how many seconds are we from being up-to-date with master
*/ */
CREATE VIEW repl_status AS CREATE VIEW repl_status AS
WITH monitor_info AS (SELECT *, ROW_NUMBER() OVER (PARTITION BY primary_node, standby_node
ORDER BY last_monitor_time desc)
FROM repl_monitor)
SELECT primary_node, standby_node, last_monitor_time, last_wal_primary_location, SELECT primary_node, standby_node, last_monitor_time, last_wal_primary_location,
last_wal_standby_location, pg_size_pretty(replication_lag) replication_lag, last_wal_standby_location, pg_size_pretty(replication_lag) replication_lag,
pg_size_pretty(apply_lag) apply_lag, pg_size_pretty(apply_lag) apply_lag,
age(now(), last_monitor_time) AS time_lag age(now(), last_monitor_time) AS time_lag
FROM monitor_info a FROM repl_monitor
WHERE row_number = 1; WHERE (standby_node, last_monitor_time) IN (SELECT standby_node, MAX(last_monitor_time)
FROM repl_monitor GROUP BY 1);
ALTER VIEW repl_status OWNER TO repmgr; ALTER VIEW repl_status OWNER TO repmgr;