src/com/InsuranceBusiness/dao/impl/UserListDaoImpl.java

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

package com.InsuranceBusiness.dao.impl;

import java.util.ArrayList;
import java.util.List;

import javax.annotation.Resource;

import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.springframework.stereotype.Component;

import com.InsuranceBusiness.dao.UserListDao;
import com.InsuranceBusiness.model.UserList;

@Component(value="UserListDao")
public class UserListDaoImpl implements UserListDao {
	private SessionFactory sessionFactory;
	public SessionFactory getSessionFactory() {
		return sessionFactory;
	}
	@Resource(name="sessionFactory")
	public void setSessionFactory(SessionFactory sessionFactory) {
		this.sessionFactory = sessionFactory;
	}
	
	public UserList login(String username, String password, String type) {
		Session session = sessionFactory.openSession();
		String sql="select * from user_list where username='"+username+"' and password='"+password+"'";
		Transaction tran = session.beginTransaction();
		SQLQuery sq = session.createSQLQuery(sql);
		List<Object[]> list = sq.list();
		UserList ul = new UserList();
		for(Object[] obj : list){
			ul.setUser_id((Integer)obj[0]);
			ul.setUsername((String)obj[1]);
			ul.setPassword((String)obj[2]);
			ul.setName((String)obj[3]);
			ul.setSex((String)obj[4]);
			ul.setAge((String)obj[5]);
			ul.setPhone((String)obj[6]);
			ul.setAddress((String)obj[7]);
			ul.setType((String)obj[8]);
		}
		tran.commit();
		session.close();
		return ul;
	}

	public void registUser(UserList ul) {
		Session session = sessionFactory.openSession();
		Transaction tran = session.beginTransaction();
		String sql = "INSERT INTO user_list (username, password, name, sex, age, phone, address, type) " +
		"VALUES ('"+ul.getUsername()+"', '"+ul.getPassword()+"', '"+ul.getName()+"', '"+ul.getSex()+"', '"+ul.getAge()+"', '"+ul.getPhone()+"', '"+ul.getAddress()+"', 'customer')";
		session.createSQLQuery(sql).executeUpdate();
		tran.commit();
		session.close();
	}