?? messagedao.java
字號:
package dboprartion;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import entity.Message;
public class MessageDao extends BaseDao{
public MessageDao() {}
Connection cn=null;
PreparedStatement ps=null;
ResultSet rs=null;
/**
* 保存記錄.
* @param message
* @return
*/
public int save(Message message){
String str="insert into Message(note,sendUname,receiveUname,postTime,readSign)values(?,?,?,?,0)";
String[] parm={message.getNote(),message.getSendUname(),message.getSendUname(),message.getPostTime()};
return super.executeSQL(str, parm);
}
/**
* 刪除記錄.
* @param id
* @return
*/
public int del(int id){
String str="delete from Message where id="+id;
return super.executeSQL(str, null);
}
/**
* 更新記錄
* @param message
* @return
*/
public int update(Message message){
String str="update Message set readSign=1 where id="+message.getId();
return super.executeSQL(str, null);
}
/**
* 通過用戶名查找信息
* @param name
* @return
*/
public ArrayList listrecivemessage(String name){
ArrayList<Message> list=new ArrayList<Message>();
try{
cn=BaseDao.dbCn();
ps=cn.prepareStatement("select * from Message where receiveUname='"+name+"'");
rs=ps.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.getShort("readsign"));
list.add(message);
}
}catch(Exception e){
System.out.print(e);
}
return list;
}
/**
* 查找每條信息
* @param id
* @return
*/
public Message findmessage(int id){
Message message=null;
try{
cn=BaseDao.dbCn();
ps=cn.prepareStatement("select * from Message where receiveUname="+id);
rs=ps.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"));
message.setReadSign(rs.getShort("readsign"));
}
}catch(Exception e){
System.out.print(e);
}
return message;
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -