温馨提示:代码在线浏览功能只能做为源码浏览参考,如果想更进一步了解该代码请下载:三层(工厂模式)简单留言板
当前文件:
FactoryMessagesBoard/SQLServerDAL/Messages.cs[1K,2009-6-12 11:42:14],打开代码结构图
FactoryMessagesBoard/SQLServerDAL/Messages.cs[1K,2009-6-12 11:42:14],打开代码结构图1using System; 2
using System.Collections.Generic; 3
using System.Text; 4
using System.Collections; 5
using System.Data; 6
using System.Data.SqlClient; 7
using MessagesBoard.Model; 8
using MessagesBoard.IDAL; 9
10
namespace MessagesBoard.SQLServerDAL 11
{ 12
public class Messages : IMessageBoard 13
{ 14
public Messages() 15
{ 16
listmessage = new ArrayList(); 17
} 18
private ArrayList listmessage; 19
private const string SQL_SELECT_MESSAGES = "SELECT [MessageBody], [MessageTime] FROM [MessageBoard] ORDER BY [Messageid] DESC"; 20
private const string SQL_INSERT_MESSAGES = "INSERT INTO MessageBoard(MessageBody,MessageTime) VALUES (@MessageBody,@MessageTime)"; 21
private const string PARM_MessageBody = "@MessageBody"; 22
private const string PARM_MessageTime = "@MessageTime"; 23
public MessageBoardInfo[] GeiMessage() 24
{ 25
SqlDataReader dt = SQLHelper.ExecuteReader(SQLHelper.Con, CommandType.Text, SQL_SELECT_MESSAGES, null); 26
while (dt.Read()) 27
{ 28
MessageBoardInfo messageboardinfo = new MessageBoardInfo(); 29
messageboardinfo.MessageBody = (string)dt["MessageBody"]; 30
messageboardinfo.MessageTime = (DateTime)dt["MessageTime"]; 31
listmessage.Add(messageboardinfo); 32
} 33
return (MessageBoardInfo[])listmessage.ToArray(typeof(MessageBoardInfo)); 34
} 35
public void SaveMessage(MessageBoardInfo mbinfo) 36
{ 37
string messagebody = mbinfo.MessageBody.Trim(); 38
DateTime datetime = DateTime.Now; 39
SqlParameter[] parm ={ new SqlParameter(PARM_MessageBody,SqlDbType.NVarChar), 40
new SqlParameter(PARM_MessageTime,SqlDbType.DateTime) 41
}; 42
parm[0].Value = messagebody; 43
parm[1].Value = datetime; 44
SQLHelper.ExecuteNonQuery(SQLHelper.Con, CommandType.Text, SQL_INSERT_MESSAGES, parm); 45
} 46
} 47
48
49
} 50






}
}