备案控制台
开发者社区 数据库 文章 正文

浅析.Net数据操作机制

2018-01-07 825
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

举个栗子，获取新闻详情的案例。

public ActionResult NewsView(int newsId)
{
            var news = _newsService.GetNewsById(newsId); // 获取数据
            NewsModel newsItem = new NewsModel();        // 新建模型存储数据
            if (null != news)
            { 
                newsItem.Id = news.Id;
                newsItem.Title = news.Title;
                newsItem.Short = news.Short;
                newsItem.Full = news.Full;
                newsItem.AllowComments = news.AllowComments;
                newsItem.CommentCount = news.CommentCount;
                newsItem.PrizeCount = news.PrizeCount;
                newsItem.ClickCount = news.ClickCount + 1;
                newsItem.CreatedOn = news.CreatedOn.ToString("yyyy-MM-dd HH:mm:ss");  // 处理日期
                newsItem.IsPrize = null != news.NewsComments.FirstOrDefault(m => m.IsPrize);
                if (news.NewsPictures.Count > 0) // 处理新闻图片
                {
                    foreach (var itemp in news.NewsPictures.OrderBy(m => m.DisplayOrder))
                    {
                        newsItem.CoverImgUrls.Add(_pictureService.GetPictureUrl(itemp.PictureId));
                    }
                }
                news.ClickCount++;
                _newsService.UpdateNews(news); // 更新点击数量
            }
            return View(newsItem); // 将数据传入界面端
}

再谈_newsService如何获取数据。

using Nop.Core;
using Nop.Core.Data;
using Nop.Core.Domain.News;
using Nop.Services.Events;
using System;
using System.Collections.Generic;
using System.Linq;

namespace Nop.Services.News
{
    /// <summary>
    /// News service
    /// </summary>
    public partial class NewsService : INewsService
    {
        #region Fields
        private readonly IRepository<NewsItem> _newsItemRepository;
        private readonly IRepository<NewsComment> _newsCommentRepository;
        private readonly IRepository<NewsPicture> _newsPictureRepository;
        private readonly IEventPublisher _eventPublisher;

        #endregion

        #region Ctor

        public NewsService(IRepository<NewsItem> newsItemRepository,
            IRepository<NewsComment> newsCommentRepository,
            IRepository<NewsPicture> newsPictureRepository,
            IEventPublisher eventPublisher)
        {
            this._newsItemRepository = newsItemRepository;
            this._newsCommentRepository = newsCommentRepository;
            this._newsPictureRepository = newsPictureRepository;
            this._eventPublisher = eventPublisher;
        }

        #endregion

        #region Methods

        /// <summary>
        /// Deletes a news
        /// </summary>
        /// <param name="newsItem">News item</param>
        public virtual void DeleteNews(NewsItem newsItem)
        {
            if (newsItem == null)
                throw new ArgumentNullException("newsItem");

            _newsItemRepository.Delete(newsItem);

            //event notification
            _eventPublisher.EntityDeleted(newsItem);
        }

        /// <summary>
        /// Gets a news
        /// </summary>
        /// <param name="newsId">The news identifier</param>
        /// <returns>News</returns>
        public virtual NewsItem GetNewsById(int newsId)
        {
            if (newsId == 0)
                return null;

            return _newsItemRepository.GetById(newsId);
        }

        /// <summary>
        /// Gets all news
        /// </summary>
        /// <param name="languageId">Language identifier; 0 if you want to get all records</param>
        /// <param name="storeId">Store identifier; 0 if you want to get all records</param>
        /// <param name="pageIndex">Page index</param>
        /// <param name="pageSize">Page size</param>
        /// <param name="showHidden">A value indicating whether to show hidden records</param>
        /// <returns>News items</returns>
        public virtual IPagedList<NewsItem> GetAllNews(int languageId = 0, int storeId = 0,
            int pageIndex = 0, int pageSize = int.MaxValue, bool showHidden = false)
        {
            var query = _newsItemRepository.Table;
            if (!showHidden)
            {
                query = query.Where(n => n.Published);
            }
            query = query.OrderByDescending(n => n.CreatedOn);

            var news = new PagedList<NewsItem>(query, pageIndex, pageSize);
            return news;
        }

        /// <summary>
        /// Inserts a news item
        /// </summary>
        /// <param name="news">News item</param>
        public virtual void InsertNews(NewsItem news)
        {
            if (news == null)
                throw new ArgumentNullException("news");

            _newsItemRepository.Insert(news);

            //event notification
            _eventPublisher.EntityInserted(news);
        }

