Hibernate5-唯一查询和聚合查询

简介:

1.创建项目,项目名称hibernatedemo8,目录结构如图所示

wKiom1jbUtOC_XvJAAAuFPz3osI396.png-wh_50


2.在项目中创建lib目录存储jar文件,目录结构如图所示

wKioL1jbUvjipkl7AACN0Wp2Aoc477.png-wh_50


3.在src目录中创建实体Bean Forum,包名(com.mycompany.demo.bean),如图所示

wKiom1jbUyygLm0LAABEhsnzq78128.png-wh_50


4.实体Bean Forum的内容如下

package com.mycompany.demo.bean;


public class Forum {
	private int fid;
	private String name;

	public Forum() {
		super();
	}
	public Forum(String name) {
		super();
		this.name = name;
	}
	public int getFid() {
		return fid;
	}
	public void setFid(int fid) {
		this.fid = fid;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	@Override
	public int hashCode() {
		final int prime = 31;
		int result = 1;
		result = prime * result + fid;
		result = prime * result + ((name == null) ? 0 : name.hashCode());
		return result;
	}
	@Override
	public boolean equals(Object obj) {
		if (this == obj)
			return true;
		if (obj == null)
			return false;
		if (getClass() != obj.getClass())
			return false;
		Forum other = (Forum) obj;
		if (fid != other.fid)
			return false;
		if (name == null) {
			if (other.name != null)
				return false;
		} else if (!name.equals(other.name))
			return false;
		return true;
	}
}


5.在src目录中创建实体Bean Forum的映射文件Forum.hbm.xml,包名(com.mycompany.demo.bean),如图所示

wKioL1jbU2_zAXHGAABCwqXFTpw280.png-wh_50


6.映射文件Forum.hbm.xml的内容如下

<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-mapping PUBLIC 
 "-//Hibernate/Hibernate Mapping DTD//EN"
 "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd"> 

<!--
	package:指定<class/>所在的包 
 -->
<hibernate-mapping package="com.mycompany.demo.bean">
	<!--
		name:类名
		table:表名 
		catalog:数据库名称,默认为hibernate.cfg.xml中配置的数据库名称
	 -->
   <class name="Forum" table="hnsq_forum" catalog="b_shequ_two">
      <meta attribute="class-description">
         This class contains the forum detail. 
      </meta>
      <!--
      	name:属性名
      	colum:列名 
       -->
      <id name="fid" type="int" column="fid">
      		<!--
      			increment:hibernate维护主键值
      			identity:数据库自增长
      			sequence:序列
      			native:根据不同的数据库选择生成策略
      			uuid:通过UUID算法生成,实际使用较多
      			assigned:手工设置
      		 -->
         <generator class="native"/>
      </id>
      
      <!--
      	length:字节长度
      	type:字段类型,支持java和hibernate类型
      	not-null:非空约束
      	unique:唯一性约束
       -->
      <property name="name" column="name" type="string" length="50" not-null="true" unique="false"/>
   </class>
</hibernate-mapping>


7.在src目录中创建工具类 HbnUtil,包名(com.mycompany.demo.util),如图所示

wKioL1jbU7Szdh7EAAA_xqBXoiw464.png-wh_50


8.工具类 HbnUtil的内容如下

package com.mycompany.demo.util;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

public class HbnUtil {
	private static SessionFactory sessionFactory;
	
	public static Session getSession(){
		if(sessionFactory == null || sessionFactory.isClosed()){
			sessionFactory = new Configuration().configure().buildSessionFactory();
		}
		
		return sessionFactory.getCurrentSession();
	}
}


9.在src目录中创建Hibernate的配置文件hibernate.cfg.xml,如图所示

wKioL1jbU-vT_fiMAAA7ZTnF4Vo548.png-wh_50


10.Hibernate的配置文件hibernate.cfg.xml的内容如下

<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-configuration SYSTEM 
"http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">

<hibernate-configuration>
   <session-factory>
   	<!-- 方言,可以从Hibernate核心jar(hibernate-core-x.x.x.Finall.jar)
   	文件中的or.hibernate.dialect包中找到相应的类,类的全名就是 -->
	   <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
	   <!-- 驱动 -->
	   <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
	
	   <!-- 数据库连接地址 -->
	   <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/b_shequ_two</property>
	   <!-- 用户名 -->
	   <property name="hibernate.connection.username">
	      root
	   </property>
	   <!-- 密码 -->
	   <property name="hibernate.connection.password"></property>
	   <!--
	   		create:每次都新创建,如果存在就删除
	   		create-drop:创建新表,sessionFactory关闭,表会删除
	   		update :表字段增加,会同步,字段减少不同步,数据改变会同步修改
	    -->
	   <property name="hibernate.hbm2ddl.auto">update</property>
	   <!-- 输出sql -->
	   <property name="hibernate.show_sql">true</property>
	   <!-- 格式化sql -->
	   <property name="hibernate.format_sql">true</property>
	   <!-- 事务环境一个线程对一个事务
	   		thread:本地事务环境
	   		jta:分布式事务环境
	   		SpringSessionContext:用于ssh整合
	    -->
	   <property name="hibernate.current_session_context_class">thread</property>	  
	   
	   <!-- 使用c3p0数据源 -->
	   <property name="hibernate.connection.provider_class">
	       org.hibernate.c3p0.internal.C3P0ConnectionProvider
	   </property> 
	
	   <!-- List of XML mapping files -->
	   <mapping resource="com/mycompany/demo/bean/Forum.hbm.xml"/>
</session-factory>
</hibernate-configuration>


11.在项目中创建test目录存储测试文件,文件名称ManageForum,包名(com.mycompany.demo.bean),目录结构如图所示

wKiom1jbVCCjXFq8AAA3ZjZYAhw588.png-wh_50


12.ManageForum测试类的内容如下

package com.mycompany.demo.bean;

import java.math.BigInteger;
import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Projections;
import org.hibernate.criterion.Restrictions;
import org.junit.Before;
import org.junit.Test;

import com.mycompany.demo.util.HbnUtil;

public class ManageForum {
	
