假设我有一个接口。
public interface IBlogRepository
{
IList<Blog> Blogs(int pageNo, int pageSize);
int TotalPosts();
}
现在,我创建了一个类来实现它并使用NHibernate。
using NHibernate;
using NHibernate.Criterion;
using NHibernate.Linq;
using NHibernate.Transform;
using System.Collections.Generic;
using System.Linq;
namespace JustBlog.Core
{
public class BlogRepository: IBlogRepository
{
// NHibernate object
private readonly ISession _session;
public BlogRepository(ISession session)
{
_session = session;
}
public IList<Post> Posts(int pageNo, int pageSize)
{
var query = _session.Query<Post>()
.Where(p => p.Published)
.OrderByDescending(p => p.PostedOn)
.Skip(pageNo * pageSize)
.Take(pageSize)
.Fetch(p => p.Category);
query.FetchMany(p => p.Tags).ToFuture();
return query.ToFuture().ToList();
}
public int TotalPosts()
{
return _session.Query<Post>().Where(p => p.Published).Count();
}
}
上面的代码来自网络上用于创建博客引擎的位置。但是我一点都不了解NHibernate,我使用Entity Framework来完成我的工作。
如何不使用NHiberate重写代码?
实体模型
假设我们有这样的实体模型:
public class Post
{
public Post() { Tags = new List<Tag>(); }
public int Id{ get; set; }
public string Title{ get; set; }
public string ShortDescription{ get; set; }
public string Description{ get; set; }
public string Meta{ get; set; }
public string UrlSlug{ get; set; }
public bool Published{ get; set; }
public DateTime PostedOn{ get; set; }
public DateTime? Modified{ get; set; }
public int CategoryId { get; set; }
public virtual Category Category{ get; set; }
public virtual IList<Tag> Tags{ get; set; }
}
public class Tag
{
public int Id { get; set; }
public string Name { get; set; }
public string UrlSlug { get; set; }
public string Description { get; set; }
public virtual IList<Post> Posts { get; set; }
}
public class Category
{
public int Id { get; set; }
public string Name { get; set; }
public string UrlSlug { get; set; }
public string Description { get; set; }
public virtual IList<Post> Posts { get; set; }
}
语境
我们的上下文类非常简单。构造函数采用in形式的连接字符串web.config
,我们定义了三个DbSet
:
public class BlogContext : DbContext
{
public BlogContext() : base("BlogContextConnectionStringName") { }
public DbSet<Category> Categories { get; set; }
public DbSet<Post> Posts { get; set; }
public DbSet<Tag> Tags { get; set; }
protected override void OnModelCreating(DbModelBuilder modelBuilder)
{
base.OnModelCreating(modelBuilder);
}
}
资料库
我们的博客存储库的界面非常简单,并且变化不大:
public interface IBlogRepository
{
IEnumerable<Post> Posts(int pageNo, int pageSize);
int TotalPosts();
}
这是博客库本身,事情变得很有趣!
public class BlogRepository : IBlogRepository
{
// NHibernate object replace with our context
private readonly BlogContext _blogContext;
public BlogRepository(BlogContext blogContext)
{
_blogContext = blogContext;
}
//Function to get a list of blogs
public IEnumerable<Post> Posts(int pageNo, int pageSize)
{
//We start with the blogs db set:
var query = _blogContext.Posts
//Filter by Published=true
.Where(p => p.Published)
//Order by date they were posted
.OrderByDescending(p => p.PostedOn)
//Jump through the list
.Skip(pageNo * pageSize)
//Get the required number of blogs
.Take(pageSize)
//Make sure the query include all the categories
.Include(b => b.Category);
//Just return what we have!
return query;
}
//Much simpler function, should be pretty self explanatory
public int TotalPosts()
{
return _blogContext.Posts.Where(p => p.Published).Count();
}
}
下一步
好的,现在我们已完成所有设置,并在您的web.config中设置了一个不错的连接字符串,我们该如何处理?好吧,让我们来一些博客!
var context = new BlogContext();
var repository = new BlogRepository(context);
var posts = repository.Posts(0, 10);
然后,我们可以对这些博客做一些事情:
foreach(var blog in blogs)
{
Console.WriteLine("Blog Id {0} was posted on {1} and has {2} categories", blog.Id, blog.PostedOn, blog.Categories.Count());
}
笔记
我没有实现这些FetchMany/ToFuture
部分,因为这里不需要它们。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句