MongoDB的集合(collection)可以看做關系型數據庫的表,文檔對象(document)可以看做關系型數據庫的一條記錄。但兩者並 不完全對等。表的結構是固定的,MongoDB集合並沒有這個約束;另外,存入集合的文檔對象甚至可以嵌入子文檔,或者“子集合”。他們最終都可以用類似 於BJSON的格式描述。我們今天就來分析MongoDB這一特性帶來的獨特數據管理方式。我們還是以samus驅動為例來分析,samus驅動支持兩種 方式訪問數據庫,基本方式和linq方式,基本方式在上篇以介紹過,linq方式我不想單獨講解應用實例,這篇我會用兩種方式來對比介紹。
一、包含子文檔的集合操作
有這麼一個應用場景,某網站提供會員登錄的功能,用戶需要注冊賬號才能享受會員服務,但是注冊者可能會因為用戶資料表單輸入項過大而放棄填寫,因此用戶信息分為主要資料和詳細資料兩項,初次注冊只需要填寫主要資料就行了。我們打算把詳細信息設計為子文檔存儲。
1) linq方式實現
1. 新建數據描述類,描述用戶信息
復制代碼 代碼如下:
/// <summary>
/// 用戶主要資料
/// </summary>
public class UserInfo
{
public string UserId { get; set; }
public string UserName { get; set; }
public string PassWord { get; set; }
public Detail Detail { get; set; }
}
/// <summary>
/// 用戶詳細資料
/// </summary>
public class Detail
{
public string Address { get; set; }
public int Age { get; set; }
public string Email { get; set; }
}
2. 我們要新建一個用戶業務操作類“UserBLL”。這個時候要讓驅動知道UserInfo類描述了“用戶資料”的字段信息,在GetMongo()方法實現了配置步驟,UserBLL完整代碼如下:
復制代碼 代碼如下:
public class UserBLL
{
public string connectionString = "mongodb://localhost";
public string databaseName = "myDatabase";
private Mongo mongo;
private MongoDatabase mongoDatabase;
//注意這裡泛型類型為“UserInfo”
private MongoCollection<UserInfo> mongoCollection;
public UserBLL()
{
mongo = GetMongo();
mongoDatabase = mongo.GetDatabase(databaseName) as MongoDatabase;
mongoCollection = mongoDatabase.GetCollection<UserInfo>() as MongoCollection<UserInfo>;
mongo.Connect();
}
~UserBLL()
{
mongo.Disconnect();
}
/// <summary>
/// 配置Mongo,將類UserInfo映射到集合
/// </summary>
private Mongo GetMongo()
{
var config = new MongoConfigurationBuilder();
config.Mapping(mapping =>
{
mapping.DefaultProfile(profile =>
{
profile.SubClassesAre(t => t.IsSubclassOf(typeof(UserInfo)));
});
mapping.Map<UserInfo>();
});
config.ConnectionString(connectionString);
return new Mongo(config.BuildConfiguration());
}
}
3. 接著,在“UserBLL”類中定義一個方法“InsertSomeData()”來插入一些數據:
復制代碼 代碼如下:
/// <summary>
/// 插入一些數據
/// </summary>
public void InsertSomeData()
{
UserInfo userInfo1 = new UserInfo()
{
UserId = "1001",
UserName = "張三",
PassWord = "123456"
};
mongoCollection.Save(userInfo1);
UserInfo userInfo2 = new UserInfo()
{
UserId = "1002",
UserName = "李四",
PassWord = "123456",
Detail = new Detail()
{
Address = "湖北",
Age = 20,
Email = "
[email protected]"
}
};
mongoCollection.Save(userInfo2);
UserInfo userInfo3 = new UserInfo()
{
UserId = "1003",
UserName = "王五",
PassWord = "123456",
Detail = new Detail()
{
Address = "廣東",
Age = 20,
Email = "
[email protected]"
}
};
mongoCollection.Save(userInfo3);
UserInfo userInfo4 = new UserInfo()
{
UserId = "1004",
UserName = "趙六",
PassWord = "123456",
Detail = new Detail()
{
Address = "湖北"
}
};
mongoCollection.Save(userInfo4);
}
4. 定義一個查找數據的方法“Select”,它將查找用戶詳細信息中,地址在湖北的全部用戶:
復制代碼 代碼如下:
/// <summary>
/// 查詢詳細資料地址為湖北的用戶信息
/// </summary>
public List<UserInfo> Select()
{
return mongoCollection.Linq().Where(x => x.Detail.Address == "湖北").ToList();