NewLife
/
XCode
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

共用Binary，避免频繁创建，提升百万级大数据持久化性能

This commit is contained in:
智能大石头 2025-07-09 04:07:52 +08:00
parent 19b7f7fb67
commit 08c1b1b3df
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
XCode/Entity/EntityExtension.cs
View File

@ -1220,9 +1220,10 @@ public static class EntityExtension
var compressed = file.EndsWithIgnoreCase(".gz"); var compressed = file.EndsWithIgnoreCase(".gz");
return file.AsFile().OpenWrite(compressed, fs => return file.AsFile().OpenWrite(compressed, fs =>
{ {
var bn = new Binary { Stream = fs, EncodeInt = true, FullTime = true };
foreach (var entity in list) foreach (var entity in list)
{ {
if (entity is IAccessor acc) acc.Write(fs, null); if (entity is IAccessor acc) acc.Write(fs, bn);
} }
}); });
} }
@ -1347,11 +1348,12 @@ public static class EntityExtension
var compressed = file.EndsWithIgnoreCase(".gz"); var compressed = file.EndsWithIgnoreCase(".gz");
file.AsFile().OpenRead(compressed, fs => file.AsFile().OpenRead(compressed, fs =>
{ {
var bn = new Binary { Stream = fs, EncodeInt = true, FullTime = true };
var fact = typeof(T).AsFactory(); var fact = typeof(T).AsFactory();
while (fs.Position < fs.Length) while (fs.Position < fs.Length)
{ {
var entity = (T)fact.Create(); var entity = (T)fact.Create();
if (entity is IAccessor acc) acc.Read(fs, null); if (entity is IAccessor acc) acc.Read(fs, bn);
list.Add(entity); list.Add(entity);
} }