mirror/dolt
1
0
Fork 0
mirror of https://github.com/dolthub/dolt.git synced 2026-02-13 03:09:06 -06:00
Code Issues Packages Projects Releases 129 Wiki Activity

Transaction tests for delete

Browse Source
This commit is contained in:
Zach Musgrave
2021-05-27 15:37:34 -07:00
parent cfdb1c0b73
commit ee6fdbb5e1
1 changed files with 219 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

219
go/libraries/doltcore/sqle/enginetest/dolt_transaction_queries.go
View File

@@ -157,6 +157,14 @@ var DoltTransactionTests = []enginetest.TransactionTest{
},
}}},
},
{
Query: "/* client a */ select * from t order by x",
Expected: []sql.Row{{1, 2}, {2, 2}},
},
{
Query: "/* client b */ select * from t order by x",
Expected: []sql.Row{{1, 2}, {2, 2}},
},
},
},
{
@@ -393,4 +401,215 @@ var DoltTransactionTests = []enginetest.TransactionTest{
},
},
},
{
Name: "non overlapping updates (diff cols)",
SetUpScript: []string{
"create table t (x int primary key, y int, z int)",
"insert into t values (1, 1, 1), (2, 2, 2)",
},
Assertions: []enginetest.ScriptTestAssertion{
{
Query: "/* client a */ start transaction",
Expected: []sql.Row{},
},
{
Query: "/* client b */ start transaction",
Expected: []sql.Row{},
},
{
Query: "/* client a */ update t set y = 2",
Expected: []sql.Row{{sql.OkResult{
RowsAffected: uint64(1),
Info: plan.UpdateInfo{
Matched: 2,
Updated: 1,
},
}}},
},
{
Query: "/* client b */ update t set z = 3",
Expected: []sql.Row{{sql.OkResult{
RowsAffected: uint64(2),
Info: plan.UpdateInfo{
Matched: 2,
Updated: 2,
},
}}},
},
{
Query: "/* client a */ commit",
Expected: []sql.Row{},
},
{
Query: "/* client b */ commit",
Expected: []sql.Row{},
},
{
Query: "/* client a */ select * from t order by x",
Expected: []sql.Row{{1, 2, 3}, {2, 2, 3}},
},
{
Query: "/* client b */ select * from t order by x",
Expected: []sql.Row{{1, 2, 3}, {2, 2, 3}},
},
},
},
{
Name: "duplicate deletes, autocommit on",
SetUpScript: []string{
"create table t (x int primary key, y int)",
"insert into t values (1, 1), (2, 2)",
},
Assertions: []enginetest.ScriptTestAssertion{
{
Query: "/* client a */ delete from t where y = 2",
Expected: []sql.Row{{sql.NewOkResult(1)}},
},
{
Query: "/* client b */ delete from t where y = 2",
Expected: []sql.Row{{sql.NewOkResult(0)}},
},
{
Query: "/* client a */ select * from t order by x",
Expected: []sql.Row{{1, 1}},
},
{
Query: "/* client b */ select * from t order by x",
Expected: []sql.Row{{1, 1}},
},
},
},
{
Name: "duplicate deletes, autocommit off",
SetUpScript: []string{
"create table t (x int primary key, y int)",
"insert into t values (1, 1), (2, 2)",
},
Assertions: []enginetest.ScriptTestAssertion{
{
Query: "/* client a */ start transaction",
Expected: []sql.Row{},
},
{
Query: "/* client b */ start transaction",
Expected: []sql.Row{},
},
{
Query: "/* client a */ delete from t where y = 2",
Expected: []sql.Row{{sql.NewOkResult(1)}},
},
{
Query: "/* client b */ delete from t where y = 2",
Expected: []sql.Row{{sql.NewOkResult(1)}},
},
{
Query: "/* client a */ commit",
Expected: []sql.Row{},
},
{
Query: "/* client b */ commit",
Expected: []sql.Row{},
},
{
Query: "/* client a */ select * from t order by x",
Expected: []sql.Row{{1, 1}},
},
{
Query: "/* client b */ select * from t order by x",
Expected: []sql.Row{{1, 1}},
},
},
},
{
Name: "non overlapping deletes",
SetUpScript: []string{
"create table t (x int primary key, y int)",
"insert into t values (1, 1), (2, 2), (3, 3)",
},
Assertions: []enginetest.ScriptTestAssertion{
{
Query: "/* client a */ start transaction",
Expected: []sql.Row{},
},
{
Query: "/* client b */ start transaction",
Expected: []sql.Row{},
},
{
Query: "/* client a */ delete from t where y = 2",
Expected: []sql.Row{{sql.NewOkResult(1)}},
},
{
Query: "/* client b */ delete from t where y = 3",
Expected: []sql.Row{{sql.NewOkResult(1)}},
},
{
Query: "/* client a */ commit",
Expected: []sql.Row{},
},
{
Query: "/* client b */ commit",
Expected: []sql.Row{},
},
{
Query: "/* client a */ select * from t order by x",
Expected: []sql.Row{{1, 1}},
},
{
Query: "/* client b */ select * from t order by x",
Expected: []sql.Row{{1, 1}},
},
},
},
{
Name: "conflicting delete and update",
SetUpScript: []string{
"create table t (x int primary key, y int)",
"insert into t values (1, 1), (2, 2)",
},
Assertions: []enginetest.ScriptTestAssertion{
{
Query: "/* client a */ start transaction",
Expected: []sql.Row{},
},
{
Query: "/* client b */ start transaction",
Expected: []sql.Row{},
},
{
Query: "/* client a */ update t set y = 3 where y = 2",
Expected: []sql.Row{{sql.OkResult{
RowsAffected: uint64(1),
Info: plan.UpdateInfo{
Matched: 1,
Updated: 1,
},
}}},
},
{
Query: "/* client b */ delete from t where y = 2",
Expected: []sql.Row{{sql.NewOkResult(1)}},
},
{
Query: "/* client a */ commit",
Expected: []sql.Row{},
},
{
Query: "/* client b */ commit",
ExpectedErrStr: "conflict in table t",
},
{
Query: "/* client b */ rollback",
Expected: []sql.Row{},
},
{
Query: "/* client a */ select * from t order by x",
Expected: []sql.Row{{1, 1}, {2, 3}},
},
{
Query: "/* client b */ select * from t order by x",
Expected: []sql.Row{{1, 1}, {2, 3}},
},
},
},
}