booksdao.java

一个图书管理系统

package com.DAO;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;


import com.VO.BooksVO;
import com.VO.PublishInfoVO;
import com.VO.View_BooksVO;
import com.database.DBAccess;
import com.exception.DataBaseException;

public class BooksDAO {

	/*
	public static void main(String[] args) {
		// TODO 自动生成方法存根

	}*/
	
	/**
	 * @return   返回一个数组对象
	 * 功能 ：查找所有的记录
	 */
	public ArrayList findBookAll(){
		String strsql="select * from books";
		ArrayList list=new ArrayList();
		DBAccess db=null;
		BooksVO book=null;
		try {
			db = DBAccess.getDBAccess();
			ResultSet rs=db.query(strsql);
			try {
				while (rs.next()){
					book=new BooksVO();
					book.setBookId(rs.getString(1));
					book.setBookName(rs.getString(2));
					book.setBookType(rs.getString(3));
					book.setBookPrice(rs.getDouble(4));
					book.setBookSum(rs.getInt(5));
					book.setBookAuthor(rs.getString(6));
					book.setPubID(rs.getString(7));
					book.setBookTime(rs.getDate(8));
					list.add(book);
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		} catch (DataBaseException e1) {
			e1.printStackTrace();
		}finally{
	//			 db.close();
		}
		return list;
	}
	
	/**
	 * @return   返回一个数组对象
	 * 功能 ：查找所有的记录
	 */
	public ArrayList findAll(){
		String strsql="select * from view_Books";
		ArrayList list=new ArrayList();
		DBAccess db=null;
		View_BooksVO book=null;
		try {
			db = DBAccess.getDBAccess();
			ResultSet rs=db.query(strsql);
			try {
				while (rs.next()){
					book=new View_BooksVO();
					book.setBookType(rs.getString(1));
					book.setBookName(rs.getString(2));
					book.setBookAuthor(rs.getString(3));
					book.setBookPrice(rs.getDouble(4));
					book.setPubName(rs.getString(5));
					book.setBookSum(rs.getInt(6));
					list.add(book);
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		} catch (DataBaseException e1) {
			e1.printStackTrace();
		}finally{
	//			 db.close();
		}
		return list;
	}

	/**
	 * @return   返回一个对象
	 * 功能 ：查找记录
	 */
	public View_BooksVO find(String bookName){
		String strsql="select * from view_Books where bookName='"+bookName+"'";
		View_BooksVO book=null;
		DBAccess db=null;
		try {
			db = DBAccess.getDBAccess();
			ResultSet rs=db.query(strsql);
			try {
				while (rs.next()){
					book=new View_BooksVO();
					book.setBookType(rs.getString(1));
					book.setBookName(rs.getString(2));
					book.setBookAuthor(rs.getString(3));
					book.setBookPrice(rs.getDouble(4));
					book.setPubName(rs.getString(5));
					book.setBookSum(rs.getInt(6));
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		} catch (DataBaseException e1) {
			e1.printStackTrace();
		}finally{
	//			 db.close();
		}
		return book;
	}

	/**
	 * @param book  
	 * @return  int (添加失败返回0)
	 * 功能： 插入操作 (一次插入一条记录)
	 */
	public int insert(BooksVO book){
		int flag=0;
		String sql="insert into books values('"+book.getBookId()+"','"+book.getBookName()+"','"+book.getBookType()+"',"+book.getBookPrice()+","+book.getBookSum()+",'"+book.getBookAuthor()+"','"+book.getPubID()+"','2005-3-5')";
//		System.out.println(sql);
		DBAccess db;
		try {
			db=DBAccess.getDBAccess();
			flag=db.update(sql);
		} catch (DataBaseException e) {
			e.printStackTrace();
		}finally{
		//	db.close();
		}
		return flag;   
	}
	
}