首页>分享>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;
	}
	
	

}
最近下载更多
zhzhzh416 LV16月6日
星星
Snly小怪兽 LV45月18日
月亮
Merlin12345 LV33月25日
星星星星星星
Tangjd LV12月22日
星星
jingyuqi LV22019年12月15日
星星星星
莫莫莫 LV42019年12月2日
月亮
王思杰 LV22019年9月23日
星星星星
lgc971 LV102019年7月24日
月亮月亮星星星星
yyyyyyyyyyyyyyyyyyy LV162019年7月3日
太阳
smalltarget LV62019年6月27日
月亮星星星星
最近浏览更多
程月龙7月3日
暂无贡献等级
hwj123456 LV46月27日
月亮
aa844152755 LV96月23日
月亮月亮星星
emmmm16月14日
暂无贡献等级
15966848095 LV166月12日
太阳
Franking LV136月12日
月亮月亮月亮星星
lqf123 LV26月8日
星星星星
Zhangdaquan LV16月7日
星星
zhzhzh416 LV16月6日
星星
顶部客服微信二维码底部
>扫描二维码关注最代码为好友扫描二维码关注最代码为好友