ProjectionDefinition.cs 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509
  1. /* Copyright 2010-present MongoDB Inc.
  2. *
  3. * Licensed under the Apache License, Version 2.0 (the "License");
  4. * you may not use this file except in compliance with the License.
  5. * You may obtain a copy of the License at
  6. *
  7. * http://www.apache.org/licenses/LICENSE-2.0
  8. *
  9. * Unless required by applicable law or agreed to in writing, software
  10. * distributed under the License is distributed on an "AS IS" BASIS,
  11. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. * See the License for the specific language governing permissions and
  13. * limitations under the License.
  14. */
  15. using System;
  16. using System.Linq.Expressions;
  17. using MongoDB.Bson;
  18. using MongoDB.Bson.Serialization;
  19. using MongoDB.Driver.Core.Misc;
  20. using MongoDB.Driver.Linq.Translators;
  21. namespace MongoDB.Driver
  22. {
  23. /// <summary>
  24. /// A rendered projection.
  25. /// </summary>
  26. /// <typeparam name="TProjection">The type of the projection.</typeparam>
  27. public sealed class RenderedProjectionDefinition<TProjection>
  28. {
  29. private readonly BsonDocument _projection;
  30. private readonly IBsonSerializer<TProjection> _projectionSerializer;
  31. /// <summary>
  32. /// Initializes a new instance of the <see cref="RenderedProjectionDefinition{TProjection}" /> class.
  33. /// </summary>
  34. /// <param name="document">The document.</param>
  35. /// <param name="projectionSerializer">The projection serializer.</param>
  36. public RenderedProjectionDefinition(BsonDocument document, IBsonSerializer<TProjection> projectionSerializer)
  37. {
  38. _projection = document;
  39. _projectionSerializer = Ensure.IsNotNull(projectionSerializer, nameof(projectionSerializer));
  40. }
  41. /// <summary>
  42. /// Gets the document.
  43. /// </summary>
  44. public BsonDocument Document
  45. {
  46. get { return _projection; }
  47. }
  48. /// <summary>
  49. /// Gets the serializer.
  50. /// </summary>
  51. public IBsonSerializer<TProjection> ProjectionSerializer
  52. {
  53. get { return _projectionSerializer; }
  54. }
  55. }
  56. /// <summary>
  57. /// Base class for projections whose projection type is not yet known.
  58. /// </summary>
  59. /// <typeparam name="TSource">The type of the source.</typeparam>
  60. public abstract class ProjectionDefinition<TSource>
  61. {
  62. /// <summary>
  63. /// Renders the projection to a <see cref="RenderedProjectionDefinition{TProjection}"/>.
  64. /// </summary>
  65. /// <param name="sourceSerializer">The source serializer.</param>
  66. /// <param name="serializerRegistry">The serializer registry.</param>
  67. /// <returns>A <see cref="BsonDocument"/>.</returns>
  68. public abstract BsonDocument Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry);
  69. /// <summary>
  70. /// Performs an implicit conversion from <see cref="BsonDocument"/> to <see cref="ProjectionDefinition{TSource}"/>.
  71. /// </summary>
  72. /// <param name="document">The document.</param>
  73. /// <returns>
  74. /// The result of the conversion.
  75. /// </returns>
  76. public static implicit operator ProjectionDefinition<TSource>(BsonDocument document)
  77. {
  78. if (document == null)
  79. {
  80. return null;
  81. }
  82. return new BsonDocumentProjectionDefinition<TSource>(document);
  83. }
  84. /// <summary>
  85. /// Performs an implicit conversion from <see cref="System.String" /> to <see cref="ProjectionDefinition{TSource, TProjection}" />.
  86. /// </summary>
  87. /// <param name="json">The JSON string.</param>
  88. /// <returns>
  89. /// The result of the conversion.
  90. /// </returns>
  91. public static implicit operator ProjectionDefinition<TSource>(string json)
  92. {
  93. if (json == null)
  94. {
  95. return null;
  96. }
  97. return new JsonProjectionDefinition<TSource>(json);
  98. }
  99. }
  100. /// <summary>
  101. /// Base class for projections.
  102. /// </summary>
  103. /// <typeparam name="TSource">The type of the source.</typeparam>
  104. /// <typeparam name="TProjection">The type of the projection.</typeparam>
  105. public abstract class ProjectionDefinition<TSource, TProjection>
  106. {
  107. /// <summary>
  108. /// Renders the projection to a <see cref="RenderedProjectionDefinition{TProjection}"/>.
  109. /// </summary>
  110. /// <param name="sourceSerializer">The source serializer.</param>
  111. /// <param name="serializerRegistry">The serializer registry.</param>
  112. /// <returns>A <see cref="RenderedProjectionDefinition{TProjection}"/>.</returns>
  113. public abstract RenderedProjectionDefinition<TProjection> Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry);
  114. /// <summary>
  115. /// Performs an implicit conversion from <see cref="BsonDocument"/> to <see cref="ProjectionDefinition{TSource, TProjection}"/>.
  116. /// </summary>
  117. /// <param name="document">The document.</param>
  118. /// <returns>
  119. /// The result of the conversion.
  120. /// </returns>
  121. public static implicit operator ProjectionDefinition<TSource, TProjection>(BsonDocument document)
  122. {
  123. if (document == null)
  124. {
  125. return null;
  126. }
  127. return new BsonDocumentProjectionDefinition<TSource, TProjection>(document);
  128. }
  129. /// <summary>
  130. /// Performs an implicit conversion from <see cref="System.String" /> to <see cref="ProjectionDefinition{TSource, TProjection}" />.
  131. /// </summary>
  132. /// <param name="json">The JSON string.</param>
  133. /// <returns>
  134. /// The result of the conversion.
  135. /// </returns>
  136. public static implicit operator ProjectionDefinition<TSource, TProjection>(string json)
  137. {
  138. if (json == null)
  139. {
  140. return null;
  141. }
  142. return new JsonProjectionDefinition<TSource, TProjection>(json);
  143. }
  144. /// <summary>
  145. /// Performs an implicit conversion from <see cref="ProjectionDefinition{TSource}"/> to <see cref="ProjectionDefinition{TSource, TProjection}"/>.
  146. /// </summary>
  147. /// <param name="projection">The projection.</param>
  148. /// <returns>
  149. /// The result of the conversion.
  150. /// </returns>
  151. public static implicit operator ProjectionDefinition<TSource, TProjection>(ProjectionDefinition<TSource> projection)
  152. {
  153. return new KnownResultTypeProjectionDefinitionAdapter<TSource, TProjection>(projection);
  154. }
  155. }
  156. /// <summary>
  157. /// A <see cref="BsonDocument" /> based projection whose projection type is not yet known.
  158. /// </summary>
  159. /// <typeparam name="TSource">The type of the source.</typeparam>
  160. public sealed class BsonDocumentProjectionDefinition<TSource> : ProjectionDefinition<TSource>
  161. {
  162. private readonly BsonDocument _document;
  163. /// <summary>
  164. /// Initializes a new instance of the <see cref="BsonDocumentProjectionDefinition{TSource}"/> class.
  165. /// </summary>
  166. /// <param name="document">The document.</param>
  167. public BsonDocumentProjectionDefinition(BsonDocument document)
  168. {
  169. _document = Ensure.IsNotNull(document, nameof(document));
  170. }
  171. /// <summary>
  172. /// Gets the document.
  173. /// </summary>
  174. public BsonDocument Document
  175. {
  176. get { return _document; }
  177. }
  178. /// <inheritdoc />
  179. public override BsonDocument Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry)
  180. {
  181. return _document;
  182. }
  183. }
  184. /// <summary>
  185. /// A <see cref="BsonDocument" /> based projection.
  186. /// </summary>
  187. /// <typeparam name="TSource">The type of the source.</typeparam>
  188. /// <typeparam name="TProjection">The type of the projection.</typeparam>
  189. public sealed class BsonDocumentProjectionDefinition<TSource, TProjection> : ProjectionDefinition<TSource, TProjection>
  190. {
  191. private readonly BsonDocument _document;
  192. private readonly IBsonSerializer<TProjection> _projectionSerializer;
  193. /// <summary>
  194. /// Initializes a new instance of the <see cref="BsonDocumentProjectionDefinition{TSource, TProjection}"/> class.
  195. /// </summary>
  196. /// <param name="document">The document.</param>
  197. /// <param name="projectionSerializer">The projection serializer.</param>
  198. public BsonDocumentProjectionDefinition(BsonDocument document, IBsonSerializer<TProjection> projectionSerializer = null)
  199. {
  200. _document = Ensure.IsNotNull(document, nameof(document));
  201. _projectionSerializer = projectionSerializer;
  202. }
  203. /// <summary>
  204. /// Gets the document.
  205. /// </summary>
  206. public BsonDocument Document
  207. {
  208. get { return _document; }
  209. }
  210. /// <summary>
  211. /// Gets the projection serializer.
  212. /// </summary>
  213. public IBsonSerializer<TProjection> ProjectionSerializer
  214. {
  215. get { return _projectionSerializer; }
  216. }
  217. /// <inheritdoc />
  218. public override RenderedProjectionDefinition<TProjection> Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry)
  219. {
  220. return new RenderedProjectionDefinition<TProjection>(
  221. _document,
  222. _projectionSerializer ?? (sourceSerializer as IBsonSerializer<TProjection>) ?? serializerRegistry.GetSerializer<TProjection>());
  223. }
  224. }
  225. /// <summary>
  226. /// A find <see cref="Expression" /> based projection.
  227. /// </summary>
  228. /// <typeparam name="TSource">The type of the source.</typeparam>
  229. /// <typeparam name="TProjection">The type of the projection.</typeparam>
  230. public sealed class FindExpressionProjectionDefinition<TSource, TProjection> : ProjectionDefinition<TSource, TProjection>
  231. {
  232. private readonly Expression<Func<TSource, TProjection>> _expression;
  233. /// <summary>
  234. /// Initializes a new instance of the <see cref="FindExpressionProjectionDefinition{TSource, TProjection}" /> class.
  235. /// </summary>
  236. /// <param name="expression">The expression.</param>
  237. public FindExpressionProjectionDefinition(Expression<Func<TSource, TProjection>> expression)
  238. {
  239. _expression = Ensure.IsNotNull(expression, nameof(expression));
  240. }
  241. /// <summary>
  242. /// Gets the expression.
  243. /// </summary>
  244. public Expression<Func<TSource, TProjection>> Expression
  245. {
  246. get { return _expression; }
  247. }
  248. /// <inheritdoc />
  249. public override RenderedProjectionDefinition<TProjection> Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry)
  250. {
  251. return FindProjectionTranslator.Translate<TSource, TProjection>(_expression, sourceSerializer, serializerRegistry);
  252. }
  253. }
  254. /// <summary>
  255. /// A JSON <see cref="String" /> based projection whose projection type is not yet known.
  256. /// </summary>
  257. /// <typeparam name="TSource">The type of the source.</typeparam>
  258. public sealed class JsonProjectionDefinition<TSource> : ProjectionDefinition<TSource>
  259. {
  260. private readonly string _json;
  261. /// <summary>
  262. /// Initializes a new instance of the <see cref="JsonProjectionDefinition{TSource}"/> class.
  263. /// </summary>
  264. /// <param name="json">The json.</param>
  265. public JsonProjectionDefinition(string json)
  266. {
  267. _json = Ensure.IsNotNullOrEmpty(json, nameof(json));
  268. }
  269. /// <summary>
  270. /// Gets the json.
  271. /// </summary>
  272. public string Json
  273. {
  274. get { return _json; }
  275. }
  276. /// <inheritdoc />
  277. public override BsonDocument Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry)
  278. {
  279. return BsonDocument.Parse(_json);
  280. }
  281. }
  282. /// <summary>
  283. /// A JSON <see cref="String" /> based projection.
  284. /// </summary>
  285. /// <typeparam name="TSource">The type of the source.</typeparam>
  286. /// <typeparam name="TProjection">The type of the projection.</typeparam>
  287. public sealed class JsonProjectionDefinition<TSource, TProjection> : ProjectionDefinition<TSource, TProjection>
  288. {
  289. private readonly string _json;
  290. private readonly IBsonSerializer<TProjection> _projectionSerializer;
  291. /// <summary>
  292. /// Initializes a new instance of the <see cref="BsonDocumentSortDefinition{TDocument}" /> class.
  293. /// </summary>
  294. /// <param name="json">The json.</param>
  295. /// <param name="projectionSerializer">The projection serializer.</param>
  296. public JsonProjectionDefinition(string json, IBsonSerializer<TProjection> projectionSerializer = null)
  297. {
  298. _json = Ensure.IsNotNullOrEmpty(json, nameof(json));
  299. _projectionSerializer = projectionSerializer;
  300. }
  301. /// <summary>
  302. /// Gets the json.
  303. /// </summary>
  304. public string Json
  305. {
  306. get { return _json; }
  307. }
  308. /// <summary>
  309. /// Gets the projection serializer.
  310. /// </summary>
  311. public IBsonSerializer<TProjection> ProjectionSerializer
  312. {
  313. get { return _projectionSerializer; }
  314. }
  315. /// <inheritdoc />
  316. public override RenderedProjectionDefinition<TProjection> Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry)
  317. {
  318. return new RenderedProjectionDefinition<TProjection>(
  319. BsonDocument.Parse(_json),
  320. _projectionSerializer ?? (sourceSerializer as IBsonSerializer<TProjection>) ?? serializerRegistry.GetSerializer<TProjection>());
  321. }
  322. }
  323. /// <summary>
  324. /// An <see cref="Object"/> based projection whose projection type is not yet known.
  325. /// </summary>
  326. /// <typeparam name="TSource">The type of the source.</typeparam>
  327. public sealed class ObjectProjectionDefinition<TSource> : ProjectionDefinition<TSource>
  328. {
  329. private readonly object _obj;
  330. /// <summary>
  331. /// Initializes a new instance of the <see cref="ObjectProjectionDefinition{TSource}"/> class.
  332. /// </summary>
  333. /// <param name="obj">The object.</param>
  334. public ObjectProjectionDefinition(object obj)
  335. {
  336. _obj = Ensure.IsNotNull(obj, nameof(obj));
  337. }
  338. /// <summary>
  339. /// Gets the object.
  340. /// </summary>
  341. public object Object
  342. {
  343. get { return _obj; }
  344. }
  345. /// <inheritdoc />
  346. public override BsonDocument Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry)
  347. {
  348. var serializer = serializerRegistry.GetSerializer(_obj.GetType());
  349. return new BsonDocumentWrapper(_obj, serializer);
  350. }
  351. }
  352. /// <summary>
  353. /// An <see cref="Object"/> based projection.
  354. /// </summary>
  355. /// <typeparam name="TSource">The type of the source.</typeparam>
  356. /// <typeparam name="TProjection">The type of the projection.</typeparam>
  357. public sealed class ObjectProjectionDefinition<TSource, TProjection> : ProjectionDefinition<TSource, TProjection>
  358. {
  359. private readonly object _obj;
  360. private readonly IBsonSerializer<TProjection> _projectionSerializer;
  361. /// <summary>
  362. /// Initializes a new instance of the <see cref="ObjectProjectionDefinition{TSource, TProjection}" /> class.
  363. /// </summary>
  364. /// <param name="obj">The object.</param>
  365. /// <param name="projectionSerializer">The projection serializer.</param>
  366. public ObjectProjectionDefinition(object obj, IBsonSerializer<TProjection> projectionSerializer = null)
  367. {
  368. _obj = Ensure.IsNotNull(obj, nameof(obj));
  369. _projectionSerializer = projectionSerializer;
  370. }
  371. /// <summary>
  372. /// Gets the object.
  373. /// </summary>
  374. public object Object
  375. {
  376. get { return _obj; }
  377. }
  378. /// <summary>
  379. /// Gets the projection serializer.
  380. /// </summary>
  381. public IBsonSerializer<TProjection> ProjectionSerializer
  382. {
  383. get { return _projectionSerializer; }
  384. }
  385. /// <inheritdoc />
  386. public override RenderedProjectionDefinition<TProjection> Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry)
  387. {
  388. var serializer = serializerRegistry.GetSerializer(_obj.GetType());
  389. return new RenderedProjectionDefinition<TProjection>(
  390. new BsonDocumentWrapper(_obj, serializer),
  391. _projectionSerializer ?? (sourceSerializer as IBsonSerializer<TProjection>) ?? serializerRegistry.GetSerializer<TProjection>());
  392. }
  393. }
  394. internal sealed class KnownResultTypeProjectionDefinitionAdapter<TSource, TProjection> : ProjectionDefinition<TSource, TProjection>
  395. {
  396. private readonly ProjectionDefinition<TSource> _projection;
  397. private readonly IBsonSerializer<TProjection> _projectionSerializer;
  398. public KnownResultTypeProjectionDefinitionAdapter(ProjectionDefinition<TSource> projection, IBsonSerializer<TProjection> projectionSerializer = null)
  399. {
  400. _projection = Ensure.IsNotNull(projection, nameof(projection));
  401. _projectionSerializer = projectionSerializer;
  402. }
  403. public ProjectionDefinition<TSource> Projection
  404. {
  405. get { return _projection; }
  406. }
  407. public IBsonSerializer<TProjection> ResultSerializer
  408. {
  409. get { return _projectionSerializer; }
  410. }
  411. public override RenderedProjectionDefinition<TProjection> Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry)
  412. {
  413. var document = _projection.Render(sourceSerializer, serializerRegistry);
  414. return new RenderedProjectionDefinition<TProjection>(
  415. document,
  416. _projectionSerializer ?? (sourceSerializer as IBsonSerializer<TProjection>) ?? serializerRegistry.GetSerializer<TProjection>());
  417. }
  418. }
  419. /// <summary>
  420. /// A client side only projection that is implemented solely by deserializing using a different serializer.
  421. /// </summary>
  422. /// <typeparam name="TSource">The type of the source.</typeparam>
  423. /// <typeparam name="TProjection">The type of the projection.</typeparam>
  424. public sealed class ClientSideDeserializationProjectionDefinition<TSource, TProjection> : ProjectionDefinition<TSource, TProjection>
  425. {
  426. private readonly IBsonSerializer<TProjection> _projectionSerializer;
  427. /// <summary>
  428. /// Initializes a new instance of the <see cref="ClientSideDeserializationProjectionDefinition{TSource, TProjection}"/> class.
  429. /// </summary>
  430. /// <param name="projectionSerializer">The projection serializer.</param>
  431. public ClientSideDeserializationProjectionDefinition(IBsonSerializer<TProjection> projectionSerializer = null)
  432. {
  433. _projectionSerializer = projectionSerializer;
  434. }
  435. /// <summary>
  436. /// Gets the result serializer.
  437. /// </summary>
  438. /// <value>
  439. /// The result serializer.
  440. /// </value>
  441. public IBsonSerializer<TProjection> ResultSerializer
  442. {
  443. get { return _projectionSerializer; }
  444. }
  445. /// <inheritdoc/>
  446. public override RenderedProjectionDefinition<TProjection> Render(IBsonSerializer<TSource> sourceSerializer, IBsonSerializerRegistry serializerRegistry)
  447. {
  448. return new RenderedProjectionDefinition<TProjection>(
  449. null,
  450. _projectionSerializer ?? (sourceSerializer as IBsonSerializer<TProjection>) ?? serializerRegistry.GetSerializer<TProjection>());
  451. }
  452. }
  453. }