	private Session session;
	
	@Before
	public void init(){
		session = HbnUtil.getSession();
	}
	
	/*
	 * 唯一性查询-SQL
	 */
	@Test
	public void testUniqueSQL(){
		try {
			session.beginTransaction();
			String sql = "SELECT * FROM hnsq_forum WHERE fid = ?";
			Forum forum = (Forum) session.createSQLQuery(sql)
					.addEntity(Forum.class)
					.setInteger(0, 54)
					.uniqueResult();
			System.out.println(forum.getName());
			session.getTransaction().commit();
		} catch (Exception e) {
			session.getTransaction().rollback();
			e.printStackTrace();
		}
	}
	
	/*
	 * 唯一性查询-HQL
	 */
	@Test
	public void testUniqueHQL(){
		try {
			session.beginTransaction();
			String sql = "FROM Forum WHERE fid = ?";
			Forum forum = (Forum) session.createQuery(sql)
					.setInteger(0, 54)
					.uniqueResult();
			System.out.println(forum.getName());
			session.getTransaction().commit();
		} catch (Exception e) {
			session.getTransaction().rollback();
			e.printStackTrace();
		}
	}
	
	/*
	 * 唯一性查询-QBC
	 */
	@Test
	public void testUniqueQBC(){
		try {
			session.beginTransaction();
			Forum forum = (Forum) session.createCriteria(Forum.class)
					.add(Restrictions.eq("fid", 54))
					.uniqueResult();
			System.out.println(forum.getName());
			session.getTransaction().commit();
		} catch (Exception e) {
			session.getTransaction().rollback();
			e.printStackTrace();
		}
	}
	
	/*
	 * 聚合函数查询-SQL
	 */
	@Test
	public void testCountSQL(){
		try {
			session.beginTransaction();
			String sql = "SELECT COUNT(*) FROM hnsq_forum";
			BigInteger total = (BigInteger) session.createSQLQuery(sql).uniqueResult();
			System.out.println(total);
			session.getTransaction().commit();
		} catch (Exception e) {
			session.getTransaction().rollback();
			e.printStackTrace();
		}
	}
	
	/*
	 * 聚合函数查询-HQL
	 */
	@Test
	public void testCountHQL(){
		try {
			session.beginTransaction();
			String sql = "SELECT COUNT(*) FROM Forum";
			Long total = (Long) session.createQuery(sql).uniqueResult();
			System.out.println(total);
			session.getTransaction().commit();
		} catch (Exception e) {
			session.getTransaction().rollback();
			e.printStackTrace();
		}
	}
	
	/*
	 * 聚合函数查询-QBC
	 */
	@Test
	public void testCountQBC(){
		try {
			session.beginTransaction();
			String sql = "SELECT COUNT(*) FROM Forum";
			Long total = (Long) session.createCriteria(Forum.class)
					.setProjection(Projections.count("fid"))
					.uniqueResult();
			System.out.println(total);
			session.getTransaction().commit();
		} catch (Exception e) {
			session.getTransaction().rollback();
			e.printStackTrace();
		}
	}
}

wKiom1jbVEjALldSAABwCKMO5XE054.png-wh_50


本文转自 素颜猪 51CTO博客,原文链接:http://blog.51cto.com/suyanzhu/1911392


相关文章
Mybatis-plus查询表中指定字段(不查询全部字段)
Mybatis-plus查询表中指定字段(不查询全部字段)
739 0
Mybatis-plus查询表中指定字段(不查询全部字段)
|
4月前
|
SQL Java 数据库连接
MyBatisPlus-聚合查询、分组查询及等值查询
MyBatisPlus-聚合查询、分组查询及等值查询
184 0
|
7月前
|
Java
jpa实现增删改查,分页,自定义查询,jpql查询
jpa实现增删改查,分页,自定义查询,jpql查询
46 0
|
4月前
|
SQL Java Spring
MybatisPlus-条件查询方式及多条件构建查询
MybatisPlus-条件查询方式及多条件构建查询
203 0
|
4月前
mybatis-plus过滤不需要查询的字段
mybatis-plus过滤不需要查询的字段
96 0
|
11月前
|
SQL XML Java
15min快速掌握Mybatis 多表操作 & 查询过程 & 查询结果
15分钟快速掌握Mybatis中的多表操作(一对一,一对多,多对多), 查询过程, 查询结果.以及学习和关键属性的应用👍👍👍
176 0
|
SQL 测试技术 数据库
软件测试最常用的 SQL 命令 | 通过实例掌握基本查询、条件查询、聚合查询
软件测试最常用的 SQL 命令 | 通过实例掌握基本查询、条件查询、聚合查询
88 0
软件测试最常用的 SQL 命令 | 通过实例掌握基本查询、条件查询、聚合查询
|
关系型数据库 MySQL 数据库
MySQL数据库基础学习Day2:条件查询,排序、限制和去重操作,聚合查询,分组查询2
MySQL数据库基础学习Day2:条件查询,排序、限制和去重操作,聚合查询,分组查询
MySQL数据库基础学习Day2:条件查询,排序、限制和去重操作,聚合查询,分组查询2
|
关系型数据库 MySQL 数据库
MySQL数据库基础学习Day2:条件查询,排序、限制和去重操作,聚合查询,分组查询
MySQL数据库基础学习Day2:条件查询,排序、限制和去重操作,聚合查询,分组查询
MySQL数据库基础学习Day2:条件查询,排序、限制和去重操作,聚合查询,分组查询