revertdao.java

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

package com.accpedu.LHcompany.dao;

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

import com.accpedu.LHcompany.entity.message;
import com.accpedu.LHcompany.entity.revert;

public class revertDao {

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