remarkop.java

博客管理系统。安装说明： 1、在SQLSERVER中创建blog数据库并创建登陆帐号blog：blog

package huc.blog.op;

import huc.blog.bean.Remark;
import huc.blog.bean.User;
import huc.blog.util.PageObject;

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class RemarkOp extends BaseOp{
	
	/**
	 * 添加remark文章
	 * @param remark
	 * @return true:添加成功；false:添加失败
	 */
	public boolean add(Remark remark){
		conn = db.getConnection();
		boolean flag = false;
		try {
			StringBuffer sql = new StringBuffer();
			sql.append("insert into H_REMARK(");
			sql.append("nickName,content,blogid,publishTime) ");
			sql.append(" values(?,?,?,?)");
			pst = conn.prepareStatement(sql.toString());
			pst.setString(1, remark.getNickName());
			pst.setString(2, remark.getContent());
			pst.setString(3, remark.getBlogid());
			pst.setString(4, remark.getPublishTime());
			
			int line = pst.executeUpdate();
			if(line == 1)
				flag = true;
			else
				flag = false;
			
		} catch (SQLException e) {
			e.printStackTrace();
			return flag;
		}
		finally{
			close();
		}
		return flag;
	}
	
	/**
	 * 更新remark信息
	 * @param remark
	 * @return
	 */
	public boolean update(Remark remark){
		conn = db.getConnection();
		boolean flag = false;
		try {
			StringBuffer sql = new StringBuffer();
			sql.append("update H_REMARK ");
			sql.append(" set nickName=?,content=?,blogid=?,publishTime=?");
			sql.append(" where id = ?");
			pst = conn.prepareStatement(sql.toString());
			pst.setString(1, remark.getNickName());
			pst.setString(2, remark.getContent());
			pst.setString(3, remark.getBlogid());
			pst.setString(4, remark.getPublishTime());
			
			int line = pst.executeUpdate();
			if(line == 1)
				flag = true;
			else
				flag = false;
			
		} catch (SQLException e) {
			e.printStackTrace();
			return flag;
		}
		finally{
			close();
		}
		return flag;
	}
	
	/**
	 * 删除remark(根据id或blogid)
	 * @param remark
	 * @return
	 */
	public boolean delete(Remark remark){
		conn = db.getConnection();
		boolean flag = false;
		try {
			StringBuffer sql = new StringBuffer();
			sql.append("delete from H_REMARK where id = ?");
			pst = conn.prepareStatement(sql.toString());
			pst.setString(1, remark.getId());
			
			int line = pst.executeUpdate();
			if(line == 1)
				flag = true;
			else
				flag = false;
			
		} catch (SQLException e) {
			e.printStackTrace();
			return flag;
		}
		finally{
			close();
		}
		return flag;
	}
	
	/**
	 * 获得分页的数据
	 * @param page		封装的分页信息
	 * @param otherSQL	分页数据的查询条件
	 * @param orderBy	分页数据的排序方式
	 * @return 封装的分页数据
	 */
	public PageObject getPage(PageObject page, String otherSQL, String orderBy){
		conn = db.getConnection();
		
		try {
			StringBuffer sql = new StringBuffer();
			//获得符合分页的对象的总记录数
			sql.append("select count(1) as total from H_REMARK where 1=1 ");
			if(otherSQL != null && !otherSQL.trim().equals(""))
				sql.append(otherSQL);

			pst = conn.prepareStatement(sql.toString());
			rs = pst.executeQuery();
			if(rs.next() && rs.getInt("total") != 0)
				page.setTotal(rs.getInt("total"));
			else{
				page.setList(new ArrayList());
				page.setTotal(0);
				return page;
			}
			rs.close();

			//得到分页sql语句
			sql = this.getSQL(page, " * from H_REMARK ", otherSQL, orderBy);
			pst = conn.prepareStatement(sql.toString());
			rs = pst.executeQuery();

			List result = new ArrayList();
			while(rs.next()){
				Remark remark = new Remark();
				
				remark.setId(rs.getString("id"));
				remark.setNickName(rs.getString("nickName"));
				remark.setContent(rs.getString("content"));
				remark.setBlogid(rs.getString("blogid"));
				remark.setPublishTime(rs.getString("publishTime"));
				
				result.add(remark);
			}
			page.setList(result);
		} catch (SQLException e) {
			e.printStackTrace();
			return page;
		}
		finally{
			close();
		}
		
		return page;
	}
}