java新闻发布系统

package com.handson.model.dao; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.List; import com.handson.model.connection.DBSession; import com.handson.model.connection.DataAccess; import com.handson.model.vo.Classes; import com.handson.model.vo.News; import com.handson.model.vo.NewsUser; import com.handson.model.vo.Page; public class NewsDAO extends BaseDAO { private NewsDAO() { } private List pageList = null; private static NewsDAO newsdao; public static synchronized BaseDAO getNewsDAO() { if (newsdao == null) { newsdao = new NewsDAO(); } return newsdao; } public List getAll() { List<News> list = new ArrayList<News>(); DataAccess dataAccess = DataAccess.getDataAccess(); DBSession dbSession = dataAccess.getDbSession(); Statement stmt = dbSession.createStatement(); ResultSet rs = null; try { rs = stmt.executeQuery("select * from news,classes where news.classid=classes.classid order by newid desc"); while (rs.next()) { News news = new News(); Classes classes = new Classes(); news.setNewId(rs.getInt("newid")); news.setNewstitle(rs.getString("newstitle")); news.setNewsDate(rs.getString("newsdate")); news.setNewSource(rs.getString("newsource")); news.setHits(rs.getInt("hits")); classes.setClassName(rs.getString("classname")); news.setClasses(classes); list.add(news); } } catch (SQLException e) { e.printStackTrace(); } finally { dbSession.resultsetClose(rs); dbSession.stmtClose(stmt); dbSession.connClose(); } return list; } public boolean remove(Object keyid) { boolean flag = false; int key = ((Integer) keyid).intValue(); DataAccess dataAccess = DataAccess.getDataAccess(); DBSession dbsession = dataAccess.getDbSession(); String sql = "delete from news where newid=?"; PreparedStatement pstmt = dbsession.PreparedStatement(sql); try { pstmt.setInt(1, key); int count = pstmt.executeUpdate(); if (count == 1) { flag = true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { dbsession.prepstmtClose(pstmt); dbsession.connClose(); } return flag; } public Object querybyid(int keyid) { News news = new News(); DataAccess dataAccess = DataAccess.getDataAccess(); DBSession dbSession = dataAccess.getDbSession(); Statement stmt = dbSession.createStatement(); ResultSet rs = null; try { rs = stmt .executeQuery("select * from news,classes,news_user where news.classid=classes.classid and news.userid=news_user.userid and newid=" + keyid); while (rs.next()) { NewsUser newsUser = new NewsUser(); Classes classes = new Classes(); news.setNewId(rs.getInt("newid")); news.setNewstitle(rs.getString("newstitle")); news.setClassId(rs.getInt("classid")); news.setNewsDate(rs.getString("newsdate")); news.setNewsKey(rs.getString("newskey")); news.setNewSource(rs.getString("newsource")); news.setNewsContent(rs.getString("newscontent")); news.setHits(rs.getInt("hits")); news.setMonthHits(rs.getInt("monthhits")); classes.setItemId(rs.getInt("itemid")); news.setClasses(classes); newsUser.setUserName(rs.getString("username")); news.setNewsuser(newsUser); } } catch (SQLException e) { e.printStackTrace(); } finally { dbSession.resultsetClose(rs); dbSession.stmtClose(stmt); dbSession.connClose(); } return news; } public List querybyAttribute(String value, String type,Page page) { int currentpage=page.getCurrentPageNum(); int OnePageInfoNums=page.getOnePageInfoNums(); List<News> list = new ArrayList<News>(); DataAccess dataAccess = DataAccess.getDataAccess(); DBSession dbSession = dataAccess.getDbSession(); String sql = "select * from news,classes where news.classid=classes.classid and " + type + " like '%" + value + "%'"; Statement stmt = dbSession.createStatement(); ResultSet rs = null; try { rs = stmt.executeQuery(sql); int infoNums = this.getRsRowNums(rs); int pageNums = infoNums % OnePageInfoNums == 0?infoNums / OnePageInfoNums :(infoNums / OnePageInfoNums)+1; Page pages=new Page(); pages.setCurrentPageNum(currentpage); pages.setOnePageInfoNums(OnePageInfoNums); pages.setPageNums(pageNums); pages.setInfoNums(infoNums); List<Page> pageList = new ArrayList<Page>(); pageList.add(pages); this.setPageList(pageList); if(currentpage !=0 && infoNums > currentpage * OnePageInfoNums){ rs.absolute(currentpage * OnePageInfoNums); } int n=0; while (rs.next()) { n++; News news = new News(); Classes classes = new Classes(); news.setNewId(rs.getInt("newid")); news.setNewstitle(rs.getString("newstitle")); news.setNewsDate(rs.getString("newsdate")); news.setNewSource(rs.getString("newsource")); news.setHits(rs.getInt("hits")); classes.setClassName(rs.getString("classname")); news.setClasses(classes); list.add(news); if(n==OnePageInfoNums) { break; } } } catch (SQLException e) { e.printStackTrace(); } finally { dbSession.resultsetClose(rs); dbSession.stmtClose(stmt); dbSession.connClose(); } return list; } public boolean insert(Object news) { boolean flag = false; News newss = (News) news; DataAccess dataAccess = DataAccess.getDataAccess(); DBSession dbsession = dataAccess.getDbSession(); String sql = "insert into news(newstitle,classid,newsdate,newskey,newsource,newscontent,userid) values(?,?,?,?,?,?,?)"; PreparedStatement pstmt = dbsession.PreparedStatement(sql); try { pstmt.setString(1, newss.getNewstitle()); pstmt.setInt(2, newss.getClassId()); pstmt.setString(3, newss.getNewsDate()); pstmt.setString(4, newss.getNewsKey()); pstmt.setString(5, newss.getNewSource()); pstmt.setString(6, newss.getNewsContent()); pstmt.setInt(7, newss.getUserId()); int count = pstmt.executeUpdate(); if (count == 1) { flag = true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { dbsession.prepstmtClose(pstmt); dbsession.connClose(); } return flag; } public boolean removemore(String[] newsid) { boolean flag = true; DataAccess dataAccess = DataAccess.getDataAccess(); DBSession dbSession = dataAccess.getDbSession(); Statement stmt = dbSession.createStatement(); try { for (int i = 0; i < newsid.length; i++) { stmt.addBatch("delete from news where newid=" + newsid[i]); } int[] result = stmt.executeBatch(); for (int i = 0; i < result.length; i++) { if (result[i] != 1) { flag = false; } } } catch (SQLException e) { flag = false; e.printStackTrace(); } finally { dbSession.stmtClose(stmt); dbSession.connClose(); } return flag; } public boolean update(Object newses) { boolean flag = false; News news = (News) newses; DataAccess dataAccess = DataAccess.getDataAccess(); DBSession dbSession = dataAccess.getDbSession(); String sql ="update news set newstitle=?,classid=?,newskey=?,newsource=?,newscontent=? where newid=?"; PreparedStatement pstmt = dbSession.PreparedStatement(sql); try { pstmt.setString(1, news.getNewstitle()); pstmt.setInt(2, news.getClassId()); pstmt.setString(3, news.getNewsKey()); pstmt.setString(4, news.getNewSource()); pstmt.setString(5, news.getNewsContent()); pstmt.setInt(6, news.getNewId()); int row = pstmt.executeUpdate(); if (row == 1) { flag = true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally