messagedao.java

JSP源代码 主要实现网页的交互功能 刚学JAVA

package com.dao;
import java.sql.*;
import java.util.Date;
import java.util.List;
import java.util.ArrayList;
import com.model.*;
import com.conn.*;
import java.text.*;
public class MessageDao {
	public List getMessageList(TabUser user){
		List list=new ArrayList();
		Connection conn=null;
		PreparedStatement ment=null;
		ResultSet set=null;
		
		try{
			conn=ConnectionManager.getConnection();
			String sql="select * from TabMessage where receiveUname=?";
			ment=conn.prepareStatement(sql);
			ment.setString(1, user.getName());
			set=ment.executeQuery();
			while(set.next()){
				int id=set.getInt("id");
				String note=set.getString("note");
				String sendUname=set.getString("sendUname");
				String receiveUname=set.getString("receiveUname");
				String postTime=set.getString("postTime");
				int readSign=set.getInt("readSign");
				TabMessage message=new TabMessage(id,note,sendUname,receiveUname,postTime,readSign);
				list.add(message);
			}
		}catch(SQLException ee){
			ee.printStackTrace();
		}finally{
			ConnectionManager.closeResultSet(set);
			ConnectionManager.closeStatement(ment);
			ConnectionManager.closeConnection(conn);
		}
		return list;
	}
	
	public TabMessage findMessage(int idM){
		Connection conn=null;
		PreparedStatement ment=null;
		ResultSet set=null;
		TabMessage ta=new TabMessage();
		try{
			conn=ConnectionManager.getConnection();
			String sql="select * from TabMessage where id=?";
			ment=conn.prepareStatement(sql);
			ment.setInt(1, idM);
			set=ment.executeQuery();
			while(set.next()){
				int id=set.getInt("id");
				String note=set.getString("note");
				String sendUname=set.getString("sendUname");
				String receiveUname=set.getString("receiveUname");
				String postTime=set.getString("postTime");
				int readSign=set.getInt("readSign");
				ta=new TabMessage(id,note,sendUname,receiveUname,postTime,readSign);
			}
		}catch(SQLException ee){
			ee.printStackTrace();
		}finally{
			ConnectionManager.closeResultSet(set);
			ConnectionManager.closeStatement(ment);
			ConnectionManager.closeConnection(conn);
		}
		return ta;
	}
	
	public void update(int idM){
		Connection conn=null;
		PreparedStatement ment=null;
		try{
			conn=ConnectionManager.getConnection();
			String sql="update TabMessage set readSign=1 where id=?";
			ment=conn.prepareStatement(sql);
			ment.setInt(1, idM);
			ment.executeUpdate();
			
		}catch(SQLException ee){
			ee.printStackTrace();
		}finally{
			
			ConnectionManager.closeStatement(ment);
			ConnectionManager.closeConnection(conn);
		}
	}
	
	public int saveMessage(TabMessage tab){
		Connection conn=null;
		PreparedStatement ment=null;
		int result=0;
		try{
			SimpleDateFormat format=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			String postTime=format.format(new Date());
			conn=ConnectionManager.getConnection();
			String sql="insert into TabMessage values(?,?,?,?,?)";
			ment=conn.prepareStatement(sql);
			ment.setString(1, tab.getNote());
			ment.setString(2, tab.getSendUname());
			ment.setString(3, tab.getReceiveUname());
			ment.setString(4, postTime);
			ment.setInt(5, 0);
			result=ment.executeUpdate();
			
		}catch(SQLException ee){
			ee.printStackTrace();
		}finally{
			
			ConnectionManager.closeStatement(ment);
			ConnectionManager.closeConnection(conn);
		}
		return result;
	}
	
	public void deleteMessage(int dId){
		Connection conn=null;
		PreparedStatement ment=null;
		try{
			conn=ConnectionManager.getConnection();
			String sql="delete from TabMessage where id=?";
			ment=conn.prepareStatement(sql);
			ment.setInt(1, dId);
			ment.executeUpdate();
			
		}catch(SQLException ee){
			ee.printStackTrace();
		}finally{
			
			ConnectionManager.closeStatement(ment);
			ConnectionManager.closeConnection(conn);
		}
	}
	
	public List getLiaoMessageList(){
		List list=new ArrayList();
		Connection conn=null;
		PreparedStatement ment=null;
		ResultSet set=null;
		
		try{
			conn=ConnectionManager.getConnection();
			String sql="select * from TabMessage";
			ment=conn.prepareStatement(sql);
			
			set=ment.executeQuery();
			while(set.next()){
				int id=set.getInt("id");
				String note=set.getString("note");
				String sendUname=set.getString("sendUname");
				String receiveUname=set.getString("receiveUname");
				String postTime=set.getString("postTime");
				int readSign=set.getInt("readSign");
				TabMessage message=new TabMessage(id,note,sendUname,receiveUname,postTime,readSign);
				list.add(message);
			}
		}catch(SQLException ee){
			ee.printStackTrace();
		}finally{
			ConnectionManager.closeResultSet(set);
			ConnectionManager.closeStatement(ment);
			ConnectionManager.closeConnection(conn);
		}
		return list;
	}
}