dmovement.cs

这是一个自动排课软件(包含源码,需求分析,详细设计).希望对你有所帮助.

                        cmd.Parameters.Add(new SqlParameter("@Movement_ID_C", searcher.MovementID));
                    }
                    if (searcher.MovementNameIsValid)
                    {
                        condition += " and Movement_Name=@Movement_Name_C";
                        cmd.Parameters.Add(new SqlParameter("@Movement_Name_C", searcher.MovementName));
                    }
                    if (searcher.IsValidIsValid)
                    {
                        condition += " and Is_Valid=@Is_Valid_C";
                        cmd.Parameters.Add(new SqlParameter("@Is_Valid_C", searcher.IsValid));
                    }
                    if (searcher.MovementColorIsValid)
                    {
                        condition += " and Movement_Color=@Movement_Color_C";
                        cmd.Parameters.Add(new SqlParameter("@Movement_Color_C", searcher.MovementColor));
                    }
                    if (condition != string.Empty)
                    {
                        condition = " where" + condition.Substring(4);
                    }
                    cmd.CommandText = "update Movement set " + updateString.Substring(1) + condition;
                    result = cmd.ExecuteNonQuery();
                }
            }
            return result;
        }
        /// <summary>
        /// 根据查询对象构建过滤条件并使用事务的更新方法
        /// </summary>
        /// <param name="connection">实现共享Command的对象</param>
        /// <param name="searcher">查询对象</param>
        /// <param name="newValues">要更新的新值</param>
        /// <returns>影响的记录行数</returns>
        public int Update(IConnection connection, MovementSearcher searcher, MovementSearcher newValues)
        {
            string updateString = string.Empty;
            string condition = string.Empty;
            SqlCommand cmd = connection.Command as SqlCommand;
            cmd.Parameters.Clear();
            if (newValues.MovementIDIsValid)
            {
                updateString += ",Movement_ID=@Movement_ID_V";
                cmd.Parameters.Add(new SqlParameter("@Movement_ID_V", newValues.MovementID));
            }
            if (newValues.MovementNameIsValid)
            {
                updateString += ",Movement_Name=@Movement_Name_V";
                cmd.Parameters.Add(new SqlParameter("@Movement_Name_V", newValues.MovementName));
            }
            if (newValues.IsValidIsValid)
            {
                updateString += ",Is_Valid=@Is_Valid_V";
                cmd.Parameters.Add(new SqlParameter("@Is_Valid_V", newValues.IsValid));
            }
            if (newValues.MovementColorIsValid)
            {
                updateString += ",Movement_Color=@Movement_Color_V";
                cmd.Parameters.Add(new SqlParameter("@Movement_Color_V", newValues.MovementColor));
            }
            if (searcher.MovementIDIsValid)
            {
                condition += " and Movement_ID=@Movement_ID_C";
                cmd.Parameters.Add(new SqlParameter("@Movement_ID_C", searcher.MovementID));
            }
            if (searcher.MovementNameIsValid)
            {
                condition += " and Movement_Name=@Movement_Name_C";
                cmd.Parameters.Add(new SqlParameter("@Movement_Name_C", searcher.MovementName));
            }
            if (searcher.IsValidIsValid)
            {
                condition += " and Is_Valid=@Is_Valid_C";
                cmd.Parameters.Add(new SqlParameter("@Is_Valid_C", searcher.IsValid));
            }
            if (searcher.MovementColorIsValid)
            {
                condition += " and Movement_Color=@Movement_Color_C";
                cmd.Parameters.Add(new SqlParameter("@Movement_Color_C", searcher.MovementColor));
            }
            if (condition != string.Empty)
            {
                condition = " where" + condition.Substring(4);
            }
            cmd.CommandText = "update Movement set " + updateString.Substring(1) + condition;
            return cmd.ExecuteNonQuery();
        }
        #endregion

        #region 查询实体集合
        /// <summary>
        /// 根据查询对象构建过滤条件查询
        /// </summary>
        /// <param name="searcher">查询对象</param>
        /// <returns>实体类对象列表</returns>
        public ArrayList Select(MovementSearcher searcher)
        {
            ArrayList entities = new ArrayList();
            string connectionString = System.Configuration.ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    entities = Select(cmd, searcher);
                }
            }
            return entities;
        }
        /// <summary>
        /// 使用事务并且依据查询对象构建过滤条件查询
        /// </summary>
        /// <param name="connection">实现共享Command的对象</param>
        /// <param name="searcher">查询对象</param>
        /// <returns>实体类对象列表</returns>
        public ArrayList Select(IConnection connection, MovementSearcher searcher)
        {
            SqlCommand cmd = connection.Command as SqlCommand;
            return Select(cmd, searcher);
        }
        public ArrayList Select(SqlCommand command, MovementSearcher searcher)
        {
            string condition = string.Empty;
            command.Parameters.Clear();
            ArrayList entities = new ArrayList();
            if (searcher.MovementIDIsValid)
            {
                condition += " and Movement_ID=@Movement_ID_C";
                command.Parameters.Add(new SqlParameter("@Movement_ID_C", searcher.MovementID));
            }
            if (searcher.MovementNameIsValid)
            {
                condition += " and Movement_Name=@Movement_Name_C";
                command.Parameters.Add(new SqlParameter("@Movement_Name_C", searcher.MovementName));
            }
            if (searcher.IsValidIsValid)
            {
                condition += " and Is_Valid=@Is_Valid_C";
                command.Parameters.Add(new SqlParameter("@Is_Valid_C", searcher.IsValid));
            }
            if (searcher.MovementColorIsValid)
            {
                condition += " and Movement_Color=@Movement_Color_C";
                command.Parameters.Add(new SqlParameter("@Movement_Color_C", searcher.MovementColor));
            }
            if (condition != string.Empty)
            {
                condition = " where" + condition.Substring(4);
            }

            command.CommandText = "select * from Movement" + condition;
            return ExcuteSelectCommand(command);
        }
        /// <summary>
        /// 执行Command获取对象列表
        /// </summary>
        /// <param name="cmd">Command对象</param>
        /// <returns>实体类对象列表</returns>
        private ArrayList ExcuteSelectCommand(SqlCommand cmd)
        {
            ArrayList entities = new ArrayList();
            using (SqlDataReader dr = cmd.ExecuteReader())
            {
                while (dr.Read())
                {
                    Movement entity = DataReaderToEntity(dr);
                    entities.Add(entity);
                }
            }
            return entities;
        }
        private void SetForeignKeyEntity(SqlCommand command, ref ArrayList entities)
        {
            //由外键获取相关实体
            foreach (Movement entity in entities)
            {
            }
        }
        /// <summary>
        /// 查询所有实体
        /// </summary>
        /// <returns>实体类对象列表</returns>
        public ArrayList Select()
        {
            ArrayList entities = new ArrayList();
            string connectionString = System.Configuration.ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = "select * from Movement";
                    entities = ExcuteSelectCommand(cmd);
                }
                return entities;
            }
        }
        /// <summary>
        /// 使用事务查询查询所有实体
        /// </summary>
        /// <param name="connection">实现共享Command的对象</param>
        /// <param name="searcher">查询对象</param>
        /// <returns>实体类对象列表</returns>
        public ArrayList Select(IConnection connection)
        {
            ArrayList entities = new ArrayList();
            SqlCommand cmd = connection.Command as SqlCommand;
            cmd.Parameters.Clear();
            cmd.CommandText = "select * from Movement";
            return ExcuteSelectCommand(cmd);
        }
        #endregion

        #region 查询单个实体
        /// <summary>
        /// 按主键字段查询特定实体
        /// </summary>
        /// <param name="pkValue">主键值</param>
        /// <returns>实体类对象</returns>
        public Movement SelectSingle(object pkValue)
        {
            Movement entity = null;
            string connectionString = System.Configuration.ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    entity = SelectSingle(cmd, pkValue);
                }
            }
            return entity;
        }

        /// <summary>
        /// 使用事务并按主键字段查询特定实体
        /// </summary>
        /// <param name="pkValue">主键值</param>
        /// <returns>实体类对象</returns>
        public Movement SelectSingle(IConnection connection, object pkValue)
        {
            SqlCommand cmd = connection.Command as SqlCommand;
            return SelectSingle(cmd, pkValue);

        }
        public Movement SelectSingle(SqlCommand command, object pkValue)
        {
            Movement entity = null;
            command.Parameters.Clear();
            command.CommandText = "select * from Movement where Movement_ID=@pk";
            command.Parameters.Add(new SqlParameter("@pk", pkValue));
            using (SqlDataReader dr = command.ExecuteReader())
            {
                if (dr.Read())
                    entity = DataReaderToEntity(dr);
            }

            //由外键获取相关实体
            return entity;
        }
        #endregion


        /// <summary>
        /// 从DataReader中取出值生成实体对象
        /// </summary>
        /// <param name="searcher">查询对象</param>
        /// <returns>过滤条件字符串</returns>
        private Movement DataReaderToEntity(SqlDataReader dr)
        {
            Movement entity = new Movement();
            if (dr["Movement_ID"] != System.DBNull.Value)
            {
                entity.MovementID = Convert.ToInt32(dr["Movement_ID"]);
            }
            if (dr["Movement_Name"] != System.DBNull.Value)
            {
                entity.MovementName = dr["Movement_Name"].ToString();
            }
            if (dr["Is_Valid"] != System.DBNull.Value)
            {
                entity.IsValid = Convert.ToBoolean(dr["Is_Valid"]);
            }
            if (dr["Movement_Color"] != System.DBNull.Value)
            {
                entity.MovementColor = dr["Movement_Color"].ToString();
            }
            return entity;
        }
    }
}