        /// <summary>
        /// Updates the news item
        /// </summary>
        /// <param name="news">News item</param>
        public virtual void UpdateNews(NewsItem news)
        {
            if (news == null)
                throw new ArgumentNullException("news");

            _newsItemRepository.Update(news);

            //event notification
            _eventPublisher.EntityUpdated(news);
        }

        /// <summary>
        /// Gets news
        /// </summary>
        /// <param name="newsIds">The news identifiers</param>
        /// <returns>News</returns>
        public virtual IList<NewsItem> GetNewsByIds(int[] newsIds)
        {
            var query = _newsItemRepository.Table;
            return query.Where(p => newsIds.Contains(p.Id)).ToList();
        }



        /// <summary>
        /// Gets all comments
        /// </summary>
        /// <param name="customerId">Customer identifier; 0 to load all records</param>
        /// <returns>Comments</returns>
        public virtual IList<NewsComment> GetAllComments(int customerId)
        {
            var query = from c in _newsCommentRepository.Table
                        orderby c.CreatedOn
                        where (customerId == 0 || c.CustomerId == customerId)
                        select c;
            var content = query.ToList();
            return content;
        }

        /// <summary>
        /// Gets a news comment
        /// </summary>
        /// <param name="newsCommentId">News comment identifier</param>
        /// <returns>News comment</returns>
        public virtual NewsComment GetNewsCommentById(int newsCommentId)
        {
            if (newsCommentId == 0)
                return null;

            return _newsCommentRepository.GetById(newsCommentId);
        }

        /// <summary>
        /// Get news comments by identifiers
        /// </summary>
        /// <param name="commentIds">News comment identifiers</param>
        /// <returns>News comments</returns>
        public virtual IList<NewsComment> GetNewsCommentsByIds(int[] commentIds)
        {
            if (commentIds == null || commentIds.Length == 0)
                return new List<NewsComment>();

            var query = from nc in _newsCommentRepository.Table
                        where commentIds.Contains(nc.Id)
                        select nc;
            var comments = query.ToList();
            //sort by passed identifiers
            var sortedComments = new List<NewsComment>();
            foreach (int id in commentIds)
            {
                var comment = comments.Find(x => x.Id == id);
                if (comment != null)
                    sortedComments.Add(comment);
            }
            return sortedComments;
        }

        /// <summary>
        /// Deletes a news comments
        /// </summary>
        /// <param name="newsComments">News comments</param>
        public virtual void DeleteNewsComments(IList<NewsComment> newsComments)
        {
            if (newsComments == null)
                throw new ArgumentNullException("newsComments");

            _newsCommentRepository.Delete(newsComments);
        }
        /// <summary>
        /// 更新新闻评论
        /// </summary>
        /// <param name="newsComment"></param>
        public virtual void UpdateNewsComment(NewsComment newsComment)
        {
            if (newsComment == null)
                throw new ArgumentNullException("newsComment");

            _newsCommentRepository.Update(newsComment);
            
            //event notification
            _eventPublisher.EntityUpdated(newsComment);
        }
        /// <summary>
        /// Deletes a news comment
        /// </summary>
        /// <param name="newsComment">News comment</param>
        public virtual void DeleteNewsComment(NewsComment newsComment)
        {
            if (newsComment == null)
                throw new ArgumentNullException("newsComment");

            _newsCommentRepository.Delete(newsComment);
        }
        public virtual IList<NewsItem> GetNewsByCategoryId(int categoryId, int pageSize = 4)
        {
            var query = (from x in _newsItemRepository.Table
                         where x.NewsCategoryId == categoryId
                         && x.Published
                         orderby x.CreatedOn descending
                         select x).Take(pageSize).ToList();
            return query;
        }
        public virtual PagedList<NewsComment> GetNewsCommentsByNewsId(int newsId, int pageIndex = 1, int pageSize = 5)
        {
            var query = from x in _newsCommentRepository.Table
                        where x.NewsItemId == newsId 
                        && !x.IsScreen
                        && !x.IsPrize
                        orderby x.CreatedOn descending
                        select x;
            return new PagedList<NewsComment>(query, pageIndex - 1, pageSize);
        }
        public virtual void ChangePrize(int newsId, int customerId, bool isPrize = true)
        {
            var news = GetNewsById(newsId);
            if (null != news)
            {
                var comments = (from x in news.NewsComments
                                where x.NewsItemId == newsId
                                && x.CustomerId == customerId
                                && x.IsPrize
                                orderby x.CreatedOn descending
                                select x).FirstOrDefault();
                if (isPrize)
                {
                    if (null == comments)
                    {
                        news.NewsComments.Add(new NewsComment
                        {
                            NewsItemId = newsId,
                            CustomerId = customerId,
                            CreatedOn = DateTime.Now,
                            IsPrize = true
                        });
                        news.PrizeCount++;
                    }
                }
                else
                {
                    if (null != comments)
                    {
                        //news.NewsComments.Remove(comments);
                        DeleteNewsComment(comments);
                        news.PrizeCount--;
                    }
                }
                UpdateNews(news);
            }
        }
        public virtual bool AddNewsComment(int newsId, int customerId, string text, out string msg)
        {
            bool result = false;
            var news = GetNewsById(newsId);
            if (null != news)
            {
                var comments = (from x in news.NewsComments
                                where x.CustomerId == customerId
                                && !x.IsPrize
                                orderby x.CreatedOn descending
                                select x).FirstOrDefault();
                if (null != comments && comments.CreatedOn > DateTime.Now.AddMinutes(-1))
                    msg = "评论过于频繁";
                else
                {
                    news.NewsComments.Add(new NewsComment
                    {
                        NewsItemId = newsId,
                        CustomerId = customerId,
                        CommentText = text,
                        CreatedOn = DateTime.Now,
                        IsPrize = false,
                        IsScreen=true
                    });
                    msg = "评论成功,等待审核";
                    result = true;
                    news.CommentCount++;
                    UpdateNews(news);
                }
            }
            else
            {
                msg = "新闻不存在";
                result = false;
            }
            return result;
        }



