diff options
Diffstat (limited to 'src/third_party/wiredtiger/test/suite/test_truncate02.py')
| -rw-r--r-- | src/third_party/wiredtiger/test/suite/test_truncate02.py | 29 |
1 files changed, 15 insertions, 14 deletions
diff --git a/src/third_party/wiredtiger/test/suite/test_truncate02.py b/src/third_party/wiredtiger/test/suite/test_truncate02.py index 7184cd67242..73fed362354 100644 --- a/src/third_party/wiredtiger/test/suite/test_truncate02.py +++ b/src/third_party/wiredtiger/test/suite/test_truncate02.py @@ -31,7 +31,7 @@ # import wiredtiger, wttest -from helper import key_populate, value_populate, simple_populate +from wtdataset import SimpleDataSet from wtscenario import make_scenarios # test_truncate_fast_delete @@ -46,8 +46,7 @@ class test_truncate_fast_delete(wttest.WiredTigerTestCase): # of individual pages in the file. types = [ ('file', dict(type='file:', config=\ - 'allocation_size=512,leaf_page_max=512,' +\ - 'value_format=S,key_format=')), + 'allocation_size=512,leaf_page_max=512')), ] # This is all about testing the btree layer, not the schema layer, test @@ -123,15 +122,17 @@ class test_truncate_fast_delete(wttest.WiredTigerTestCase): ''' # Create the object. - simple_populate(self, uri, self.config + self.keyfmt, self.nentries) + ds = SimpleDataSet(self, uri, self.nentries, + config=self.config, key_format=self.keyfmt) + ds.populate() # Optionally add a few overflow records so we block fast delete on # those pages. if self.overflow: cursor = self.session.open_cursor(uri, None, 'overwrite=false') for i in range(1, self.nentries, 3123): - cursor.set_key(key_populate(cursor, i)) - cursor.set_value(value_populate(cursor, i)) + cursor.set_key(ds.key(i)) + cursor.set_value(ds.value(i)) cursor.update() cursor.close() @@ -143,21 +144,21 @@ class test_truncate_fast_delete(wttest.WiredTigerTestCase): cursor = self.session.open_cursor(uri, None, 'overwrite=false') if self.readbefore: for i in range(1, self.nentries, 737): - cursor.set_key(key_populate(cursor, i)) + cursor.set_key(ds.key(i)) cursor.search() if self.writebefore: for i in range(1, self.nentries, 988): - cursor.set_key(key_populate(cursor, i)) - cursor.set_value(value_populate(cursor, i + 100)) + cursor.set_key(ds.key(i)) + cursor.set_value(ds.value(i + 100)) cursor.update() cursor.close() # Begin a transaction, and truncate a big range of rows. self.session.begin_transaction(None) start = self.session.open_cursor(uri, None) - start.set_key(key_populate(start, 10)) + start.set_key(ds.key(10)) end = self.session.open_cursor(uri, None) - end.set_key(key_populate(end, self.nentries - 10)) + end.set_key(ds.key(self.nentries - 10)) self.session.truncate(None, start, end, None) start.close() end.close() @@ -167,12 +168,12 @@ class test_truncate_fast_delete(wttest.WiredTigerTestCase): cursor = self.session.open_cursor(uri, None, 'overwrite=false') if self.readafter: for i in range(1, self.nentries, 1123): - cursor.set_key(key_populate(cursor, i)) + cursor.set_key(ds.key(i)) cursor.search() if self.writeafter: for i in range(1, self.nentries, 621): - cursor.set_key(key_populate(cursor, i)) - cursor.set_value(value_populate(cursor, i + 100)) + cursor.set_key(ds.key(i)) + cursor.set_value(ds.value(i + 100)) cursor.update() cursor.close() |