accoutdao.java

来自「Java购物车及JSTL的应用」· Java 代码 · 共 131 行

package org.qhit.li.store.dao;

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

import org.qhit.li.store.dbmade.DBMade;
import org.qhit.li.store.dto.AccoutDTO;

public class AccoutDAO {
	
	/**
	 * 验证管理员登录
	 * @param name
	 * @param psd
	 * @return
	 */
	public int checkAccout(String name,String psd){
		int sid=0;
		String sql="select sId from Accounts where sName=? and sPassword=?";
		Connection con=null;
		PreparedStatement pds=null;
		ResultSet rs=null;
		
		try {
			con=DBMade.getCon();
			pds=DBMade.getPds(con, sql);
			pds.setString(1, name);
			pds.setString(2, psd);
			rs=pds.executeQuery();
			if(rs.next()){
				sid=rs.getInt(1);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			DBMade.close(rs, pds, con);
		}
		
		return sid;
	}
	
	/**
	 * 添加一个管理员
	 * @param info
	 * @return
	 */
	public int insertAccout(AccoutDTO info){
		int result=0;
		String sql="insert into Accounts values(?,?,?,'员工',1)";
		Connection con=null;
		PreparedStatement pds=null;
		
		try {
			con=DBMade.getCon();
			pds=DBMade.getPds(con, sql);
			pds.setString(1, info.getSname());
			pds.setString(2, info.getSpassword());
			pds.setString(3, info.getStname());
			result=pds.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			DBMade.close(null, pds, con);
		}
		
		return result;
	}
	
	/**
	 * 得到单个客服人员的信息
	 * @param sid
	 * @return
	 */
	public AccoutDTO selelctAccout(int sid){
		AccoutDTO dto=new AccoutDTO();
		String sql="select sId,sName,sPassword,sTname from Accounts where sId=?";
		Connection con=null;
		PreparedStatement pds=null;
		ResultSet rs=null;
		
		try {
			con=DBMade.getCon();
			pds=DBMade.getPds(con, sql);
			pds.setInt(1, sid);
			rs=pds.executeQuery();
			if(rs.next()){
				dto=new AccoutDTO();
				dto.setSid(rs.getInt(1));
				dto.setSname(rs.getString(2));
				dto.setSpassword(rs.getString(3));
				dto.setStname(rs.getString(4));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			DBMade.close(rs, pds, con);
		}
		return dto;
	}
	
	public int updateAccout(int sid,String psd){
		int result=0;
		String sql="update Accounts set sPassword=? where sId=?";
		Connection con=null;
		PreparedStatement pds=null;
		
		try {
			con=DBMade.getCon();
			pds=DBMade.getPds(con, sql);
			pds.setString(1, psd);
			pds.setInt(2, sid);
			result=pds.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			DBMade.close(null, pds, con);
		}
		return result;
	}
}