RecommendsManage.cs 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using CB.Interface.Infrastructure;
  6. using CB.Entity;
  7. using System.Data;
  8. using CB.Common;
  9. using System.Data.Common;
  10. namespace CB.Data.SqlServer
  11. {
  12. public class RecommendsManage : Repository<RecommendInfo>, IRecommendsService
  13. {
  14. public RecommendsManage(string interfaceId)
  15. : base(interfaceId)
  16. {
  17. }
  18. public override bool Save(RecommendInfo entity)
  19. {
  20. throw new NotImplementedException();
  21. }
  22. public override bool Update(RecommendInfo entity)
  23. {
  24. DbParameter[] pars ={
  25. DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,entity.Id),
  26. DbHelper.MakeInParam(InterfaceId,"@Context",(DbType)SqlDbType.NVarChar,0,entity.Content)
  27. };
  28. return DbHelper.ExecuteNonQuery(InterfaceId, CommandType.Text, @"UPDATE [DT_Page] SET [Content]=@Context WHERE [Id]=@Id", pars) > 0;
  29. }
  30. public override bool Delete(int Id)
  31. {
  32. throw new NotImplementedException();
  33. }
  34. public override RecommendInfo Get<TKey>(TKey key)
  35. {
  36. RecommendInfo Entity = null;
  37. DbParameter[] para =
  38. {
  39. DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,key)
  40. };
  41. using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId, CommandType.Text,
  42. "SELECT TOP 1 [Id],[ClassName],[Content],[PageId] FROM [DT_Page] WHERE [Id]=@Id",
  43. para))
  44. {
  45. if (reader.Read())
  46. {
  47. Entity = LoadEntity(reader);
  48. }
  49. reader.Dispose();
  50. }
  51. return Entity;
  52. }
  53. public override IList<RecommendInfo> ToList()
  54. {
  55. IList<RecommendInfo> list = new List<RecommendInfo>();
  56. using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, CommandType.Text, @"SELECT [Id],[ClassName],[Content],[PageId] FROM [DT_Page]"))
  57. {
  58. if (null != dt && 0 < dt.Rows.Count)
  59. {
  60. foreach (DataRow dr in dt.Rows)
  61. { list.Add(LoadEntity(dr)); }
  62. }
  63. dt.Dispose();
  64. }
  65. return list;
  66. }
  67. public override IList<RecommendInfo> ToList(RecommendInfo entity)
  68. {
  69. IList<RecommendInfo> list = new List<RecommendInfo>();
  70. DbParameter[] para =
  71. {
  72. DbHelper.MakeInParam(InterfaceId,"@pageid",(DbType)SqlDbType.Int,4,entity.PageId)
  73. };
  74. using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, CommandType.Text, @"SELECT [Id],[ClassName],[Content],[PageId] FROM [DT_Page] WHERE [PageId]=@pageid", para))
  75. {
  76. if (null != dt && 0 < dt.Rows.Count)
  77. {
  78. foreach (DataRow dr in dt.Rows)
  79. { list.Add(LoadEntity(dr)); }
  80. }
  81. dt.Dispose();
  82. }
  83. return list;
  84. }
  85. public override IList<RecommendInfo> ToPaging(RecommendInfo entity, int pageSize, int pageIndex, out int recordCount)
  86. {
  87. throw new NotImplementedException();
  88. }
  89. protected override RecommendInfo LoadEntity(IDataReader reader)
  90. {
  91. return new RecommendInfo()
  92. {
  93. Id = TypeConverter.ObjectToInt(reader["Id"]),
  94. ClassName = reader["ClassName"].ToString().Trim(),
  95. Content = reader["Content"].ToString().Trim(),
  96. PageId = TypeConverter.ObjectToInt(reader["PageId"])
  97. };
  98. }
  99. protected override RecommendInfo LoadEntity(DataRow dr)
  100. {
  101. return new RecommendInfo()
  102. {
  103. Id = TypeConverter.ObjectToInt(dr["Id"]),
  104. ClassName = dr["ClassName"].ToString().Trim(),
  105. Content = dr["Content"].ToString().Trim(),
  106. PageId = TypeConverter.ObjectToInt(dr["PageId"])
  107. };
  108. }
  109. }
  110. }