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)
暂无评论。