From a20afe28ec631513faca46c05feb371922518fa6 Mon Sep 17 00:00:00 2001
From: Ian Barwick <barwick@gmail.com>
Date: Thu, 15 Jan 2015 23:54:07 +0900
Subject: [PATCH] Add upstream_node_id to repl_nodes table

---
 repmgr.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/repmgr.c b/repmgr.c
index a233b6d8..30ea2fea 100644
--- a/repmgr.c
+++ b/repmgr.c
@@ -2041,11 +2041,13 @@ create_schema(PGconn *conn)
 	sqlquery_snprintf(sqlquery,
 					  "CREATE TABLE %s.repl_nodes (     "
 					  "  id               INTEGER PRIMARY KEY, "
+					  "  upstream_node_id INTEGER NULL REFERENCES %s.repl_nodes (id), "
 					  "  cluster          TEXT    NOT NULL,    "
 					  "  name             TEXT    NOT NULL,    "
 					  "  conninfo         TEXT    NOT NULL,    "
 					  "  priority         INTEGER NOT NULL,    "
 					  "  witness          BOOLEAN NOT NULL DEFAULT FALSE) ",
+					  get_repmgr_schema_quoted(conn),
 					  get_repmgr_schema_quoted(conn));
 
 	log_debug(_("master register: %s\n"), sqlquery);