using MongoDB.Bson; using MongoDB.Bson.IO; using MongoDB.Bson.Serialization; using MongoDB.Bson.Serialization.Serializers; using System; using System.Collections.Generic; using System.IO; namespace KYFramework { public static class MongoHelper { static MongoHelper() { Type[] types = typeof(Game).Assembly.GetTypes(); foreach (Type type in types) { if (!type.IsSubclassOf(typeof(Component))) { continue; } BsonClassMap.LookupClassMap(type); } } public static string ToJson(object obj) { return obj.ToJson(); } public static string ToJson(object obj, JsonWriterSettings settings) { return obj.ToJson(settings); } public static T FromJson(string str) { return BsonSerializer.Deserialize(str); } public static object FromJson(Type type, string str) { return BsonSerializer.Deserialize(str, type); } public static byte[] ToBson(object obj) { return obj.ToBson(); } public static void ToBson(object obj, MemoryStream stream) { using (BsonBinaryWriter bsonWriter = new BsonBinaryWriter(stream, BsonBinaryWriterSettings.Defaults)) { BsonSerializationContext context = BsonSerializationContext.CreateRoot(bsonWriter); BsonSerializationArgs args = default(BsonSerializationArgs); args.NominalType = typeof(object); IBsonSerializer serializer = BsonSerializer.LookupSerializer(args.NominalType); serializer.Serialize(context, args, obj); } } public static object FromBson(Type type, byte[] bytes) { return BsonSerializer.Deserialize(bytes, type); } public static object FromBson(Type type, byte[] bytes, int index, int count) { using (MemoryStream memoryStream = new MemoryStream(bytes, index, count)) { return BsonSerializer.Deserialize(memoryStream, type); } } public static object FromBson(object instance, byte[] bytes, int index, int count) { using (MemoryStream memoryStream = new MemoryStream(bytes, index, count)) { return BsonSerializer.Deserialize(memoryStream, instance.GetType()); } } public static object FromBson(object instance, Stream stream) { return BsonSerializer.Deserialize(stream, instance.GetType()); } public static object FromStream(Type type, Stream stream) { return BsonSerializer.Deserialize(stream, type); } public static T FromBson(byte[] bytes) { using (MemoryStream memoryStream = new MemoryStream(bytes)) { return (T)BsonSerializer.Deserialize(memoryStream, typeof(T)); } } public static T FromBson(byte[] bytes, int index, int count) { return (T)FromBson(typeof(T), bytes, index, count); } public static T Clone(T t) { return FromBson(ToBson(t)); } public static void AvoidAOT() { ArraySerializer aint = new ArraySerializer(); ArraySerializer astring = new ArraySerializer(); ArraySerializer along = new ArraySerializer(); EnumerableInterfaceImplementerSerializer> e = new EnumerableInterfaceImplementerSerializer>(); EnumerableInterfaceImplementerSerializer, int> elistint = new EnumerableInterfaceImplementerSerializer, int>(); } } }