customerinfodao.java

java开发购物车+网上书城

package com.xaccp.aj3q8073.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.List;

import com.xaccp.aj3q8073.db.DBManager;
import com.xaccp.aj3q8073.db.RowMapper;
import com.xaccp.aj3q8073.vo.OrderInfoVo;
import com.xaccp.aj3q8073.vo.UserInfoVo;

public class CustomerInfoDao {
	DBManager db=new DBManager();
	
	/**
	 * 查询所有用户信息
	 * @return
	 */
	public List execute(){
		String sql="select * from userInfo";
		List list= db.queryForList(sql, null, new UserMapper());
		return list;
	}
	
	/**
	 * 根据id查询用户信息
	 * @param id
	 * @return
	 */
	public Object findCur(int id){
		String sql="select * from userInfo where userId=?";
		Object[] obj=new Object[]{id};
		Object jt= db.queryForObject(sql, obj, new UserMapper());
		return jt;
	}
	
	/**
	 * 根据用户id或者昵称查询用户
	 * @param id
	 * @return
	 */
	public List findCurByIdOrName(String id){
		String sql="select * from userInfo where userId like ? or userName like ?";
		Object[] obj=new Object[]{id,"%"+id+"%"};
		List list= db.queryForList(sql, obj, new UserMapper());
		return list;
	}
	
	/**
	 * 删除客户前先看客户有没有订单记录
	 * @param id
	 * @return
	 */
	public List findIsOrder(int id){
		String sql="select * from orderinfo where userId=?";
		Object[] obj=new Object[]{id};
		List list= db.queryForList(sql, obj, new orderMapper());
		return list;
	}
	
	/**
	 * 删除用户
	 * @param id
	 * @return
	 */
	public int delCur(int id){
		String sql="delete from userInfo where userId=?";
		Object[] obj=new Object[]{id};
		int i= db.executeUpdate(sql, obj);
		return i;
	}
	
	class UserMapper implements RowMapper{

		public Object rowMapper(ResultSet rt) throws SQLException {
			SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			UserInfoVo vo=new UserInfoVo();
			vo.setUserId(rt.getInt("userId"));
			vo.setUserName(rt.getString("userName"));
			vo.setUserPwd(rt.getString("userPwd"));
			vo.setUserQuestion(rt.getString("userQuestion"));
			vo.setUserAnswer(rt.getString("userAnswer"));
			vo.setUserRname(rt.getString("userRname"));
			vo.setUserAge(rt.getInt("userAge"));
			vo.setUserSex(rt.getInt("userSex"));
			vo.setUserTel(rt.getString("userTel"));
			vo.setUserAddress(rt.getString("userAddress"));
			try {
				vo.setUserTime(sdf.parse(rt.getString("userTime")));
			} catch (ParseException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			vo.setUserPost(rt.getString("userPost"));
			return vo;
		}
		
	}
}
	class orderMapper implements RowMapper{

		public Object rowMapper(ResultSet rt) throws SQLException {
			OrderInfoVo vo=new OrderInfoVo();
			vo.setOrderId(rt.getInt("orderId"));
			vo.setUserId(rt.getInt("userId"));
			vo.setCustmorName(rt.getString("custmorName"));
			vo.setCustmorTel(rt.getString("custmorTel"));
			vo.setCustmorSex(rt.getString("custmorSex"));
			vo.setCustmorPostman(rt.getString("custmorPostman"));
			vo.setCustmorAddress(rt.getString("custmorAddress"));
			vo.setCustmorEmail(rt.getString("custmorEmail"));
			vo.setSendStyle(rt.getString("sendStyle"));
			vo.setPayStyle(rt.getString("payStyle"));
			vo.setOrderState(rt.getInt("orderState"));
			vo.setOrderTime(rt.getString("orderTime"));
			return vo;
		}
		
	}