博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
MessageDAL
阅读量:4650 次
发布时间:2019-06-09

本文共 6122 字,大约阅读时间需要 20 分钟。

using System;using System.Data;using System.Text;using System.Data.SqlClient;namespace Website.DAL{	/// 	/// 数据访问类Message。	/// 	public class Message	{		public Message()		{}		#region  成员方法		/// 		/// 得到最大ID		/// 		public int GetMaxId()		{		return DbHelperSQL.GetMaxID("MessageId", "Message"); 		}		/// 		/// 是否存在该记录		/// 		public bool Exists(int MessageId)		{			StringBuilder strSql=new StringBuilder();			strSql.Append("select count(1) from Message");			strSql.Append(" where MessageId=@MessageId ");			SqlParameter[] parameters = {					new SqlParameter("@MessageId", SqlDbType.Int,4)};			parameters[0].Value = MessageId;			return DbHelperSQL.Exists(strSql.ToString(),parameters);		}		/// 		/// 增加一条数据		/// 		public int Add(Website.Model.Message model)		{			StringBuilder strSql=new StringBuilder();			strSql.Append("insert into Message(");			strSql.Append("MessageContent,MessageAddTime,MessageAddId,MessageToId,MessageIsDisplay)");			strSql.Append(" values (");			strSql.Append("@MessageContent,@MessageAddTime,@MessageAddId,@MessageToId,@MessageIsDisplay)");			strSql.Append(";select @@IDENTITY");			SqlParameter[] parameters = {					new SqlParameter("@MessageContent", SqlDbType.VarChar,400),					new SqlParameter("@MessageAddTime", SqlDbType.DateTime),					new SqlParameter("@MessageAddId", SqlDbType.Int,4),					new SqlParameter("@MessageToId", SqlDbType.Int,4),					new SqlParameter("@MessageIsDisplay", SqlDbType.Int,4)};			parameters[0].Value = model.MessageContent;			parameters[1].Value = model.MessageAddTime;			parameters[2].Value = model.MessageAddId;			parameters[3].Value = model.MessageToId;			parameters[4].Value = model.MessageIsDisplay;			object obj = DbHelperSQL.GetSingle(strSql.ToString(),parameters);			if (obj == null)			{				return 1;			}			else			{				return Convert.ToInt32(obj);			}		}		/// 		/// 更新一条数据		/// 		public void Update(Website.Model.Message model)		{			StringBuilder strSql=new StringBuilder();			strSql.Append("update Message set ");			strSql.Append("MessageContent=@MessageContent,");			strSql.Append("MessageAddTime=@MessageAddTime,");			strSql.Append("MessageAddId=@MessageAddId,");			strSql.Append("MessageToId=@MessageToId,");			strSql.Append("MessageIsDisplay=@MessageIsDisplay");			strSql.Append(" where MessageId=@MessageId ");			SqlParameter[] parameters = {					new SqlParameter("@MessageId", SqlDbType.Int,4),					new SqlParameter("@MessageContent", SqlDbType.VarChar,400),					new SqlParameter("@MessageAddTime", SqlDbType.DateTime),					new SqlParameter("@MessageAddId", SqlDbType.Int,4),					new SqlParameter("@MessageToId", SqlDbType.Int,4),					new SqlParameter("@MessageIsDisplay", SqlDbType.Int,4)};			parameters[0].Value = model.MessageId;			parameters[1].Value = model.MessageContent;			parameters[2].Value = model.MessageAddTime;			parameters[3].Value = model.MessageAddId;			parameters[4].Value = model.MessageToId;			parameters[5].Value = model.MessageIsDisplay;			DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);		}		/// 		/// 删除一条数据		/// 		public void Delete(int MessageId)		{			StringBuilder strSql=new StringBuilder();			strSql.Append("delete Message ");			strSql.Append(" where MessageId=@MessageId ");			SqlParameter[] parameters = {					new SqlParameter("@MessageId", SqlDbType.Int,4)};			parameters[0].Value = MessageId;			DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);		}		/// 		/// 得到一个对象实体		/// 		public Website.Model.Message GetModel(int MessageId)		{			StringBuilder strSql=new StringBuilder();			strSql.Append("select MessageId,MessageContent,MessageAddTime,MessageAddId,MessageToId,MessageIsDisplay from Message ");			strSql.Append(" where MessageId=@MessageId ");			SqlParameter[] parameters = {					new SqlParameter("@MessageId", SqlDbType.Int,4)};			parameters[0].Value = MessageId;			Website.Model.Message model=new Website.Model.Message();			DataSet ds=DbHelperSQL.Query(strSql.ToString(),parameters);			if(ds.Tables[0].Rows.Count>0)			{				if(ds.Tables[0].Rows[0]["MessageId"].ToString()!="")				{					model.MessageId=int.Parse(ds.Tables[0].Rows[0]["MessageId"].ToString());				}				model.MessageContent=ds.Tables[0].Rows[0]["MessageContent"].ToString();				if(ds.Tables[0].Rows[0]["MessageAddTime"].ToString()!="")				{					model.MessageAddTime=DateTime.Parse(ds.Tables[0].Rows[0]["MessageAddTime"].ToString());				}				if(ds.Tables[0].Rows[0]["MessageAddId"].ToString()!="")				{					model.MessageAddId=int.Parse(ds.Tables[0].Rows[0]["MessageAddId"].ToString());				}				if(ds.Tables[0].Rows[0]["MessageToId"].ToString()!="")				{					model.MessageToId=int.Parse(ds.Tables[0].Rows[0]["MessageToId"].ToString());				}				if(ds.Tables[0].Rows[0]["MessageIsDisplay"].ToString()!="")				{					model.MessageIsDisplay=int.Parse(ds.Tables[0].Rows[0]["MessageIsDisplay"].ToString());				}				return model;			}			else			{			return null;			}		}		/// 		/// 获得数据列表		/// 		public DataSet GetList(string strWhere)		{			StringBuilder strSql=new StringBuilder();			strSql.Append("select MessageId,MessageContent,MessageAddTime,MessageAddId,MessageToId,MessageIsDisplay ");			strSql.Append(" FROM Message ");			if(strWhere.Trim()!="")			{				strSql.Append(" where "+strWhere);			}			return DbHelperSQL.Query(strSql.ToString());		}		/*		/// 		/// 分页获取数据列表		/// 		public DataSet GetList(int PageSize,int PageIndex,string strWhere)		{			SqlParameter[] parameters = {					new SqlParameter("@tblName", SqlDbType.VarChar, 255),					new SqlParameter("@fldName", SqlDbType.VarChar, 255),					new SqlParameter("@PageSize", SqlDbType.Int),					new SqlParameter("@PageIndex", SqlDbType.Int),					new SqlParameter("@IsReCount", SqlDbType.Bit),					new SqlParameter("@OrderType", SqlDbType.Bit),					new SqlParameter("@strWhere", SqlDbType.VarChar,1000),					};			parameters[0].Value = "Message";			parameters[1].Value = "ID";			parameters[2].Value = PageSize;			parameters[3].Value = PageIndex;			parameters[4].Value = 0;			parameters[5].Value = 0;			parameters[6].Value = strWhere;				return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");		}*/		#endregion  成员方法	}}

 

转载于:https://www.cnblogs.com/lx1988729/archive/2013/05/27/3100851.html

你可能感兴趣的文章