package com.t70.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.t70.entity.Message;
public class MessageDAO extends BaseDAO {
public boolean saveMessage(Message message){
String sql = "insert into message values(?,?,?)";
Connection con = this.getConnection();
PreparedStatement pstmt = null;
if(con!=null){
try {
pstmt = con.prepareStatement(sql);
pstmt.setString(1, message.getMessage());
pstmt.setString(2, message.getAuthor());
pstmt.setString(3, message.getPostTime().toLocaleString());
pstmt.execute();
return true;
} catch (SQLException e) {
e.printStackTrace();
}finally{
try {
pstmt.close();
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return false;
}
public List<Message> findAllMessage(){
String sql = "select * from message order by id desc";
Connection con = this.getConnection();
PreparedStatement pstmt = null;
ResultSet rs = null;
List<Message> list = new ArrayList<Message>();
if(con !=null){
try {
pstmt = con.prepareStatement(sql);
rs = pstmt.executeQuery();
while(rs.next()){
list.add(new Message(rs.getInt(1),
rs.getString(2),
rs.getString(3),
rs.getDate(4)));
}
return list;
} catch (SQLException e) {
e.printStackTrace();
}finally{
try {
rs.close();
pstmt.close();
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return null;
}
}