hbndaoimpl.java

基于java的物资管理系统非常好用啊相当简单

package com.university.goodsmanager.dao.hbndao;

import java.util.*;

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

import com.university.goodsmanager.dao.util.*;

import com.university.goodsmanager.biz.entity.BuyOrder;
import com.university.goodsmanager.biz.entity.Dept;
import com.university.goodsmanager.biz.entity.Employee;
import com.university.goodsmanager.biz.entity.ReturnProduct;
import com.university.goodsmanager.biz.entity.StockPile;
import com.university.goodsmanager.biz.entity.StoreHouse;
import com.university.goodsmanager.biz.entity.Supplier;
import com.university.goodsmanager.biz.entity.User;

public class HbnDaoImpl implements HbnDao {
	/*用户**********/
	public void save(User user) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.save(user);
		tran.commit();
		s.close();
	}

	public void update(User user) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.update(user);
		tran.commit();
		s.close();
	}

	public void delete(int id) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		User user=null;
		user=(User) s.get(User.class,id);
		s.delete(user);
		tran.commit();
		s.close();
		
	}

	public List queryUser() {
		List list=new ArrayList();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from User");
		list=q.list();
		return list;
	}
	public User queryUser(int id) throws Exception{
		User user=null;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		return user=(User) s.get(User.class,id);
	}
	public User queryUser(String name) throws Exception{
		User user=null;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from User u where u.name=:name");
		System.out.println("wo li le");
		q.setString("name",name);
		tran.commit();
		user=(User)q.uniqueResult();
		s.close();
		
		return user;
		
	}
	/*部门************/
	public void save(Dept dept) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.save(dept);
		tran.commit();
		s.close();
	}

	public void update(Dept dept) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.update(dept);
		tran.commit();
		s.close();
	}

	public List queryDept() throws Exception {
		List list=new ArrayList();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from Dept");
		list=q.list();
		return list;
	}

	public void delete(Dept dept) throws Exception {
		int dept_id=dept.getDept_id();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		dept=(Dept) s.get(Dept.class,dept_id);
		s.delete(dept);
		tran.commit();
		s.close();
	}
	public Dept queryDept(int dept_id) throws Exception{
		Dept dept=null;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from Dept d where d.dept_id=:dept_id");
		q.setInteger("dept_id",dept_id);
		tran.commit();
		dept=(Dept)q.uniqueResult();
		s.close();
		return dept;
		
	}
	/* 供应商*******************/
	public void save(Supplier supplier) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.save(supplier);
		tran.commit();
		s.close();
	}

	public void update(Supplier supplier) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.update(supplier);
		tran.commit();
		s.close();
	}

	public List querySupplier() throws Exception {
		List list=new ArrayList();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from Supplier");
		list=q.list();
		return list;
	}

	public void delete(Supplier supplier) throws Exception {
		int supplier_id=supplier.getSupplier_id();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		supplier=(Supplier) s.get(Supplier.class,supplier_id);
		s.delete(supplier);
		tran.commit();
		s.close();
	}

	public Supplier querySupplier(int supplier_id) throws Exception {
		Supplier supplier=null;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from Supplier s where s.supplier_id=:supplier_id");
		q.setInteger("supplier_id",supplier_id);
		tran.commit();
		supplier=(Supplier)q.uniqueResult();
		s.close();
		return supplier;
	}
/*公司员工***************/
	public void save(Employee employee) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.save(employee);
		tran.commit();
		s.close();
	}

	public void update(Employee employee) throws Exception {
		Session s=HbnUtil.getSession();
		Employee emp;
		Transaction tran=s.beginTransaction();
		emp=(Employee)s.load(Employee.class,employee.getEmployee_id());
		emp.setAddress(employee.getAddress());
		emp.setDept(employee.getDept());
		emp.setDuty(employee.getDuty());
		emp.setEmail(employee.getEmail());
		emp.setGender(employee.getGender());
		emp.setHireDate(employee.getHireDate());
		emp.setIdentityCard(employee.getIdentityCard());
		emp.setMatureDate(employee.getMatureDate());
		emp.setName(employee.getName());
		emp.setPhone(employee.getPhone());
		s.update(emp);
		tran.commit();
		s.close();
	}

	public List queryEmployee() throws Exception {
		List list=new ArrayList();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from Employee");
		list=q.list();
		return list;
	}

	public void delete(Employee employee) throws Exception {
		int employee_id=employee.getEmployee_id();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		employee=(Employee) s.get(Employee.class,employee_id);
		s.delete(employee);
		tran.commit();
		s.close();
	}

	public Employee queryEmployee(int employee_id) throws Exception {
		Employee employee=null;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from Employee e where e.employee_id=:employee_id");
		q.setInteger("employee_id",employee_id);
		tran.commit();
		employee=(Employee)q.uniqueResult();
		s.close();
		return employee;
	}
