using System; using System.Collections.Generic; using System.Linq.Expressions; using MongoDB.Driver; namespace ET.Server { [FriendOf(typeof(DBComponent))] public static class DBComponentSystem { public class DBComponentAwakeSystem : AwakeSystem { protected override void Awake(DBComponent self, string dbConnection, string dbName, int zone) { self.mongoClient = new MongoClient(dbConnection); self.database = self.mongoClient.GetDatabase(dbName); } } private static IMongoCollection GetCollection(this DBComponent self, string collection = null) { return self.database.GetCollection(collection ?? typeof (T).Name); } private static IMongoCollection GetCollection(this DBComponent self, string name) { return self.database.GetCollection(name); } #region Query public static async ETTask Query(this DBComponent self, long id, string collection = null) where T : Entity { using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, id % DBComponent.TaskCount)) { IAsyncCursor cursor = await self.GetCollection(collection).FindAsync(d => d.Id == id); return await cursor.FirstOrDefaultAsync(); } } public static async ETTask> Query(this DBComponent self, Expression> filter, string collection = null) where T : Entity { using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, RandomGenerator.RandInt64() % DBComponent.TaskCount)) { IAsyncCursor cursor = await self.GetCollection(collection).FindAsync(filter); return await cursor.ToListAsync(); } } public static async ETTask> Query(this DBComponent self, long taskId, Expression> filter, string collection = null) where T : Entity { using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, taskId % DBComponent.TaskCount)) { IAsyncCursor cursor = await self.GetCollection(collection).FindAsync(filter); return await cursor.ToListAsync(); } } public static async ETTask Query(this DBComponent self, long id, List collectionNames, List result) { if (collectionNames == null || collectionNames.Count == 0) { return; } using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, id % DBComponent.TaskCount)) { foreach (string collectionName in collectionNames) { IAsyncCursor cursor = await self.GetCollection(collectionName).FindAsync(d => d.Id == id); Entity e = await cursor.FirstOrDefaultAsync(); if (e == null) { continue; } result.Add(e); } } } public static async ETTask> QueryJson(this DBComponent self, string json, string collection = null) where T : Entity { using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, RandomGenerator.RandInt64() % DBComponent.TaskCount)) { FilterDefinition filterDefinition = new JsonFilterDefinition(json); IAsyncCursor cursor = await self.GetCollection(collection).FindAsync(filterDefinition); return await cursor.ToListAsync(); } } public static async ETTask> QueryJson(this DBComponent self, long taskId, string json, string collection = null) where T : Entity { using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, RandomGenerator.RandInt64() % DBComponent.TaskCount)) { FilterDefinition filterDefinition = new JsonFilterDefinition(json); IAsyncCursor cursor = await self.GetCollection(collection).FindAsync(filterDefinition); return await cursor.ToListAsync(); } } #endregion #region Insert public static async ETTask InsertBatch(this DBComponent self, IEnumerable list, string collection = null) where T: Entity { if (collection == null) { collection = typeof (T).Name; } using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, RandomGenerator.RandInt64() % DBComponent.TaskCount)) { await self.GetCollection(collection).InsertManyAsync(list); } } #endregion #region Save public static async ETTask Save(this DBComponent self, T entity, string collection = null) where T : Entity { if (entity == null) { Log.Error($"save entity is null: {typeof (T).Name}"); return; } if (collection == null) { collection = entity.GetType().Name; } using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, entity.Id % DBComponent.TaskCount)) { await self.GetCollection(collection).ReplaceOneAsync(d => d.Id == entity.Id, entity, new ReplaceOptions { IsUpsert = true }); } } public static async ETTask Save(this DBComponent self, long taskId, T entity, string collection = null) where T : Entity { if (entity == null) { Log.Error($"save entity is null: {typeof (T).Name}"); return; } if (collection == null) { collection = entity.GetType().Name; } using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, taskId % DBComponent.TaskCount)) { await self.GetCollection(collection).ReplaceOneAsync(d => d.Id == entity.Id, entity, new ReplaceOptions { IsUpsert = true }); } } public static async ETTask Save(this DBComponent self, long id, List entities) { if (entities == null) { Log.Error($"save entity is null"); return; } using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, id % DBComponent.TaskCount)) { foreach (Entity entity in entities) { if (entity == null) { continue; } await self.GetCollection(entity.GetType().Name) .ReplaceOneAsync(d => d.Id == entity.Id, entity, new ReplaceOptions { IsUpsert = true }); } } } public static async ETTask SaveNotWait(this DBComponent self, T entity, long taskId = 0, string collection = null) where T : Entity { if (taskId == 0) { await self.Save(entity, collection); return; } await self.Save(taskId, entity, collection); } #endregion #region Remove public static async ETTask Remove(this DBComponent self, long id, string collection = null) where T : Entity { using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, id % DBComponent.TaskCount)) { DeleteResult result = await self.GetCollection(collection).DeleteOneAsync(d => d.Id == id); return result.DeletedCount; } } public static async ETTask Remove(this DBComponent self, long taskId, long id, string collection = null) where T : Entity { using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, taskId % DBComponent.TaskCount)) { DeleteResult result = await self.GetCollection(collection).DeleteOneAsync(d => d.Id == id); return result.DeletedCount; } } public static async ETTask Remove(this DBComponent self, Expression> filter, string collection = null) where T : Entity { using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, RandomGenerator.RandInt64() % DBComponent.TaskCount)) { DeleteResult result = await self.GetCollection(collection).DeleteManyAsync(filter); return result.DeletedCount; } } public static async ETTask Remove(this DBComponent self, long taskId, Expression> filter, string collection = null) where T : Entity { using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, taskId % DBComponent.TaskCount)) { DeleteResult result = await self.GetCollection(collection).DeleteManyAsync(filter); return result.DeletedCount; } } #endregion } }