ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

try：update-by-query实现bulk del

Browse Source
This commit is contained in:
李鹏军 2024-04-24 10:40:26 +08:00
parent 141e6f1ee7
commit ae1b785273
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
View File

@ -217,13 +217,15 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
public async Task DeleteTrackAsync(int[] orderIds, List<string> trackCodes)
{
var r = await Context.DeleteByQueryAsync<TrackDetailsIndex>(x => x
.Query(
q =>
q.Terms(t => t.Field(f => f.OrderId).Terms(orderIds))
&& q.Term(t => t.IsCanDelete, true)
&& q.Terms(t => t.Field(f => f.TrackCode.Suffix("keyword")).Terms(trackCodes)))
//.Refresh(Refresh.True) // 可选：立即刷新索引使更改立即可见
var r = await Context.UpdateByQueryAsync<TrackDetailsIndex>(x => x
.Script(s => s
.Source("ctx.op = 'delete'")
)
.Query(
q =>
q.Terms(t => t.Field(f => f.OrderId).Terms(orderIds))
&& q.Term(t => t.IsCanDelete, true)
&& q.Terms(t => t.Field(f => f.TrackCode.Suffix("keyword")).Terms(trackCodes)))
);
if (!r.IsValid)