update ForUpdate tests

28810 · 28810 · commit f1625202020f · 2019-12-14T12:21:55.000+08:00
diff --git a/FreeSql.DbContext/FreeSql.DbContext.xml b/FreeSql.DbContext/FreeSql.DbContext.xml
diff --git a/FreeSql.Tests/FreeSql.Tests.Provider.MySqlConnector/MySqlConnector/Curd/MySqlSelectTest.cs b/FreeSql.Tests/FreeSql.Tests.Provider.MySqlConnector/MySqlConnector/Curd/MySqlSelectTest.cs
@@ -1603,6 +1603,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.mysql;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/Dameng/Curd/DamengSelectTest.cs b/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/Dameng/Curd/DamengSelectTest.cs
@@ -1530,6 +1530,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.dameng;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/Default/Curd/OdbcSelectTest.cs b/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/Default/Curd/OdbcSelectTest.cs
@@ -1341,6 +1341,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.odbc;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/MySql/Curd/MySqlSelectTest.cs b/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/MySql/Curd/MySqlSelectTest.cs
@@ -1614,6 +1614,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.mysql;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/Oracle/Curd/OracleSelectTest.cs b/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/Oracle/Curd/OracleSelectTest.cs
@@ -1530,6 +1530,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.oracle;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/PostgreSQL/Curd/PostgreSQLSelectTest.cs b/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/PostgreSQL/Curd/PostgreSQLSelectTest.cs
@@ -1586,6 +1586,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.pgsql;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/SqlServer/Curd/SqlServerSelectTest.cs b/FreeSql.Tests/FreeSql.Tests.Provider.Odbc/SqlServer/Curd/SqlServerSelectTest.cs
@@ -1480,6 +1480,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.sqlserver;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests/MySql/Curd/MySqlSelectTest.cs b/FreeSql.Tests/FreeSql.Tests/MySql/Curd/MySqlSelectTest.cs
@@ -1645,6 +1645,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.mysql;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests/Oracle/Curd/OracleSelectTest.cs b/FreeSql.Tests/FreeSql.Tests/Oracle/Curd/OracleSelectTest.cs
@@ -1530,6 +1530,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.oracle;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests/PostgreSQL/Curd/PostgreSQLSelectTest.cs b/FreeSql.Tests/FreeSql.Tests/PostgreSQL/Curd/PostgreSQLSelectTest.cs
@@ -1603,6 +1603,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.pgsql;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests/SqlServer/Curd/SqlServerSelectTest.cs b/FreeSql.Tests/FreeSql.Tests/SqlServer/Curd/SqlServerSelectTest.cs
@@ -1548,6 +1548,10 @@ public void WithLock()
         public void ForUpdate()
         {
             var orm = g.sqlserver;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql.Tests/FreeSql.Tests/Sqlite/Curd/SqliteSelectTest.cs b/FreeSql.Tests/FreeSql.Tests/Sqlite/Curd/SqliteSelectTest.cs
@@ -1678,6 +1678,10 @@ public void ToUpdate()
         public void ForUpdate()
         {
             var orm = g.sqlite;
+
+            Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",
+                Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);
+
             orm.Transaction(() =>
             {
                 var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");
diff --git a/FreeSql/FreeSql.xml b/FreeSql/FreeSql.xml

Original file line number	Diff line number	Diff line change
`@@ -1603,6 +1603,10 @@ public void ToUpdate()`
`1603`	`1603`	`public void ForUpdate()`
`1604`	`1604`	`{`
`1605`	`1605`	`var orm = g.mysql;`
	`1606`	`+`
	`1607`	`+ Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",`
	`1608`	`+ Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);`
	`1609`	`+`
`1606`	`1610`	`orm.Transaction(() =>`
`1607`	`1611`	`{`
`1608`	`1612`	`var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");`
Original file line number	Diff line number	Diff line change
`@@ -1530,6 +1530,10 @@ public void ToUpdate()`
`1530`	`1530`	`public void ForUpdate()`
`1531`	`1531`	`{`
`1532`	`1532`	`var orm = g.dameng;`
	`1533`	`+`
	`1534`	`+ Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",`
	`1535`	`+ Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);`
	`1536`	`+`
`1533`	`1537`	`orm.Transaction(() =>`
`1534`	`1538`	`{`
`1535`	`1539`	`var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");`
Original file line number	Diff line number	Diff line change
`@@ -1341,6 +1341,10 @@ public void ToUpdate()`
`1341`	`1341`	`public void ForUpdate()`
`1342`	`1342`	`{`
`1343`	`1343`	`var orm = g.odbc;`
	`1344`	`+`
	`1345`	`+ Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",`
	`1346`	`+ Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);`
	`1347`	`+`
`1344`	`1348`	`orm.Transaction(() =>`
`1345`	`1349`	`{`
`1346`	`1350`	`var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");`
Original file line number	Diff line number	Diff line change
`@@ -1614,6 +1614,10 @@ public void ToUpdate()`
`1614`	`1614`	`public void ForUpdate()`
`1615`	`1615`	`{`
`1616`	`1616`	`var orm = g.mysql;`
	`1617`	`+`
	`1618`	`+ Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",`
	`1619`	`+ Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);`
	`1620`	`+`
`1617`	`1621`	`orm.Transaction(() =>`
`1618`	`1622`	`{`
`1619`	`1623`	`var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");`
Original file line number	Diff line number	Diff line change
`@@ -1586,6 +1586,10 @@ public void ToUpdate()`
`1586`	`1586`	`public void ForUpdate()`
`1587`	`1587`	`{`
`1588`	`1588`	`var orm = g.pgsql;`
	`1589`	`+`
	`1590`	`+ Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",`
	`1591`	`+ Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);`
	`1592`	`+`
`1589`	`1593`	`orm.Transaction(() =>`
`1590`	`1594`	`{`
`1591`	`1595`	`var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");`
Original file line number	Diff line number	Diff line change
`@@ -1480,6 +1480,10 @@ public void ToUpdate()`
`1480`	`1480`	`public void ForUpdate()`
`1481`	`1481`	`{`
`1482`	`1482`	`var orm = g.sqlserver;`
	`1483`	`+`
	`1484`	`+ Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",`
	`1485`	`+ Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);`
	`1486`	`+`
`1483`	`1487`	`orm.Transaction(() =>`
`1484`	`1488`	`{`
`1485`	`1489`	`var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");`
Original file line number	Diff line number	Diff line change
`@@ -1645,6 +1645,10 @@ public void ToUpdate()`
`1645`	`1645`	`public void ForUpdate()`
`1646`	`1646`	`{`
`1647`	`1647`	`var orm = g.mysql;`
	`1648`	`+`
	`1649`	`+ Assert.Equal("安全起见，请务必在事务开启之后，再使用 ForUpdate",`
	`1650`	`+ Assert.Throws<Exception>(() => orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToList())?.Message);`
	`1651`	`+`
`1648`	`1652`	`orm.Transaction(() =>`
`1649`	`1653`	`{`
`1650`	`1654`	`var sql = orm.Select<ToUpd1Pk>().ForUpdate().Limit(1).ToSql().Replace("\r\n", "");`