userdaohbn.java

电子商务系统： 项目描述：该系统主要完成用户网上购物、订单管理、产品管理、管理员管理等功能。后台管理员对产品类别和产品进行管理后

package com.tarena.shop.entity.dao.hbn;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;

import com.tarena.shop.entity.User;
import com.tarena.shop.entity.dao.UserDao;
import com.tarena.shop.util.ConnectionFactory;
import com.tarena.shop.util.HbnUtil;


public class UserDaoHbn implements UserDao {

	public void delete(int id) {
		
	}

	public void insert(User user) {
		Session sess = null;
		Transaction tran = null;
		try{
			sess = HbnUtil.getSession();
			tran = sess.beginTransaction();
			sess.save(user);
			tran.commit();
		}catch(Exception e){
			System.out.println("null point1");
			e.printStackTrace();
			System.out.println("null point");
			if(tran!=null) tran.rollback();
		}finally{
			System.out.println("null point2");
			if(sess!=null && sess.isOpen())	sess.close();
		}
	}

	public Collection<User> selectAll() {
		String sql = "select * from userxp";
		Collection user = new ArrayList();
		
		Connection con = ConnectionFactory.getConnection();
		try {
			Statement st = con.createStatement
						(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
			ResultSet rs=st.executeQuery(sql);
			while(rs.next()){
				User u1 = new User();
				u1.setUserName(rs.getString("userName"));
				u1.setPassword(rs.getString("password"));
				u1.setId(rs.getInt("id"));
				u1.setAddress(rs.getString("address"));
				u1.setCellPhone(rs.getString("cellPhone"));
				u1.setEmail(rs.getString("email"));
				u1.setOfficePhone(rs.getString("officePhone"));
				u1.setPostCode(rs.getString("postCode"));
				user.add(u1);
			}
		} catch (SQLException e) {
			
			e.printStackTrace();
		}
		return user;
	}

	public User selectById(int id) {
		// TODO Auto-generated method stub
		return null;
	}

	public User selectByUser(User user) {
		
		User newUser =null;
		Session sess = null;
		Transaction tran = null;
		try{
			sess = HbnUtil.getSession();
			tran = sess.beginTransaction();
			String hql = "from User u where u.userName like ? and u.password like ? ";
			Query query = sess.createQuery(hql).setString(0, user.getUserName())
														.setString(1, user.getPassword());
			List<User> users = query.list();//uniqueResult();
			//newUser = (User)query.uniquerResult();
			for(User u:users){
				newUser = u;
			}
			
//			for(int i =0;i<users.size();i++){
//				
//			}
//			
//			Iterator it = users.iterator();
//			while(it.hasNext()){
//				
//			}
			tran.commit();
		}catch(HibernateException e){
			e.printStackTrace();
			if(tran!=null) tran.rollback();
		}finally{
			if(sess!=null && sess.isOpen())	sess.close();
		}
		return newUser;
	}
	public User SelectByUserName(String userName) {
		User newUser =null;
		Session sess = null;
		Transaction tran = null;
		try{
			sess = HbnUtil.getSession();
			tran = sess.beginTransaction();
			String hql = "from User u where u.userName like ? ";
			Query query = sess.createQuery(hql).setString(0, userName);
			List<User> users = query.list();
			for(User u:users){
				newUser = u;
			}
			tran.commit();
		}catch(HibernateException e){
			e.printStackTrace();
			if(tran!=null) tran.rollback();
		}finally{
			if(sess!=null && sess.isOpen())	sess.close();
		}
		return newUser;
	
		
	}


	public void update(User user) {
	
		
	}

	
}