Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit88fed2b

Browse files
committed
tests: add suit of basic tests
1 parent8514420 commit88fed2b

17 files changed

+59
-149
lines changed

‎tests/Readme.md‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,11 @@ Specify path to pg_probackup binary file. By default tests use <Path to Git repo
2424
export PGPROBACKUPBIN=<path to pg_probackup>
2525
2626
Remote backup depends on key authentithication to local machine via ssh as current user.
27-
PGPROBACKUP_SSH_REMOTE=ON
27+
export PGPROBACKUP_SSH_REMOTE=ON
28+
29+
Run suit of basic simple tests:
30+
export PG_PROBACKUP_TEST_BASIC=ON
31+
2832
2933
Usage:
3034
pip install testgres

‎tests/__init__.py‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
importunittest
2+
importos
23

34
from .importinit,merge,option,show,compatibility, \
45
backup,delete,delta,restore,validate, \
@@ -10,6 +11,10 @@
1011

1112
defload_tests(loader,tests,pattern):
1213
suite=unittest.TestSuite()
14+
15+
ifos.environ['PG_PROBACKUP_TEST_BASIC']=='ON':
16+
loader.testMethodPrefix='test_basic'
17+
1318
# suite.addTests(loader.loadTestsFromModule(auth_test))
1419
suite.addTests(loader.loadTestsFromModule(archive))
1520
suite.addTests(loader.loadTestsFromModule(backup))

‎tests/archive.py‎

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@ def test_pgpro434_1(self):
2525
set_replication=True,
2626
initdb_params=['--data-checksums'],
2727
pg_options={
28-
'max_wal_senders':'2',
2928
'checkpoint_timeout':'30s'}
3029
)
3130
self.init_pb(backup_dir)
@@ -83,7 +82,6 @@ def test_pgpro434_2(self):
8382
set_replication=True,
8483
initdb_params=['--data-checksums'],
8584
pg_options={
86-
'max_wal_senders':'2',
8785
'checkpoint_timeout':'30s'}
8886
)
8987
self.init_pb(backup_dir)
@@ -232,7 +230,6 @@ def test_pgpro434_3(self):
232230
set_replication=True,
233231
initdb_params=['--data-checksums'],
234232
pg_options={
235-
'max_wal_senders':'2',
236233
'checkpoint_timeout':'30s'}
237234
)
238235
self.init_pb(backup_dir)
@@ -287,7 +284,6 @@ def test_arhive_push_file_exists(self):
287284
set_replication=True,
288285
initdb_params=['--data-checksums'],
289286
pg_options={
290-
'max_wal_senders':'2',
291287
'checkpoint_timeout':'30s'}
292288
)
293289
self.init_pb(backup_dir)
@@ -363,7 +359,6 @@ def test_arhive_push_file_exists_overwrite(self):
363359
set_replication=True,
364360
initdb_params=['--data-checksums'],
365361
pg_options={
366-
'max_wal_senders':'2',
367362
'checkpoint_timeout':'30s'}
368363
)
369364
self.init_pb(backup_dir)
@@ -639,7 +634,7 @@ def test_master_and_replica_parallel_archiving(self):
639634

