java servlet高仿QQ空间,包括前端显示和后台管理的代码详情-代码-最代码

首页>代码>java servlet高仿QQ空间,包括前端显示和后台管理>/QQroom/src/org/QQroom/dao/impl/DiaryDaoImpl.java
001package org.QQroom.dao.impl;
002 
003import java.sql.ResultSet;
004import java.sql.SQLException;
005import java.text.SimpleDateFormat;
006import java.util.ArrayList;
007import java.util.Date;
008import java.util.List;
009 
010import org.QQroom.dao.DiaryDao;
011import org.QQroom.entity.Diary;
012import org.QQroom.entity.PageBean;
013import org.QQroom.entity.UserLogin;
014import org.QQroom.utils.BaseDao;
015/**
016 * 日志实现类
017 * @author lenovo
018 *
019 */
020public class DiaryDaoImpl extends BaseDao implements DiaryDao {
021    /**
022     *(当前用户)得到所有的日志
023     */
024    @Override
025    public List<Diary> getAllDiary(int userId) {//wirteTime,
026        String sql = "select id,wirteTime,title,content, userID from diary where userID=? order by id desc";
027        List<Diary> list = new ArrayList<Diary>();
028        ResultSet rs = super.getResultSet(sql, userId);
029        if(rs!=null){
030            try {
031                while(rs.next()){
032                    Diary diary = new Diary();
033                    diary.setId(rs.getInt("id"));
034                    diary.setWriteTime(rs.getDate("wirteTime"));
035 
036                     
037                    diary.setWriteTime(rs.getTimestamp("wirteTime"));
038                    diary.setTitle(rs.getString("title"));
039                    diary.setContent(rs.getString("content"));
040                    diary.setUserId(rs.getInt("userID"));
041                    list.add(diary);
042                }
043            } catch (SQLException e) {
044                // TODO Auto-generated catch block
045                e.printStackTrace();
046            }finally{
047                if(rs!=null){
048                    try {
049                        super.closeAll(rs, rs.getStatement(), rs.getStatement().getConnection());
050                    } catch (SQLException e) {
051                        // TODO Auto-generated catch block
052                        e.printStackTrace();
053                    }
054                }   
055            }
056        }
057        return list;
058    }
059    /**
060     *(当前用户)得到所有的日志
061     */
062     
063    /*public List<Diary> getAllDiary(PageBean pageBean,int userId) {//wirteTime,
064        String sql = "select top (?) * from diary where id not in(select  top (?) id from diary ) and userID=? order by id desc";
065        List<Diary> list = new ArrayList<Diary>();
066        Object params[] = {pageBean.getPageSize(),(pageBean.getPageNum()-1)*pageBean.getPageSize(),userId};
067        ResultSet rs = super.getResultSet(sql, params);
068        if(rs!=null){
069            try {
070                while(rs.next()){
071                    Diary diary = new Diary();
072                    diary.setId(rs.getInt("id"));
073                    diary.setWriteTime(rs.getDate("wirteTime"));
074 
075                     
076                    diary.setWriteTime(rs.getTimestamp("wirteTime"));
077                    diary.setTitle(rs.getString("title"));
078                    diary.setContent(rs.getString("content"));
079                    diary.setUserId(rs.getInt("userID"));
080                    list.add(diary);
081                }
082            } catch (SQLException e) {
083                // TODO Auto-generated catch block
084                e.printStackTrace();
085            }finally{
086                if(rs!=null){
087                    try {
088                        super.closeAll(rs, rs.getStatement(), rs.getStatement().getConnection());
089                    } catch (SQLException e) {
090                        // TODO Auto-generated catch block
091                        e.printStackTrace();
092                    }
093                }   
094            }
095        }
096        return list;
097    }*/
098    /**
099     *添加日志
100     */
101    @Override
102    public int addDiary(Diary diary) {
103        String sql = "insert into diary(wirteTime, title, content, userID) values(default,?,?,?)";
104        Object[] params = {diary.getTitle(),diary.getContent(),diary.getUserId()};
105        return super.updateDate(sql, params);
106    }
107    /**
108     * 修改日志（通过当前登录的账号和日志编号）
109     * @return
110     */
111    public int updateDiary(Diary diary){
112        String sql = "update diary set wirteTime=getdate(),title=?,content=? where id=? and userID=?";
113        Object[] params = {diary.getTitle(),diary.getContent(),diary.getId(),diary.getUserId()};
114        return super.updateDate(sql, params);
115    }
116    /**
117     *删除日志
118     */
119    @Override
120    public int deleteDiary(int id,int userId) {
121        String sql = "delete diary where id = ? and userID = ?";
122        Object[] params = {id,userId};
123        return super.updateDate(sql, params); 
124    }
125    /**
126     * 获取日志对象 （根据日志编号 和 用户的acc ）
127     */
128    @Override
129    public Diary getOntDiay(Diary diary) {
130        String sql = "select id,wirteTime,title,content, userID from diary where userID=? and id=? ";
131        Diary diaryOne = null;
132        Object[] params = {diary.getUserId(),diary.getId()};
133        ResultSet rs = super.getResultSet(sql, params);
134        if(rs!=null){
135            try {
136                while(rs.next()){
137                    diaryOne = new Diary();
138                    diaryOne.setId(rs.getInt("id"));
139                    /*diary.setWriteTime((rs.getDate("wirteTime")).toString());*/
140                     
141                    /*diaryOne.setWriteTime(new Date(rs.getTime("wirteTime").getTime()));*/
142                    diaryOne.setWriteTime(rs.getDate("wirteTime"));
143                    /*diaryOne.setWriteTime(rs.getTimestamp("wirteTime"));*/
144                    diaryOne.setTitle(rs.getString("title"));
145                    diaryOne.setContent(rs.getString("content"));
146                    diaryOne.setUserId(rs.getInt("userID"));
147                     
148                }
149            } catch (SQLException e) {
150                // TODO Auto-generated catch block
151                e.printStackTrace();
152            }finally{
153                if(rs!=null){
154                    try {
155                        super.closeAll(rs, rs.getStatement(), rs.getStatement().getConnection());
156                    } catch (SQLException e) {
157                        // TODO Auto-generated catch block
158                        e.printStackTrace();
159                    }
160                }   
161            }
162        }
163        return diaryOne;
164    }
165    /**
166     * 得到当前用户日志的总数
167     */
168    @Override
169    public int getDiarySum(UserLogin user) {
170        String sql = "select count(0) as c from diary where userID=?";
171        ResultSet rs = super.getResultSet(sql, user.getAcc());
172        int result = 0;
173        if(rs!=null){
174            try {
175                while(rs.next()){
176                    result=rs.getInt("c");
177                }
178            } catch (SQLException e) {
179                // TODO Auto-generated catch block
180                e.printStackTrace();
181            }finally{
182                if(rs!=null){
183                    try {
184                        super.closeAll(rs, rs.getStatement(), rs.getStatement().getConnection());
185                    } catch (SQLException e) {
186                        // TODO Auto-generated catch block
187                        e.printStackTrace();
188                    }
189                }   
190            }
191        }
192        return result;
193    }
194     
195     
196 
197}