开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > OA系统 > 查看源码
documentDAL.cs
资源名称：OASystem.rar　[点击查看]
上传用户：lishan0805
上传日期：2019-12-08
资源大小：12048k
文件大小：25k
源码类别：

OA系统

开发平台：

C#

documentDAL.cs：源码内容
  1. // =================================================================== 
  2. // 产品(COM.OA.SqlServerDAL)项目
  3. //====================================================================
  4. // wangyp @Copy Right 2006-2008
  5. // 文件：documentDAL.cs
  6. // 项目名称：工程项目管理
  7. // 创建时间：2008-9-23
  8. // 负责人：wangyp
  9. // 先创建SqlHelper.cs文件,引用System.Configuration程序集和实体(COM.OA.Entity)、产品规则(COM.OA.IDAL)项目、引用业务逻辑(COM.OA.BLL)项目
  10. // ===================================================================
  11. using System;
  12. using System.Collections;
  13. using System.Collections.Generic;
  14. using System.Data;
  15. using System.Data.SqlClient;
  16. using System.Text;
  17. using COM.OA.Entity;
  18. using COM.OA.IDAL;
  19. using COM.OA.BLL;
  21. namespace COM.OA.SqlServerDAL
  22. {
  23.     /// <summary>
  24.     /// 数据访问层dbo.document
  25.     /// </summary>
  26.     public partial class documentDAL : IdocumentDAL
  27.     {
  28.         #region 构造函数
  29.         /// <summary>
  30.         /// 数据层实例化
  31.         /// </summary>
  32.         public documentDAL()
  33.         {
  34.         }
  35.         #endregion
  37.         #region -----------实例化接口函数-----------
  39.         #region 添加
  40.         /// <summary>
  41.         /// 向数据库中插入一条新记录
  42.         /// </summary>
  43.         /// <param name="document">document实体对象</param>
  44.         /// <returns></returns>
  45.         public int Insert(document document)
  46.         {
  47.             string sqlCommand = "documentInsert";
  48.             int res;
  49.             SqlParameter[] param ={
  50. new SqlParameter("@doc_id",SqlDbType.Int),
  51. new SqlParameter("@doc_dept_id",SqlDbType.Int),
  52. new SqlParameter("@doc_g_id",SqlDbType.Int),
  53. new SqlParameter("@doc_u_id",SqlDbType.Int),
  54. new SqlParameter("@doc_title",SqlDbType.VarChar),
  55. new SqlParameter("@doc_annex",SqlDbType.VarChar),
  56. new SqlParameter("@doc_downloads",SqlDbType.Int),
  57. new SqlParameter("@doc_reads",SqlDbType.Int),
  58. new SqlParameter("@doc_clicks",SqlDbType.Int),
  59. new SqlParameter("@doc_releasetime",SqlDbType.DateTime),
  60. new SqlParameter("@doc_sendu_id",SqlDbType.Int)
  61. };
  62.             param[0].Direction = ParameterDirection.Output;
  63.             param[1].Value = document.doc_dept_id;
  64.             param[2].Value = document.doc_g_id;
  65.             param[3].Value = document.doc_u_id;
  66.             param[4].Value = document.doc_title;
  67.             param[5].Value = document.doc_annex;
  68.             param[6].Value = document.doc_downloads;
  69.             param[7].Value = document.doc_reads;
  70.             param[8].Value = document.doc_clicks;
  71.             param[9].Value = document.doc_releasetime;
  72.             param[10].Value = document.doc_sendu_id;
  73.             res = SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
  74.             document.doc_id = ((param[0].Value) == DBNull.Value) ? 0 : Convert.ToInt32(param[0].Value);
  75.             return res;
  76.         }
  77.         /// <summary>
  78.         /// 向数据库中插入一条新记录。带事务
  79.         /// </summary>
  80.         /// <param name="sp">事务对象</param>
  81.         /// <param name="document">document实体对象</param>
  82.         /// <returns></returns>
  83.         public int Insert(SqlTransaction sp, document document)
  84.         {
  85.             string sqlCommand = "documentInsert";
  86.             int res;
  87.             SqlParameter[] param ={
  88. new SqlParameter("@doc_id",SqlDbType.Int),
  89. new SqlParameter("@doc_dept_id",SqlDbType.Int),
  90. new SqlParameter("@doc_g_id",SqlDbType.Int),
  91. new SqlParameter("@doc_u_id",SqlDbType.Int),
  92. new SqlParameter("@doc_title",SqlDbType.VarChar),
  93. new SqlParameter("@doc_annex",SqlDbType.VarChar),
  94. new SqlParameter("@doc_downloads",SqlDbType.Int),
  95. new SqlParameter("@doc_reads",SqlDbType.Int),
  96. new SqlParameter("@doc_clicks",SqlDbType.Int),
  97. new SqlParameter("@doc_releasetime",SqlDbType.DateTime),
  98. new SqlParameter("@doc_sendu_id",SqlDbType.Int)
  99. };
  100.             param[0].Direction = ParameterDirection.Output;
  101.             param[1].Value = document.doc_dept_id;
  102.             param[2].Value = document.doc_g_id;
  103.             param[3].Value = document.doc_u_id;
  104.             param[4].Value = document.doc_title;
  105.             param[5].Value = document.doc_annex;
  106.             param[6].Value = document.doc_downloads;
  107.             param[7].Value = document.doc_reads;
  108.             param[8].Value = document.doc_clicks;
  109.             param[9].Value = document.doc_releasetime;
  110.             param[10].Value = document.doc_sendu_id;
  111.             res = SqlHelper.ExecuteNonQuery(sp, CommandType.StoredProcedure, sqlCommand, param);
  112.             document.doc_id = ((param[0].Value) == DBNull.Value) ? 0 : Convert.ToInt32(param[0].Value);
  113.             return res;
  114.         }
  115.         #endregion
  117.         #region 更新
  118.         /// <summary>
  119.         /// 向数据表document更新一条记录
  120.         /// </summary>
  121.         /// <param name="document">document实体对象</param>
  122.         /// <returns></returns>
  123.         public int Update(document document)
  124.         {
  125.             string sqlCommand = "documentUpdate";
  126.             SqlParameter[] param ={
  127. new SqlParameter("@doc_id",SqlDbType.Int),
  128. new SqlParameter("@doc_dept_id",SqlDbType.Int),
  129. new SqlParameter("@doc_g_id",SqlDbType.Int),
  130. new SqlParameter("@doc_u_id",SqlDbType.Int),
  131. new SqlParameter("@doc_title",SqlDbType.VarChar),
  132. new SqlParameter("@doc_annex",SqlDbType.VarChar),
  133. new SqlParameter("@doc_downloads",SqlDbType.Int),
  134. new SqlParameter("@doc_reads",SqlDbType.Int),
  135. new SqlParameter("@doc_clicks",SqlDbType.Int),
  136. new SqlParameter("@doc_releasetime",SqlDbType.DateTime),
  137. new SqlParameter("@doc_sendu_id",SqlDbType.Int)
  138. };
  139.             param[0].Value = document.doc_id;
  140.             param[1].Value = document.doc_dept_id;
  141.             param[2].Value = document.doc_g_id;
  142.             param[3].Value = document.doc_u_id;
  143.             param[4].Value = document.doc_title;
  144.             param[5].Value = document.doc_annex;
  145.             param[6].Value = document.doc_downloads;
  146.             param[7].Value = document.doc_reads;
  147.             param[8].Value = document.doc_clicks;
  148.             param[9].Value = document.doc_releasetime;
  149.             param[10].Value = document.doc_sendu_id;
  150.             return SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
  151.         }
  152.         /// <summary>
  153.         /// 向数据表document更新一条记录。带事务
  154.         /// </summary>
  155.         /// <param name="sp">事务对象</param>
  156.         /// <param name="document">document实体对象</param>
  157.         /// <returns></returns>
  158.         public int Update(SqlTransaction sp, document document)
  159.         {
  160.             string sqlCommand = "documentUpdate";
  161.             SqlParameter[] param ={
  162. new SqlParameter("@doc_id",SqlDbType.Int),
  163. new SqlParameter("@doc_dept_id",SqlDbType.Int),
  164. new SqlParameter("@doc_g_id",SqlDbType.Int),
  165. new SqlParameter("@doc_u_id",SqlDbType.Int),
  166. new SqlParameter("@doc_title",SqlDbType.VarChar),
  167. new SqlParameter("@doc_annex",SqlDbType.VarChar),
  168. new SqlParameter("@doc_downloads",SqlDbType.Int),
  169. new SqlParameter("@doc_reads",SqlDbType.Int),
  170. new SqlParameter("@doc_clicks",SqlDbType.Int),
  171. new SqlParameter("@doc_releasetime",SqlDbType.DateTime),
  172. new SqlParameter("@doc_sendu_id",SqlDbType.Int)
  173. };
  174.             param[0].Value = document.doc_id;
  175.             param[1].Value = document.doc_dept_id;
  176.             param[2].Value = document.doc_g_id;
  177.             param[3].Value = document.doc_u_id;
  178.             param[4].Value = document.doc_title;
  179.             param[5].Value = document.doc_annex;
  180.             param[6].Value = document.doc_downloads;
  181.             param[7].Value = document.doc_reads;
  182.             param[8].Value = document.doc_clicks;
  183.             param[9].Value = document.doc_releasetime;
  184.             param[10].Value = document.doc_sendu_id;
  185.             return SqlHelper.ExecuteNonQuery(sp, CommandType.StoredProcedure, sqlCommand, param);
  186.         }
  187.         #endregion
  189.         #region 删除
  190.         /// <summary>
  191.         /// 删除数据表document中的一条记录
  192.         /// </summary>
  193.         /// <param name="doc_id">doc_id</param>
  194.         /// <returns></returns>
  195.         public int Delete(int doc_id)
  196.         {
  197.             string sqlCommand = "documentDelete";
  198.             SqlParameter[] param ={
  199. new SqlParameter("@doc_id",SqlDbType.Int)
  200. };
  201.             param[0].Value = doc_id;
  202.             return SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
  203.         }
  204.         /// <summary>
  205.         /// 删除数据表document中的一条记录
  206.         /// </summary>
  207.         /// <param name="document">document实体对象</param>
  208.         /// <returns></returns>
  209.         public int Delete(document document)
  210.         {
  211.             string sqlCommand = "documentDelete";
  212.             SqlParameter[] param ={
  213. new SqlParameter("@doc_id",SqlDbType.Int)
  214. };
  215.             param[0].Value = document.doc_id;
  216.             return SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
  217.         }
  218.         /// <summary>
  219.         /// 删除数据表document中的一条记录,带事务
  220.         /// </summary>
  221.         /// <param name="sp">事务对象</param>
  222.         /// <param name="doc_id">doc_id</param>
  223.         /// <returns></returns>
  224.         public int Delete(SqlTransaction sp, int doc_id)
  225.         {
  226.             string sqlCommand = "documentDelete";
  227.             SqlParameter[] param ={
  228. new SqlParameter("@doc_id",SqlDbType.Int)
  229. };
  230.             param[0].Value = doc_id;
  231.             return SqlHelper.ExecuteNonQuery(sp, CommandType.StoredProcedure, sqlCommand, param);
  232.         }
  234.         /// <summary>
  235.         /// 删除数据表document中的一条记录,带事务
  236.         /// </summary>
  237.         /// <param name="sp">事务对象</param>
  238.         /// <param name="document">document实体对象</param>
  239.         /// <returns></returns>
  240.         public int Delete(SqlTransaction sp, document document)
  241.         {
  242.             string sqlCommand = "documentDelete";
  243.             SqlParameter[] param ={
  244. new SqlParameter("@doc_id",SqlDbType.Int)
  245. };
  246.             param[0].Value = document.doc_id;
  247.             return SqlHelper.ExecuteNonQuery(sp, CommandType.StoredProcedure, sqlCommand, param);
  248.         }
  249.         #endregion
  251.         #region 实体对象
  252.         /// <summary>
  253.         /// 得到document实体对象
  254.         /// </summary>
  255.         /// <param name="row">row</param>
  256.         /// <returns>document实体对象</returns>
  257.         public document Select(DataRow row)
  258.         {
  259.             document obj = new document();
  260.             if (row != null)
  261.             {
  262.                 obj.doc_id = ((row["doc_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["doc_id"]);
  263.                 obj.doc_dept_id = ((row["doc_dept_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["doc_dept_id"]);
  264.                 obj.doc_g_id = ((row["doc_g_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["doc_g_id"]);
  265.                 obj.doc_u_id = ((row["doc_u_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["doc_u_id"]);
  266.                 obj.doc_title = row["doc_title"].ToString();
  267.                 obj.doc_annex = row["doc_annex"].ToString();
  268.                 obj.doc_downloads = ((row["doc_downloads"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["doc_downloads"]);
  269.                 obj.doc_reads = ((row["doc_reads"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["doc_reads"]);
  270.                 obj.doc_clicks = ((row["doc_clicks"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["doc_clicks"]);
  271.                 obj.doc_releasetime = ((row["doc_releasetime"]) == DBNull.Value) ? DateTime.MinValue : Convert.ToDateTime(row["doc_releasetime"]);
  272.                 obj.doc_sendu_id = ((row["doc_sendu_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["doc_sendu_id"]);
  273.             }
  274.             else
  275.             {
  276.                 return null;
  277.             }
  278.             return obj;
  279.         }
  281.         /// <summary>
  282.         /// 得到document实体对象
  283.         /// </summary>
  284.         /// <param name="dr">dr</param>
  285.         /// <returns>document实体对象</returns>
  286.         public document Select(IDataReader dr)
  287.         {
  288.             document obj = new document();
  289.             obj.doc_id = ((dr["doc_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["doc_id"]);
  290.             obj.doc_dept_id = ((dr["doc_dept_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["doc_dept_id"]);
  291.             obj.doc_g_id = ((dr["doc_g_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["doc_g_id"]);
  292.             obj.doc_u_id = ((dr["doc_u_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["doc_u_id"]);
  293.             obj.doc_title = dr["doc_title"].ToString();
  294.             obj.doc_annex = dr["doc_annex"].ToString();
  295.             obj.doc_downloads = ((dr["doc_downloads"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["doc_downloads"]);
  296.             obj.doc_reads = ((dr["doc_reads"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["doc_reads"]);
  297.             obj.doc_clicks = ((dr["doc_clicks"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["doc_clicks"]);
  298.             obj.doc_releasetime = ((dr["doc_releasetime"]) == DBNull.Value) ? DateTime.MinValue : Convert.ToDateTime(dr["doc_releasetime"]);
  299.             obj.doc_sendu_id = ((dr["doc_sendu_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["doc_sendu_id"]);
  300.             return obj;
  301.         }
  303.         /// <summary>
  304.         /// 根据ID,返回一个document实体对象
  305.         /// </summary>
  306.         /// <param name="doc_id">doc_id</param>
  307.         /// <returns>document实体对象</returns>
  308.         public document Select(int doc_id)
  309.         {
  310.             return this.Select(doc_id, false, false);
  311.         }
  312.         /// <summary>
  313.         /// 根据ID,返回一个document实体对象
  314.         /// </summary>
  315.         /// <param name="doc_id">doc_id</param>
  316.         /// <param name="bParentTable">将document对象设置与父表关联</param>
  317.         /// <param name="bChildrenTable">将document对象设置与子表关联</param>
  318.         /// <returns>document实体对象</returns>
  319.         public document Select(int doc_id, bool bParentTable, bool bChildrenTable)
  320.         {
  321.             document obj = null;
  322.             SqlParameter[] param ={
  323. new SqlParameter("@doc_id",SqlDbType.Int)
  324. };
  325.             param[0].Value = doc_id;
  326.             string sqlCommand = "documentSelect";
  327.             using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param))
  328.             {
  329.                 while (dr.Read())
  330.                 {
  331.                     obj = this.Select(dr);
  332.                 }
  333.             }
  334.             this.Select(obj, bParentTable, bChildrenTable);
  335.             return obj;
  336.         }
  337.         /// <summary>
  338.         /// 将document实体对象设置与父表和子表关联
  339.         /// </summary>
  340.         /// <param name="obj">document实体对象</param>
  341.         /// <param name="bParentTable">是/否设置与父表对象关联</param>
  342.         /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
  343.         public void Select(document obj, bool bParentTable, bool bChildrenTable)
  344.         {
  345.             //关联的主表
  346.             if (bParentTable)
  347.             {
  348.                 obj.users = usersBLL.Select(obj.doc_u_id);
  349.                 obj.groups = groupsBLL.Select(obj.doc_g_id);
  350.                 obj.department = departmentBLL.Select(obj.doc_dept_id);
  351.             }
  352.             //关联的子表集合
  353.             if (bChildrenTable)
  354.             {
  355.             }
  356.         }
  357.         #endregion
  359.         #region 父表
  360.         /// <summary>
  361.         /// 设置实体对象(document)的父表对象
  362.         /// </summary>
  363.         /// <param name="document">实体对象</param>
  364.         public void users(document document)
  365.         {
  366.             document.users = usersBLL.Select(document.doc_u_id);
  367.         }
  368.         /// <summary>
  369.         /// 设置实体对象(document)的父表对象
  370.         /// </summary>
  371.         /// <param name="document">实体对象</param>
  372.         public void groups(document document)
  373.         {
  374.             document.groups = groupsBLL.Select(document.doc_g_id);
  375.         }
  376.         /// <summary>
  377.         /// 设置实体对象(document)的父表对象
  378.         /// </summary>
  379.         /// <param name="document">实体对象</param>
  380.         public void department(document document)
  381.         {
  382.             document.department = departmentBLL.Select(document.doc_dept_id);
  383.         }
  384.         #endregion
  386.         #region 子表
  387.         #endregion
  389.         #region 查询
  390.         /// <summary>
  391.         /// 得到数据表document所有记录
  392.         /// </summary>
  393.         /// <returns>结果集</returns>
  394.         public IList<document> Select()
  395.         {
  396.             return this.Select(false, false);
  397.         }
  398.         /// <summary>
  399.         /// 得到数据表document所有记录
  400.         /// </summary>
  401.         /// <param name="bParentTable">是/否设置与父表对象关联</param>
  402.         /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
  403.         /// <returns>结果集</returns>
  404.         public IList<document> Select(bool bParentTable, bool bChildrenTable)
  405.         {
  406.             IList<document> list = new List<document>();
  407.             string sqlCommand = "documentSelectAll";
  408.             using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand))
  409.             {
  410.                 while (dr.Read())
  411.                 {
  412.                     list.Add(this.Select(dr));
  413.                 }
  414.             }
  415.             foreach (document obj in list)
  416.             {
  417.                 this.Select(obj, bParentTable, bChildrenTable);
  418.             }
  419.             return list;
  420.         }
  421.         /// <summary>
  422.         /// 得到数据表document满足查询条件的记录
  423.         /// </summary>
  424.         /// <param name="where">查询条件</param>
  425.         /// <returns>结果集</returns>
  426.         public IList<document> Select(string where)
  427.         {
  428.             return this.Select(where, false, false);
  429.         }
  430.         /// <summary>
  431.         /// 得到数据表document满足查询条件的记录
  432.         /// </summary>
  433.         /// <param name="where">查询条件</param>
  434.         /// <param name="bParentTable">是/否设置与父表对象关联</param>
  435.         /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
  436.         /// <returns>结果集</returns>
  437.         public IList<document> Select(string where, bool bParentTable, bool bChildrenTable)
  438.         {
  439.             IList<document> list = new List<document>();
  440.             SqlParameter[] param ={
  441. new SqlParameter("@where",SqlDbType.VarChar,8000)
  442. };
  443.             param[0].Value = where;
  444.             string sqlCommand = "documentSelectByParams";
  445.             using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param))
  446.             {
  447.                 while (dr.Read())
  448.                 {
  449.                     list.Add(this.Select(dr));
  450.                 }
  451.             }
  452.             foreach (document obj in list)
  453.             {
  454.                 this.Select(obj, bParentTable, bChildrenTable);
  455.             }
  456.             return list;
  457.         }
  458.         /// <summary>
  459.         /// 得到数据表ArticalInfo满足外键字段查询条件的记录
  460.         /// </summary>
  461.         /// <param name="foreignFieldName">外键字段名称</param>
  462.         /// <param name="foreignFieldValue">外键字段值</param>
  463.         /// <returns>结果集</returns>
  464.         public IList<document> Select(string foreignFieldName, int foreignFieldValue)
  465.         {
  466.             return this.Select(foreignFieldName, foreignFieldValue, false, false);
  467.         }
  468.         /// <summary>
  469.         /// 得到数据表ArticalInfo满足外键字段查询条件的记录
  470.         /// </summary>
  471.         /// <param name="foreignFieldName">外键字段名称</param>
  472.         /// <param name="foreignFieldValue">外键字段值</param>
  473.         /// <param name="bParentTable">是/否设置与父表对象关联</param>
  474.         /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
  475.         /// <returns>结果集</returns>
  476.         public IList<document> Select(string foreignFieldName, int foreignFieldValue, bool bParentTable, bool bChildrenTable)
  477.         {
  478.             return this.Select(string.Format("{0}='{1}'", foreignFieldName, foreignFieldValue), bParentTable, bChildrenTable);
  479.         }
  480.         /// <summary>
  481.         /// 得到数据表document满足查询条件的记录数
  482.         /// </summary>
  483.         /// <param name="where">查询条件</param>
  484.         /// <param name="recordCount">记录数</param>
  485.         public void Select(string where, out int recordCount)
  486.         {
  487.             string sqlCommand = "documentCountByWhere";
  488.             SqlParameter[] param ={
  489. new SqlParameter("@where",SqlDbType.VarChar,8000),
  490. new SqlParameter("@recordCount",SqlDbType.Int)
  491. };
  492.             param[0].Value = where;
  493.             param[1].Direction = ParameterDirection.Output;
  494.             SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
  495.             recordCount = Convert.ToInt32(param[1].Value);
  496.         }
  497.         /// <summary>
  498.         /// 得到数据表document满足查询条件的分页记录
  499.         /// </summary>
  500.         /// <param name="pageSize">每页显示记录数</param>
  501.         /// <param name="pageIndex">当前显示第几页</param>
  502.         /// <param name="where">查询条件</param>
  503.         /// <returns>结果集</returns>
  504.         public IList<document> Select(int pageSize, int pageIndex, string where)
  505.         {
  506.             return this.Select(pageSize, pageIndex, where, false, false);
  507.         }
  508.         /// <summary>
  509.         /// 得到数据表document满足查询条件的分页记录
  510.         /// </summary>
  511.         /// <param name="pageSize">每页显示记录数</param>
  512.         /// <param name="pageIndex">当前显示第几页</param>
  513.         /// <param name="where">查询条件</param>
  514.         /// <param name="bParentTable">是/否设置与父表对象关联</param>
  515.         /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
  516.         /// <returns>结果集</returns>
  517.         public IList<document> Select(int pageSize, int pageIndex, string where, bool bParentTable, bool bChildrenTable)
  518.         {
  519.             IList<document> list = new List<document>();
  520.             string sqlCommand = "documentSelectByPagerParams";
  521.             SqlParameter[] param ={
  522. new SqlParameter("@pageSize",SqlDbType.Int),
  523. new SqlParameter("@pageIndex",SqlDbType.Int),
  524. new SqlParameter("@where",SqlDbType.VarChar,8000)
  525. };
  526.             param[0].Value = pageSize;
  527.             param[1].Value = pageIndex;
  528.             param[2].Value = where;
  529.             using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param))
  530.             {
  531.                 while (dr.Read())
  532.                 {
  533.                     list.Add(this.Select(dr));
  534.                 }
  535.             }
  536.             foreach (document obj in list)
  537.             {
  538.                 this.Select(obj, bParentTable, bChildrenTable);
  539.             }
  540.             return list;
  541.         }
  542.         /// <summary>
  543.         /// 得到数据表document满足查询条件记录
  544.         /// </summary>
  545.         /// <param name="commandType">命令类型</param>
  546.         /// <param name="sqlCommand">SQL命令</param>
  547.         /// <param name="SqlParameter[]">命令参数数组</param>
  548.         /// <returns>结果集</returns>
  549.         public IList<document> Select(CommandType commandType, string sqlCommand, params SqlParameter[] param)
  550.         {
  551.             return this.Select(false, false, commandType, sqlCommand, param);
  552.         }
  553.         /// <summary>
  554.         /// 得到数据表document满足查询条件记录
  555.         /// </summary>
  556.         /// <param name="bParentTable">是/否设置与父表对象关联</param>
  557.         /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
  558.         /// <param name="commandType">命令类型</param>
  559.         /// <param name="sqlCommand">SQL命令</param>
  560.         /// <param name="SqlParameter[]">命令参数数组</param>
  561.         /// <returns>结果集</returns>
  562.         public IList<document> Select(bool bParentTable, bool bChildrenTable, CommandType commandType, string sqlCommand, params SqlParameter[] param)
  563.         {
  564.             IList<document> list = new List<document>();
  565.             using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, commandType, sqlCommand, param))
  566.             {
  567.                 while (dr.Read())
  568.                 {
  569.                     list.Add(this.Select(dr));
  570.                 }
  571.             }
  572.             foreach (document obj in list)
  573.             {
  574.                 this.Select(obj, bParentTable, bChildrenTable);
  575.             }
  576.             return list;
  577.         }
  578.         /// <summary>
  579.         /// 根据主键检测是否存在该条记录
  580.         /// </summary>
  581.         /// <param name="doc_id">doc_id</param>
  582.         /// <returns>存在/不存在</returns>
  583.         public bool Exists(int doc_id)
  584.         {
  585.             SqlParameter[] param ={
  586.                                  new SqlParameter("@doc_id",SqlDbType.Int)
  587.                                  };
  588.             param[0].Value = doc_id;
  589.             string sqlCommand = "documentIsExist";
  590.             int a = Convert.ToInt32(SqlHelper.ExecuteScalar(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param));
  591.             if (a > 0)
  592.             {
  593.                 return true;
  594.             }
  595.             else
  596.             {
  597.                 return false;
  598.             }
  599.         }
  600.         #endregion
  602.         #endregion
  603.     }
  604. }