MongoHelper.cs 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130
  1. using System;
  2. using System.IO;
  3. using MongoDB.Bson;
  4. using MongoDB.Bson.IO;
  5. using MongoDB.Bson.Serialization;
  6. using MongoDB.Bson.Serialization.Serializers;
  7. using System.Collections.Generic;
  8. namespace ETModel
  9. {
  10. public static class MongoHelper
  11. {
  12. static MongoHelper()
  13. {
  14. Type[] types = typeof(Game).Assembly.GetTypes();
  15. foreach (Type type in types)
  16. {
  17. if (!type.IsSubclassOf(typeof(Component)))
  18. {
  19. continue;
  20. }
  21. BsonClassMap.LookupClassMap(type);
  22. }
  23. BsonSerializer.RegisterSerializer(new EnumSerializer<NumericType>(BsonType.String));
  24. }
  25. public static string ToJson(object obj)
  26. {
  27. return obj.ToJson();
  28. }
  29. public static string ToJson(object obj, JsonWriterSettings settings)
  30. {
  31. return obj.ToJson(settings);
  32. }
  33. public static T FromJson<T>(string str)
  34. {
  35. return BsonSerializer.Deserialize<T>(str);
  36. }
  37. public static object FromJson(Type type, string str)
  38. {
  39. return BsonSerializer.Deserialize(str, type);
  40. }
  41. public static byte[] ToBson(object obj)
  42. {
  43. return obj.ToBson();
  44. }
  45. public static void ToBson(object obj, MemoryStream stream)
  46. {
  47. using (BsonBinaryWriter bsonWriter = new BsonBinaryWriter(stream, BsonBinaryWriterSettings.Defaults))
  48. {
  49. BsonSerializationContext context = BsonSerializationContext.CreateRoot(bsonWriter);
  50. BsonSerializationArgs args = default (BsonSerializationArgs);
  51. args.NominalType = typeof(object);
  52. IBsonSerializer serializer = BsonSerializer.LookupSerializer(args.NominalType);
  53. serializer.Serialize(context, args, obj);
  54. }
  55. }
  56. public static object FromBson(Type type, byte[] bytes)
  57. {
  58. return BsonSerializer.Deserialize(bytes, type);
  59. }
  60. public static object FromBson(Type type, byte[] bytes, int index, int count)
  61. {
  62. using (MemoryStream memoryStream = new MemoryStream(bytes, index, count))
  63. {
  64. return BsonSerializer.Deserialize(memoryStream, type);
  65. }
  66. }
  67. public static object FromBson(object instance, byte[] bytes, int index, int count)
  68. {
  69. using (MemoryStream memoryStream = new MemoryStream(bytes, index, count))
  70. {
  71. return BsonSerializer.Deserialize(memoryStream, instance.GetType());
  72. }
  73. }
  74. public static object FromBson(object instance, Stream stream)
  75. {
  76. return BsonSerializer.Deserialize(stream, instance.GetType());
  77. }
  78. public static object FromStream(Type type, Stream stream)
  79. {
  80. return BsonSerializer.Deserialize(stream, type);
  81. }
  82. public static T FromBson<T>(byte[] bytes)
  83. {
  84. using (MemoryStream memoryStream = new MemoryStream(bytes))
  85. {
  86. return (T) BsonSerializer.Deserialize(memoryStream, typeof (T));
  87. }
  88. }
  89. public static T FromBson<T>(byte[] bytes, int index, int count)
  90. {
  91. return (T) FromBson(typeof (T), bytes, index, count);
  92. }
  93. public static T Clone<T>(T t)
  94. {
  95. return FromBson<T>(ToBson(t));
  96. }
  97. public static void AvoidAOT()
  98. {
  99. ArraySerializer<int> aint = new ArraySerializer<int>();
  100. ArraySerializer<string> astring = new ArraySerializer<string>();
  101. ArraySerializer<long> along = new ArraySerializer<long>();
  102. EnumerableInterfaceImplementerSerializer<List<int>> e =
  103. new EnumerableInterfaceImplementerSerializer<List<int>>();
  104. EnumerableInterfaceImplementerSerializer<List<int>, int> elistint =
  105. new EnumerableInterfaceImplementerSerializer<List<int>, int>();
  106. }
  107. }
  108. }