friendlynamazu/server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

optimize query

Browse Source
This commit is contained in:
rootdarkarchon
2023-10-19 03:50:26 +02:00
parent 18331c1021
commit f67893134b
1 changed files with 88 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

122
MareSynchronosServer/MareSynchronosServer/Hubs/MareHub.Functions.cs
View File

@@ -251,30 +251,49 @@ public partial class MareHub
private async Task<UserInfo?> GetPairInfo(string uid, string otheruid) private async Task<UserInfo?> GetPairInfo(string uid, string otheruid)
{ {
var query = _dbContext.ClientPairs.Where(u => u.UserUID == uid && u.OtherUserUID == otheruid) var clientPairs = from cp in _dbContext.ClientPairs.Where(u => u.UserUID == uid && u.OtherUserUID == otheruid)
.Join(_dbContext.ClientPairs.Where(u => u.UserUID == otheruid && u.OtherUserUID == uid), join cp2 in _dbContext.ClientPairs.Where(u => u.OtherUserUID == uid && u.UserUID == otheruid)
user => user.OtherUserUID, user => user.UserUID, (user, otheruser) => on new
new
{ {
UserUID = user.UserUID, UserUID = cp.UserUID,
OtherUserUID = user.OtherUserUID, OtherUserUID = cp.OtherUserUID
}
equals new
{
UserUID = cp2.OtherUserUID,
OtherUserUID = cp2.UserUID
} into joined
from c in joined.DefaultIfEmpty()
where cp.UserUID == uid
select new
{
UserUID = cp.UserUID,
OtherUserUID = cp.OtherUserUID,
Gid = string.Empty, Gid = string.Empty,
Synced = otheruser != null Synced = c != null
}); };
var query2 = _dbContext.GroupPairs.Where(u => u.GroupUserUID == uid)
.Join(_dbContext.GroupPairs.Where(u => u.GroupUserUID == otheruid), var groupPairs = from gp in _dbContext.GroupPairs.Where(u => u.GroupUserUID == uid)
ownPair => ownPair.GroupGID, otherPair => otherPair.GroupGID, join gp2 in _dbContext.GroupPairs.Where(u => u.GroupUserUID == otheruid)
(ownPair, otherPair) => on new
new
{ {
UserUID = ownPair.GroupUserUID, GID = gp.GroupGID
OtherUserUID = otherPair.GroupUserUID, }
Gid = Convert.ToString(ownPair.GroupGID), equals new
Synced = true, {
}); GID = gp2.GroupGID
}
where gp.GroupUserUID == uid
select new
{
UserUID = gp.GroupUserUID,
OtherUserUID = gp2.GroupUserUID,
Gid = Convert.ToString(gp2.GroupGID),
Synced = true
};
var result = from user in query.Union(query2) var result = from user in clientPairs.Concat(groupPairs)
join u in _dbContext.Users on user.OtherUserUID equals u.UID join u in _dbContext.Users on user.OtherUserUID equals u.UID
join o in _dbContext.Permissions.Where(u => u.UserUID == uid) join o in _dbContext.Permissions.Where(u => u.UserUID == uid)
on new { UserUID = user.UserUID, OtherUserUID = user.OtherUserUID } on new { UserUID = user.UserUID, OtherUserUID = user.OtherUserUID }
@@ -286,6 +305,9 @@ public partial class MareHub
equals new { UserUID = p.UserUID, OtherUserUID = p.OtherUserUID } equals new { UserUID = p.UserUID, OtherUserUID = p.OtherUserUID }
into otherperms into otherperms
from otherperm in otherperms.DefaultIfEmpty() from otherperm in otherperms.DefaultIfEmpty()
where user.UserUID == uid
&& u.UID == user.OtherUserUID
&& ownperm.UserUID == uid
select new select new
{ {
UserUID = user.UserUID, UserUID = user.UserUID,
@@ -312,32 +334,49 @@ public partial class MareHub
private async Task<Dictionary<string, UserInfo>> GetAllPairInfo(string uid) private async Task<Dictionary<string, UserInfo>> GetAllPairInfo(string uid)
{ {
var query = _dbContext.ClientPairs.Where(u => u.UserUID == uid) var clientPairs = from cp in _dbContext.ClientPairs.Where(u => u.UserUID == uid)
.Join(_dbContext.ClientPairs.Where(u => u.OtherUserUID == uid), join cp2 in _dbContext.ClientPairs.Where(u => u.OtherUserUID == uid)
user => user.OtherUserUID, on new
user => user.UserUID,
(user, otheruser) =>
new
{ {
UserUID = user.UserUID, UserUID = cp.UserUID,
OtherUserUID = user.OtherUserUID, OtherUserUID = cp.OtherUserUID
}
equals new
{
UserUID = cp2.OtherUserUID,
OtherUserUID = cp2.UserUID
} into joined
from c in joined.DefaultIfEmpty()
where cp.UserUID == uid
select new
{
UserUID = cp.UserUID,
OtherUserUID = cp.OtherUserUID,
Gid = string.Empty, Gid = string.Empty,
Synced = otheruser != null Synced = c != null
}); };
var query2 = _dbContext.GroupPairs.Where(u => u.GroupUserUID == uid)
.Join(_dbContext.GroupPairs.Where(u => u.GroupUserUID != uid), var groupPairs = from gp in _dbContext.GroupPairs.Where(u => u.GroupUserUID == uid)
ownPair => ownPair.GroupGID, otherPair => otherPair.GroupGID, join gp2 in _dbContext.GroupPairs.Where(u => u.GroupUserUID != uid)
(ownPair, otherPair) => on new
new
{ {
UserUID = ownPair.GroupUserUID, GID = gp.GroupGID
OtherUserUID = otherPair.GroupUserUID, }
Gid = Convert.ToString(ownPair.GroupGID), equals new
Synced = true, {
}); GID = gp2.GroupGID
}
where gp.GroupUserUID == uid
select new
{
UserUID = gp.GroupUserUID,
OtherUserUID = gp2.GroupUserUID,
Gid = Convert.ToString(gp2.GroupGID),
Synced = true
};
var result = from user in query.Concat(query2) var result = from user in clientPairs.Concat(groupPairs)
join u in _dbContext.Users on user.OtherUserUID equals u.UID join u in _dbContext.Users on user.OtherUserUID equals u.UID
join o in _dbContext.Permissions.Where(u => u.UserUID == uid) join o in _dbContext.Permissions.Where(u => u.UserUID == uid)
on new { UserUID = user.UserUID, OtherUserUID = user.OtherUserUID } on new { UserUID = user.UserUID, OtherUserUID = user.OtherUserUID }
@@ -349,6 +388,9 @@ public partial class MareHub
equals new { UserUID = p.UserUID, OtherUserUID = p.OtherUserUID } equals new { UserUID = p.UserUID, OtherUserUID = p.OtherUserUID }
into otherperms into otherperms
from otherperm in otherperms.DefaultIfEmpty() from otherperm in otherperms.DefaultIfEmpty()
where user.UserUID == uid
&& u.UID == user.OtherUserUID
&& ownperm.UserUID == uid
select new select new
{ {
UserUID = user.UserUID, UserUID = user.UserUID,