messagedao.java

企业宣传网 用JSP+SQLSERVER开发 商品展示 在线聊天 留言板 新闻发布 后台管理

package com.accpedu.LHcompany.dao;

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

import com.accpedu.LHcompany.entity.message;

public class messageDao {

	Connection con=null;
	PreparedStatement ps=null;
	DBAccess dba=new DBAccess();
	
	public ArrayList<message> select()
	{
		ArrayList<message> al=new ArrayList<message>();
		con=dba.DBOpen();
		try
		{
			ps=con.prepareStatement("select * from message");
			ResultSet rs=ps.executeQuery();
			while(rs.next())
			{
				message m=new message();
				m.setContent(rs.getString("content"));
				m.setCount(rs.getInt("count"));
				m.setMessageID(rs.getInt("messageID"));
				m.setTitle(rs.getString("title"));
				m.setWriter(rs.getString("writer"));
				m.setWriterDate(rs.getString("writeDate"));
				al.add(m);
			}
			rs.close();
			dba.DBClose();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		
		return al;
	}
	
	public int insert(message m)
	{
		int x=0;
		SimpleDateFormat sdf=new SimpleDateFormat("yy-MM-dd hh:mm:ss");
		
		m.setWriterDate(sdf.format(new Date()));
		
		con=dba.DBOpen();
		try
		{
			ps=con.prepareStatement("insert into message values(?,?,?,?,1)");
			ps.setString(1,m.getTitle());
			ps.setString(2,m.getContent());
			ps.setString(3,m.getWriter());
			ps.setString(4,m.getWriterDate());
			x=ps.executeUpdate();
			ps.close();
			dba.DBClose();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		
		return x;
	}
	
	public message selectID(int id)
	{
		message m=new message();
		con=dba.DBOpen();
		try
		{
			ps=con.prepareStatement("select * from message where messageID="+id);
			ResultSet rs=ps.executeQuery();
			while(rs.next())
			{
				m.setContent(rs.getString("content"));
				m.setCount(rs.getInt("count"));
				m.setMessageID(rs.getInt("messageID"));
				m.setTitle(rs.getString("title"));
				m.setWriter(rs.getString("writer"));
				m.setWriterDate(rs.getString("writeDate"));
			}
			rs.close();
			dba.DBClose();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		
		return m;
	}
	public int updateCount(int count,int id)
	{
		count++;
		int x=0;
		message m=new message();
		con=dba.DBOpen();
		try
		{
			ps=con.prepareStatement("update message set count="+count+"where messageid="+id);
			x=ps.executeUpdate();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		return x;
	}
}