mysqlboardfactory.java

一个用jsp技术实现的新闻发布系统

package net.ijsp.news.news.mysql;

/**
*  Title  栏目相关操作
*  @author: ccjsmile
*  Company: http://www.ijsp.net
*  Copyright: Copyright (c) 2003
*  @version 1.0 beta
*/

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.BoardFactory;
import net.ijsp.news.news.Board;
import net.ijsp.news.news.BoardNotFoundException;
import net.ijsp.news.database.DBConnect;


public class MysqlBoardFactory extends BoardFactory {

	private ResultSet rs;
	private final String getMaxIdSQL = "SELECT @@IDENTITY";

	/**
	* 增加栏目
	* @param Board 栏目的相关信息
	*/
	public void add(Board board) {
		DBConnect dbc = null;
		try{
			dbc = new DBConnect();
			dbc.prepareStatement(" INSERT INTO class1 (classname,parentid,orders) VALUES (?,?,?) ");
			dbc.setString(1,board.getBoardname());
			dbc.setInt(2,board.getParentID());
			dbc.setInt(3,board.getOrders());
			dbc.executeUpdate();

			if(board.getParentID()==0) {
				dbc.prepareStatement(getMaxIdSQL);
				rs = dbc.executeQuery();
				int id = 0;
				if(rs.next())
					id = rs.getInt(1);
				dbc.prepareStatement("UPDATE class1 SET  parentid=? WHERE id=?");
				dbc.setInt(1,id);
				dbc.setInt(2,id);
				dbc.executeUpdate();
			}
		}catch(SQLException se){
			System.err.println(se);
		}finally{
			try{
				if(dbc!=null)
					dbc.close();
			}catch(Exception e){
				System.err.println(e);
			}
		}
	}

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

	/**
	* 编辑栏目
	*/
	public void edit(Board board)  {
		DBConnect dbc = null;
			try{
				dbc = new DBConnect();
				dbc.prepareStatement("UPDATE class1 SET classname=?,parentid=? WHERE id = ? ");
				dbc.setString(1,board.getBoardname());
				dbc.setInt(2,board.getParentID());
//				dbc.setInt(3,board.getOrders());
				dbc.setInt(3,board.getID());
				dbc.executeUpdate();
			}catch(SQLException se){
				System.err.println(se);
			}finally{
				try{
					if(dbc!=null)
						dbc.close();
				}catch(Exception e){
					System.err.println(e);
				}
			}
	}

	/**
	* 显示所栏目
	*/ 
	public Iterator list() {
		ArrayList arrayList = new ArrayList();
		DBConnect dbc = null;
		try{
			dbc = new DBConnect();
			dbc.prepareStatement("SELECT id,classname,parentid,orders FROM class1 ORDER BY parentid,orders,id ");
			rs =  dbc.executeQuery();
			while(rs.next()) {
				Board board = Factory.getInstance().getBoard();
				board.setID(rs.getInt(1));
				board.setBoardname(rs.getString(2));
				board.setParentID(rs.getInt(3));
				board.setOrders(rs.getInt(4));
				arrayList.add(board);
			}
		}catch(SQLException se){
			System.err.println(se);
		}finally{
			try{
				if(dbc!=null)
					dbc.close();
			}catch(Exception e){
				System.err.println(e);
			}
		}
		return arrayList.iterator();
	}

	/**
	* 显示指定栏目信息
	*/
	public Board board(int id) throws BoardNotFoundException {
		Board board = Factory.getInstance().getBoard();
		DBConnect dbc = null;
		try{
			dbc = new DBConnect();
			dbc.prepareStatement("SELECT id,classname,parentid,orders FROM class1 WHERE id=? ");
			dbc.setInt(1,id);
			rs =  dbc.executeQuery();
			if(rs.next()) {
				board.setID(rs.getInt(1));
				board.setBoardname(rs.getString(2));
				board.setParentID(rs.getInt(3));
				board.setOrders(rs.getInt(4));
			}else
				throw new BoardNotFoundException();
		}catch(SQLException se){
			System.err.println(se);
		}finally{
			try{
				if(dbc!=null)
					dbc.close();
			}catch(Exception e){
				System.err.println(e);
			}
		}
		return board;		
	}

}