Skip to content

Commit a6c1981

Browse files
committed
- 增加 IUpdate.Join 联表更新功能;
1 parent 39bb327 commit a6c1981

File tree

7 files changed

+627
-14
lines changed

7 files changed

+627
-14
lines changed

Examples/base_entity/Program.cs

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -528,7 +528,7 @@ static void Main(string[] args)
528528
//.UseSlaveWeight(10, 1, 1, 5)
529529

530530

531-
//.UseConnectionString(FreeSql.DataType.Firebird, @"database=localhost:D:\fbdata\EXAMPLES.fdb;user=sysdba;password=123456;max pool size=5")
531+
.UseConnectionString(FreeSql.DataType.Firebird, @"database=localhost:D:\fbdata\EXAMPLES.fdb;user=sysdba;password=123456;max pool size=5")
532532
//.UseQuoteSqlName(false)
533533

534534
//.UseConnectionString(FreeSql.DataType.MySql, "Data Source=127.0.0.1;Port=3306;User ID=root;Password=root;Initial Catalog=cccddd;Charset=utf8;SslMode=none;min pool size=1;Max pool size=2")
@@ -569,6 +569,15 @@ static void Main(string[] args)
569569
#endregion
570570
fsql.UseJsonMap();
571571

572+
var updatejoin01 = fsql.Update<User1>()
573+
.Join(fsql.Select<UserGroup>(), (a, b) => a.GroupId == b.Id)
574+
.Set((a, b) => a.Nickname == b.GroupName)
575+
.ExecuteAffrows();
576+
var updatejoin02 = fsql.Update<User1>()
577+
.Join<UserGroup>((a, b) => a.GroupId == b.Id)
578+
.Set((a, b) => a.Nickname == b.GroupName)
579+
.ExecuteAffrows();
580+
572581
fsql.Select<User1>().IncludeMany(a => a.Roles);
573582

574583
var displayNameTb = fsql.CodeFirst.GetTableByEntity(typeof(DeviceCodes));

FreeSql.DbContext/FreeSql.DbContext.xml

Lines changed: 0 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

FreeSql/FreeSql.xml

Lines changed: 148 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

FreeSql/Interface/Curd/IUpdate.cs