        /// <summary>
        /// 搜索所有的新闻
        /// </summary>
        /// <param name="dateFrom"></param>
        /// <param name="dateTo"></param>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <param name="showHidden"></param>
        /// <returns></returns>
        public virtual IPagedList<NewsItem> GetAllNews(DateTime? dateFrom = null, DateTime? dateTo = null,
            int pageIndex = 0, int pageSize = int.MaxValue, bool showHidden = false)
        {
            var query = _newsItemRepository.Table;
            if (dateFrom.HasValue)
                query = query.Where(c => dateFrom.Value <= c.CreatedOn);
            if (dateTo.HasValue)
                query = query.Where(c => dateTo.Value >= c.CreatedOn);
            if (!showHidden)
            {
                query = query.Where(n => n.Published);
            }
            query = query.OrderByDescending(n => n.CreatedOn);

            var news = new PagedList<NewsItem>(query, pageIndex, pageSize);
            return news;
        }


        /// <summary>
        /// 搜索所有的新闻评论
        /// </summary>
        /// <param name="dateFrom"></param>
        /// <param name="dateTo"></param>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <param name="showHidden"></param>
        /// <returns></returns>
        public virtual IPagedList<NewsComment> GetAllComments(string commentContent=null,int pageIndex = 0, int pageSize = int.MaxValue)
        {
            var query = from c in _newsCommentRepository.Table
                        where (!string.IsNullOrEmpty(commentContent)&&c.CommentText.Contains(commentContent.Trim()))||(string.IsNullOrEmpty(commentContent))
                        orderby c.Id descending
                        select c;
                        
            //if (!showHidden)
            //{
            //    query = query.Where(n => n.Published);
            //}
            return new PagedList<NewsComment>(query, pageIndex, pageSize);
        }




        #region News pictures

        /// <summary>
        /// Deletes a news picture
        /// </summary>
        /// <param name="newsPicture">News picture</param>
        public virtual void DeleteNewsPicture(NewsPicture newsPicture)
        {
            if (newsPicture == null)
                throw new ArgumentNullException("newsPicture");

            _newsPictureRepository.Delete(newsPicture);

            //event notification
            _eventPublisher.EntityDeleted(newsPicture);
        }

        /// <summary>
        /// Gets a news pictures by newsItem identifier
        /// </summary>
        /// <param name="newsItemId">The news identifier</param>
        /// <returns>News pictures</returns>
        public virtual IList<NewsPicture> GetNewsPicturesByNewsItemId(int newsItemId)
        {
            var query = from np in _newsPictureRepository.Table
                        where np.NewsItemId == newsItemId
                        orderby np.DisplayOrder
                        select np;
            var newsItemPictures = query.ToList();
            return newsItemPictures;
        }