640635
# @unittest.expectedFailure
641636
# @unittest.skip("skip")
642-
deftest_master_and_replica_concurrent_archiving(self):
637+
deftest_basic_master_and_replica_concurrent_archiving(self):
643638
"""
644639
make node 'master 'with archiving,
645640
take archive backup and turn it into replica,
@@ -736,7 +731,6 @@ def test_archive_pg_receivexlog(self):
736731
set_replication=True,
737732
initdb_params=['--data-checksums'],
738733
pg_options={
739-
'max_wal_senders':'2',
740734
'checkpoint_timeout':'30s'})
741735

742736
self.init_pb(backup_dir)
@@ -810,7 +804,6 @@ def test_archive_pg_receivexlog_compression_pg10(self):
810804
set_replication=True,
811805
initdb_params=['--data-checksums'],
812806
pg_options={
813-
'max_wal_senders':'2',
814807
'checkpoint_timeout':'30s'}
815808
)
816809
self.init_pb(backup_dir)

‎tests/backup.py‎

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -263,8 +263,7 @@ def test_ptrack_threads_stream(self):
263263
set_replication=True,
264264
initdb_params=['--data-checksums'],
265265
pg_options={
266-
'ptrack_enable':'on',
267-
'max_wal_senders':'2'})
266+
'ptrack_enable':'on'})
268267

269268
backup_dir=os.path.join(self.tmp_path,module_name,fname,'backup')
270269
self.init_pb(backup_dir)
@@ -291,8 +290,7 @@ def test_page_corruption_heal_via_ptrack_1(self):
291290
node=self.make_simple_node(
292291
base_dir=os.path.join(module_name,fname,'node'),
293292
set_replication=True,
294-
initdb_params=['--data-checksums'],
295-
pg_options={'max_wal_senders':'2'})
293+
initdb_params=['--data-checksums'])
296294

297295
backup_dir=os.path.join(self.tmp_path,module_name,fname,'backup')
298296

@@ -348,8 +346,7 @@ def test_page_corruption_heal_via_ptrack_2(self):
348346
node=self.make_simple_node(
349347
base_dir=os.path.join(module_name,fname,'node'),
350348
set_replication=True,
351-
initdb_params=['--data-checksums'],
352-
pg_options={'max_wal_senders':'2'})
349+
initdb_params=['--data-checksums'])
353350

354351
backup_dir=os.path.join(self.tmp_path,module_name,fname,'backup')
355352

@@ -521,7 +518,7 @@ def test_tablespace_in_pgdata_pgpro_1376(self):
521518
self.del_test_dir(module_name,fname)
522519

523520
# @unittest.skip("skip")
524-
deftest_tablespace_handling(self):
521+
deftest_basic_tablespace_handling(self):
525522
"""
526523
make node, take full backup, check that restore with
527524
tablespace mapping will end with error, take page backup,
@@ -968,7 +965,7 @@ def test_persistent_slot_for_stream_backup(self):
968965
self.del_test_dir(module_name,fname)
969966

970967
# @unittest.skip("skip")
971-
deftest_temp_slot_for_stream_backup(self):
968+
deftest_basic_temp_slot_for_stream_backup(self):
972969
""""""
973970
fname=self.id().split('.')[3]
974971
backup_dir=os.path.join(self.tmp_path,module_name,fname,'backup')

‎tests/checkdb.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -212,7 +212,7 @@ def test_checkdb_amcheck_only_sanity(self):
212212
self.del_test_dir(module_name,fname)
213213

214214
# @unittest.skip("skip")
215-
deftest_checkdb_amcheck_only_sanity_1(self):
215+
deftest_basic_checkdb_amcheck_only_sanity(self):
216216
""""""
217217
fname=self.id().split('.')[3]
218218
backup_dir=os.path.join(self.tmp_path,module_name,fname,'backup')

‎tests/compatibility.py‎

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ def test_backward_compatibility_page(self):
2020
set_replication=True,
2121
initdb_params=['--data-checksums'],
2222
pg_options={
23-
'max_wal_senders':'2',
2423
'autovacuum':'off'}
2524
)
2625
self.init_pb(backup_dir,old_binary=True)
@@ -123,7 +122,6 @@ def test_backward_compatibility_delta(self):
123122
set_replication=True,
124123
initdb_params=['--data-checksums'],
125124
pg_options={
126-
'max_wal_senders':'2',
127125
'autovacuum':'off'}
128126
)
129127
self.init_pb(backup_dir,old_binary=True)
@@ -226,7 +224,6 @@ def test_backward_compatibility_ptrack(self):
226224
set_replication=True,
227225
initdb_params=['--data-checksums'],
228226
pg_options={
229-
'max_wal_senders':'2',
230227
'autovacuum':'off'}
231228
)
232229
self.init_pb(backup_dir,old_binary=True)
@@ -329,7 +326,6 @@ def test_backward_compatibility_compression(self):
329326
set_replication=True,
330327
initdb_params=['--data-checksums'],
331328
pg_options={
332-
'max_wal_senders':'2',
333329
'autovacuum':'off'})
334330

335331
self.init_pb(backup_dir,old_binary=True)
@@ -494,7 +490,6 @@ def test_backward_compatibility_merge(self):
494490
set_replication=True,
495491
initdb_params=['--data-checksums'],
496492
pg_options={
497-
'max_wal_senders':'2',
498493
'autovacuum':'off'})
499494

500495
self.init_pb(backup_dir,old_binary=True)

‎tests/compression.py‎

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ class CompressionTest(ProbackupTest, unittest.TestCase):
1212

