@@ -1210,10 +1210,12 @@ def test_multi_timeline_page(self):
1210
1210
self .set_archiving (backup_dir , 'node' , node )
1211
1211
node .slow_start ()
1212
1212
1213
- node .pgbench_init (scale = 50 )
1213
+ node .safe_psql ("postgres" , "create extension pageinspect" )
1214
+
1215
+ node .pgbench_init (scale = 20 )
1214
1216
full_id = self .backup_node (backup_dir , 'node' , node )
1215
1217
1216
- pgbench = node .pgbench (options = ['-T' , '20 ' , '-c' , '1' , '--no-vacuum' ])
1218
+ pgbench = node .pgbench (options = ['-T' , '10 ' , '-c' , '1' , '--no-vacuum' ])
1217
1219
pgbench .wait ()
1218
1220
1219
1221
self .backup_node (backup_dir , 'node' , node , backup_type = 'delta' )
@@ -1231,23 +1233,43 @@ def test_multi_timeline_page(self):
1231
1233
pgbench .wait ()
1232
1234
1233
1235
# create timelines
1234
- for i in range (2 , 12 ):
1236
+ for i in range (2 , 6 ):
1235
1237
node .cleanup ()
1236
1238
self .restore_node (
1237
1239
backup_dir , 'node' , node , backup_id = full_id ,
1238
1240
options = ['--recovery-target-timeline={0}' .format (i )])
1239
1241
node .slow_start ()
1240
- pgbench = node .pgbench (options = ['-T' , '3' , '-c' , '1' , '--no-vacuum' ])
1242
+ node .safe_psql ("postgres" , "CHECKPOINT" )
1243
+ pgbench = node .pgbench (options = ['-T' , '10' , '-c' , '1' , '--no-vacuum' ])
1241
1244
pgbench .wait ()
1242
1245
1246
+ if i % 2 == 0 :
1247
+ self .backup_node (backup_dir , 'node' , node , backup_type = 'page' )
1248
+
1243
1249
page_id = self .backup_node (
1244
1250
backup_dir , 'node' , node , backup_type = 'page' ,
1245
1251
options = ['--log-level-file=VERBOSE' ])
1246
1252
1247
1253
pgdata = self .pgdata_content (node .data_dir )
1248
- node .cleanup ()
1249
- self .restore_node (backup_dir , 'node' , node )
1250
- pgdata_restored = self .pgdata_content (node .data_dir )
1254
+
1255
+ # result = node.safe_psql(
1256
+ # "postgres", "select * from pgbench_accounts")
1257
+
1258
+ node_restored = self .make_simple_node (
1259
+ base_dir = os .path .join (module_name , fname , 'node_restored' ))
1260
+ node_restored .cleanup ()
1261
+
1262
+ self .restore_node (backup_dir , 'node' , node_restored )
1263
+ pgdata_restored = self .pgdata_content (node_restored .data_dir )
1264
+
1265
+ self .set_auto_conf (node_restored , {'port' : node_restored .port })
1266
+ node_restored .slow_start ()
1267
+
1268
+ # result_new = node_restored.safe_psql(
1269
+ # "postgres", "select * from pgbench_accounts")
1270
+
1271
+ # self.assertEqual(result, result_new)
1272
+
1251
1273
self .compare_pgdata (pgdata , pgdata_restored )
1252
1274
1253
1275
show = self .show_archive (backup_dir )
0 commit comments