ABP框架用Dapper实现通过SQL访问数据库

为了防止不提供原网址的转载，特在这里加上原文链接：
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。

下面我们将完成这些步骤来实现数据库的访问：

  1. 配置数据库连接
  2. 新建tweet表以及相应的Model类型
  3. 实现访问数据的Repository
  4. 用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）来解决这些问题。

最后，放上代码链接：https://github.com/sKabYY/MyTweet-AbpDemo

时间： 2024-10-10 16:25:39

ABP框架用Dapper实现通过SQL访问数据库的相关文章

ABP框架源码学习之修改默认数据库表前缀或表名称

1,源码 1 namespace Abp.Zero.EntityFramework 2 { 3 /// <summary> 4 /// Extension methods for <see cref="DbModelBuilder"/>. 5 /// </summary> 6 public static class AbpZeroDbModelBuilderExtensions 7 { 8 /// <summary> 9 /// Chan

2014-07-30　MVC框架中对SQL Server数据库的访问

今天是在吾索实习的第16天.我自己主要学习了基于MVC框架的系统的开发时,对SQL Server数据库的相关访问.其步骤如下: 第一步,在Models文件夹中创建一个类,并命名为Movies.cs,如图1所示: 图1 第二步,在上述Movies.cs文件中的namespace MvcTest.Models{}中输入如下代码: 1 public class Movie 2 { 3 public int ID { get; set; } 4 public string Title { get; se

abp框架中使用angularjs访问后台方法

这段时间接触abp框架,使用angularjs方式访问,总结一点 1.访问方式 js模块 对应以下类 注意首字母小写,后续首字母大写 说明: abp 的 Application Service 动态 web api 用的是驼峰命名法,在生成js 的时候,会扫描 实现IApplicationService 接口的实现类,并且 替换掉 AppService 和 ApplicationService 后缀 2.js命名规则遵循大小驼峰方法

使用ABP框架踩过的坑系列1

诚如ABP的作者所说:We are creating different applications based on different needs. But implementing common and similar structures over and over again, at least in some level. Authorization, Validation, Exception Handling, Logging, Localization, Database Con

ABP框架 - 我的第一个Web API

上一篇我们已经对ABP是什么,能做什么.有了一个印象.那么接下来我们将动手使用ABP框架快速开发一个API,你将会发现使用ABP框架有多么便利,会实实在在感受到它的魅力. 环境要求 Visual Studio 2017 SQL Server .Net Core SDK 创建应用程序 我们使用ABP模板来创建应用程序,访问http://www.aspnetboilerplate.com/Templates,你将会看到如下页面 参照上图所示的选项选择 输入项目名称,我这里是"AbpTraining&

X-Admin&amp;ABP框架开发-代码生成器

在日常开发中,有时会遇到一些相似的代码,甚至是只要CV一次,改几个名称,就可以实现功能了,而且总归起来,都可以由一些公用的页面更改而来,因此,结合我日常开发中使用到的页面,封装一个适合自己的代码生成器,仅处于入门阶段,包括生成的代码结构都仅是把框架展示出来,内部详细暂时没得,针对于应用服务中的接口和实现,相关Dto,MVC中的控制器.视图及视图模型进行了模板制作及生成相关的文件. 一.设计思路 方案一:开始想到的是,搞个控制台,然后给一个.cs文件,然后控制台去解析其中的命名空间,类名,属性,再

基于abp框架的数据库种子数据初始化

目录 Abp系列 一.abp框架运行--前后端分离(基于VUE) 二.基于abp框架的数据库种子数据初始化 基于abp框架的数据库种子数据初始化 1.背景 2.参照 3.解决方案 3.1 初始化数据 3.2 依赖注入方法容器里获取数据库上下文 3.3 封装创建初始化数据列表方法 3.4 数据库中没有的初始化数据,补充到数据库中去 4.效果 5. Area实体 6.小结 Abp系列 一.abp框架运行--前后端分离(基于VUE) 二.基于abp框架的数据库种子数据初始化 基于abp框架的数据库种子

企业级应用框架(二)三层架构之数据访问层的封装与抽象

接上一篇我们来对数据访问层进行封装与抽象.在上一篇我们知道,要解除BLL对DAL的依赖,我们就必须抽象出DAL层的接口,同时基于DAL的数据访问技术很多,如EF,ADO.NET,LINQ TO SQL,因此,我们的数据访问层必须对这些技术提供相应的支持.所以今天我们要做的事情有两件,第一,定义我们的数据访问层接口:第二,屏蔽各类数据库访问技术的差异,提供统一的数据库访问模型.举个例子,我们只需要修改一下我们的配置文件,就能够把ADO.NET的实现方式,改变成EF的实现方式.好下面搭建我们的三层构

c#.net 是如何访问 SQL Server 数据库

1.导入命名空间 using System.Data.SqlClient; //连接SQLServer 数据库专用 2.创建连接 SqlConnection lo_conn = New SqlConnection("Server=服务器名字或IP;Database=数据库名字;uid=用户名;pwd=密码"); 3.打开连接,第2步并没有真正连接数据库 lo_conn.Open(); //真正与数据库连接 4.向数据库发送SQL命令要使用SqlCommand: SqlCommand l