operatordaoimpl.java

使用jdbc作的一个图书馆管理系统

package lib_jdbc.daoimpl;

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

import lib_jdbc.JDBCConnection;
import lib_jdbc.dao.OperatorDAO;
import lib_jdbc.vo.OperatorVO;

public class OperatorDAOImpl implements OperatorDAO {

	@Override
	public boolean delete(String id) {
		String sql = "DELETE FROM operators WHERE operatorid=?" ;
		PreparedStatement pstmt = null ;
		JDBCConnection jdbc = null ;
		
		try {
			jdbc = new JDBCConnection() ;
			pstmt = jdbc.getConnection().prepareStatement(sql) ;			
			pstmt.setString(1,id) ;
			// 进行数据库更新操作
			pstmt.executeUpdate() ;
			pstmt.close() ;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally{
			jdbc.close();
		}
		return false;

	}

	@Override
	public List<OperatorVO> findAll() {
		List<OperatorVO> all = new ArrayList<OperatorVO>();
		String sql = "SELECT * FROM operators" ;
		PreparedStatement pstmt = null ;
		JDBCConnection dbc = null ;
		
		try {
			dbc = new JDBCConnection() ;
			pstmt = dbc.getConnection().prepareStatement(sql) ;			
			// 进行数据库查询操作
			ResultSet rs = pstmt.executeQuery() ;
			while(rs.next())
			{
				// 查询出内容，之后将查询出的内容赋值给person对象
				OperatorVO operator = new OperatorVO() ;
				
				operator.setOperatorID(rs.getString(1));
				operator.setPassword(rs.getString(2));
				operator.setName(rs.getString(3));

				// 将查询出来的数据加入到List对象之中
				all.add(operator) ;
			}
			rs.close() ;
			pstmt.close() ;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			dbc.close();
		}
		
		return all;

	}

	@Override
	public OperatorVO findOperatorByNameAndPass(String name, String pass) {
		
		String sql = "SELECT * FROM operators WHERE name = ? and password = ?" ;
		PreparedStatement pstmt = null ;
		JDBCConnection dbc = null ;
		OperatorVO operator = null;
		
		try {
			dbc = new JDBCConnection() ;
			pstmt = dbc.getConnection().prepareStatement(sql) ;		
			pstmt.setString(1, name);
			pstmt.setString(2, pass);
			// 进行数据库查询操作
			ResultSet rs = pstmt.executeQuery() ;
			
			while(rs.next())
			{
				// 查询出内容，之后将查询出的内容赋值给person对象
				operator = new OperatorVO();
				
				operator.setOperatorID(rs.getString(1));
				operator.setPassword(rs.getString(2));
				operator.setName(rs.getString(3));

				// 将查询出来的数据加入到List对象之中
				
			}
			rs.close() ;
			pstmt.close() ;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			dbc.close();
		}
		
		return operator;
	}

	@Override
	public boolean insert(OperatorVO operator) {
		String sql = "INSERT INTO operators VALUES (?,?,?)" ;
		PreparedStatement pstmt = null ;
		JDBCConnection dbc = null ;
		boolean flag =false;
		try {
			dbc = new JDBCConnection() ;
			pstmt = dbc.getConnection().prepareStatement(sql) ;	
			pstmt.setString(1, operator.getOperatorID());
			pstmt.setString(2, operator.getPassword()) ;
			pstmt.setString(3, operator.getName()) ;
			
			// 进行数据库更新操作
			int result = pstmt.executeUpdate() ;
			if(result>0)
				flag = true;
			pstmt.close() ;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally{
			dbc.close();
		}
		return flag;

	}

	@Override
	public boolean update(OperatorVO operator) {
		String sql = "UPDATE operators SET password=?,name=? WHERE operatorid=?";
		PreparedStatement pstmt = null;
		JDBCConnection dbc = null;
		boolean flag = false;
		try {
			dbc = new JDBCConnection();
			pstmt = dbc.getConnection().prepareStatement(sql);
			pstmt.setString(1, operator.getPassword());
			pstmt.setString(2, operator.getName());
			// 进行数据库更新操作
			int result = pstmt.executeUpdate();
			if (result > 0)
				flag = true;
			pstmt.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			dbc.close();
		}
		return flag;

	}

}