/**定货单***************/
	public void save(BuyOrder buyorder,int employee_id) {
		Employee emp;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		emp=(Employee)s.load(Employee.class,employee_id);
		emp.addBuyOrder(buyorder);
		s.update(emp);
		tran.commit();
		s.close();
	}

	public void update(BuyOrder buyorder) {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.update(buyorder);
		tran.commit();
		s.close();
	}

	public List queryBuyOrder() {
		List list=new ArrayList();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from BuyOrder");
		list=q.list();
		return list;
	}

	public void delete(BuyOrder buyorder,int employee_id) {
		Employee emp;
		int buyorder_id=buyorder.getBuyOrder_ID();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		emp=(Employee)s.load(Employee.class,employee_id);
		Set set=emp.getBuyOrder();	
		buyorder=(BuyOrder)s.load(BuyOrder.class,buyorder_id);
		buyorder.setEmp(null);
		emp.removeBuyOrder(buyorder);
		s.update(emp);
		s.delete(buyorder);
		tran.commit();
		s.close();
	}

	public BuyOrder queryBuyOrder(int buyorder_id) {
		BuyOrder buyorder;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from BuyOrder b where b.buyOrder_ID=:buyorder_id");
		q.setInteger("buyorder_id",buyorder_id);
		tran.commit();
		buyorder=(BuyOrder)q.uniqueResult();
		s.close();
		return buyorder;
	}
/*仓库***********************/
	public void save(StoreHouse storehouse, int employee_id) {
		Employee emp;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		emp=(Employee)s.load(Employee.class,employee_id);
		emp.addStoreHouse(storehouse);
		s.update(emp);
		tran.commit();
		s.close();
	}

	public void update(StoreHouse storehouse) {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.update(storehouse);
		tran.commit();
		s.close();
	}

	public List queryStoreHouse() {
		List list=new ArrayList();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from StoreHouse");
		list=q.list();
		return list;
	}

	public void delete(StoreHouse storehouse, int employee_id) {
		Employee emp;
		int storehouse_id=storehouse.getStoreHouse_ID();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		emp=(Employee)s.load(Employee.class,employee_id);
		Set set=emp.getBuyOrder();	
		storehouse=(StoreHouse)s.load(StoreHouse.class,storehouse_id);
		storehouse.setEmp(null);
		emp.removeStoreHouse(storehouse);
		s.update(emp);
		s.delete(storehouse);
		tran.commit();
		s.close();
	}

	public StoreHouse queryStoreHouse(int storehouse_id) {
		StoreHouse storehouse;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from StoreHouse s where s.storeHouse_ID=:storeHouse_id");
		q.setInteger("storeHouse_id",storehouse_id);
		tran.commit();
		storehouse=(StoreHouse)q.uniqueResult();
		s.close();
		return storehouse;
	}
/*库存***************/
	public void save(StockPile sp) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.save(sp);
		tran.commit();
		s.close();
	}

	public void update(StockPile sp) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.update(sp);
		tran.commit();
		s.close();
	}

	public List queryStockPile() throws Exception {
		List list=new ArrayList();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from StockPile");
		list=q.list();
		return list;
	}

	public void delete(StockPile sp) throws Exception {
		int stockpile_id=sp.getStockPile_ID();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		sp=(StockPile) s.get(StockPile.class,stockpile_id);
		s.delete(sp);
		tran.commit();
		s.close();
	}

	public StockPile queryStockPile(int stockpile_id) throws Exception {
		StockPile stockpile=null;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from StockPile s where s.stockPile_ID=:stockpile_id");
		q.setInteger("stockpile_id",stockpile_id);
		tran.commit();
		stockpile=(StockPile)q.uniqueResult();
		s.close();
		return stockpile;
	}
/*退货*********************/
	public void save(ReturnProduct rp) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.save(rp);
		tran.commit();
		s.close();
	}

	public void update(ReturnProduct rp) throws Exception {
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		s.update(rp);
		tran.commit();
		s.close();
	}

	public List queryReturnProduct() throws Exception {
		List list=new ArrayList();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from ReturnProduct");
		list=q.list();
		return list;
	}

	public void delete(ReturnProduct rp) throws Exception {
		int returnproduct_id=rp.getReturn_ID();
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		rp=(ReturnProduct) s.get(ReturnProduct.class,returnproduct_id);
		s.delete(rp);
		tran.commit();
		s.close();
	}

	public ReturnProduct queryReturnProduct(int returnproduct_id) throws Exception {
		ReturnProduct rp;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from ReturnProduct r where r.return_ID=:return_id");
		q.setInteger("return_id",returnproduct_id);
		tran.commit();
		rp=(ReturnProduct)q.uniqueResult();
		s.close();
		return rp;
	}
/*库存查询*********************/
	public List queryStockPileByCard(String card) {
		List list;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from StockPile s where s.card=:card");
		q.setString("card",card);
		tran.commit();
		list=q.list();
		s.close();
		return list;
	}

	public List queryStockPileByPoduct(String product) {
		List list;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from StockPile s where s.product=:product");
		q.setString("product",product);
		tran.commit();
		list=q.list();
		s.close();
		return list;
	}

	public List queryStockPileByType(String type) {
		List list;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from StockPile s where s.type=:type");
		q.setString("type",type);
		tran.commit();
		list=q.list();
		s.close();
		return list;
	}

	public List queryStockPileByStoreHouse(String storehouse) {
		List list;
		Session s=HbnUtil.getSession();
		Transaction tran=s.beginTransaction();
		Query q=s.createQuery("from StockPile s where s.storehouse=:storehouse");
		q.setString("storehouse",storehouse);
		tran.commit();
		list=q.list();
		s.close();
		return list;
	}
}