From 02224c78f33aa183c57d72a0da06d58545b1a350 Mon Sep 17 00:00:00 2001 From: Jan Tuomi Date: Mon, 7 Oct 2024 14:44:18 +0300 Subject: Implement some of the py bindings --- log_db/tests/integration.rs | 30 +++++++++++++++--------------- 1 file changed, 15 insertions(+), 15 deletions(-) (limited to 'log_db/tests') diff --git a/log_db/tests/integration.rs b/log_db/tests/integration.rs index a2453b2..76ed853 100644 --- a/log_db/tests/integration.rs +++ b/log_db/tests/integration.rs @@ -38,7 +38,7 @@ fn test_initialize() { let data_dir = tmp_dir(); let _db = DB::configure() .data_dir(&data_dir) - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Name, RecordField::string()), (Field::Data, RecordField::bytes()), @@ -53,7 +53,7 @@ fn test_upsert_and_get_with_primary_memtable() { let data_dir = tmp_dir(); let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Name, RecordField::string()), (Field::Data, RecordField::bytes()), @@ -86,7 +86,7 @@ fn test_upsert_and_get_without_memtable() { let mut db = DB::configure() .data_dir(&data_dir) .memtable_capacity(0) - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Name, RecordField::string().nullable()), (Field::Data, RecordField::bytes()), @@ -164,7 +164,7 @@ fn test_upsert_fails_on_null_in_non_nullable_field() { let data_dir = tmp_dir(); let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![(Field::Id, RecordField::int())]) + .fields(vec![(Field::Id, RecordField::int())]) .primary_key(Field::Id) .initialize() .expect("Failed to initialize DB instance"); @@ -181,7 +181,7 @@ fn test_upsert_fails_on_invalid_number_of_values() { let data_dir = tmp_dir(); let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Name, RecordField::string()), (Field::Data, RecordField::bytes()), @@ -205,7 +205,7 @@ fn test_upsert_fails_on_invalid_value_type() { let data_dir = tmp_dir(); let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Name, RecordField::string()), (Field::Data, RecordField::bytes()), @@ -229,7 +229,7 @@ fn test_upsert_and_get_from_secondary_memtable() { let data_dir = tmp_dir(); let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Name, RecordField::string()), (Field::Data, RecordField::bytes()), @@ -291,7 +291,7 @@ fn test_initialize_and_read_from_primary_memtable_fixture_db2() { let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Name, RecordField::string()), (Field::Data, RecordField::bytes()), @@ -326,7 +326,7 @@ fn test_initialize_without_memtables_fixture_db3() { let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Name, RecordField::string()), (Field::Data, RecordField::bytes()), @@ -357,7 +357,7 @@ fn test_multiple_writing_threads() { threads.push(thread::spawn(move || { let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![(Field::Id, RecordField::int())]) + .fields(vec![(Field::Id, RecordField::int())]) .primary_key(Field::Id) .initialize() .expect("Failed to initialize DB instance"); @@ -376,7 +376,7 @@ fn test_multiple_writing_threads() { // Read the records let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![(Field::Id, RecordField::int())]) + .fields(vec![(Field::Id, RecordField::int())]) .primary_key(Field::Id) .initialize() .expect("Failed to initialize DB instance"); @@ -406,7 +406,7 @@ fn test_one_writer_and_multiple_reading_threads() { threads.push(thread::spawn(move || { let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![(Field::Id, RecordField::int())]) + .fields(vec![(Field::Id, RecordField::int())]) .primary_key(Field::Id) .initialize() .expect("Failed to initialize DB instance"); @@ -437,7 +437,7 @@ fn test_one_writer_and_multiple_reading_threads() { threads.push(thread::spawn(move || { let mut db = DB::configure() .data_dir(&data_dir) - .fields(&vec![(Field::Id, RecordField::int())]) + .fields(vec![(Field::Id, RecordField::int())]) .primary_key(Field::Id) .initialize() .expect("Failed to initialize DB instance"); @@ -462,7 +462,7 @@ fn test_literal_escape_is_escaped() { let mut db = DB::configure() .data_dir(&data_dir) .memtable_capacity(0) // disable memtables - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Data, RecordField::bytes()), ]) @@ -505,7 +505,7 @@ fn test_log_is_rotated_when_capacity_reached() { .data_dir(&data_dir) .memtable_capacity(0) // disable memtables .segment_size(10 * record_len) // small log segment size - .fields(&vec![ + .fields(vec![ (Field::Id, RecordField::int()), (Field::Data, RecordField::bytes()), ]) -- cgit v1.3