Commit5ea4bd8

committed

Add PostgresNode.promote() method which promotes standby node to master

1 parent72d0373 commit5ea4bd8Copy full SHA for 5ea4bd8

File tree

+36

-0

lines changed

+36

-0

lines changed

Lines changed: 22 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -691,6 +691,28 @@ def reload(self, params=[]):`
`691`	`691`
`692`	`692`	`returnself`
`693`	`693`
	`694`	`+defpromote(self):`
	`695`	`+"""`
	`696`	`+ Promote standby instance to master using pg_ctl.`
	`697`	`+`
	`698`	`+ Returns:`
	`699`	+ This instance of :class:`.PostgresNode`.
	`700`	`+ """`
	`701`	`+`
	`702`	`+_params= [`
	`703`	`+get_bin_path("pg_ctl"),`
	`704`	`+"-D",self.data_dir,`
	`705`	`+"-w",# wait`
	`706`	`+"promote"`
	`707`	`+ ]# yapf: disable`
	`708`	`+`
	`709`	`+execute_utility(_params,self.utils_log_file)`
	`710`	`+`
	`711`	`+# Node becomes master itself`
	`712`	`+self._master=None`
	`713`	`+`
	`714`	`+returnself`
	`715`	`+`
`694`	`716`	`defpg_ctl(self,params):`
`695`	`717`	`"""`
`696`	`718`	`Invoke pg_ctl with params.`

Lines changed: 14 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -529,6 +529,20 @@ def test_incorrect_catchup(self):`
`529`	`529`	`withself.assertRaises(TestgresException):`
`530`	`530`	`node.catchup()`
`531`	`531`
	`532`	`+deftest_promotion(self):`
	`533`	`+withget_new_node()asmaster:`
	`534`	`+master.init().start()`
	`535`	`+master.safe_psql('create table abc(id serial)')`
	`536`	`+`
	`537`	`+withmaster.replicate().start()asreplica:`
	`538`	`+master.stop()`
	`539`	`+replica.promote()`
	`540`	`+`
	`541`	`+# make standby becomes writable master`
	`542`	`+replica.safe_psql('insert into abc values (1)')`
	`543`	`+res=replica.safe_psql('select * from abc')`
	`544`	`+self.assertEqual(res,b'1\n')`
	`545`	`+`
`532`	`546`	`deftest_dump(self):`
`533`	`547`	`query_create='create table test as select generate_series(1, 2) as val'`
`534`	`548`	`query_select='select * from test order by val asc'`

Comments

(0)