基于javaweb实现的新闻发布管理系统源码

package com.news.dao; import java.sql.Connection; import java.sql.Date; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import net.sf.json.JSONArray; import org.apache.commons.dbutils.DbUtils; import com.news.domain.Category; import com.news.domain.News; import com.news.utils.JdbcUtils; import com.news.utils.WebUtils; public class NewsManagerDao { public void addNews(News news){ String sql="insert into tb_news(title,content,date,category_id) values(?,?,?,?) "; Connection conn=null; PreparedStatement pst=null; try { conn=JdbcUtils.getConnection(); pst=conn.prepareStatement(sql); pst.setString(1, news.getTitle()); pst.setString(2, news.getContent()); pst.setDate(3, WebUtils.getCurrentTime()); pst.setInt(4, news.getCategory().getCategory_id()); pst.executeUpdate(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ DbUtils.closeQuietly(conn, pst, null); } } public void updateNews(News news){ String sql="update tb_news set title=?,content=?,date=?,category_id=? where id=?"; Connection conn=null; PreparedStatement pst=null; try { conn=JdbcUtils.getConnection(); pst=conn.prepareStatement(sql); pst.setString(1, news.getTitle()); pst.setString(2, news.getContent()); pst.setDate(3, WebUtils.getCurrentTime()); pst.setInt(4, news.getCategory().getCategory_id()); pst.setInt(5,news.getNews_id()); pst.executeUpdate(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ DbUtils.closeQuietly(conn, pst, null); } } public News findByNews_id(int news_id){ String sql="select n.title,n.content,n.date,c.id c_id,c.name from tb_news n,tb_category c where n.category_id=c.id and n.id=?"; Connection conn=null; PreparedStatement pst=null; ResultSet rs=null; News news=null; try { conn=JdbcUtils.getConnection(); pst=conn.prepareStatement(sql); pst.setInt(1, news_id); rs=pst.executeQuery(); if(rs.next()){ news =new News(); news.setNews_id(news_id); news.setTitle(rs.getString("title")); news.setContent(rs.getString("content")); news.setDate(rs.getDate("date")); news.setCategory(new Category(rs.getInt("c_id"), rs.getString("name"))); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ DbUtils.closeQuietly(conn, pst, null); } return news; } public void deleteNewsById(int news_id){ String sql="delete from tb_news where id=?"; Connection conn=null; PreparedStatement pst=null; try { conn=JdbcUtils.getConnection(); pst=conn.prepareStatement(sql); pst.setInt(1,news_id); pst.executeUpdate(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ DbUtils.closeQuietly(conn, pst, null); } } public Map<String, Object> findAll(int currentpage, int pagesize) throws Exception { Map<String ,Object> result=new HashMap<String, Object>(); Connection conn=null; PreparedStatement pst=null; ResultSet rs=null; try{ conn=JdbcUtils.getConnection(); String sql="select n.id,n.title,n.date,c.name from tb_news n,tb_category c where n.category_id=c.id limit ?,?"; pst=conn.prepareStatement(sql); pst.setInt(1, (currentpage-1)*pagesize); pst.setInt(2, pagesize); rs=pst.executeQuery(); List<Map<String,Object>> list=new ArrayList<Map<String,Object>>(); while(rs.next()){ Map<String, Object> map=new HashMap<String, Object>(); int news_id=rs.getInt("id"); String title=rs.getString("title"); String category_name=rs.getString("name"); map.put("news_id", news_id+""); map.put("title",title); map.put("date",rs.getDate("date")+""); map.put("category_name", category_name); map.put("operate", "<a href='javascript:void(0);' onclick=\"deleteNews('"+news_id+"')\">删除</a>&nbsp<a href='javascript:void(0);' onclick=\"findNewsById('"+news_id+"')\">编辑</a>"); list.add(map); } result.put("rows", JSONArray.fromObject(list)); sql="select count(*) from tb_news"; pst=conn.prepareStatement(sql); rs=pst.executeQuery(); if(rs.next()){ result.put("total", rs.getInt(1)); } return result; }catch (Exception e) { throw new Exception(e); }finally{ DbUtils.closeQuietly(conn, pst, rs); } } }