        /// <summary>
        /// Gets a newsItem picture
        /// </summary>
        /// <param name="newsItemIdPictureId">News picture identifier</param>
        /// <returns>News picture</returns>
        public virtual NewsPicture GetNewsPictureById(int newsPictureId)
        {
            if (newsPictureId == 0)
                return null;

            return _newsPictureRepository.GetById(newsPictureId);
        }

        /// <summary>
        /// Inserts a newsItem picture
        /// </summary>
        /// <param name="newsPicture">News picture</param>
        public virtual void InsertNewsPicture(NewsPicture newsPicture)
        {
            if (newsPicture == null)
                throw new ArgumentNullException("newsPicture");

            _newsPictureRepository.Insert(newsPicture);

            //event notification
            _eventPublisher.EntityInserted(newsPicture);
        }

        /// <summary>
        /// Updates a newsItem picture
        /// </summary>
        /// <param name="newsPicture">News picture</param>
        public virtual void UpdateNewsPicture(NewsPicture newsPicture)
        {
            if (newsPicture == null)
                throw new ArgumentNullException("newsPicture");

            _newsPictureRepository.Update(newsPicture);

            //event notification
            _eventPublisher.EntityUpdated(newsPicture);
        }

        /// <summary>
        /// Get the IDs of all newsItem images 
        /// </summary>
        /// <param name="NewsItemIds">News IDs</param>
        /// <returns>All picture identifiers grouped by newsItem ID</returns>
        public IDictionary<int, int[]> GetNewsItemsImagesIds(int[] newsItemsIds)
        {
            return _newsPictureRepository.Table.Where(p => newsItemsIds.Contains(p.NewsItemId))
                .GroupBy(p => p.NewsItemId).ToDictionary(p => p.Key, p => p.Select(p1 => p1.PictureId).ToArray());
        }

        #endregion



        #endregion
    }
}

这上面都是自己写的一些常用的数据库交互方法。

系统最核心的还是它! ##IRepository

using System.Collections.Generic;
using System.Linq;

namespace Nop.Core.Data
{
    /// <summary>
    /// Repository
    /// </summary>
    public partial interface IRepository<T> where T : BaseEntity
    {
        /// <summary>
        /// Get entity by identifier
        /// </summary>
        /// <param name="id">Identifier</param>
        /// <returns>Entity</returns>
        T GetById(object id);

        /// <summary>
        /// Insert entity
        /// </summary>
        /// <param name="entity">Entity</param>
        void Insert(T entity);

        /// <summary>
        /// Insert entities
        /// </summary>
        /// <param name="entities">Entities</param>
        void Insert(IEnumerable<T> entities);

        /// <summary>
        /// Update entity
        /// </summary>
        /// <param name="entity">Entity</param>
        void Update(T entity);

        /// <summary>
        /// Update entities
        /// </summary>
        /// <param name="entities">Entities</param>
        void Update(IEnumerable<T> entities);

        /// <summary>
        /// Delete entity
        /// </summary>
        /// <param name="entity">Entity</param>
        void Delete(T entity);

        /// <summary>
        /// Delete entities
        /// </summary>
        /// <param name="entities">Entities</param>
        void Delete(IEnumerable<T> entities);

        /// <summary>
        /// Gets a table
        /// </summary>
        IQueryable<T> Table { get; }

        /// <summary>
        /// Gets a table with "no tracking" enabled (EF feature) Use it only when you load record(s) only for read-only operations
        /// </summary>
        IQueryable<T> TableNoTracking { get; }
    }
}

为了处理，获取的数据，还需要定义个常用的Model模型来存储数据，这个真心的蛋疼。

using Nop.Web.Framework.Mvc;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;

namespace Nop.Web.Models.News
{
    public partial class AppNewsModel
    {
        public AppNewsModel()
        {
            this.News = new List<NewsModel>();
        }
        public bool result { get; set; }
        public string msg { get; set; }
        public List<NewsModel> News { get; set; }
    }
    /// <summary>
    /// 新闻
    /// </summary>
    public partial class NewsModel : BaseNopEntityModel
    {
        public NewsModel()
        {
            this.CoverImgUrls = new List<string>();
        }
        /// <summary>
        /// 标题
        /// </summary>
        public string Title { get; set; }
        /// <summary>
        /// 概要
        /// </summary>
        public string Short { get; set; }
        /// <summary>
        /// 详情(新闻列表不传该字段)
        /// </summary>
        public string Full { get; set; }
        /// <summary>
        /// 允许评论
        /// </summary>
        public bool AllowComments { get; set; }
        /// <summary>
        /// 评论量
        /// </summary>
        public int CommentCount { get; set; }
        /// <summary>
        /// 点赞量
        /// </summary>
        public int PrizeCount { get; set; }
        /// <summary>
        /// 创建时间
        /// </summary>
        public string CreatedOn { get; set; }
        /// <summary>
        /// 赞
        /// </summary>
        public bool IsPrize { get; set; }
        /// <summary>
        /// 点击数量
        /// </summary>
        public int ClickCount { get; set; }
        public List<string> CoverImgUrls { get; set; }
    }
}

