CSHARP-1749: Support creating views.

Author: rstam

src/MongoDB.Driver.Core/Core/Misc/Feature.cs

@@ -30,6 +30,7 @@ public class Feature
         private static readonly Feature __aggregateOut = new Feature("Aggregate", new SemanticVersion(2, 6, 0));
         private static readonly Feature __bypassDocumentValidation = new Feature("BypassDocumentValidation", new SemanticVersion(3, 2, 0));
         private static readonly CollationFeature __collation = new CollationFeature("Collation", new SemanticVersion(3, 3, 11));
+        private static readonly Feature __commandsWriteConcern = new CollationFeature("CommandsWriteConcern", new SemanticVersion(3, 3, 11));
         private static readonly Feature __createIndexesCommand = new Feature("CreateIndexesCommand", new SemanticVersion(3, 0, 0));
         private static readonly Feature __currentOpCommand = new Feature("CurrentOpCommand", new SemanticVersion(3, 2, 0));
         private static readonly Feature __documentValidation = new Feature("DocumentValidation", new SemanticVersion(3, 2, 0));
@@ -46,6 +47,7 @@ public class Feature
         private static readonly ReadConcernFeature __readConcern = new ReadConcernFeature("ReadConcern", new SemanticVersion(3, 2, 0));
         private static readonly Feature __scramSha1Authentication = new Feature("ScramSha1Authentication", new SemanticVersion(3, 0, 0));
         private static readonly Feature __userManagementCommands = new Feature("UserManagementCommands", new SemanticVersion(2, 6, 0));
+        private static readonly Feature __views = new Feature("Views", new SemanticVersion(3, 3, 11));
         private static readonly Feature __writeCommands = new Feature("WriteCommands", new SemanticVersion(2, 6, 0));
 
         /// <summary>
@@ -83,6 +85,11 @@ public class Feature
         /// </summary>
         public static CollationFeature Collation => __collation;
 
+        /// <summary>
+        /// Gets the commands write concern feature.
+        /// </summary>
+        public static Feature CommandsWriteConcern => __commandsWriteConcern;
+
         /// <summary>
         /// Gets the create indexes command feature.
         /// </summary>
@@ -163,6 +170,11 @@ public class Feature
         /// </summary>
         public static Feature UserManagementCommands => __userManagementCommands;
 
+        /// <summary>
+        /// Gets the views feature.
+        /// </summary>
+        public static Feature Views => __views;
+
         /// <summary>
         /// Gets the write commands feature.
         /// </summary>
@@ -218,6 +230,18 @@ public SemanticVersion SupportedOrNotSupportedVersion(bool isSupported)
             return isSupported ? _firstSupportedVersion : VersionBefore(_firstSupportedVersion);
         }
 
