test: do not rely on replication in more read cases

Some read cases were missing in #404, #406 and #408 test stabilization commits. This patch updates missing read cases. 1. https://github.com/tarantool/crud/actions/runs/7322196516/job/19943422319 Follows #404
tarantool · Mar 22, 2024 · 01d31d2 · 01d31d2
1 parent 5b05d38
commit 01d31d2
Show file tree

Hide file tree

Showing 8 changed files with 140 additions and 79 deletions.
diff --git a/test/doc/playground_test.lua b/test/doc/playground_test.lua
@@ -61,7 +61,7 @@ end
 
 local cases = {
     test_select_customers = {
-        request = "crud.select('customers', {{'<=', 'age', 35}}, {first = 10})",
+        request = "crud.select('customers', {{'<=', 'age', 35}}, {first = 10, mode = 'write'})",
         retval_1 = {
             metadata = {
                 {name = 'id', type = 'unsigned'},
@@ -79,7 +79,7 @@ local cases = {
         }
     },
     test_select_developers = {
-        request = "crud.select('developers', nil, {first = 6})",
+        request = "crud.select('developers', nil, {first = 6, mode = 'write'})",
         retval_1 = {
             metadata = {
                 {name = 'id', type = 'unsigned'},
@@ -117,7 +117,7 @@ local cases = {
     test_error = {
         request = [[
             do
-                local res, err = crud.select('non_existent', nil, {first = 10})
+                local res, err = crud.select('non_existent', nil, {first = 10, mode = 'write'})
                 return res, err and err.err or nil
             end
         ]],

diff --git a/test/integration/borders_test.lua b/test/integration/borders_test.lua
@@ -26,83 +26,103 @@ end)
 
 pgroup.test_non_existent_space = function(g)
     -- min
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.min', {'non_existent_space'}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.min', {
+        'non_existent_space',
+        nil,
+        {mode = 'write'},
+    })
 
     t.assert_equals(result, nil)
     t.assert_str_contains(err.err, "Space \"non_existent_space\" doesn't exist")
 
     -- max
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.max', {'non_existent_space'}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.max', {
+        'non_existent_space',
+        nil,
+        {mode = 'write'},
+    })
 
     t.assert_equals(result, nil)
     t.assert_str_contains(err.err, "Space \"non_existent_space\" doesn't exist")
 end
 
 pgroup.test_non_existent_index = function(g)
     -- min
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.min', {'customers', 'non_existent_index'}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.min', {
+        'customers',
+        'non_existent_index',
+        {mode = 'write'},
+    })
 
     t.assert_equals(result, nil)
     t.assert_str_contains(err.err, "Index \"non_existent_index\" of space \"customers\" doesn't exist")
 
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.min', {'customers', 13}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.min', {
+        'customers',
+        13,
+        {mode = 'write'},
+    })
 
     t.assert_equals(result, nil)
     t.assert_str_contains(err.err, "Index \"13\" of space \"customers\" doesn't exist")
 
     -- max
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.max', {'customers', 'non_existent_index'}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.max', {
+        'customers',
+        'non_existent_index',
+        {mode = 'write'},
+    })
 
     t.assert_equals(result, nil)
     t.assert_str_contains(err.err, "Index \"non_existent_index\" of space \"customers\" doesn't exist")
 
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.max', {'customers', 13}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.max', {
+        'customers',
+        13,
+        {mode = 'write'},
+    })
 
     t.assert_equals(result, nil)
     t.assert_str_contains(err.err, "Index \"13\" of space \"customers\" doesn't exist")
 end
 
 pgroup.test_empty_space = function(g)
     -- min
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.min', {'customers'}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.min', {
+        'customers',
+        nil,
+        {mode = 'write'},
+    })
 
     t.assert_equals(err, nil)
     t.assert_equals(#result.rows, 0)
 
     -- min by age index with fields
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.min', {'customers', 'age_index', {fields = {'name'}}}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.min', {
+        'customers',
+        'age_index',
+        {fields = {'name'}, mode = 'write'},
+    })
 
     t.assert_equals(err, nil)
     t.assert_equals(#result.rows, 0)
 
     -- max
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.max', {'customers'}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.max', {
+        'customers',
+        nil,
+        {mode = 'write'},
+    })
 
     t.assert_equals(err, nil)
     t.assert_equals(#result.rows, 0)
 
     -- max by age index with fields
-    local result, err = g.cluster.main_server.net_box:call(
-       'crud.max', {'customers', 'age_index', {fields = {'name'}}}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.max', {
+        'customers',
+        'age_index',
+        {fields = {'name'}, mode = 'write'},
+    })
 
     t.assert_equals(err, nil)
     t.assert_equals(#result.rows, 0)

diff --git a/test/integration/count_test.lua b/test/integration/count_test.lua
@@ -33,14 +33,22 @@ pgroup.before_each(function(g)
 end)
 
 pgroup.test_count_non_existent_space = function(g)
-    local result, err = g.cluster.main_server.net_box:call('crud.count', {'non_existent_space', nil, {fullscan = true}})
+    local result, err = g.cluster.main_server.net_box:call('crud.count', {
+        'non_existent_space',
+        nil,
+        {fullscan = true, mode = 'write'},
+    })
 
     t.assert_equals(result, nil)
     t.assert_str_contains(err.err, "Space \"non_existent_space\" doesn't exist")
 end
 
 pgroup.test_count_empty_space = function(g)
-    local result, err = g.cluster.main_server.net_box:call('crud.count', {'customers', nil, {fullscan = true}})
+    local result, err = g.cluster.main_server.net_box:call('crud.count', {
+        'customers',
+        nil,
+        {fullscan = true, mode = 'write'},
+    })
 
     t.assert_equals(err, nil)
     t.assert_equals(result, 0)
@@ -51,9 +59,11 @@ pgroup.test_not_valid_value_type = function(g)
         {'==', 'id', 'not_number'}
     }
 