1313
# @unittest.skip("skip")
1414
# @unittest.expectedFailure
15-
deftest_compression_stream_zlib(self):
15+
deftest_basic_compression_stream_zlib(self):
1616
"""
1717
make archive node, make full and page stream backups,
1818
check data correctness in restored instance
@@ -25,7 +25,6 @@ def test_compression_stream_zlib(self):
2525
set_replication=True,
2626
initdb_params=['--data-checksums'],
2727
pg_options={
28-
'max_wal_senders':'2',
2928
'checkpoint_timeout':'30s',
3029
'ptrack_enable':'on'}
3130
)
@@ -245,7 +244,6 @@ def test_compression_stream_pglz(self):
245244
set_replication=True,
246245
initdb_params=['--data-checksums'],
247246
pg_options={
248-
'max_wal_senders':'2',
249247
'checkpoint_timeout':'30s',
250248
'ptrack_enable':'on'}
251249
)
@@ -355,7 +353,6 @@ def test_compression_archive_pglz(self):
355353
set_replication=True,
356354
initdb_params=['--data-checksums'],
357355
pg_options={
358-
'max_wal_senders':'2',
359356
'checkpoint_timeout':'30s',
360357
'ptrack_enable':'on'}
361358
)
@@ -465,7 +462,6 @@ def test_compression_wrong_algorithm(self):
465462
set_replication=True,
466463
initdb_params=['--data-checksums'],
467464
pg_options={
468-
'max_wal_senders':'2',
469465
'checkpoint_timeout':'30s',
470466
'ptrack_enable':'on'}
471467
)

‎tests/delta.py‎

Lines changed: 5 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
classDeltaTest(ProbackupTest,unittest.TestCase):
1414

1515
# @unittest.skip("skip")
16-
deftest_delta_vacuum_truncate_1(self):
16+
deftest_basic_delta_vacuum_truncate(self):
1717
"""
1818
make node, create table, take full backup,
1919
delete last 3 pages, vacuum relation,
@@ -27,7 +27,6 @@ def test_delta_vacuum_truncate_1(self):
2727
set_replication=True,
2828
initdb_params=['--data-checksums'],
2929
pg_options={
30-
'max_wal_senders':'2',
3130
'checkpoint_timeout':'300s',
3231
'autovacuum':'off'})
3332

@@ -92,7 +91,7 @@ def test_delta_vacuum_truncate_1(self):
9291
self.del_test_dir(module_name,fname)
9392

