2021-05-24

Hibernate-Query 保存和查询

创建单例模式

package Dao;

import org.hibernate.HibernateException;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
//SessionFactory单态模式
public class HibernateUtil {
	private static Configuration cfg = null;
	private static SessionFactory sf = null;
	//静态代码块
	static {  //在类加载的时候只能执行一次
		try {
			cfg = new Configuration().configure();
			sf = cfg.buildSessionFactory();
		} catch (HibernateException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	//获得session工厂
	public static SessionFactory getSessionFactory() {
		return sf;
	}
	//关闭工厂
	public static void closeSessionFactory() {
		sf.close();
	}
	
}



	}
}

创建Session

<!--
  ~ Hibernate, Relational Persistence for Idiomatic Java
  ~
  ~ License: GNU Lesser General Public License (LGPL), version 2.1 or later.
  ~ See the lgpl.txt file in the root directory or <http://www.gnu.org/licenses/lgpl-2.1.html>.
  -->
<!DOCTYPE hibernate-configuration PUBLIC
	"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
	"http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
 
<hibernate-configuration>
	<session-factory>
	
	<property name="hibernate.dialect">org.hibernate.dialect.MySQLInnoDBDialect</property>
	<property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
	<property name="hibernate.connection.url">jdbc:mysql://localhost:3306/firstorm?useSSL=false</property>
	<property name="hibernate.connection.username">root</property>
	<property name="hibernate.connection.password">root</property>
	
		<property name="show_sql">true</property>
		<property name="hibernate.current_session_context_class">thread</property>
		<mapping resource="cn/hrbust/pojo/User.hbm.xml"/>
	</session-factory>
</hibernate-configuration>

保存

public void testSavaUser() {
		Configuration cfg = null;
		SessionFactory sf = null;
		Session session = null;
		Transaction ts = null;
		User u = new User();
		u.setName("杨淳淇");
		u.setGender("男");
		u.setAge(21);
		u.setBirthday(Date.valueOf("2000-10-24"));
		try {
			sf = HibernateUtil.getSessionFactory();
			session = sf.getCurrentSession();
			ts = session.beginTransaction();
			session.save(u);
			ts.commit();
		} catch (HibernateException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			if(ts != null) {
				ts.rollback();
		}
	}
}


查询

public void testQueryUser() {
		SessionFactory sf=null;
		Session session =null;
		Transaction ts=null;
		
		try {
			sf=HibernateUtil.getSessionFactory();//SessionFactory单态模式
			session =sf.getCurrentSession(); //保证每个读写线程有唯一的session实例
			ts=session.beginTransaction();
			Query query=session.createQuery("from User");//类名
			List<User> users =query.list();
			//遍历方法一
//			for (int i=0;i<users.size();i++) { 
//				User u=users.get(i);
//				System.out.println(u.getName()+"  "+u.getGender()+"  "+u.getAge()+"  "+u.getBirthday());
//			}
            //遍历方法二
			for(User u:users) {  
				System.out.println(u.getName()+"  "+u.getGender()+"  "+u.getAge()+"  "+u.getBirthday());
			}
			
			ts.commit();
		} catch (HibernateException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			if(ts!=null) {
				ts.rollback();
			}
		}
	}


上一篇:Excel数据导入hive步骤


下一篇:轻松让你理解装饰器与面向切面编程(AOP)