-    local result, err = g.cluster.main_server.net_box:call('crud.count',
-            {'customers', conditions}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.count', {
+        'customers',
+        conditions,
+        {mode = 'write'},
+    })
 
     t.assert_equals(result, nil)
     t.assert_str_contains(err.err, "Supplied key type of part 0 does not match index part type: expected unsigned")
@@ -64,9 +74,11 @@ pgroup.test_not_valid_operation = function(g)
         {{}, 'id', 5}
     }
 
-    local result, err = g.cluster.main_server.net_box:call('crud.count',
-            {'customers', conditions, {fullscan = true}}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.count', {
+        'customers',
+        conditions,
+        {fullscan = true, mode = 'write'},
+    })
 
     t.assert_equals(result, nil)
     t.assert_str_contains(err.err, "Failed to parse conditions")
@@ -77,9 +89,11 @@ pgroup.test_conditions_with_non_existed_field = function(g)
         {'==', 'non_existed_field', 'value'}
     }
 
-    local result, err = g.cluster.main_server.net_box:call('crud.count',
-            {'customers', conditions}
-    )
+    local result, err = g.cluster.main_server.net_box:call('crud.count', {
+        'customers',
+        conditions,
+        {mode = 'write'},
+    })
 
     t.assert_equals(err, nil)
     t.assert_equals(result, 0)

diff --git a/test/integration/pairs_test.lua b/test/integration/pairs_test.lua
@@ -419,7 +419,7 @@ pgroup.test_pairs_partial_result = function(g)
         local conditions, fields = ...
 
         local tuples = {}
-        for _, tuple in crud.pairs('customers', conditions, {fields = fields}) do
+        for _, tuple in crud.pairs('customers', conditions, {fields = fields, mode = 'write'}) do
             table.insert(tuples, tuple)
         end
 

diff --git a/test/integration/select_test.lua b/test/integration/select_test.lua
@@ -40,7 +40,9 @@ end)
 pgroup.test_non_existent_space = function(g)
     -- insert
     local obj, err = g.cluster.main_server.net_box:call('crud.select', {
-       'non_existent_space', nil, {fullscan = true},
+        'non_existent_space',
+        nil,
+        {fullscan = true, mode = 'write'},
     })
 
     t.assert_equals(obj, nil)
@@ -49,7 +51,9 @@ end
 
 pgroup.test_select_no_index = function(g)
     local obj, err = g.cluster.main_server.net_box:call('crud.select', {
-        'no_index_space', nil, {fullscan = true},
+        'no_index_space',
+        nil,
+        {fullscan = true, mode = 'write'},
     })
 
     t.assert_equals(obj, nil)