db/pg_probackup
db/pg_probackup
1
0
Fork 0
mirror of https://github.com/postgrespro/pg_probackup.git synced 2025-02-03 14:01:57 +02:00
Code Issues Releases Activity

tests: added checkdb.CheckdbTest.test_checkdb_block_validation

Browse Source
This commit is contained in:
Grigory Smolkin 2019-03-31 11:43:50 +03:00
parent 820a0a63a6
commit 0b549f317f
1 changed files with 55 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
tests/checkdb.py
View File

@ -14,7 +14,8 @@ module_name = 'checkdb'
class CheckdbTest(ProbackupTest, unittest.TestCase):
def test_checkdb_index_loss(self):
@unittest.skip("skip")
def checkdb_index_loss(self):
"""make node, make full and ptrack stream backups,"
" restore them and check data correctness"""
fname = self.id().split('.')[3]
@ -22,12 +23,8 @@ class CheckdbTest(ProbackupTest, unittest.TestCase):
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',
}
)
initdb_params=['--data-checksums'])
self.init_pb(backup_dir)
self.add_instance(backup_dir, 'node', node)
self.set_archiving(backup_dir, 'node', node)
@ -59,4 +56,54 @@ class CheckdbTest(ProbackupTest, unittest.TestCase):
gdb.continue_execution_until_exit()
# Clean after yourself
self.del_test_dir(module_name, fname)
self.del_test_dir(module_name, fname)
# @unittest.skip("skip")
def test_checkdb_block_validation(self):
"""make node, corrupt some pages, check that checkdb failed"""
fname = self.id().split('.')[3]
node = self.make_simple_node(
base_dir=os.path.join(module_name, fname, 'node'),
set_replication=True,
initdb_params=['--data-checksums'])
backup_dir = os.path.join(self.tmp_path, module_name, fname, 'backup')
self.init_pb(backup_dir)
self.add_instance(backup_dir, 'node', node)
node.slow_start()
#self.backup_node(
# backup_dir, 'node', node,
# backup_type="full", options=["-j", "4", "--stream"])
node.safe_psql(
"postgres",
"create table t_heap as select 1 as id, md5(i::text) as text, "
"md5(repeat(i::text,10))::tsvector as tsvector "
"from generate_series(0,1000) i")
node.safe_psql(
"postgres",
"CHECKPOINT;")
heap_path = node.safe_psql(
"postgres",
"select pg_relation_filepath('t_heap')").rstrip()
with open(os.path.join(node.data_dir, heap_path), "rb+", 0) as f:
f.seek(9000)
f.write(b"bla")
f.flush()
f.close
with open(os.path.join(node.data_dir, heap_path), "rb+", 0) as f:
f.seek(42000)
f.write(b"bla")
f.flush()
f.close
print(self.checkdb_node('node', backup_dir,
data_dir=node.data_dir, options=['--block-validation']))
# Clean after yourself
self.del_test_dir(module_name, fname)