/*
* 短消息数据库访问类
*/
package com.accp.dao;
import java.sql.*;
import java.util.*;
import com.accp.entity.Message;
public class MessageDao extends BaseDao {
private Connection conn = null; // 数据库连接
private PreparedStatement pstmt = null; // 创建PreparedStatement对象
private ResultSet rs = null; // 创建结果集对象
/**
* 保存一条消息
* @param message
* @return
*/
public int save(Message message){
String sql = "insert into TBL_MESSAGE(note,sendUname,receiveUname,postTime,readSign) values(?,?,?,?,0)";
String[] param = {message.getNote(),message.getSendUname(),message.getReceiveUname(),message.getPostTime()};
return super.executeSQL(sql, param);
}
/**
* 删除一条消息
* @param message
* @return
*/
public int delete(int id){
String sql = "delete from TBL_MESSAGE where id="+id;
return super.executeSQL(sql, null);
}
/**
* 更新读标记
* @param message
* @return
*/
public int update(Message message){
String sql = "update TBL_MESSAGE set readSign=1 where id="+message.getId();
return super.executeSQL(sql, null);
}
/**
* 查询参数用户收到的消息列表
* @param uid
* @return
*/
public List listByReceiveUname(String uname) {
List list = new ArrayList();
String sql = "select * from TBL_MESSAGE where receiveUname=?";
try {
conn = this.getConn();
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, uname);
rs = pstmt.executeQuery();
while(rs.next()) {
Message message = new Message();
message.setId(rs.getInt("id"));
message.setNote(rs.getString("note"));
message.setSendUname(rs.getString("sendUname"));
message.setReceiveUname(rs.getString("receiveUname"));
message.setPostTime(rs.getString("postTime"));
message.setReadSign(rs.getInt("readSign"));
list.add(message);
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally{
this.closeAll(conn, pstmt, rs);
}
return list;
}
/**
* 根据短信息id查一条短信息
* @param id
* @return
*/
public Message findMessage(int id){
Message message = null;
String sql = "select * from TBL_MESSAGE where id=?";
try {
conn = this.getConn();
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, id);
rs = pstmt.executeQuery();
while(rs.next()) {
message = new Message();
message.setId(rs.getInt("id"));
message.setNote(rs.getString("note"));
message.setSendUname(rs.getString("sendUname"));
message.setReceiveUname(rs.getString("receiveUname"));
message.setPostTime(rs.getString("postTime"));
}
} catch (ClassNotFoundException e) {
message = null;
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally{
this.closeAll(conn, pstmt, rs);
}
return message;
}
}
没有合适的资源?快使用搜索试试~ 我知道了~
accp S2 论坛短消息
共40个文件
class:8个
java:8个
jsp:8个
需积分: 3 28 下载量 191 浏览量
2009-02-07
20:15:49
上传
评论
收藏 431KB RAR 举报
温馨提示
ACCP5.0 S2 阶段项目6 论坛短消息
资源推荐
资源详情
资源评论
收起资源包目录
.rar (40个子文件)
短消息
messageBoard
src
com
accp
entity
Message.java 1KB
User.java 489B
test.java 652B
biz
UserBiz.java 397B
MessageBiz.java 1KB
dao
MessageDao.java 3KB
BaseDao.java 3KB
UserDao.java 936B
.classpath 410B
.mymetadata 310B
.settings
com.genuitec.eclipse.j2eedt.core.prefs 1KB
com.genuitec.jboss.ide.eclipse.xdoclet.run.prefs 120B
org.eclipse.jdt.ui.prefs 179B
.myeclipse
.project 1KB
WebRoot
style
style.css 2KB
META-INF
MANIFEST.MF 39B
showMsg.jsp 2KB
listMsg.jsp 2KB
doLogout.jsp 115B
index.jsp 759B
doLogin.jsp 595B
image
new.jpg 9KB
old.jpg 9KB
doDelete.jsp 711B
post.jsp 2KB
doPost.jsp 648B
WEB-INF
classes
com
accp
entity
User.class 850B
test.class 1KB
Message.class 2KB
biz
MessageBiz.class 1KB
UserBiz.class 548B
dao
MessageDao.class 4KB
BaseDao.class 2KB
UserDao.class 1KB
lib
sqljdbc.jar 247KB
web.xml 375B
.myumldata 66B
.checkstyle 300B
myMessage_log.ldf 1024KB
myMessage.mdf 3MB
共 40 条
- 1
资源评论
vickyu
- 粉丝: 0
- 资源: 2
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功