基本上，还是很清晰的。就跟王者荣耀游戏一样，玩几局，就摸透了。
F12定位恒好用。


本文转自TBHacker博客园博客，原文链接：http://www.cnblogs.com/jiqing9006/p/6868169.html，如需转载请自行联系原作者

文章标签：
数据库
存储
关键词：
.NET数据
.NET机制
.NET数据机制
.NET数据操作
桃子红了呐
目录
相关文章
a15034260562-24955
|
1月前
mvc.net分页查询案例——DLL数据访问层（HouseDLL.cs）
mvc.net分页查询案例——DLL数据访问层（HouseDLL.cs）
a15034260562-24955
13 0
拓端数据部落
|
1月前
|
存储 测试技术 计算机视觉
高维数据惩罚回归方法：主成分回归PCR、岭回归、lasso、弹性网络elastic net分析基因数据
高维数据惩罚回归方法：主成分回归PCR、岭回归、lasso、弹性网络elastic net分析基因数据
拓端数据部落
52 0
a15034260562-24955
|
1月前
|
SQL 数据库
使用ADO.NET查询和操作数据
使用ADO.NET查询和操作数据
a15034260562-24955
15 0
红目香薰
|
1月前
|
SQL 开发框架 .NET
ASP.NET WEB+EntityFramework数据持久化——考核练习库——1、用户管理系统(考点：查询列表、增加、删除)
ASP.NET WEB+EntityFramework数据持久化——考核练习库——1、用户管理系统(考点：查询列表、增加、删除)
红目香薰
84 0
追逐时光者
|
1月前
|
小程序 安全 JavaScript
.NET微信网页开发之通过UnionID机制解决多应用用户帐号统一问题
.NET微信网页开发之通过UnionID机制解决多应用用户帐号统一问题
追逐时光者
60 0
.NET微信网页开发之通过UnionID机制解决多应用用户帐号统一问题
淘源码-taoydm168
|
1月前
|
Oracle 关系型数据库 数据管理
.NET医院检验系统LIS源码，使用了oracle数据库,保证数据的隔离和安全性
LIS系统实现了实验室人力资源管理、标本管理、日常事务管理、网络管理、检验数据管理（采集、传输、处理、输出、发布）、报表管理过程的自动化，使实验室的操作人员和管理者从繁杂的手工劳作中解放出来，提高了检验人员的工作效率和效益，降低了劳动成本和差错发生率。
淘源码-taoydm168
55 0
GoodTime
|
8月前
|
前端开发 JavaScript
.net core 前端传递参数有值 后端接收到的数据却是null
1、问题分析 在做接口测试时，偶然出现了前端输出有值，但是后端断点调试时却出现接收参数总是为null的情况 2、解决办法 前端打印log，看前端的每一个传值的数据类型，与后端请求参数类进行认真的一一比对 小技巧： ① 直接打印调用接口的传参值的数据类型，例如 console.log(type of this.form.name) --string console.log(type of this.form.age) --number 打印的数据类型与后端接口的参数类比对，查出不对应的类型 ② 关于非必填的值，默认传值可能出现空字符串(' ')、NaN值(Not a Number
GoodTime
142 0
1054125860120823
|
9月前
|
JSON 数据格式
.NET Core - 配置绑定：使用强类型对象承载配置数据
.NET Core - 配置绑定：使用强类型对象承载配置数据
1054125860120823
90 0
谷艳爽faye
|
11月前
|
数据库 C#
C#，.net,winform导入Excel功能以及下载Excel文件到本地，并使用SqlBulkCopy把DataTable类型的数据写入到sqlserver数据库中
C#，.net,winform导入Excel功能以及下载Excel文件到本地，并使用SqlBulkCopy把DataTable类型的数据写入到sqlserver数据库中
谷艳爽faye
275 0
爬虫工程师Azeroth
|
数据采集 JavaScript 前端开发
为什么用Python爬取网页数据，在检查net work中很多和教程上不一样？
今天就来说说，我们为什么会出现这个问题，以及我们应该怎么做，才能解决这个问题？
爬虫工程师Azeroth
121 0