db_test.java

文本文档中的报表数据转换为数据库中的记录

package POJO_Action;

import java.util.List;

import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;
import org.hibernate.criterion.Order;

import POJO.Test;

public class DB_Test {

	static SessionFactory sessionFactory;
	//private Session session = sessionFactory.openSession();
	static {
		try {
			Configuration config = new Configuration().configure();
			sessionFactory = config.buildSessionFactory();

		} catch (Exception e) {
			System.out.println(e.getMessage());
		}
	}
	

	public int insertTest(Test test)
	{
		int ret = 1;
		Session session=sessionFactory.openSession();
		Transaction tx = null;

		try {
			tx = session.beginTransaction();
			session.save(test);
			tx.commit();
		} catch (Exception e) {
			if (tx != null) {
				tx.rollback();
			}
			ret = 0;
			//System.out.println("插入回复信息的时候发生错误：" + e.getMessage());
		} finally {
			session.close();
		}
		return ret;
	}
	
	public List queryTest()
	{
		/*
		String hql="from Test order by id asc";
		Query query=(Query)session.createQuery(hql);
		List list=query.list();
		return list;
		*/
		Session session=sessionFactory.openSession();
		Criteria criteria=(Criteria)session.createCriteria(Test.class);
		criteria.addOrder(Order.asc("id"));
		List list=criteria.list();
		session.close();
		return list;
	}
	public int deleteTest(int id)
	{
		int ret=1;
		Transaction tx=null;
		String hql="from Test where id="+id;
		Session session=sessionFactory.openSession();
		tx=session.beginTransaction();
		Query query=(Query)session.createQuery(hql);
		Test t=(Test)query.list();
		session.delete(t);
		tx.commit();
		if(tx!=null)
		{
			ret=0;
			tx.rollback();
		}
		session.close();
		return ret;
	}
}