最代码广告位
首页>分享>java servlet高仿QQ空间,包括前端显示和后台管理>/QQroom/src/org/QQroom/dao/impl/DiaryDaoImpl.java
package org.QQroom.dao.impl;

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

import org.QQroom.dao.DiaryDao;
import org.QQroom.entity.Diary;
import org.QQroom.entity.PageBean;
import org.QQroom.entity.UserLogin;
import org.QQroom.utils.BaseDao;
/**
 * 日志实现类
 * @author lenovo
 *
 */
public class DiaryDaoImpl extends BaseDao implements DiaryDao {
	/**
	 *(当前用户)得到所有的日志
	 */
	@Override
	public List<Diary> getAllDiary(int userId) {//wirteTime,
		String sql = "select id,wirteTime,title,content, userID from diary where userID=? order by id desc";
		List<Diary> list = new ArrayList<Diary>();
		ResultSet rs = super.getResultSet(sql, userId);
		if(rs!=null){
			try {
				while(rs.next()){
					Diary diary = new Diary();
					diary.setId(rs.getInt("id"));
					diary.setWriteTime(rs.getDate("wirteTime"));

					
					diary.setWriteTime(rs.getTimestamp("wirteTime"));
					diary.setTitle(rs.getString("title"));
					diary.setContent(rs.getString("content"));
					diary.setUserId(rs.getInt("userID"));
					list.add(diary);
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally{
				if(rs!=null){
					try {
						super.closeAll(rs, rs.getStatement(), rs.getStatement().getConnection());
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}	
			}
		}
		return list;
	}
	/**
	 *(当前用户)得到所有的日志
	 */
	
	/*public List<Diary> getAllDiary(PageBean pageBean,int userId) {//wirteTime,
		String sql = "select top (?) * from diary where id not in(select  top (?) id from diary ) and userID=? order by id desc";
		List<Diary> list = new ArrayList<Diary>();
		Object params[] = {pageBean.getPageSize(),(pageBean.getPageNum()-1)*pageBean.getPageSize(),userId};
		ResultSet rs = super.getResultSet(sql, params);
		if(rs!=null){
			try {
				while(rs.next()){
					Diary diary = new Diary();
					diary.setId(rs.getInt("id"));
					diary.setWriteTime(rs.getDate("wirteTime"));

					
					diary.setWriteTime(rs.getTimestamp("wirteTime"));
					diary.setTitle(rs.getString("title"));
					diary.setContent(rs.getString("content"));
					diary.setUserId(rs.getInt("userID"));
					list.add(diary);
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally{
				if(rs!=null){
					try {
						super.closeAll(rs, rs.getStatement(), rs.getStatement().getConnection());
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}	
			}
		}
		return list;
	}*/
	/**
	 *添加日志
	 */
	@Override
	public int addDiary(Diary diary) {
		String sql = "insert into diary(wirteTime, title, content, userID) values(default,?,?,?)";
		Object[] params = {diary.getTitle(),diary.getContent(),diary.getUserId()};
		return super.updateDate(sql, params);
	}
	/**
	 * 修改日志(通过当前登录的账号和日志编号)
	 * @return
	 */
	public int updateDiary(Diary diary){
		String sql = "update diary set wirteTime=getdate(),title=?,content=? where id=? and userID=?";
		Object[] params = {diary.getTitle(),diary.getContent(),diary.getId(),diary.getUserId()};
		return super.updateDate(sql, params);
	}
	/**
	 *删除日志
	 */
	@Override
	public int deleteDiary(int id,int userId) {
		String sql = "delete diary where id = ? and userID = ?";
		Object[] params = {id,userId};
		return super.updateDate(sql, params); 
	}
	/**
	 * 获取日志对象 (根据日志编号 和 用户的acc )
	 */
	@Override
	public Diary getOntDiay(Diary diary) {
		String sql = "select id,wirteTime,title,content, userID from diary where userID=? and id=? ";
		Diary diaryOne = null;
		Object[] params = {diary.getUserId(),diary.getId()};
		ResultSet rs = super.getResultSet(sql, params);
		if(rs!=null){
			try {
				while(rs.next()){
					diaryOne = new Diary();
					diaryOne.setId(rs.getInt("id"));
					/*diary.setWriteTime((rs.getDate("wirteTime")).toString());*/
					
					/*diaryOne.setWriteTime(new Date(rs.getTime("wirteTime").getTime()));*/
					diaryOne.setWriteTime(rs.getDate("wirteTime"));
					/*diaryOne.setWriteTime(rs.getTimestamp("wirteTime"));*/
					diaryOne.setTitle(rs.getString("title"));
					diaryOne.setContent(rs.getString("content"));
					diaryOne.setUserId(rs.getInt("userID"));
					
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally{
				if(rs!=null){
					try {
						super.closeAll(rs, rs.getStatement(), rs.getStatement().getConnection());
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}	
			}
		}
		return diaryOne;
	}
	/**
	 * 得到当前用户日志的总数
	 */
	@Override
	public int getDiarySum(UserLogin user) {
		String sql = "select count(0) as c from diary where userID=?";
		ResultSet rs = super.getResultSet(sql, user.getAcc());
		int result = 0;
		if(rs!=null){
			try {
				while(rs.next()){
					result=rs.getInt("c");
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally{
				if(rs!=null){
					try {
						super.closeAll(rs, rs.getStatement(), rs.getStatement().getConnection());
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}	
			}
		}
		return result;
	}
	
	

}
最近下载更多
莫莫莫 LV312月2日
星星星星星星
王思杰 LV29月23日
星星星星
lgc971 LV107月24日
月亮月亮星星星星
yyyyyyyyyyyyyyyyyyy LV167月3日
太阳
smalltarget LV56月27日
月亮星星
rain112 LV255月24日
太阳月亮月亮星星
wumaojie LV25月2日
星星星星
刘健java LV14月15日
星星
忧郁先生 LV44月11日
月亮
2722602224 LV23月27日
星星星星
最近浏览更多
yan143 LV12小时前
星星
adminima LV47小时前
月亮
fourrr昨天
暂无贡献等级
2017_yd LV112月5日
星星
qwe420116 LV312月5日
星星星星星星
simple丶余心 LV1112月3日
月亮月亮星星星星星星
莫莫莫 LV312月2日
星星星星星星
1786401885 LV212月1日
星星星星
padndgmcdsy11月22日
暂无贡献等级
Wave666 LV311月16日
星星星星星星
最代码广告位
顶部客服微信二维码底部
>扫描二维码关注最代码为好友扫描二维码关注最代码为好友