9493
# @unittest.skip("skip")
95-
deftest_delta_vacuum_truncate_2(self):
94+
deftest_delta_vacuum_truncate_1(self):
9695
"""
9796
make node, create table, take full backup,
9897
delete last 3 pages, vacuum relation,
@@ -106,7 +105,6 @@ def test_delta_vacuum_truncate_2(self):
106105
set_replication=True,
107106
initdb_params=['--data-checksums'],
108107
pg_options={
109-
'max_wal_senders':'2',
110108
'checkpoint_timeout':'300s',
111109
'autovacuum':'off'
112110
}
@@ -182,7 +180,7 @@ def test_delta_vacuum_truncate_2(self):
182180
self.del_test_dir(module_name,fname)
183181

184182
# @unittest.skip("skip")
185-
deftest_delta_vacuum_truncate_3(self):
183+
deftest_delta_vacuum_truncate_2(self):
186184
"""
187185
make node, create table, take full backup,
188186
delete last 3 pages, vacuum relation,
@@ -196,7 +194,6 @@ def test_delta_vacuum_truncate_3(self):
196194
set_replication=True,
197195
initdb_params=['--data-checksums'],
198196
pg_options={
199-
'max_wal_senders':'2',
200197
'checkpoint_timeout':'300s',
201198
'autovacuum':'off'
202199
}
@@ -265,7 +262,6 @@ def test_delta_stream(self):
265262
set_replication=True,
266263
initdb_params=['--data-checksums'],
267264
pg_options={
268-
'max_wal_senders':'2',
269265
'checkpoint_timeout':'30s'
270266
}
271267
)
@@ -424,7 +420,6 @@ def test_delta_multiple_segments(self):
424420
set_replication=True,
425421
initdb_params=['--data-checksums'],
426422
pg_options={
427-
'max_wal_senders':'2',
428423
'fsync':'off',
429424
'shared_buffers':'1GB',
430425
'maintenance_work_mem':'1GB',
@@ -506,7 +501,6 @@ def test_delta_vacuum_full(self):
506501
set_replication=True,
507502
initdb_params=['--data-checksums'],
508503
pg_options={
509-
'max_wal_senders':'2',
510504
'checkpoint_timeout':'300s'
511505
}
512506
)
@@ -598,7 +592,6 @@ def test_create_db(self):
598592
initdb_params=['--data-checksums'],
599593
pg_options={
600594
'max_wal_size':'10GB',
601-
'max_wal_senders':'2',
602595
'checkpoint_timeout':'5min',
603596
'autovacuum':'off'
604597
}
@@ -728,7 +721,6 @@ def test_exists_in_previous_backup(self):
728721
initdb_params=['--data-checksums'],
729722
pg_options={
730723
'max_wal_size':'10GB',
731-
'max_wal_senders':'2',
732724
'checkpoint_timeout':'5min',
733725
'autovacuum':'off'
734726
}
@@ -835,7 +827,6 @@ def test_alter_table_set_tablespace_delta(self):
835827
base_dir=os.path.join(module_name,fname,'node'),
836828
set_replication=True,initdb_params=['--data-checksums'],
837829
pg_options={
838-
'max_wal_senders':'2',
839830
'checkpoint_timeout':'30s',
840831
'autovacuum':'off'
841832
}
@@ -1019,7 +1010,6 @@ def test_delta_delete(self):
10191010
base_dir=os.path.join(module_name,fname,'node'),
10201011
set_replication=True,initdb_params=['--data-checksums'],
10211012
pg_options={
1022-
'max_wal_senders':'2',
10231013
'checkpoint_timeout':'30s',
10241014
'autovacuum':'off'
10251015
}
@@ -1099,8 +1089,7 @@ def test_delta_corruption_heal_via_ptrack_1(self):
10991089
node=self.make_simple_node(
11001090
base_dir=os.path.join(module_name,fname,'node'),
11011091
set_replication=True,
1102-
initdb_params=['--data-checksums'],
1103-
pg_options={'max_wal_senders':'2'})
1092+
initdb_params=['--data-checksums'])
11041093

11051094
backup_dir=os.path.join(self.tmp_path,module_name,fname,'backup')
11061095

@@ -1158,8 +1147,7 @@ def test_page_corruption_heal_via_ptrack_2(self):
11581147
node=self.make_simple_node(
11591148
base_dir=os.path.join(module_name,fname,'node'),
11601149
set_replication=True,
1161-
initdb_params=['--data-checksums'],
1162-
pg_options={'max_wal_senders':'2'})
1150+
initdb_params=['--data-checksums'])
11631151

11641152
backup_dir=os.path.join(self.tmp_path,module_name,fname,'backup')
11651153

‎tests/external.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ class ExternalTest(ProbackupTest, unittest.TestCase):
1313

1414
# @unittest.skip("skip")
1515
# @unittest.expectedFailure
16-
deftest_external_simple(self):
16+
deftest_basic_external(self):
1717
"""
1818
make node, create external directory, take backup
1919
with external directory, restore backup, check that

‎tests/false_positive.py‎

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,7 @@ def test_validate_wal_lost_segment(self):
2020
node=self.make_simple_node(
2121
base_dir=os.path.join(module_name,fname,'node'),
2222
set_replication=True,
23-
initdb_params=['--data-checksums'],
24-
pg_options={
25-
'max_wal_senders':'2'})
23+
initdb_params=['--data-checksums'])
2624

2725
backup_dir=os.path.join(self.tmp_path,module_name,fname,'backup')
2826
self.init_pb(backup_dir)
@@ -123,7 +121,6 @@ def test_ptrack_concurrent_get_and_clear_1(self):
123121
set_replication=True,
124122
initdb_params=['--data-checksums'],
125123
pg_options={
126-
'max_wal_senders':'2',
127124
'checkpoint_timeout':'300s',
128125
'ptrack_enable':'on'
129126
}
@@ -205,7 +202,6 @@ def test_ptrack_concurrent_get_and_clear_2(self):
205202
set_replication=True,
206203
initdb_params=['--data-checksums'],
207204
pg_options={
208-
'max_wal_senders':'2',
209205
'checkpoint_timeout':'300s',
210206
'ptrack_enable':'on'
211207
}

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp