oracledataprovider.cs

其主要的功能就是,进行后台管理模块整合. 1)其可以支持多个应用,多个模块的权限管理. 2)支持Access和MsSql200/2005. 3)采用角色来进行权限的授权,每个用户可以属于多个角色

            PopulateDelegate mypd = new PopulateDelegate(base.Populatesys_Module);
            return this.GetObjectList(mypd, qp, out RecordCount);
        }

        #endregion

        #region "sys_RoleApplication - OracleDataProvider"
        /// <summary>
        /// 新增/删除/修改 sys_RoleApplication
        /// </summary>
        /// <param name="fam">sys_RoleApplicationTable实体类</param>
        /// <returns>返回0操正常</returns>
        public override int sys_RoleApplicationInsertUpdate(sys_RoleApplicationTable fam)
        {
            int rInt = 0;

            using (OracleConnection Conn = GetSqlConnection())
            {
                string CommTxt;
                OracleCommand cmd = new OracleCommand();
                cmd.Connection = Conn;
                if (fam.DB_Option_Action_ == "Insert")
                {
                    CommTxt = "Insert into 	sys_RoleApplication(A_RoleID,A_ApplicationID)VALUES(:A_RoleID,:A_ApplicationID)";
                    cmd.CommandText = CommTxt;

                    cmd.Parameters.Add("A_RoleID", OracleType.Int32).Value = fam.A_RoleID; //角色ID与sys_Roles中RoleID相关	
                    cmd.Parameters.Add("A_ApplicationID", OracleType.Int32).Value = fam.A_ApplicationID; //应用ID与sys_Applications中Appl
                }
                else if (fam.DB_Option_Action_ == "Update")
                {

                    CommTxt = "UPDATE sys_RoleApplication SET	A_RoleID = :A_RoleID,A_ApplicationID = :A_ApplicationID WHERE (A_RoleID= :A_RoleID and A_ApplicationID = :A_ApplicationID)";
                    cmd.CommandText = CommTxt;

                    cmd.Parameters.Add("A_RoleID", OracleType.Int32).Value = fam.A_RoleID; //角色ID与sys_Roles中RoleID相关	
                    cmd.Parameters.Add("A_ApplicationID", OracleType.Int32).Value = fam.A_ApplicationID; //应用ID与sys_Applications中Appl
                }
                else if (fam.DB_Option_Action_ == "Delete")
                {
                    CommTxt = "Delete from  sys_RoleApplication  WHERE (A_RoleID= :A_RoleID and A_ApplicationID = :A_ApplicationID)";
                    cmd.CommandText = CommTxt;
                    cmd.Parameters.Add("A_RoleID", OracleType.Int32).Value = fam.A_RoleID; //角色ID与sys_Roles中RoleID相关	
                    cmd.Parameters.Add("A_ApplicationID", OracleType.Int32).Value = fam.A_ApplicationID; //应用ID与sys_Applications中Appl
                }
                else
                    throw new ApplicationException("无法识别的操作命令!");
                Conn.Open();
                OracleTransaction Tran = Conn.BeginTransaction();
                cmd.Transaction = Tran;
                try
                {
                    rInt = cmd.ExecuteNonQuery();
                    cmd.Parameters.Clear();
                    Tran.Commit();
                }
                catch (Exception ex)
                {
                    Tran.Rollback();
                    throw new ApplicationException(ex.ToString());
                }
                finally
                {
                    Tran.Dispose();
                    cmd.Dispose();
                    Conn.Dispose();
                    Conn.Close();
                }
            }
            return rInt;
        }

        /// <summary>
        /// 返回sys_RoleApplicationTable实体类的ArrayList对象
        /// </summary>
        /// <param name="qp">查询类</param>
        /// <param name="RecordCount">返回记录总数</param>
        /// <returns>sys_RoleApplicationTable实体类的ArrayList对象</returns>
        public override ArrayList sys_RoleApplicationList(QueryParam qp, out int RecordCount)
        {
            PopulateDelegate mypd = new PopulateDelegate(base.Populatesys_RoleApplication);
            return this.GetObjectList(mypd, qp, out RecordCount);
        }

        #endregion

        #region "sys_RolePermission - OracleDataProvider"
        /// <summary>
        /// 新增/删除/修改 sys_RolePermission
        /// </summary>
        /// <param name="fam">sys_RolePermissionTable实体类</param>
        /// <returns>返回0操正常</returns>
        public override int sys_RolePermissionInsertUpdate(sys_RolePermissionTable fam)
        {
            int rInt = 0;

            using (OracleConnection Conn = GetSqlConnection())
            {
                string CommTxt;
                OracleCommand cmd = new OracleCommand();
                cmd.Connection = Conn;
                if (fam.DB_Option_Action_ == "Insert")
                {
                    CommTxt = "Insert into 	sys_RolePermission(PermissionID,P_RoleID,P_ApplicationID,P_PageCode,P_Value)VALUES(SEQ_sys_RolePermission_ID.NEXTVAL,:P_RoleID,:P_ApplicationID,:P_PageCode,:P_Value)";
                    cmd.CommandText = CommTxt;

                    cmd.Parameters.Add("P_RoleID", OracleType.Int32).Value = fam.P_RoleID; //角色ID与sys_Roles表中RoleID相	
                    cmd.Parameters.Add("P_ApplicationID", OracleType.Int32).Value = fam.P_ApplicationID; //角色所属应用ID与sys_Applicatio	
                    cmd.Parameters.Add("P_PageCode", OracleType.VarChar).Value = fam.P_PageCode + ""; //角色应用中页面权限代码	
                    cmd.Parameters.Add("P_Value", OracleType.Int32).Value = fam.P_Value; //权限值
                }
                else if (fam.DB_Option_Action_ == "Update")
                {

                    CommTxt = "UPDATE sys_RolePermission SET	P_RoleID = :P_RoleID,P_ApplicationID = :P_ApplicationID,P_PageCode = :P_PageCode,P_Value = :P_Value WHERE (PermissionID = :PermissionID)";
                    cmd.CommandText = CommTxt;

                    cmd.Parameters.Add("P_RoleID", OracleType.Int32).Value = fam.P_RoleID; //角色ID与sys_Roles表中RoleID相	
                    cmd.Parameters.Add("P_ApplicationID", OracleType.Int32).Value = fam.P_ApplicationID; //角色所属应用ID与sys_Applicatio	
                    cmd.Parameters.Add("P_PageCode", OracleType.VarChar).Value = fam.P_PageCode + ""; //角色应用中页面权限代码	
                    cmd.Parameters.Add("P_Value", OracleType.Int32).Value = fam.P_Value; //权限值
                    cmd.Parameters.Add("PermissionID", OracleType.Int32).Value = fam.PermissionID;
                }
                else if (fam.DB_Option_Action_ == "Delete")
                {
                    CommTxt = "Delete from  sys_RolePermission  WHERE (PermissionID = :PermissionID)";
                    cmd.CommandText = CommTxt;
                    cmd.Parameters.Add("PermissionID", OracleType.Int32).Value = fam.PermissionID;
                }
                else
                    throw new ApplicationException("无法识别的操作命令!");
                Conn.Open();
                OracleTransaction Tran = Conn.BeginTransaction();
                cmd.Transaction = Tran;
                try
                {
                    rInt = cmd.ExecuteNonQuery();
                    cmd.Parameters.Clear();
                    if (fam.DB_Option_Action_ == "Insert")
                    {
                        cmd.CommandText = "select SEQ_sys_RolePermission_ID.CURRVAL from  dual";
                        rInt = Convert.ToInt32(cmd.ExecuteScalar());
                    }
                    Tran.Commit();
                }
                catch (Exception ex)
                {
                    Tran.Rollback();
                    throw new ApplicationException(ex.ToString());
                }
                finally
                {
                    Tran.Dispose();
                    cmd.Dispose();
                    Conn.Dispose();
                    Conn.Close();
                }
            }
            return rInt;
        }

        /// <summary>
        /// 返回sys_RolePermissionTable实体类的ArrayList对象
        /// </summary>
        /// <param name="qp">查询类</param>
        /// <param name="RecordCount">返回记录总数</param>
        /// <returns>sys_RolePermissionTable实体类的ArrayList对象</returns>
        public override ArrayList sys_RolePermissionList(QueryParam qp, out int RecordCount)
        {
            PopulateDelegate mypd = new PopulateDelegate(base.Populatesys_RolePermission);
            return this.GetObjectList(mypd, qp, out RecordCount);
        }

        #endregion

        #region "sys_Roles - OracleDataProvider"
        /// <summary>
        /// 新增/删除/修改 sys_Roles
        /// </summary>
        /// <param name="fam">sys_RolesTable实体类</param>
        /// <returns>返回0操正常</returns>
        public override int sys_RolesInsertUpdate(sys_RolesTable fam)
        {
            int rInt = 0;

            using (OracleConnection Conn = GetSqlConnection())
            {
                string CommTxt;
                OracleCommand cmd = new OracleCommand();
                cmd.Connection = Conn;
                if (fam.DB_Option_Action_ == "Insert")
                {
                    CommTxt = "Insert into 	sys_Roles(RoleID,R_RoleName,R_Description)VALUES(SEQ_sys_Roles_ID.NEXTVAL,:R_RoleName,:R_Description)";
                    cmd.CommandText = CommTxt;

                    cmd.Parameters.Add("R_RoleName", OracleType.NVarChar).Value = fam.R_RoleName + ""; //角色名称
                    cmd.Parameters.Add("R_Description", OracleType.NVarChar).Value = fam.R_Description + ""; //角色介绍
                }
                else if (fam.DB_Option_Action_ == "Update")
                {

                    CommTxt = "UPDATE sys_Roles SET	R_RoleName = :R_RoleName,R_Description = :R_Description WHERE (RoleID = :RoleID)";
                    cmd.CommandText = CommTxt;

                    cmd.Parameters.Add("R_RoleName", OracleType.NVarChar).Value = fam.R_RoleName + ""; //角色名称
                    cmd.Parameters.Add("R_Description", OracleType.NVarChar).Value = fam.R_Description + ""; //角色介绍
                    cmd.Parameters.Add("RoleID", OracleType.Int32).Value = fam.RoleID;
                }
                else if (fam.DB_Option_Action_ == "Delete")
                {
                    CommTxt = "Delete from  sys_Roles  WHERE (RoleID = :RoleID)";
                    cmd.CommandText = CommTxt;
                    cmd.Parameters.Add("RoleID", OracleType.Int32).Value = fam.RoleID;
                }
                else
                    throw new ApplicationException("无法识别的操作命令!");
                Conn.Open();
                OracleTransaction Tran = Conn.BeginTransaction();
                cmd.Transaction = Tran;
                try
                {
                    rInt = cmd.ExecuteNonQuery();
                    cmd.Parameters.Clear();
                    if (fam.DB_Option_Action_ == "Insert")
                    {
                        cmd.CommandText = "select SEQ_sys_Roles_ID.CURRVAL from  dual";
                        rInt = Convert.ToInt32(cmd.ExecuteScalar());
                    }
                    Tran.Commit();
                }
                catch (Exception ex)
                {
                    Tran.Rollback();
                    throw new ApplicationException(ex.ToString());
                }
                finally
                {
                    Tran.Dispose();
                    cmd.Dispose();
                    Conn.Dispose();
                    Conn.Close();
                }
            }