소스 검색

JsonQueryDB是无法cache的

tanghai 7 년 전
부모
커밋
9a9c4c6116

+ 0 - 1
Proto/InnerMessage.proto

@@ -91,7 +91,6 @@
 	{
 		required string CollectionName = 1;
 		required string Json = 2;
-		required bool NeedCache = 3;
 	}
 
 	message DBQueryJsonResponse // IResponse

+ 0 - 9
Server/Hotfix/Module/DB/DBQueryJsonRequestHandler.cs

@@ -14,17 +14,8 @@ namespace ETHotfix
 			{
 				DBCacheComponent dbCacheComponent = Game.Scene.GetComponent<DBCacheComponent>();
 				List<ComponentWithId> components = await dbCacheComponent.GetJson(message.CollectionName, message.Json);
-
 				response.Components = components;
 
-				if (message.NeedCache)
-				{
-					foreach (ComponentWithId component in components)
-					{
-						dbCacheComponent.AddToCache(component, message.CollectionName);
-					}
-				}
-
 				reply(response);
 			}
 			catch (Exception e)

+ 0 - 2
Server/Model/Module/DB/DBCacheComponent.cs

@@ -35,8 +35,6 @@ namespace ETModel
 		{
 			TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>();
 
-			this.AddToCache(component, collectionName);
-
 			if (string.IsNullOrEmpty(collectionName))
 			{
 				collectionName = component.GetType().Name;

+ 2 - 2
Server/Model/Module/DB/DBProxyComponent.cs

@@ -70,11 +70,11 @@ namespace ETModel
 			return list;
 		}
 
-		public async Task<List<T>> QueryJson<T>(string json, bool needCache = true) where T : ComponentWithId
+		public async Task<List<T>> QueryJson<T>(string json) where T : ComponentWithId
 		{
 			List<T> list = new List<T>();
 			Session session = Game.Scene.GetComponent<NetInnerComponent>().Get(dbAddress);
-			DBQueryJsonResponse dbQueryJsonResponse = (DBQueryJsonResponse)await session.Call(new DBQueryJsonRequest { CollectionName = typeof(T).Name, Json = json, NeedCache = needCache});
+			DBQueryJsonResponse dbQueryJsonResponse = (DBQueryJsonResponse)await session.Call(new DBQueryJsonRequest { CollectionName = typeof(T).Name, Json = json });
 			foreach (ComponentWithId component in dbQueryJsonResponse.Components)
 			{
 				list.Add((T)component);

+ 0 - 3
Server/Model/Module/Message/InnerMessage.cs

@@ -269,9 +269,6 @@ namespace ETModel
 		[ProtoMember(2, IsRequired = true)]
 		public string Json;
 
-		[ProtoMember(3, IsRequired = true)]
-		public bool NeedCache;
-
 	}
 
 	[Message(InnerOpcode.DBQueryJsonResponse)]