在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
好了,有了前面的准备工作,我们可以开始在C#中使用MongoDB了。不过,由于本示例项目的代码也不少,因此本文将只展示与MongoDB交互的相关代码,更完整的代码请自行查阅示例项目。 接下来,本文演示通过C#完成【客户资料】的一些基本的数据操作,还是先来定义一个客户资料的类型吧。 public sealed class Customer { [MongoId] public string CustomerID { get; set; } public string CustomerName { get; set; } public string ContactName { get; set; } public string Address { get; set; } public string PostalCode { get; set; } public string Tel { get; set; } } 说明:这就是一个简单的类,而且代码中的[MongoId]也是可以不要的(这个后面再说)。 在操作数据库之前,我要说明一下:MongoDB在使用前,并不要求您事先创建好相应的数据库,设计数据表结构! 再来定义二个变量: private static readonly string _connectionString = "Server=127.0.0.1"; private static readonly string _dbName = "MyNorthwind"; 新增记录public void Insert(Customer customer) { customer.CustomerID = Guid.NewGuid().ToString("N"); // 首先创建一个连接 using( Mongo mongo = new Mongo(_connectionString) ) { // 打开连接 mongo.Connect(); // 切换到指定的数据库 var db = mongo.GetDatabase(_dbName); // 根据类型获取相应的集合 var collection = db.GetCollection<Customer>(); // 向集合中插入对象 collection.Insert(customer); } } 上面的代码中,每一行都有注释,这里就不再解释了。 删除记录public void Delete(string customerId) { using( Mongo mongo = new Mongo(_connectionString) ) { mongo.Connect(); var db = mongo.GetDatabase(_dbName); var collection = db.GetCollection<Customer>(); // 从集合中删除指定的对象 collection.Remove(x => x.CustomerID == customerId); } } 更新记录public void Update(Customer customer) { using( Mongo mongo = new Mongo(_connectionString) ) { mongo.Connect(); var db = mongo.GetDatabase(_dbName); var collection = db.GetCollection<Customer>(); // 更新对象 collection.Update(customer, (x => x.CustomerID == customer.CustomerID)); } } 获取记录列表public List<Customer> GetList(string searchWord, PagingInfo pagingInfo) { using( Mongo mongo = new Mongo(_connectionString) ) { mongo.Connect(); var db = mongo.GetDatabase(_dbName); var collection = db.GetCollection<Customer>(); // 先创建一个查询 var query = from customer in collection.Linq() select customer; // 增加查询过滤条件 if( string.IsNullOrEmpty(searchWord) == false ) query = query.Where(c => c.CustomerName.Contains(searchWord) || c.Address.Contains(searchWord)); // 先按名称排序,再返回分页结果. return query.OrderBy(x => x.CustomerName).GetPagingList<Customer>(pagingInfo); } } 获取单个对象public Customer GetById(string customerId) { using( Mongo mongo = new Mongo(_connectionString) ) { mongo.Connect(); var db = mongo.GetDatabase(_dbName); var collection = db.GetCollection<Customer>(); // 查询单个对象 return collection.FindOne(x => x.CustomerID == customerId); } } |
请发表评论