mysqlnewsfactory.java

JSP新闻发布系统 JSP新闻发布系统

package net.ijsp.news.news.mysql;

/**
 * <p>Title: 新闻相关操作</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: ijsp.net</p>
 * @author ccjsmile
 * @version 1.0
 */

import java.util.Iterator;
import java.util.ArrayList;
import java.sql.ResultSet;
import java.sql.SQLException;
import net.ijsp.news.news.Factory;
import net.ijsp.news.news.News;
import net.ijsp.news.news.NewsFactory;
import net.ijsp.news.database.DBConnect;
import net.ijsp.news.search.SearchManager;

public class MysqlNewsFactory extends NewsFactory{

        private ResultSet rs ;

        /**
        * 添加新闻
        */
        public void add(News news)  {
                DBConnect dbc = null;
                try{
                        dbc = new DBConnect();
                        dbc.prepareStatement("INSERT INTO news (class,editer,title,newsfile,date) VALUES (?,?,?,?,?) ");
                        dbc.setInt(1,news.getBoardID());
                        dbc.setString(2,news.getEditer());
                        dbc.setString(3,news.getTitle());
                        dbc.setString(4,news.getNewsFile());
                        dbc.setLong(5,news.getDate());
                        dbc.executeUpdate();
                }catch(SQLException se){
                        System.err.println(se);
                        System.err.println("MYsqlNewsFactory.add");
                }finally{
                        try{
                                if(dbc!=null)
                                        dbc.close();
                        }catch(Exception e){
                                System.err.println(e);
                        }
                }

                // 建索引
                SearchManager searchManager = Factory.getInstance().getSearchManager();
                searchManager.addToIndex(news);

        }

        /**
        * 删除新闻
        */
        public  void del(int id) {
                DBConnect dbc = null;
                try{
                        dbc = new DBConnect();
                        dbc.prepareStatement("DELETE FROM news WHERE id=?");
                        dbc.setInt(1,id);
                        dbc.executeUpdate();
                }catch(SQLException se){
                        System.err.println(se);
                        System.err.println("MYsqlNewsFactory.del");
                }finally{
                        try{
                                if(dbc!=null)
                                        dbc.close();
                        }catch(Exception e){
                                System.err.println(e);
                        }
                }
        }



        /**
        * 编辑新闻
        */
        public void edit(News news) {

        }

        /**
        * 显示指定栏目新闻
        * @param int boardID:新闻栏目ID， int startPage:开始页， int perPage：每页显示新闻数
        */
        public  Iterator list(int boardID,int startPage,int perPage) {
                ArrayList arrayList = new ArrayList();
                DBConnect dbc = null;
                try{
                        dbc = new DBConnect();
                        dbc.prepareStatement("SELECT id,class,title,newsfile,editer,date FROM news WHERE class= ? ORDER BY date DESC LIMIT ?,?");
                        dbc.setInt(1,boardID);
                        dbc.setInt(2,(startPage-1)*perPage);
                        dbc.setInt(3,perPage);
                        rs = dbc.executeQuery();
                        while(rs.next()) {
                                News news = Factory.getInstance().getNews();
                                news.setID(rs.getInt(1));
                                news.setBoardID(rs.getInt(2));
                                news.setTitle(rs.getString(3));
                                news.setNewsFile(rs.getString(4));
                                news.setEditer(rs.getString(5));
                                news.setDate(rs.getLong(6));
                                arrayList.add(news);
                        }
                }catch(SQLException se){
                        System.err.println(se);
                        System.err.println("MYsqlNewsFactory.list");
                }finally{
                        try{
                                if(dbc!=null)
                                        dbc.close();
                        }catch(Exception e){
                                System.err.println(e);
                        }
                }
                return arrayList.iterator();
        }

        /**
        * 显示指定新闻信息
        */
        //public abstract News news(int newsID) throws ;

        /**
        * 指定斑面新闻数
        */
        public int count(int boardID) {
                int count = 0;
                DBConnect dbc = null;
                try{
                        dbc = new DBConnect();
                        dbc.prepareStatement("SELECT COUNT(id) FROM news WHERE class= ? ");
                        dbc.setInt(1,boardID);
                        rs = dbc.executeQuery();
                        if(rs.next())
                                count = rs.getInt(1);
                }catch(SQLException se){
                        System.err.println(se);
                        System.err.println("MYsqlNewsFactory.count");
                }finally{
                        try{
                                if(dbc!=null)
                                        dbc.close();
                        }catch(Exception e){
                                System.err.println(e);
                        }
                }
        return count;
        }

        /**
        * 显示最近文章
        * @param int startPage:开始页， int perPage：每页显示新闻数
        */
        public Iterator listNew(int startPage,int perPage) {
                ArrayList arrayList = new ArrayList();
                DBConnect dbc = null;
                try{
                        dbc = new DBConnect();
                        dbc.prepareStatement("SELECT id,class,title,newsfile,editer,date FROM news ORDER BY date DESC LIMIT ?,?");
                        dbc.setInt(1,(startPage-1)*perPage);
                        dbc.setInt(2,perPage);
                        rs = dbc.executeQuery();
                        while(rs.next()) {
                                News news = Factory.getInstance().getNews();
                                news.setID(rs.getInt(1));
                                news.setBoardID(rs.getInt(2));
                                news.setTitle(rs.getString(3));
                                news.setNewsFile(rs.getString(4));
                                news.setEditer(rs.getString(5));
                                news.setDate(rs.getLong(6));
                                arrayList.add(news);
                        }
                }catch(SQLException se){
                        System.err.println(se);
                        System.err.println("MYsqlNewsFactory.listNew");
                }finally{
                        try{
                                if(dbc!=null)
                                        dbc.close();
                        }catch(Exception e){
                                System.err.println(e);
                        }
                }
                return arrayList.iterator();
        }
}