using System; using System.Collections.Generic; using System.Linq; using System.Text; using CB.Interface.Infrastructure; using CB.Entity; using System.Data; using CB.Common; using System.Data.Common; namespace CB.Data.SqlServer { public class RecommendsManage : Repository, IRecommendsService { public RecommendsManage(string interfaceId) : base(interfaceId) { } public override bool Save(RecommendInfo entity) { throw new NotImplementedException(); } public override bool Update(RecommendInfo entity) { DbParameter[] pars ={ DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,entity.Id), DbHelper.MakeInParam(InterfaceId,"@Context",(DbType)SqlDbType.NVarChar,0,entity.Content) }; return DbHelper.ExecuteNonQuery(InterfaceId, CommandType.Text, @"UPDATE [DT_Page] SET [Content]=@Context WHERE [Id]=@Id", pars) > 0; } public override bool Delete(int Id) { throw new NotImplementedException(); } public override RecommendInfo Get(TKey key) { RecommendInfo Entity = null; DbParameter[] para = { DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,key) }; using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId, CommandType.Text, "SELECT TOP 1 [Id],[ClassName],[Content],[PageId] FROM [DT_Page] WHERE [Id]=@Id", para)) { if (reader.Read()) { Entity = LoadEntity(reader); } reader.Dispose(); } return Entity; } public override IList ToList() { IList list = new List(); using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, CommandType.Text, @"SELECT [Id],[ClassName],[Content],[PageId] FROM [DT_Page]")) { if (null != dt && 0 < dt.Rows.Count) { foreach (DataRow dr in dt.Rows) { list.Add(LoadEntity(dr)); } } dt.Dispose(); } return list; } public override IList ToList(RecommendInfo entity) { IList list = new List(); DbParameter[] para = { DbHelper.MakeInParam(InterfaceId,"@pageid",(DbType)SqlDbType.Int,4,entity.PageId) }; using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, CommandType.Text, @"SELECT [Id],[ClassName],[Content],[PageId] FROM [DT_Page] WHERE [PageId]=@pageid", para)) { if (null != dt && 0 < dt.Rows.Count) { foreach (DataRow dr in dt.Rows) { list.Add(LoadEntity(dr)); } } dt.Dispose(); } return list; } public override IList ToPaging(RecommendInfo entity, int pageSize, int pageIndex, out int recordCount) { throw new NotImplementedException(); } protected override RecommendInfo LoadEntity(IDataReader reader) { return new RecommendInfo() { Id = TypeConverter.ObjectToInt(reader["Id"]), ClassName = reader["ClassName"].ToString().Trim(), Content = reader["Content"].ToString().Trim(), PageId = TypeConverter.ObjectToInt(reader["PageId"]) }; } protected override RecommendInfo LoadEntity(DataRow dr) { return new RecommendInfo() { Id = TypeConverter.ObjectToInt(dr["Id"]), ClassName = dr["ClassName"].ToString().Trim(), Content = dr["Content"].ToString().Trim(), PageId = TypeConverter.ObjectToInt(dr["PageId"]) }; } } }