mirror of
https://github.com/postgrespro/pg_probackup.git
synced 2025-02-09 14:33:17 +02:00
tests ptrack.py fixes
This commit is contained in:
Grigory Smolkin
parent
6c2050f1d5
commit
d21412d274
@ -60,7 +60,11 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
node.start()
|
||||
|
||||
# FULL BACKUP
|
||||
print('START')
|
||||
print(node.safe_psql('postgres', "select pg_ptrack_control_lsn()"))
|
||||
self.backup_node(backup_dir, 'node', node, options=['--stream'])
|
||||
print('AFTER FULL')
|
||||
print(node.safe_psql('postgres', "select pg_ptrack_control_lsn()"))
|
||||
# DISABLE PTRACK
|
||||
node.safe_psql('postgres', "alter system set ptrack_enable to off")
|
||||
node.restart()
|
||||
@ -85,44 +89,6 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
# Clean after yourself
|
||||
self.del_test_dir(module_name, fname)
|
||||
|
||||
# @unittest.skip("skip")
|
||||
# @unittest.expectedFailure
|
||||
def test_ptrack_control(self):
|
||||
"""make ptrack without full backup, should result in error"""
|
||||
self.maxDiff = None
|
||||
fname = self.id().split('.')[3]
|
||||
backup_dir = os.path.join(self.tmp_path, module_name, fname, 'backup')
|
||||
node = self.make_simple_node(base_dir="{0}/{1}/node".format(module_name, fname),
|
||||
set_replication=True,
|
||||
initdb_params=['--data-checksums'],
|
||||
pg_options={'wal_level': 'replica', 'max_wal_senders': '2', 'checkpoint_timeout': '30s', 'ptrack_enable': 'on'}
|
||||
)
|
||||
self.init_pb(backup_dir)
|
||||
self.add_instance(backup_dir, 'node', node)
|
||||
node.start()
|
||||
|
||||
# FULL BACKUP
|
||||
self.backup_node(backup_dir, 'node', node, options=['--stream'])
|
||||
# DISABLE PTRACK
|
||||
node.safe_psql('postgres', "select ")
|
||||
node.restart()
|
||||
# ENABLE PTRACK
|
||||
node.safe_psql('postgres', "alter system set ptrack_enable to on")
|
||||
node.restart()
|
||||
|
||||
# PTRACK BACKUP
|
||||
try:
|
||||
self.backup_node(backup_dir, 'node', node, backup_type='ptrack', options=["--stream"])
|
||||
# we should die here because exception is what we expect to happen
|
||||
self.assertEqual(1, 0, "Expecting Error because ptrack_enable was set to OFF at some point after previous backup.\n Output: {0} \n CMD: {1}".format(
|
||||
repr(self.output), self.cmd))
|
||||
except ProbackupException as e:
|
||||
self.assertIn('ERROR: LSN from ptrack_control', e.message,
|
||||
'\n Unexpected Error Message: {0}\n CMD: {1}'.format(repr(e.message), self.cmd))
|
||||
|
||||
# Clean after yourself
|
||||
self.del_test_dir(module_name, fname)
|
||||
|
||||
# @unittest.skip("skip")
|
||||
def test_ptrack_stream(self):
|
||||
"""make node, make full and ptrack stream backups, restore them and check data correctness"""
|
||||
@ -417,9 +383,8 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
node.safe_psql("db1", "create table t_heap as select i as id, md5(i::text) as text, md5(i::text)::tsvector as tsvector from generate_series(0,100) i")
|
||||
|
||||
# PTRACK BACKUP
|
||||
node.safe_psql("postgres", "checkpoint")
|
||||
pgdata = self.pgdata_content(node.data_dir)
|
||||
backup_id = self.backup_node(backup_dir, 'node', node, backup_type='ptrack', options=["--stream"])
|
||||
pgdata = self.pgdata_content(node.data_dir)
|
||||
|
||||
# RESTORE
|
||||
node_restored = self.make_simple_node(base_dir="{0}/{1}/node_restored".format(module_name, fname))
|
||||
@ -432,13 +397,13 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
# START RESTORED NODE
|
||||
node_restored.append_conf("postgresql.auto.conf", "port = {0}".format(node_restored.port))
|
||||
node_restored.start()
|
||||
# result_new = node_restored.safe_psql("postgres", "select * from pg_class")
|
||||
|
||||
# DROP DATABASE DB1
|
||||
node.safe_psql(
|
||||
"postgres", "drop database db1")
|
||||
# SECOND PTRACK BACKUP
|
||||
backup_id = self.backup_node(backup_dir, 'node', node, backup_type='ptrack', options=["--stream"])
|
||||
pgdata = self.pgdata_content(node.data_dir)
|
||||
|
||||
# RESTORE SECOND PTRACK BACKUP
|
||||
node_restored.cleanup()
|
||||
@ -447,10 +412,10 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
# START RESTORED NODE
|
||||
node_restored.append_conf("postgresql.auto.conf", "port = {0}".format(node_restored.port))
|
||||
node_restored.start()
|
||||
|
||||
# COMPARE PHYSICAL CONTENT
|
||||
#pgdata = self.pgdata_content(node.data_dir)
|
||||
#pgdata_new = self.pgdata_content(node_restored.data_dir)
|
||||
#self.compare_pgdata(pgdata, pgdata_new)
|
||||
pgdata_new = self.pgdata_content(node_restored.data_dir)
|
||||
self.compare_pgdata(pgdata, pgdata_new)
|
||||
|
||||
try:
|
||||
node_restored.safe_psql('db1', 'select 1')
|
||||
@ -495,7 +460,6 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
|
||||
# PTRACK BACKUP
|
||||
result = node.safe_psql("postgres", "select * from t_heap")
|
||||
node.safe_psql("postgres", "select * from pg_class; checkpoint")
|
||||
self.backup_node(backup_dir, 'node', node, backup_type='ptrack', options=["--stream"])
|
||||
pgdata_content = self.pgdata_content(node.data_dir)
|
||||
node.stop()
|
||||
@ -549,7 +513,7 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
|
||||
# PTRACK BACKUP
|
||||
self.backup_node(backup_dir, 'node', node, backup_type='ptrack', options=["--stream"])
|
||||
pgdata_content = self.pgdata_content(node.data_dir)
|
||||
pgdata= self.pgdata_content(node.data_dir)
|
||||
node.stop()
|
||||
|
||||
# RESTORE
|
||||
@ -559,9 +523,9 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
"-T", "{0}={1}".format(self.get_tblspace_path(node,'somedata'), self.get_tblspace_path(node_restored,'somedata'))])
|
||||
|
||||
# GET PHYSICAL CONTENT
|
||||
pgdata_content_new = self.pgdata_content(node_restored.data_dir)
|
||||
pgdata_new = self.pgdata_content(node_restored.data_dir)
|
||||
# COMPARE PHYSICAL CONTENT
|
||||
self.compare_pgdata(pgdata_content, pgdata_content_new)
|
||||
self.compare_pgdata(pgdata, pgdata_new)
|
||||
# START RESTORED NODE
|
||||
node_restored.start()
|
||||
|
||||
@ -718,11 +682,10 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
self.add_instance(backup_dir, 'node', node)
|
||||
node.start()
|
||||
|
||||
# self.create_tblspace_in_node(node, 'somedata')
|
||||
self.create_tblspace_in_node(node, 'somedata')
|
||||
|
||||
# CREATE TABLE
|
||||
# node.pgbench_init(scale=300, options=['--tablespace=somedata'])
|
||||
pgbench = node.pgbench_init(scale=30)
|
||||
node.pgbench_init(scale=30, options=['--tablespace=somedata'])
|
||||
# FULL BACKUP
|
||||
self.backup_node(backup_dir, 'node', node, options=["--stream"])
|
||||
|
||||
@ -736,24 +699,25 @@ class PtrackBackupTest(ProbackupTest, unittest.TestCase):
|
||||
pgdata = self.pgdata_content(node.data_dir)
|
||||
|
||||
# RESTORE NODE
|
||||
# self.restore_node(backup_dir, 'node', restored_node, options=[
|
||||
# "-j", "4", "-T", "{0}={1}".format(tblspc_path, tblspc_path_new)])
|
||||
restored_node = self.make_simple_node(base_dir="{0}/{1}/restored_node".format(module_name, fname))
|
||||
restored_node.cleanup()
|
||||
# tblspc_path = self.get_tblspace_path(node, 'somedata')
|
||||
# tblspc_path_new = self.get_tblspace_path(restored_node, 'somedata_restored')
|
||||
tblspc_path = self.get_tblspace_path(node, 'somedata')
|
||||
tblspc_path_new = self.get_tblspace_path(restored_node, 'somedata_restored')
|
||||
|
||||
self.restore_node(backup_dir, 'node', restored_node, options=[
|
||||
"-j", "4"])
|
||||
"-j", "4", "-T", "{0}={1}".format(tblspc_path, tblspc_path_new)])
|
||||
# self.restore_node(backup_dir, 'node', restored_node, options=[
|
||||
# "-j", "4"])
|
||||
# GET PHYSICAL CONTENT FROM NODE_RESTORED
|
||||
pgdata_restored = self.pgdata_content(restored_node.data_dir)
|
||||
self.compare_pgdata(pgdata, pgdata_restored)
|
||||
|
||||
# START RESTORED NODE
|
||||
restored_node.append_conf("postgresql.auto.conf", "port = {0}".format(restored_node.port))
|
||||
restored_node.start()
|
||||
|
||||
result_new = restored_node.safe_psql("postgres", "select * from pgbench_accounts")
|
||||
self.assertEqual(result, result_new)
|
||||
self.compare_pgdata(pgdata, pgdata_restored)
|
||||
|
||||
# Clean after yourself
|
||||
self.del_test_dir(module_name, fname)
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user