sayingdao.java

来自「具备留言的功能」· Java 代码 · 共 146 行

package j2ee.pj.dao;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.MessageFormat;

import j2ee.pj.db.DataBaseTool;
import j2ee.pj.javabean.SayingBean;

public class SayingDao {
	public boolean insertSaying(SayingBean saying){
		String sql="insert into saying values(''{0}'',''{1}'',''{2}'',''{3}'')";
		Object[] ob=new Object[]{
				saying.getStitle(),
				saying.getSauthor(),
				new Date().toLocaleString(),
				saying.getScontent()
		};
		MessageFormat mf=new MessageFormat(sql);
		sql=mf.format(ob);
		return DataBaseTool.getDataBaseTool().insertAndUpdateAndDelete(sql);
	}
	public boolean updateSaying(SayingBean saying){
		String sql="update saying set stitle='"+saying.getStitle()+"', sauthor='"+saying.getSauthor()+"', scontent='"+saying.getScontent()+"' where sid="+saying.getSid()+"";
		return DataBaseTool.getDataBaseTool().insertAndUpdateAndDelete(sql);
	}
	public boolean deleteSaying(int sid){
		String sql="delete saying where sid="+sid+"";
		return DataBaseTool.getDataBaseTool().insertAndUpdateAndDelete(sql);
	}
	public List query(){
		String sql="select * from saying";
		ResultSet rs=DataBaseTool.getDataBaseTool().query(sql);
		List li=new ArrayList();
		SayingBean saying=null;
		try {
			while(rs.next()){
				saying=new SayingBean(
						rs.getInt(1),
						rs.getString(2),
						rs.getString(3),
						rs.getString(4),
						rs.getString(5)
						);
				li.add(saying);
			}
			return li;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			DataBaseTool.getDataBaseTool().closeConnection();
		}
		return null;
	}
	public SayingBean getOneSaying(int sid){
		String sql="select * from saying where sid="+sid+"";
		ResultSet rs=DataBaseTool.getDataBaseTool().query(sql);
		SayingBean saying=null;
		try {
			while(rs.next()){
				saying=new SayingBean(
						rs.getInt(1),
						rs.getString(2),
						rs.getString(3),
						rs.getString(4),
						rs.getString(5)
						);
			}
			
			return saying;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return null;
		}finally{
			DataBaseTool.getDataBaseTool().closeConnection();
		}
	}
	public int getSayingSize(){
		int count=0;
		ResultSet rs=DataBaseTool.getDataBaseTool().query("select count(*) from saying");
		try {
			while(rs.next()){
					count=rs.getInt(1);
			 }
			return count;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			DataBaseTool.getDataBaseTool().closeConnection();
		}
		return 0;
	}
	//总共多少条留言
	public List getPageSaying(int pagecount,int currpage){
		int p=(currpage-1)*pagecount;
		String sql="select top "+pagecount+" * from saying where sid not in (select top "+p+" sid from saying order by sid asc)";
		ResultSet rs=DataBaseTool.getDataBaseTool().query(sql);
		List li=new ArrayList();
		SayingBean saying=null;
		try {
			while(rs.next()){
				saying=new SayingBean(
						rs.getInt(1),
						rs.getString(2),
						rs.getString(3),
						rs.getString(4),
						rs.getString(5)
				);
				li.add(saying);
				
			}
			return li;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			DataBaseTool.getDataBaseTool().closeConnection();
		}
		return null;
	}
	//总共多少页
	public int getPageSize(int zonggong,int pagesize){
		if(zonggong%pagesize==0){
			return zonggong/pagesize;
		}else{
			return (zonggong/pagesize)+1;
		}
	}
	public boolean isNumber(String s){
		try {
			Integer.parseInt(s);
			return true;
		} catch (NumberFormatException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return false;
		}
	}
}