readermanagerdaoimp.java

一个简单的图书馆的管理系统,该系统主要是针对学校的图书馆而做的

package librarymanagement.dao.readerManagerDao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Vector;

import javax.swing.JOptionPane;

import librarymanagement.dao.common.DBConnectionManager;
import librarymanagement.dao.common.DbException;
import librarymanagement.dao.common.DbSql;
import librarymanagement.vo.BookVo;
import librarymanagement.vo.ReaderVo;

public class ReaderManagerdaoImp implements ReaderManagerDao {

	DBConnectionManager manager = DBConnectionManager.getInstance();

	/**
	 * 根据传入的读者id查询这个读者的所有信息并将查到的信息用ReaderVo返回
	 * 
	 * @param id
	 * @return ReaderVo
	 */
	public ReaderVo getReaderVo(int id) {
		ReaderVo r = null;
		PreparedStatement pstmt = null;
		Connection con = null;
		ResultSet set = null;
		try {
			// System.out.println(manager);
			con = manager.getConnection("oracle");
			pstmt = con.prepareStatement(DbSql.READER_SELECT_ALL_BY_ID);
			pstmt.setInt(1, id);
			set = pstmt.executeQuery();

			while (set.next()) {
				String readerName = set.getString("reader_name");
				String sex = set.getString("sex");
				String acd = set.getString("acd");
				String tell = set.getString("tell");
				String job = set.getString("job");
				String zhengId = set.getString("zheng_id");
				String eMail = set.getString("e_mail");
				String registDate = set.getString("regist_date");

				r = new ReaderVo(id, readerName, sex, acd, tell, job, zhengId,
						eMail, registDate);
			}

		} catch (Exception e) {
			JOptionPane.showConfirmDialog(null, e.getMessage(), "异常提示",
					JOptionPane.YES_OPTION);
		} finally {
			manager.freeConnection("oracle", con);
		}
		return r;
	}

	public boolean deleteReaderById(int reader_id) {
		Connection con = null;
		PreparedStatement pstmt = null;
		boolean flag = false;
		try {
			con = manager.getConnection("oracle");
			pstmt = con.prepareStatement(DbSql.DELETEBy_READER_ID);
			pstmt.setInt(1, reader_id);
			int count = pstmt.executeUpdate();
			if (count != 0) {
				flag = true;
			}
		} catch (SQLException e) {
			System.out.println("信息删除dao异常:= " + e.getMessage());
		}
		return flag;
	}

	public Vector findReaderInfo() throws DbException {

		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet set = null;
		Vector v = null;

		try {
			con = manager.getConnection("oracle");
			pstmt = con.prepareStatement(DbSql.READER_SELECT_ALL);
			set = pstmt.executeQuery();
			System.out.println(set);
			v = new Vector();
			while (set.next()) {
				int id = set.getInt("reader_id");
				String readerName = set.getString("reader_name");
				String sex = set.getString("sex");
				String acd = set.getString("acd");
				String tell = set.getString("tell");
				String job = set.getString("job");
				String zhengId = set.getString("zheng_id");
				String eMail = set.getString("e_mail");
				String registDate = set.getString("regist_date");
				v.addElement(new ReaderVo(id, readerName, sex, acd, tell, job,
						zhengId, eMail, registDate));
			}
			if (v.size() == 0) {
				throw new DbException("数据库中不存在符合条件的记录,请重新输入");
			}
		} catch (SQLException e) {
			System.out.println("查找读者信息dao异常: " + e.getMessage());
		} finally {
			manager.freeConnection("oracle", con);
		}
		return v;
	}
}