messagebean.java

一个jsp+javabean+access留言板

/**
 * @(#)MessageBean.java
 * 在MessageBean中，有两个执行数据库操作的方法，一个是添加一条消息到数据库
 * 另一个是显示数据库中的所有留言。
 * @solin 
 * @version 1.00 2007/12/18
 */
package com.web;

import java.sql.*;
import java.util.*;
import java.text.*;

public class MessageBean {
	private Connection con;
	MessageVO msg;

    //获得数据库连接
    public MessageBean() {
    	//获取数据库连接
    	DBConn dbc=new DBConn();
    	con=dbc.DBConn();
    }
    
    //设置属性
    public void setMessage(MessageVO msg){
    	this.msg=msg;
    }
    
    //增加一个消息
    public void addMessage() throws Exception{
    	//SQL语句，将留言插入表格lyb
    	//注意，数据库字段的名字 不能设为date否则会出错。这里我的字段为ly_date。
    	String addLy="insert into record (title, name, email, content, ly_date) values (?,?,?,?,?)";
    	
    	try{
    		PreparedStatement stm=con.prepareStatement(addLy);
    		//System.out.println(msg.getTitle());//测试用
    		//获取数据
    		String title=msg.getTitle();
    		String name=msg.getName();
    		String email=msg.getEmail();
    		String content=msg.getContent();
    		//取得util时间，并转换为sql.Timestamp存入数据库。由于sql.Date只能存日期，所以用sql.Timestamp
			java.util.Date ud=new java.util.Date();
			//取得sql.Timestamp时间并打印
			java.sql.Timestamp stp=new java.sql.Timestamp(ud.getTime()); 
			//System.out.println(stp);//测试用
    		
    		//中文字符处理
    		commonBean cb = new commonBean();
    		title=cb.ShowCH(title);
    		name=cb.ShowCH(name);
    		content=cb.ShowCH(content);
    		
    		//空email处理
    		email=cb.trim(email);
    		
    		//插入数据到表格
    		stm.setString(1,title);
    		stm.setString(2,name);
    		stm.setString(3,email);
    		stm.setString(4,content);
    		stm.setTimestamp(5,stp);
    		
    		//数据库更新
    		stm.executeUpdate();
    		
    		//关闭数据库
    		stm.close();
    		con.close();
    	}catch(Exception e){
    		e.printStackTrace();
    		throw e;
    	}
    }
    
    //获得所有留言信息，并且返回结果到JSP页面
    public Collection getMessage() throws Exception{
    	//SQL语句，从表格lyb里面获得所有数据
    	String getLy="select count(*) from record";
    	String getLy1="select * from record order by id desc";
    	
    	Collection ret=new ArrayList();
    	try{
    		Statement stm=con.createStatement();
    		ResultSet res=stm.executeQuery(getLy);
    		int msg_count=0;
    		if(res.next()){
    			msg_count=res.getInt(1);
    			res.close();
    		}
    		if(msg_count>0){
    			res=stm.executeQuery(getLy1);
    			while(res.next()){
    				int id=res.getInt("id");
    				String title=res.getString("title");
    				String name=res.getString("name");
    				String email=res.getString("email");
    				String content=res.getString("content");
    				java.sql.Timestamp ts=res.getTimestamp("ly_date");
    				java.sql.Date date=new java.sql.Date(ts.getTime());
    				//System.out.println(date);
    				
    				
    				MessageVO message=new MessageVO();
    				message.setId(id);
    				message.setTitle(title);
    				message.setName(name);
    				message.setEmail(email);
    				message.setContent(content);
    				message.setDate(date);
    				ret.add(message);
    			}
    			res.close();
    			stm.close();
    		}
    		con.close();
    	}catch(Exception e){
    		e.printStackTrace();
    		throw e;
    	}
    	return ret;
    }
    
    //删除一条留言
    public void deleteMessage(int id) throws Exception
    {
    	id=id;
    	//SQL语句
    	String deleteLy="delete from record where id = ?";
    	try
    	{
    		PreparedStatement pstm=con.prepareStatement(deleteLy);
    		pstm.setInt(1,id);
    		pstm.executeUpdate();
    		
    		pstm.close();
    		con.close();
    	}
    	catch(Exception e)
    	{
    		e.printStackTrace();
    		throw e;
    	}
    }
    
    //用main测试addMessage()
//	public static void main (String[] args) {
//		try{
//	    	MessageVO m = new MessageVO();
//	    	m.setName("solin");
//	    	m.setTitle("test");
//	    	m.setEmail("[e-mail]");
//	    	m.setContent("abcd,abcd.");
//	    	System.out.println(m.getName());
//	    	System.out.println(m.getTitle());
//	    	System.out.println(m.getEmail());
//	    	System.out.println(m.getContent());
//	    	MessageBean a = new MessageBean();
//	    	a.setMessage(m);
//	       	a.addMessage();
//		}catch(Exception e){
//			System.out.println(e);
//		}
//	}
//    
    //用main测试getMessage()
    public static void main (String[] args) {
    	try{
    		MessageBean g=new MessageBean();
    		Collection msgs=g.getMessage();
    		Iterator it=msgs.iterator();
    		while(it.hasNext()){
    			MessageVO m=(MessageVO)it.next();
    			System.out.println(m.getId());
    			System.out.println(m.getTitle());
    			System.out.println(m.getName());
    			System.out.println(m.getEmail());
    			System.out.println(m.getDateString());
    			System.out.println(m.getContent());
    		}
    		
    	}catch(Exception e){
    		System.out.println(e);
    	}
    }
    
//    //用main测试deleteMessage()
//    public static void main (String[] args) {
//    	try{
//    		MessageBean g=new MessageBean();
//    		g.deleteMessage(20);  		
//    	}catch(Exception e){
//    		System.out.println(e);
//    	}
//    }
    
}