Lines changed: 27 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,31 @@ namespace FreeSql
1010
{
1111
public interface IUpdate<T1>
1212
{
13+
/// <summary>
14+
/// 联表更新(危险操作),支持更复杂的联表更新<para></para>
15+
/// fsql.Update&lt;T1&gt;()<para></para>
16+
/// .Join(fsql.Select&lt;T1&gt;(), (a, b) => a.id == b.id)<para></para>
17+
/// .Set((a, b) => a.name == b.name)<para></para>
18+
/// .Set((a, b) => a.time == b.time2)<para></para>
19+
/// .ExecuteAffrows();
20+
/// </summary>
21+
/// <typeparam name="T2"></typeparam>
22+
/// <param name="query"></param>
23+
/// <param name="on"></param>
24+
/// <returns></returns>
25+
IUpdateJoin<T1, T2> Join<T2>(ISelect<T2> query, Expression<Func<T1, T2, bool>> on) where T2 : class;
26+
/// <summary>
27+
/// 联表更新(危险操作)<para></para>
28+
/// fsql.Update&lt;T1&gt;()<para></para>
29+
/// .Join&lt;T2&gt;((a, b) => a.id == b.id)<para></para>
30+
/// .Set((a, b) => a.name == b.name)<para></para>
31+
/// .Set((a, b) => a.time == b.time2)<para></para>
32+
/// .ExecuteAffrows();
33+
/// </summary>
34+
/// <typeparam name="T2"></typeparam>
35+
/// <param name="on"></param>
36+
/// <returns></returns>
37+
IUpdateJoin<T1, T2> Join<T2>(Expression<Func<T1, T2, bool>> on) where T2 : class;
1338

1439
/// <summary>
1540
/// 指定事务对象
@@ -134,7 +159,7 @@ public interface IUpdate<T1>
134159
/// <returns></returns>
135160
IUpdate<T1> SetIf<TMember>(bool condition, Expression<Func<T1, TMember>> column, TMember value);
136161
/// <summary>
137-
/// 设置列的的新值为基础上增加,格式:Set(a => a.Clicks + 1) 相当于 clicks=clicks+1
162+
/// 设置列的新值为基础上增加,格式:Set(a => a.Clicks + 1) 相当于 clicks=clicks+1
138163
/// <para></para>
139164
/// 指定更新,格式:Set(a => new T { Clicks = a.Clicks + 1, Time = DateTime.Now }) 相当于 set clicks=clicks+1,time='2019-06-19....'
140165
/// </summary>
@@ -143,7 +168,7 @@ public interface IUpdate<T1>
143168
/// <returns></returns>
144169
IUpdate<T1> Set<TMember>(Expression<Func<T1, TMember>> exp);
145170
/// <summary>
146-
/// 设置列的的新值为基础上增加,格式:Set(a => a.Clicks + 1) 相当于 clicks=clicks+1
171+
/// 设置列的新值为基础上增加,格式:Set(a => a.Clicks + 1) 相当于 clicks=clicks+1
147172
/// <para></para>
148173
/// 指定更新,格式:Set(a => new T { Clicks = a.Clicks + 1, Time = DateTime.Now }) 相当于 set clicks=clicks+1,time='2019-06-19....'
149174
/// </summary>
Lines changed: 127 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,127 @@
1+
using FreeSql.Internal.Model;
2+
using System;
3+
using System.Collections.Generic;
4+
using System.Data.Common;
5+
using System.Linq.Expressions;
6+
using System.Threading;
7+
using System.Threading.Tasks;
8+
9+
namespace FreeSql
10+
{
11+
public interface IUpdateJoin<T1, T2>
12+
{
13+
/// <summary>
14+
/// 指定事务对象
15+
/// </summary>
16+
/// <param name="transaction"></param>
17+
/// <returns></returns>
18+
IUpdateJoin<T1, T2> WithTransaction(DbTransaction transaction);
19+
/// <summary>
20+
/// 指定事务对象
21+
/// </summary>
22+
/// <param name="connection"></param>
23+
/// <returns></returns>
24+
IUpdateJoin<T1, T2> WithConnection(DbConnection connection);
25+
/// <summary>
26+
/// 命令超时设置(秒)
27+
/// </summary>
28+
/// <param name="timeout"></param>
29+
/// <returns></returns>
30+
IUpdateJoin<T1, T2> CommandTimeout(int timeout);
31+
32+
/// <summary>
33+
/// 设置列的固定新值,Set(a => a.Name, "newvalue")
34+
/// </summary>
35+
/// <typeparam name="TMember"></typeparam>
36+
/// <param name="column">lambda选择列</param>
37+
/// <param name="value">新值</param>
38+
/// <returns></returns>
39+
IUpdateJoin<T1, T2> Set<TMember>(Expression<Func<T1, TMember>> column, TMember value);
40+
/// <summary>
41+
/// 设置列的固定新值,Set(a => a.Name, "newvalue")
42+
/// </summary>
43+
/// <typeparam name="TMember"></typeparam>
44+
/// <param name="condition">true 时生效</param>
45+
/// <param name="column">lambda选择列</param>
46+
/// <param name="value">新值</param>
47+
/// <returns></returns>
48+
IUpdateJoin<T1, T2> SetIf<TMember>(bool condition, Expression<Func<T1, TMember>> column, TMember value);
49+
/// <summary>
50+
/// 设置列的联表值,格式:<para></para>
51+
/// Set((a, b) => a.Clicks == b.xxx)<para></para>
52+
/// Set((a, b) => a.Clicks == a.Clicks + 1)
53+
/// </summary>
54+
/// <param name="exp"></param>
55+
/// <returns></returns>
56+
IUpdateJoin<T1, T2> Set(Expression<Func<T1, T2, bool>> exp);
57+
/// <summary>
58+
/// 设置列的联表值,格式:<para></para>
59+
/// Set((a, b) => a.Clicks == b.xxx)<para></para>
60+
/// Set((a, b) => a.Clicks == a.Clicks + 1)
61+
/// <para></para>
62+
/// </summary>
63+
/// <param name="condition">true 时生效</param>
64+
/// <param name="exp"></param>
65+
/// <returns></returns>
66+
IUpdateJoin<T1, T2> SetIf(bool condition, Expression<Func<T1, T2, bool>> exp);
67+
/// <summary>
68+
/// 设置值,自定义SQL语法,SetRaw("title = @title", new { title = "newtitle" })<para></para>
69+
/// 提示:parms 参数还可以传 Dictionary&lt;string, object&gt;
70+
/// </summary>
71+
/// <param name="sql">sql语法</param>
72+
/// <param name="parms">参数</param>
73+
/// <returns></returns>
74+
IUpdateJoin<T1, T2> SetRaw(string sql, object parms = null);
75+
76+
/// <summary>
77+
/// lambda表达式条件,仅支持实体基础成员(不包含导航对象)
78+
/// </summary>
79+
/// <param name="exp">lambda表达式条件</param>
80+
/// <returns></returns>
81+
IUpdateJoin<T1, T2> Where(Expression<Func<T1, T2, bool>> exp);
82+
/// <summary>
83+
/// lambda表达式条件,仅支持实体基础成员(不包含导航对象)
84+
/// </summary>
85+
/// <param name="condition">true 时生效</param>
86+
/// <param name="exp">lambda表达式条件</param>
87+
/// <returns></returns>
88+
IUpdateJoin<T1, T2> WhereIf(bool condition, Expression<Func<T1, T2, bool>> exp);
89+
/// <summary>
90+
/// 原生sql语法条件,Where("id = @id", new { id = 1 })<para></para>
91+
/// 提示:parms 参数还可以传 Dictionary&lt;string, object&gt;
92+
/// </summary>
93+
/// <param name="sql">sql语法条件</param>
94+
/// <param name="parms">参数</param>
95+
/// <returns></returns>
96+
IUpdateJoin<T1, T2> Where(string sql, object parms = null);
97+
98+
/// <summary>
99+
/// 禁用全局过滤功能,不传参数时将禁用所有
100+
/// </summary>
101+
/// <param name="name">零个或多个过滤器名字</param>
102+
/// <returns></returns>
103+
IUpdateJoin<T1, T2> DisableGlobalFilter(params string[] name);
104+
105+
/// <summary>
106+
/// 设置表名
107+
/// </summary>
108+
/// <param name="tableName"></param>
109+
/// <returns></returns>
110+
IUpdateJoin<T1, T2> AsTable(string tableName);
111+
/// <summary>
112+
/// 返回即将执行的SQL语句
113+
/// </summary>
114+
/// <returns></returns>
115+
string ToSql();
116+
/// <summary>
117+
/// 执行SQL语句,返回影响的行数
118+
/// </summary>
119+
/// <returns></returns>
120+
int ExecuteAffrows();
121+
122+
#if net40
123+
#else
124+
Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default);
125+
#endif
126+
}
127+
}

0 commit comments

Comments
 (0)