@@ -2803,3 +2803,44 @@ def test_parent_backup_made_by_newer_version(self):
28032803
28042804 # Clean after yourself
28052805 self .del_test_dir (module_name , fname )
2806+
2807+ @unittest .skip ("skip" )
2808+ def test_issue_203 (self ):
2809+ """
2810+ https://github.com/postgrespro/pg_probackup/issues/203
2811+ """
2812+ fname = self .id ().split ('.' )[3 ]
2813+ backup_dir = os .path .join (self .tmp_path , module_name , fname , 'backup' )
2814+ node = self .make_simple_node (
2815+ base_dir = os .path .join (module_name , fname , 'node' ),
2816+ set_replication = True ,
2817+ initdb_params = ['--data-checksums' ],
2818+ pg_options = {'autovacuum' : 'off' })
2819+
2820+ self .init_pb (backup_dir )
2821+ self .add_instance (backup_dir , 'node' , node )
2822+ node .slow_start ()
2823+
2824+ with node .connect ("postgres" ) as conn :
2825+ for i in range (1200000 ):
2826+ conn .execute (
2827+ "CREATE TABLE t_{0} as select 1" .format (i ))
2828+ conn .commit ()
2829+
2830+ full_id = self .backup_node (
2831+ backup_dir , 'node' , node , options = ['--stream' ])
2832+
2833+ pgdata = self .pgdata_content (node .data_dir )
2834+
2835+ node_restored = self .make_simple_node (
2836+ base_dir = os .path .join (module_name , fname , 'node_restored' ))
2837+ node_restored .cleanup ()
2838+
2839+ self .restore_node (backup_dir , 'node' ,
2840+ node_restored , data_dir = node_restored .data_dir )
2841+
2842+ pgdata_restored = self .pgdata_content (node_restored .data_dir )
2843+ self .compare_pgdata (pgdata , pgdata_restored )
2844+
2845+ # Clean after yourself
2846+ self .del_test_dir (module_name , fname )
0 commit comments