+        /// <summary>
+        /// Throws if the feature is not supported by a version of the server.
+        /// </summary>
+        /// <param name="serverVersion">The server version.</param>
+        public void ThrowIfNotSupported(SemanticVersion serverVersion)
+        {
+            if (!IsSupported(serverVersion))
+            {
+                throw new NotSupportedException($"Server version {serverVersion} does not support the {_name} feature.");
+            }
+        }
+
         private SemanticVersion VersionBefore(SemanticVersion version)
         {
             if (version.Patch > 0)

src/MongoDB.Driver.Core/Core/Operations/CreateViewOperation.cs

@@ -0,0 +1,196 @@
+/* Copyright 2016 MongoDB Inc.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using MongoDB.Bson;
+using MongoDB.Bson.Serialization.Serializers;
+using MongoDB.Driver.Core.Bindings;
+using MongoDB.Driver.Core.Misc;
+using MongoDB.Driver.Core.WireProtocol.Messages.Encoders;
+
+namespace MongoDB.Driver.Core.Operations
+{
+    /// <summary>
+    /// Represents a create view operation.
+    /// </summary>
+    public class CreateViewOperation : IWriteOperation<BsonDocument>
+    {
+        // private fields
+        private Collation _collation;
+        private readonly DatabaseNamespace _databaseNamespace;
+        private readonly MessageEncoderSettings _messageEncoderSettings;
+        private readonly IReadOnlyList<BsonDocument> _pipeline;
+        private readonly string _viewName;
+        private readonly string _viewOn;
+        private WriteConcern _writeConcern;
+
+        // constructors
+        /// <summary>
+        /// Initializes a new instance of the <see cref="CreateCollectionOperation" /> class.
+        /// </summary>
+        /// <param name="databaseNamespace">Name of the database.</param>
+        /// <param name="viewName">Name of the view.</param>
+        /// <param name="viewOn">The view on.</param>
+        /// <param name="pipeline">The pipeline.</param>
+        /// <param name="messageEncoderSettings">The message encoder settings.</param>
+        public CreateViewOperation(
+            DatabaseNamespace databaseNamespace,
+            string viewName,
+            string viewOn,
+            IEnumerable<BsonDocument> pipeline,
+            MessageEncoderSettings messageEncoderSettings)
+        {
+            _databaseNamespace = Ensure.IsNotNull(databaseNamespace, nameof(databaseNamespace));
+            _viewName = Ensure.IsNotNull(viewName, nameof(viewName));
+            _viewOn = Ensure.IsNotNull(viewOn, nameof(viewOn));
+            _pipeline = Ensure.IsNotNull(pipeline, nameof(pipeline)).ToList();
+            _messageEncoderSettings = Ensure.IsNotNull(messageEncoderSettings, nameof(messageEncoderSettings));
+        }
+
+        // public properties
+        /// <summary>
+        /// Gets or sets the collation.
+        /// </summary>
+        /// <value>
+        /// The collation.
+        /// </value>
+        public Collation Collation
+        {
+            get { return _collation; }
+            set { _collation = value; }
+        }
+
+        /// <summary>
+        /// Gets the namespace of the database.
+        /// </summary>
+        /// <value>
+        /// The namespace of the database.
+        /// </value>
+        public DatabaseNamespace DatabaseNamespace
+        {
+            get { return _databaseNamespace; }
+        }
+
+        /// <summary>
+        /// Gets the message encoder settings.
+        /// </summary>
+        /// <value>
+        /// The message encoder settings.
+        /// </value>
+        public MessageEncoderSettings MessageEncoderSettings
+        {
+            get { return _messageEncoderSettings; }
+        }
+
+        /// <summary>
+        /// Gets the pipeline.
+        /// </summary>
+        /// <value>
+        /// The pipeline.
+        /// </value>
+        public IReadOnlyList<BsonDocument> Pipeline
+        {
+            get { return _pipeline; }
+        }
+
+        /// <summary>
+        /// Gets the name of the view.
+        /// </summary>
+        /// <value>
+        /// The name of the view.
+        /// </value>
+        public string ViewName
+        {
+            get { return _viewName; }
+        }
+
+        /// <summary>
+        /// Gets the collection namespace.
+        /// </summary>
+        /// <value>
+        /// The collection namespace.
+        /// </value>
+        public string ViewOn
+        {
+            get { return _viewOn; }
+        }
+
+        /// <summary>
+        /// Gets or sets the write concern.
+        /// </summary>
+        /// <value>
+        /// The write concern.
+        /// </value>
+        public WriteConcern WriteConcern
+        {
+            get { return _writeConcern; }
+            set { _writeConcern = value; }
+        }
+
+        // public methods
+        /// <inheritdoc/>
+        public BsonDocument Execute(IWriteBinding binding, CancellationToken cancellationToken)
+        {
+            Ensure.IsNotNull(binding, nameof(binding));
+
+            using (var channelSource = binding.GetWriteChannelSource(cancellationToken))
+            using (var channel = channelSource.GetChannel(cancellationToken))
+            using (var channelBinding = new ChannelReadWriteBinding(channelSource.Server, channel))
+            {
+                var operation = CreateOperation(channel.ConnectionDescription.ServerVersion);
+                return operation.Execute(channelBinding, cancellationToken);
+            }
+        }
+
+        /// <inheritdoc/>
+        public async Task<BsonDocument> ExecuteAsync(IWriteBinding binding, CancellationToken cancellationToken)
+        {
+            Ensure.IsNotNull(binding, nameof(binding));
+
+            using (var channelSource = await binding.GetWriteChannelSourceAsync(cancellationToken).ConfigureAwait(false))
+            using (var channel = await channelSource.GetChannelAsync(cancellationToken).ConfigureAwait(false))
+            using (var channelBinding = new ChannelReadWriteBinding(channelSource.Server, channel))
+            {
+                var operation = CreateOperation(channel.ConnectionDescription.ServerVersion);
+                return await operation.ExecuteAsync(channelBinding, cancellationToken).ConfigureAwait(false);
+            }
+        }
+
+        // private methods
+        internal BsonDocument CreateCommand(SemanticVersion serverVersion)
+        {
+            Feature.Views.ThrowIfNotSupported(serverVersion);
+            Feature.Collation.ThrowIfNotSupported(serverVersion, _collation);
+
+            return new BsonDocument
+            {
+                { "create", _viewName },
+                { "viewOn", _viewOn },
+                { "pipeline", new BsonArray(_pipeline) },
+                { "collation", () => _collation.ToBsonDocument(), _collation != null },
+                { "writeConcern", () => _writeConcern.ToBsonDocument(), _writeConcern != null && !_writeConcern.IsServerDefault && Feature.CommandsWriteConcern.IsSupported(serverVersion) }
+            };
+        }
+
+        private WriteCommandOperation<BsonDocument> CreateOperation(SemanticVersion serverVersion)
+        {
+            var command = CreateCommand(serverVersion);
+            return new WriteCommandOperation<BsonDocument>(_databaseNamespace, command, BsonDocumentSerializer.Instance, _messageEncoderSettings);
+        }
+    }
+}

src/MongoDB.Driver.Core/MongoDB.Driver.Core.csproj

@@ -76,6 +76,7 @@
     <Compile Include="Core\Misc\ReadAheadEnumerable.cs" />
     <Compile Include="Core\Misc\ReadConcernFeature.cs" />
     <Compile Include="Core\Misc\TaskExtensions.cs" />
+    <Compile Include="Core\Operations\CreateViewOperation.cs" />
     <Compile Include="Core\Servers\IServerMonitor.cs" />
     <Compile Include="Core\Servers\IServerMonitorFactory.cs" />
     <Compile Include="Core\Servers\ServerMonitorFactory.cs" />

src/MongoDB.Driver.Legacy/Builders/CreateViewOptionsBuilder.cs

@@ -0,0 +1,94 @@
+/* Copyright 2016 MongoDB Inc.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using MongoDB.Bson;
+using MongoDB.Bson.Serialization;
+using MongoDB.Bson.Serialization.Attributes;
+using MongoDB.Bson.Serialization.Serializers;
+
+namespace MongoDB.Driver.Builders
+{
+    /// <summary>
+    /// A builder for the options used when creating a view.
+    /// </summary>
+    public static class CreateViewOptions
+    {
+        /// <summary>
+        /// Sets the collation.
+        /// </summary>
+        /// <param name="collation">The collation.</param>
+        /// <returns>The builder (so method calls can be chained).</returns>
+        public static CreateViewOptionsBuilder SetCollation(Collation collation)
+        {
+            return new CreateViewOptionsBuilder().SetCollation(collation);
+        }
+    }
+
+    /// <summary>
+    /// A builder for the options used when creating a view.
+    /// </summary>
+    [BsonSerializer(typeof(CreateViewOptionsBuilder.Serializer))]
+    public class CreateViewOptionsBuilder : BuilderBase, IMongoCreateViewOptions
+    {
+        private BsonDocument _document;
+
+        /// <summary>
+        /// Initializes a new instance of the <see cref="CreateViewOptionsBuilder"/> class.
+        /// </summary>
+        public CreateViewOptionsBuilder()
+        {
+            _document = new BsonDocument();
+        }
+
+        /// <summary>
+        /// Sets the collation.
+        /// </summary>
+        /// <param name="collation">The collation.</param>
+        /// <returns>The builder (so method calls can be chained).</returns>
+        public CreateViewOptionsBuilder SetCollation(Collation collation)
+        {
+            if (collation == null)
+            {
+                _document.Remove("collation");
+            }
+            else
+            {
+                _document["collation"] = collation.ToBsonDocument();
+            }
+
+            return this;
+        }
+
+        /// <inheritdoc/>
+         public override BsonDocument ToBsonDocument()
+        {
+            return _document;
+        }
+
+        // nested classes
+        new internal class Serializer : SerializerBase<CreateViewOptionsBuilder>
+        {
+            public override void Serialize(BsonSerializationContext context, BsonSerializationArgs args, CreateViewOptionsBuilder value)
+            {
+                BsonDocumentSerializer.Instance.Serialize(context, value._document);
+            }
+        }
+    }
+}

src/MongoDB.Driver.Legacy/IMongoCreateViewOptions.cs

@@ -0,0 +1,28 @@
+/* Copyright 2016 MongoDB Inc.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using MongoDB.Bson.Serialization.Attributes;
+using MongoDB.Bson.Serialization.Serializers;
+
+namespace MongoDB.Driver
+{
+    /// <summary>
+    /// A marker interface that represents options for creating a view (see CreateViewOptionsDocument and the CreateViewOptions builder).
+    /// </summary>
+    [BsonSerializer(typeof(UndiscriminatedActualTypeSerializer<IMongoCreateViewOptions>))]
+    public interface IMongoCreateViewOptions
+    {
+    }
+}