/*
* s2jsp.xmal.dao.MessageDao.java
* 2007-08-10
* 短消息数据库访问类
*/
package s2jsp.xmal.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.ArrayList;
import s2jsp.xmal.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;
}
}
- 1
- 2
前往页