C# mongodb map reduce 计算 实例源码下载

【实例简介】mongodb map-reduce计算 源码

主要参考: 

http://docs.mongodb.org/manual/tutorial/map-reduce-examples/

http://odetocode.com/blogs/scott/archive/2012/03/19/a-simple-mapreduce-with-mongodb-and-c.aspx

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;

namespace MongoDBWinDemo
{
    public partial class MapReduceForm2 : Form
    {
        public MapReduceForm2()
        {
            InitializeComponent();
        }



        public class Movie
        {
            public string Title { get; set; }
            public string Category { get; set; }
            public int Minutes { get; set; }
        }

        public MongoCollection<T> GetCollection<T>()
        {

            //var connectionString = "mongodb://localhost";
            //var client = new MongoClient(connectionString);
            //var server = client.GetServer();
            //var database = server.GetDatabase("test");
            //var collection = database.GetCollection<Entity>("entities");

            var connectionString = "mongodb://localhost";
            var client = new MongoClient(connectionString);
            var server = client.GetServer();
            var database = server.GetDatabase("test");
            var collection = database.GetCollection<T>("movies");
            return collection;
        }

        private void AddMovies(MongoCollection<Movie> collection)
        {
            var movies = new List<Movie>
            {
                new Movie
                {
                    Title = "The Perfect Developer",
                    Category = "SciFi",
                    Minutes = 118
                },
                new Movie
                {
                    Title = "Lost In Frankfurt am Main",
                    Category = "Horror",
                    Minutes = 122
                },
                new Movie
                {
                    Title = "The Infinite Standup",
                    Category = "Horror",
                    Minutes = 341
                }
            };
            collection.InsertBatch(movies);
        }

        private void btnCal_Click(object sender, EventArgs e)
        {
            string map = @"
            function() {
                var movie = this;
                emit(movie.Category, { count: 1, totalMinutes: movie.Minutes });
            }";

            string reduce = @"        
            function(key, values) {
                var result = {count: 0, totalMinutes: 0 };

                values.forEach(function(value){               
                    result.count  = value.count;
                    result.totalMinutes  = value.totalMinutes;
                });

                return result;
            }";

            string finalize = @"
            function(key, value){
      
              value.average = value.totalMinutes / value.count;
              return value;

            }";
            //var collection = db.GetCollection("movies");
            var collection = this.GetCollection<Movie>();
            AddMovies(collection);
            var options = new MapReduceOptionsBuilder();
            options.SetFinalize(finalize);
            options.SetOutput(MapReduceOutput.Inline);
            var results = collection.MapReduce(map, reduce, options);

            foreach (var result in results.GetResults())
            {
                //Console.WriteLine(result.ToJson());
                MessageBox.Show(result.ToJson());
            }
        }
    }
}