Skip to content

Commit

Permalink
test
Browse files Browse the repository at this point in the history
  • Loading branch information
better0fdead committed Sep 26, 2023
1 parent 86f4560 commit 01c6529
Showing 1 changed file with 51 additions and 50 deletions.
101 changes: 51 additions & 50 deletions test/integration/select_readview_test.lua
Original file line number Diff line number Diff line change
Expand Up @@ -66,56 +66,6 @@ local function set_master(cluster, uuid, master_uuid)
})
end

pgroup.test_select_switch_master = function(g)
helpers.insert_objects(g, 'customers', {
{
id = 1, name = "Elizabeth", last_name = "Jackson",
age = 12, city = "New York",
}, {
id = 2, name = "Mary", last_name = "Brown",
age = 46, city = "Los Angeles",
}, {
id = 3, name = "David", last_name = "Smith",
age = 33, city = "Los Angeles",
}, {
id = 4, name = "William", last_name = "White",
age = 81, city = "Chicago",
},
})

local _, err = g.cluster.main_server.net_box:eval([[
local crud = require('crud')
local foo, err = crud.readview({name = 'foo'})
if err ~= nil then
return nil, err
end
rawset(_G, 'foo', foo)
return nil, err
]])
t.assert_equals(err, nil)
local replicasets = helpers.get_test_replicasets()
set_master(g.cluster, replicasets[2].uuid, replicasets[2].servers[2].instance_uuid)
fiber.sleep(3)
local obj, err = g.cluster.main_server.net_box:eval([[
local crud = require('crud')
local foo = rawget(_G, 'foo')
local result, err = foo:select('customers', nil, {fullscan = true})
foo:close()
return result, err
]])
set_master(g.cluster, replicasets[2].uuid, replicasets[2].servers[1].instance_uuid)
fiber.sleep(3)
t.assert_equals(err, nil)
t.assert_equals(obj.rows, {
{1, 477, "Elizabeth", "Jackson", 12, "New York"},
{2, 401, "Mary", "Brown", 46, "Los Angeles"},
{3, 2804, "David", "Smith", 33, "Los Angeles"},
{4, 1161, "William", "White", 81, "Chicago"},
})

end

pgroup.test_non_existent_space = function(g)
local obj, err = g.cluster.main_server.net_box:eval([[
local crud = require('crud')
Expand Down Expand Up @@ -2296,3 +2246,54 @@ pgroup.test_stop_select = function(g)
t.assert_str_contains(err.err, 'Connection refused')

end

pgroup.test_select_switch_master = function(g)
helpers.insert_objects(g, 'customers', {
{
id = 1, name = "Elizabeth", last_name = "Jackson",
age = 12, city = "New York",
}, {
id = 2, name = "Mary", last_name = "Brown",
age = 46, city = "Los Angeles",
}, {
id = 3, name = "David", last_name = "Smith",
age = 33, city = "Los Angeles",
}, {
id = 4, name = "William", last_name = "White",
age = 81, city = "Chicago",
},
})

local _, err = g.cluster.main_server.net_box:eval([[
local crud = require('crud')
local foo, err = crud.readview({name = 'foo'})
if err ~= nil then
return nil, err
end
rawset(_G, 'foo', foo)
return nil, err
]])
t.assert_equals(err, nil)
local replicasets = helpers.get_test_replicasets()
set_master(g.cluster, replicasets[2].uuid, replicasets[2].servers[2].instance_uuid)
fiber.sleep(3)
local obj, err = g.cluster.main_server.net_box:eval([[
local crud = require('crud')
local foo = rawget(_G, 'foo')
local result, err = foo:select('customers', nil, {fullscan = true})
local log = require('log')
log.info('123')
foo:close()
return result, err
]])
set_master(g.cluster, replicasets[2].uuid, replicasets[2].servers[1].instance_uuid)
fiber.sleep(3)
t.assert_equals(err, nil)
t.assert_equals(obj.rows, {
{1, 477, "Elizabeth", "Jackson", 12, "New York"},
{2, 401, "Mary", "Brown", 46, "Los Angeles"},
{3, 2804, "David", "Smith", 33, "Los Angeles"},
{4, 1161, "William", "White", 81, "Chicago"},
})

end

0 comments on commit 01c6529

Please sign in to comment.