C#操作MongoDB简单示例

using System;
using System.Linq;
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;
using MongoDB.Driver.Linq;

namespace ConsoleApplication2
{
    public class User
    {
        public ObjectId Id { get; set; }
        public string Name { get; set; }
        public int Age { get; set; }
    }

    class Program
    {
        static void Main(string[] args)
        {
            var connectionString = "mongodb://localhost/?safe=true";
            var server = MongoServer.Create(connectionString);
            var database = server.GetDatabase("test");          
            var collection = database.GetCollection<User>("user");
            
            //增加
            collection.Insert(new User() { Name = "user1", Age = 20 });
            collection.Insert(new User() { Name = "user2", Age = 25 });
            collection.Insert(new User() { Name = "user3", Age = 30 });

            //修改
            var user = collection.AsQueryable().FirstOrDefault(s => s.Name == "user1");
            if (user != null)
            {
                user.Age = 28;
                collection.Save(user);
            }

            //删除
            var query = Query.EQ("Name", "user2");
            collection.Remove(query);
            
            //查询记录
            var result = from item in collection.AsQueryable()
                           where item.Age >= 25
                           select item;
            foreach (var item in result)
                Console.WriteLine("{0},{1}", item.Name, item.Age);
            
            Console.ReadKey();
            database.DropCollection("user");
        }
    }
}

本例使用MongoDB版本:2.0.6

评论: 0 | 引用: 0 | 查看次数: 4416
发表评论
登录后再发表评论!