為了防止不提供原網址的轉載，特在這里加上原文鏈接：
http://www.cnblogs.com/skabyy/p/7517397.html
本篇我們實現數據庫的訪問。我們將實現兩種數據庫訪問方法來訪問一個SQLite數據庫——使用NHibernate實現的ORM映射訪問和使用Dapper實現的SQL語句訪問。然后完成前一篇未完成的CreateTweet和GetTweets接口。
在開始之前，先做一些准備工作，新建Domain層的Module：
public class MyTweetDomainModule : AbpModule
{
public override void Initialize()
{
IocManager.RegisterAssemblyByConvention(Assembly.GetExecutingAssembly());
}
}
同時MyTweetApplicationModule添加對MyTweetDomainModule的依賴：
[DependsOn(typeof(MyTweetDomainModule))]
public class MyTweetApplicationModule : AbpModule
安裝NuGet包Abp.NHibernate到MyTweet.Domain和MyTweet.Infrastructure。
下面我們將完成這些步驟來實現數據庫的訪問：
- 配置數據庫連接
- 新建
tweet表以及相應的Model類型 - 實現訪問數據的Repository
- 用Dapper實現通過SQL訪問數據庫
使用Fluent NHibernate配置數據庫連接
我們這里使用的數據庫是SQLite數據庫，其他數據庫的配置也是類似的。我們將連接到App_Data文件夾下的一個SQLite數據庫。新建LocalDbSessionProvider類並在構造函數處配置數據庫連接。由於LocalDbSessionProvider實現了接口ISingletonDependency，模塊初始化時LocalDbSessionProvider會以單例的形式注冊到IoC容器。
public class LocalDbSessionProvider : ISessionProvider, ISingletonDependency, IDisposable
{
protected FluentConfiguration FluentConfiguration { get; private set; }
private ISessionFactory _sessionFactory;
public LocalDbSessionProvider()
{
FluentConfiguration = Fluently.Configure();
// 數據庫連接串
var connString = "data source=|DataDirectory|MySQLite.db;";
FluentConfiguration
// 配置連接串
.Database(SQLiteConfiguration.Standard.ConnectionString(connString))
// 配置ORM
.Mappings(m => m.FluentMappings.AddFromAssembly(Assembly.GetExecutingAssembly()));
// 生成session factory
_sessionFactory = FluentConfiguration.BuildSessionFactory();
}
private ISession _session;
public ISession Session
{
get
{
if (_session != null)
{
// 每次訪問都flush上一個session。這里有效率和多線程問題，暫且這樣用，后面會改。
_session.Flush();
_session.Dispose();
}
_session = _sessionFactory.OpenSession();
return _session;
}
}
public void Dispose()
{
_sessionFactory.Dispose();
}
}
這里每次用到session都只是簡單地把上一次的session flush了，然后打開新的session。這會有效率和多線程沖突的問題。這里只是單純為了展示實現數據庫鏈接的方法而先用的簡單實現。后面做工作單元（UoW）時會解決這個問題。
為了NHibernate能創建SQLite的連接，還需要安裝System.Data.SQLite.Core到MyTweet.Web（其他數據庫的話要安裝其他相應的包）。
新建tweet表以及相應的Model類型
我們用tweet表保存tweet數據。tweet數據表接口以及對應Model屬性如下：
| 數據庫字段 | Model屬性 | 類型 | 描述 |
|---|---|---|---|
pk_id |
PkId |
string |
主鍵 |
content |
Content |
string |
內容 |
create_time |
CreateTime |
string |
創建時間 |
使用SQLite工具新建MySQLite.db文件，並新建表tweet。
然后將MySQLite.db文件拷貝到App_Data文件夾下。
CREATE TABLE `tweet` (
`pk_id` TEXT,
`content` TEXT,
`create_time` TEXT NOT NULL,
PRIMARY KEY(`pk_id`)
);
接下來新建Model類Tweet以及映射TweetMapper。Tweet繼承Entity<string>，其中的string表示Tweet的主鍵Id是string類型的。TweetMapper繼承ClassMap<Tweet>，上面LocalDbSessionProvider構造函數執行到.Mappings(m => m.FluentMappings.AddFromAssembly(Assembly.GetExecutingAssembly()))這個方法時，會用反射的方式搜索程序集中ClassMap<T>的子類，建立Model和數據庫表的映射（Tweet和tweet表的映射）。
public class Tweet : Entity<string> // 主鍵為string類型
{
public string Content { get; set; }
public DateTime CreateTime { get; set; }
}
public class TweetMapper : ClassMap<Tweet>
{
public TweetMapper()
{
// 禁用惰性加載
Not.LazyLoad();
// 映射到表tweet
Table("tweet");
// 主鍵映射
Id(x => x.Id).Column("pk_id");
// 字段映射
Map(x => x.Content).Column("content");
Map(x => x.CreateTime).Column("create_time");
}
}
實現Repository與增查接口
Repository即是DDD中的倉儲，它封裝了數據對象的增刪改查操作。ABP的NhRepositoryBase已經實現了常用的增刪改查功能，因此這里只需要繼承一下就行了。
public interface ITweetRepository : IRepository<Tweet, string> { }
public class TweetRepository : NhRepositoryBase<Tweet, string>, ITweetRepository
{
public TweetRepository()
: base(IocManager.Instance.Resolve<LocalDbSessionProvider>())
{ }
}
最后，修改MyTweetAppService，實現CreateTweet接口和GetTweets接口。
public class CreateTweetInput
{
public string Content { get; set; }
}
public class MyTweetAppService : ApplicationService, IMyTweetAppService
{
public ITweetRepository TweetRepository { get; set; }
public object GetTweets(string msg)
{
return TweetRepository.GetAll().OrderByDescending(x => x.CreateTime).ToList();
}
public object CreateTweet(CreateTweetInput input)
{
var tweet = new Tweet
{
Id = Guid.NewGuid().ToString("N"),
Content = input.Content,
CreateTime = DateTime.Now
};
var o = TweetRepository.Insert(tweet);
return o;
}
}
大功告成！測試一下。用Postman調用CreateTweet接口插入一條tweet：
然后調用GetTweets查詢：
ABP的依賴注入
可能有同學會疑惑，在MyTweetAppService中只聲明了ITweetRepository類型的屬性TweetRepository，但是並沒有進行賦值，那么這個屬性的對象實例是哪里來的呢？這就涉及到ABP框架的依賴注入策略了。
ABP基於Castle Windsor框架實現自己的依賴注入功能。依賴注入最基本的功能無非是注冊（Register）和解析（Resolve）兩個，注冊功能將對象注冊到IoC容器，解析功能根據類名或接口名獲從IoC容器獲取已注冊的對象。我們可以直接通過IocManager獲得Castle Windsor的IoC容器，直接進行注冊和解析操作。
// 以單例模式注冊類型T
IocManager.Register<T>(Abp.Dependency.DependencyLifeStyle.Singleton);
// 以臨時對象模式注冊類型T，解析的時候會生成T的一個新對象
IocManager.Register<T>(Abp.Dependency.DependencyLifeStyle.Transient);
// 從IoC容器解析已注冊的類型T的對象
var obj = IocManager.Resolve<T>();
還有一些其他方法可以做注冊和解析，具體可以參照ABP的文檔。不過一般都不需要使用這些方法。ABP框架有一套依賴注入的規則，通過編寫應用程序時遵循最佳實踐和一些約定，使得依賴注入對於開發者幾乎是透明的。
ABP的注冊
基本上每個模塊的初始化方法都會有這么一行代碼：
IocManager.RegisterAssemblyByConvention(Assembly.GetExecutingAssembly());
模塊初始化時，ABP會搜索這個模塊所在的程序集，自動注冊滿足常規注冊條件與實現幫助接口的類。
常規注冊
ABP自動注冊所有Repositories， Domain Services， Application Services， MVC 控制器和Web API控制器。ABP通過判斷是否實現了相應接口來判斷是不是上述幾類。例如下面的MyAppService：
public interface IMyAppService : IApplicationService { }
public class MyAppService : IMyAppService { }
由於它實現了接口IApplicationService，ABP會自動注冊，我們就可以通過IMyAppService解析出一個MyAppService對象。
通過常規注冊的類的生命期都是transient（臨時的），每次解析時都會生成一個新的臨時對象。
幫助接口
ABP另外提供了ITransientDependency和ISingletonDependency兩個接口。這兩個接口前面也有用到過了。實現了ITransientDependency的類會被注冊為transient。而實現了ISingletonDependency的類則被注冊為單例。
ABP的解析
除了手工解析外，還可以通過構造函數和公共屬性注入來獲取類的依賴。這也是最常用的方法。例如：
public class MyAppService : IMyAppService
{
public ILogger Logger { get; set; }
private IMyRepository _repo;
public MyAppService(IMyRepository repo)
{
_repo = repo;
}
}
ILogger從公共屬性注入，IMyRepository從構造函數注入。注入過程對開發者是透明的，開發者不需要去寫注入的代碼。
QueryService - 使用SQL語句查詢數據
實際開發中，經常需要直接使用SQL進行數據訪問。查詢邏輯比較復雜時直接使用SQL可以避免復雜的Mapper。通常復雜的Mapper會導致低效率的查詢甚至會觸發NHibernate一些奇怪的bug。實際上，在開發中，對於單純的讀取數據的功能（即使查詢邏輯不復雜），我們建議直接使用SQL查詢實現。直接使用SQL查詢在調試時更為方便——直接拷貝SQL語句到SQL客戶端執行即可檢驗該語句是否正確。
下面簡要介紹一下使用Dapper來實現數據庫查詢功能。封裝了sql查詢操作的類我們稱為QueryService。
首先，安裝dapper包到MyTweet.Infrastructure。在MyTweet.Infrastructure實現QueryService的基類BaseQueryService：
public class BaseQueryService : ITransientDependency
{
private ISessionProvider _sessionProvider;
protected BaseQueryService(ISessionProvider sessionProvider)
{
_sessionProvider = sessionProvider;
}
public IEnumerable<T> Query<T>(string sql, object param = null)
{
var conn = _sessionProvider.Session.Connection;
return conn.Query<T>(sql, param);
}
}
Dapper給System.Data.IDbConnection接口擴展了Query<T>方法，該方法執行SQL查詢並將查詢結構映射為IEnumerable<T>類型的對象。為了使用這個擴展方法，還需在文件開頭加個using語句。
using Dapper;
QueryService並不在ABP依賴注入的常規注冊規則里，所以讓BaseQueryService實現了ITransientDependency，這樣它的子類都會自動被注冊到IoC容器。
接下來在MyTweet.Domain新建類TweetQueryService，它負責實現具體的SQL查詢。方法SearchTweets實現了查詢包含關鍵詞keyword的所有tweet。
public interface ITweetQueryService
{
IList<Tweet> SearchTweets(string keyword);
}
public class TweetQueryService : BaseQueryService, ITweetQueryService
{
public TweetQueryService() : base(IocManager.Instance.Resolve<LocalDbSessionProvider>())
{ }
public IList<Tweet> SearchTweets(string keyword)
{
var sql = @"select
pk_id Id,
content Content,
create_time CreateTime
from tweet
where content like '%' || @Keyword || '%'";
return Query<Tweet>(sql, new { Keyword = keyword ?? "" }).ToList();
}
}
最后在MyTweetAppService實現查詢tweet數據的接口GetTweetsFromQS：
public ITweetQueryService TweetQueryService { get; set; }
public object GetTweetsFromQS(string keyword)
{
return TweetQueryService.SearchTweets(keyword);
}
測試一下：
結束
本文介紹了通過NHibernate以及Dapper進行數據庫訪問的方法，簡單說明了ABP依賴注入策略。現在數據庫連接部分的代碼只是單純為了演示的簡單實現，沒有做合理的數據庫Session管理，會有效率和多線程沖突的問題。后面會加上工作單元（Unit of Work）來解決這些問題。