Hibernate【查询、连接池、逆向工程】

ゞ浴缸里的玫瑰 2021-09-14 23:40 403阅读 0赞

# 前言 #

在Hibernate的第二篇中只是简单地说了Hibernate的几种查询方式….到目前为止，我们都是使用一些简单的主键查询阿…使用HQL查询所有的数据….**本博文主要讲解Hibernate的查询操作，连接池，逆向工程的知识点**…

# get/load主键查询 #

由于主键查询这个方法用得比较多，于是Hibernate专门为我们封装了起来…

*  **get()立即查询**  
    
    
     *  ![这里写图片描述][SouthEast]
 *  **load()懒加载**  
    
    
     *  ![这里写图片描述][SouthEast 1]

# 对象导航查询 #

如果对象与对象之前存在一对多、多对一的关系的时候

*  在以前SQL查询的时候：我们如果**想要得到当前对象与另一对象的关联关系的时候，就必须用多表查询来得到数据**
 *  Hibernate提供了对象导航查询：我们可以使用主键查询完之后，得到的对象，**直接使用对象得到集合…就可以得到对应的数据了**。

// 对象导航查询
            Dept dept =  (Dept) session.get(Dept.class, 12);
            System.out.println(dept.getDeptName());
    
            //这里就可以得到部门对应的所有员工
            System.out.println(dept.getEmps());

# HQL查询 #

在**Hibernate的前面章节中已经讲解过了基本的概念了**。在这里我们就直接看看怎么使用了。

值得注意的是：

*  在hbm.xml文件中的auto-import=”true” 要设置true。当然了，默认值就是ture
 *  如果是false，写hql的时候，要指定类的全名

## 查询全部列 ##

//方式一：直接写对象
        Query q = session.createQuery("from Dept");
    
        //方式二：可以为对象取别名
        Query q = session.createQuery("select d from Dept d");

值得注意的是：**HQL不支持\*号**，下面的代码是错误的。

//不能用*
        Query q = session.createQuery("select * from Dept d");

--------------------

## 查询指定的列 ##

值得注意的是：**使用HQL查询指定的列，返回的是对象数组Object\[\]**

//只查询name和eatBanana列
            Query query = session.createQuery("select m.name,m.eatBanana from Monkey m");
            System.out.println(query.list());

![这里写图片描述][SouthEast 2]

### **封装对象** ###

前面测试了查询指定的列的时候，返回的是对象数组…可是对象数组我们不好操作啊…**Hibernate还提供了将对象数组封装成对象的功能**

*  **JavaBean要有对应的构造函数**

Query query = session.createQuery("select new Monkey(m.name,m.eatBanana )from Monkey m");

--------------------

## 条件查询 ##

在SQL中条件查询我们也用得比较多，我们来看看HQL中的条件查询有什么新特性。

### **占位符** ###

**占位符就是指?号**，我们在SQL中也常常用…

Query query = session.createQuery("from Monkey m where m.name=?");
            //HQL是从0开始的
            query.setParameter(0, "大猴子");
    
            System.out.println(query.list());

![这里写图片描述][SouthEast 3]

--------------------

### **命名参数** ###

**HQL还支持命名参数查询**！下面我们来看一下怎么用：

语法：`:命名`

Query query = session.createQuery("from Monkey m where m.name=:monkeyName");
            //HQL是从0开始的
            query.setParameter("monkeyName", "大猴子");
            System.out.println(query.list());

![这里写图片描述][SouthEast 4]

--------------------

### **范围查询** ###

**范围查询就是使用between and关键字来查询特定范围的数据**。。和SQL是一样的…

Query q = session.createQuery("from Dept d where deptId between ? and ?");
            q.setParameter(0, 1);
            q.setParameter(1, 20);
            System.out.println(q.list());

--------------------

### **模糊查询** ###

**模糊查询就是使用Like关键字进行查询**，和SQL也是一样的。

*  **%号要写在参数上，不能写带SQL上！**

//模糊
            Query q = session.createQuery("from Dept d where deptName like ?");
            q.setString(0, "%部%");
            System.out.println(q.list());

--------------------

## 聚合函数统计 ##

我们也经常会查询数据库中一共有多少条记录这样的需求。那么在HQL中怎么用呢？

*  **HQL提供了uniqueResult()这么一个方法，返回只有一条记录的数据**

Query query = session.createQuery("select COUNT(*) from Monkey");
            Object o = query.uniqueResult();
            System.out.println(o);

![这里写图片描述][SouthEast 5]

--------------------

## 分组查询 ##

分组查询和SQL是一样的…

//-- 统计t_employee表中，每个部门的人数
            //数据库写法：SELECT dept_id,COUNT(*) FROM t_employee GROUP BY dept_id;
            // HQL写法
            Query q = session.createQuery("select e.dept, count(*) from Employee e group by e.dept");
            System.out.println(q.list());

--------------------

## 连接查询 ##

连接查询也就是多表查询…多表查询有三种

*  **内连接【等值连接】**
 *  **左外连接**
 *  **有外链接**

值得注意的是：**连接查询返回的也是对象数组！**

//1) 内连接 【映射已经配置好了关系，关联的时候，直接写对象的属性即可】
            Query q = session.createQuery("from Dept d inner join d.emps");
    
            //2) 左外连接
            Query q = session.createQuery("from Dept d left join d.emps");
    
            //3) 右外连接
            Query q = session.createQuery("from Employee e right join e.dept");
            q.list();

### **迫切连接** ###

由于连接查询返回的是对象数组，我们使用对象数组来操作的话会很不方便…**既然是连接查询，那么对象与对象是肯定有关联关系的**…于是乎，我们想把左表的数据填充到右表中，或者将右表的数据填充到左表中…**使在返回的时候是一个对象、而不是对象数组！\*\*HQL提供了\*\*fetch关键字供我们做迫切连接**～

//1) 迫切内连接 【使用fetch, 会把右表的数据，填充到左表对象中！】
            Query q = session.createQuery("from Dept d inner join fetch d.emps");
            q.list();
    
            //2) 迫切左外连接
            Query q = session.createQuery("from Dept d left join fetch d.emps");
            q.list();

--------------------

## 查询语句放在配置文件中【命名查询】 ##

我们可以在**具体的映射配置文件中存放一些常用的语句**。以Dept为例

<query name="getAllDept">
            <![CDATA[
                from Dept d where deptId < ?
            ]]>
        </query>

**在程序中，我们可以获取配置文件配置的语句**

Query q = session.getNamedQuery("getAllDept");
            q.setParameter(0, 10);
            System.out.println(q.list());

--------------------

# Criteria 查询 #

**Criteria是一种完全面向对象的查询**…

**Criteria使用的是add()来添加条件。条件又使用一个Restrictions类来封装**

Criteria criteria = session.createCriteria(Monkey.class);
            criteria.add(Restrictions.eq())

我们来简单看一下Restrictions的方法：

![这里写图片描述][SouthEast 6]

都是一些大于、小于、等于之类的….**Criteria查询就使用不了分组、连接查询了。**

--------------------

# SQLQuery本地SQL查询 #

有的时候，我们可能表的结构十分复杂，**如果使用关联映射的话，配置文件是十分臃肿的**…因此，我们并不是把全部的数据表都使用映射的方式来创建数据表…

这时，我们就需要用到SQLQuery来维护我们的数据了..

**SQLQuery是不能跨数据库的，因为Hibernate在配置的时候就指定了数据库的“方言”**…

SQLQuery sqlQuery = session.createSQLQuery("SELECT * FROM monkey_ limit 0,3");
    
            System.out.println(sqlQuery.list());

**返回的也是对象数组:**

![这里写图片描述][SouthEast 7]

Hibernate也支持在SQLQuery中对数据进行对象封装..只要添加类型就行了

SQLQuery sqlQuery = session.createSQLQuery("SELECT * FROM monkey_ limit 0,3").addEntity(Monkey.class);
    
            System.out.println(sqlQuery.list());

![这里写图片描述][SouthEast 8]

--------------------

# 分页查询 #

传统的SQL我们在DAO层中往往都是使用**两个步骤来实现分页查询**

*  **得到数据库表中的总记录数**
 *  **查询起始位置到末尾位数的数据**

Hibernate对分页查询也有很好地支持，我们来一下:

Query query = session.createQuery("from Monkey");
    
            //得到滚动结果集
            ScrollableResults scroll = query.scroll();
            //滚动到最后一行
            scroll.last();
            int i = scroll.getRowNumber() + 1;
            System.out.println("总计路数：" + i);
    
            //设置分页位置
            query.setFirstResult(0);
            query.setMaxResults(3);
    
            System.out.println(query.list());

*  **提供了方法让我们设置起始位置和结束位置**
 *  **提供了ScrollableResults来得到滚动结果集，最终得到总记录数**

**值得注意的是，滚动结果集是从0开始的，因此需要+1才可得到总记录数！**

![这里写图片描述][SouthEast 9]

--------------------

**如果我们们使用的是`SELECT COUNT(*) FROM 实体`，我们可以通过uniqueResult()方法获取数据的唯一记录，得到的数据转换成Long类型即可。**

Long totalRecord = (Long) queryCount.uniqueResult();

# Hibernate连接池 #

Hibernate自带了连接池，但是呢，该连接池比较简单..而Hibernate又对C3P0这个连接池支持…因此我们来更换Hibernate连接池为C3P0

## 查看Hibernate自带的连接池 ##

我们可以通过Hibernate.properties文件中查看Hibernate默认配置的连接池

hibernate.properties的配置文件可以在`\project\etc`找到

**Hibernate的自带连接池啥都没有，就一个连接数量为1**…

![这里写图片描述][SouthEast 10]

--------------------

## 查看Hibernate对C3P0的支持 ##

*  \#hibernate.c3p0.max\_size 2 最大连接数
 *  \#hibernate.c3p0.min\_size 2 最小连接数
 *  \#hibernate.c3p0.timeout 5000 超时时间
 *  \#hibernate.c3p0.max\_statements 100 最大执行的命令的个数
 *  \#hibernate.c3p0.idle\_test\_period 3000 空闲测试时间
 *  \#hibernate.c3p0.acquire\_increment 2 连接不够用的时候， 每次增加的连接数
 *  \#hibernate.c3p0.validate false

![这里写图片描述][SouthEast 11]

## 修改Hibernate连接池 ##

我们在hibernate.cfg.xml中配置C3p0，让C30P0作为Hibernate的数据库连接池

**查找Hibernate支持的连接池组件有什么**：

![这里写图片描述][SouthEast 12]

既然找到了，那么我们在hibernate.cfg.xml中配置对应的类就和相关配置就行了

<property name="hibernate.connection.provider_class">org.hibernate.connection.C3P0ConnectionProvider</property>
            
            <property name="hibernate.c3p0.min_size">2</property>
            <property name="hibernate.c3p0.max_size">4</property>
            <property name="hibernate.c3p0.timeout">5000</property>
            <property name="hibernate.c3p0.max_statements">10</property>
            <property name="hibernate.c3p0.idle_test_period">30000</property>
            <property name="hibernate.c3p0.acquire_increment">2</property>

--------------------

# 线程Session使用 #

我们创建Session的时候，有两个方法

*  **openSession()【每次都会创建新的Session】**
 *  **getCurrentSession()【获取当前线程的Session，如果没有则创建】**

一般地，我们**使用线程Session比较多**

如果要使用getCurrentSession()，需要在配置文件中配置:

<property name="hibernate.current_session_context_class">thread</property>

## 测试数据 ##

@Test
        public void testSession() throws Exception {
            //openSession: 创建Session, 每次都会创建一个新的session
            Session session1 = sf.openSession();
            Session session2 = sf.openSession();
            System.out.println(session1 == session2);
            session1.close();
            session2.close();
    
            //getCurrentSession 创建或者获取session
            // 线程的方式创建session 
            // 一定要配置：<property name="hibernate.current_session_context_class">thread</property>
            Session session3 = sf.getCurrentSession();// 创建session，绑定到线程
            Session session4 = sf.getCurrentSession();// 从当前访问线程获取session
            System.out.println(session3 == session4);
    
            // 关闭 【以线程方式创建的session，可以不用关闭； 线程结束session自动关闭】
            //session3.close();
            //session4.close(); 报错，因为同一个session已经关闭了！
        }

# 为什么要使用逆向工程 #

由于我们每次编写Hibernate的时候都需要写实体，写映射文件。而且Hibernate的映射文件也容易出错。而**逆向工程可以帮我们自动生成实体和映射文件，这样就非常方便了。**

## 使用PowerDesigner ##

在设计数据库表时，我们使用PowerDesigner来生成概念模型\\物理模型…

设计一个人员组织架构：有机构、部门、员工、领导、角色、权限。

*  **一个机构有多个部门**
 *  **一个部门有多个员工**
 *  **领导可以管理多个部门，同时领导他自己也是员工**
 *  **一个员工可以有多个角色**
 *  **一个角色可以分配给多个人**
 *  **人员角色分配后可以设置是否有效，分配时间等**
 *  **一个角色有多个权限**

## 概念模型： ##

![这里写图片描述][SouthEast 13]

**在PowerDesigner中，箭头指向的方向永远是“一”的一方**

## 生成物理模型： ##

![这里写图片描述][SouthEast 14]

![这里写图片描述][SouthEast 15]

最后生成物理模型是这样子的：

![这里写图片描述][SouthEast 16]

## 生成sql语句 ##

我们可以单个生成，一个一个复制

![这里写图片描述][SouthEast 17]

也可以把整个物理模型的sql语句一起生成：

![这里写图片描述][SouthEast 18]

/*==============================================================*/
        /* DBMS name: MySQL 5.0 */
        /* Created on: 2017/6/5 20:22:52 */
        /*==============================================================*/
    
    
        drop table if exists person_role;
    
        drop table if exists t_company;
    
        drop table if exists t_dept;
    
        drop table if exists t_employee;
    
        drop table if exists t_person;
    
        drop table if exists t_privilege;
    
        drop table if exists t_role;
    
        drop table if exists t_role_privilege;
    
        /*==============================================================*/
        /* Table: person_role */
        /*==============================================================*/
        create table person_role ( person_id varchar(32) not null, role_id varchar(32) not null, state varchar(32), primary key (person_id, role_id) );
    
        /*==============================================================*/
        /* Table: t_company */
        /*==============================================================*/
        create table t_company ( company_id varchar(32) not null, name varchar(32), primary key (company_id) );
    
        /*==============================================================*/
        /* Table: t_dept */
        /*==============================================================*/
        create table t_dept ( dept_id varchar(32) not null, company_id varchar(32) not null, name varchar(32), primary key (dept_id) );
    
        /*==============================================================*/
        /* Table: t_employee */
        /*==============================================================*/
        create table t_employee ( person_id varchar(32) not null, dept_id varchar(32), name varchar(32), employee_id varchar(32), primary key (person_id) );
    
        /*==============================================================*/
        /* Table: t_person */
        /*==============================================================*/
        create table t_person ( person_id varchar(32) not null, dept_id varchar(32) not null, name varchar(32), primary key (person_id) );
    
        /*==============================================================*/
        /* Table: t_privilege */
        /*==============================================================*/
        create table t_privilege ( privilege_id varchar(32) not null, name varchar(32), primary key (privilege_id) );
    
        /*==============================================================*/
        /* Table: t_role */
        /*==============================================================*/
        create table t_role ( role_id varchar(32) not null, name varchar(32), primary key (role_id) );
    
        /*==============================================================*/
        /* Table: t_role_privilege */
        /*==============================================================*/
        create table t_role_privilege ( role_id varchar(32) not null, privilege_id varchar(32) not null, primary key (role_id, privilege_id) );
    
        alter table person_role add constraint FK_person_role foreign key (person_id) references t_person (person_id) on delete restrict on update restrict;
    
        alter table person_role add constraint FK_person_role2 foreign key (role_id) references t_role (role_id) on delete restrict on update restrict;
    
        alter table t_dept add constraint FK_companty_dept foreign key (company_id) references t_company (company_id) on delete restrict on update restrict;
    
        alter table t_employee add constraint FK_inherit foreign key (person_id) references t_person (person_id) on delete restrict on update restrict;
    
        alter table t_person add constraint FK_dept_person foreign key (dept_id) references t_dept (dept_id) on delete restrict on update restrict;
    
        alter table t_role_privilege add constraint FK_belong foreign key (role_id) references t_role (role_id) on delete restrict on update restrict;
    
        alter table t_role_privilege add constraint FK_own foreign key (privilege_id) references t_privilege (privilege_id) on delete restrict on update restrict;

在数据库生成八张表：

![这里写图片描述][SouthEast 19]

--------------------

## 在Idea下使用Hibernate逆向工程 ##

![这里写图片描述][SouthEast 20]

值得注意的是：**Intellij idea下生成出来的映射文件是没有对应的关联关系的**。也就是说：一对多或多对多的关系，**它是不会帮你自动生成的【好像是这样子的】**。。。因此，需要我们自己添加Set【如果需要】

[更新，如果想要体现对应的关联关系的话，请参考该博文！][Link 1]

*  [https://my.oschina.net/wangyuefive/blog/683771][Link 1]

--------------------

> 如果文章有错的地方欢迎指正，大家互相交流。习惯在微信看技术文章，想要获取更多的Java资源的同学，可以**关注微信公众号:Java3y**

[SouthEast]: /images/20210827/ae1d2b1bd52b4a42aefda500413f0060.png
[SouthEast 1]: /images/20210827/858dee5a0103427b86ac6e2596f1be6b.png
[SouthEast 2]: /images/20210827/e78eae6ddd8d43558c5e985f509434da.png
[SouthEast 3]: /images/20210827/3fc24c2516364b9083a9e5fecb0cbe40.png
[SouthEast 4]: /images/20210827/7748ef124ce14cdb9b576f2782897a2e.png
[SouthEast 5]: /images/20210827/b57f4ecfb50e413c96648071c4953bac.png
[SouthEast 6]: /images/20210827/94458a6c28ff4affa3f0660d5a112dac.png
[SouthEast 7]: /images/20210827/0b7451911a0b44b4a2fe04a7101a5e43.png
[SouthEast 8]: /images/20210827/f14b246e0d404c0dad7f9a59f11a3612.png
[SouthEast 9]: /images/20210827/e3a19bf9872942408cbf2dc08ecd3534.png
[SouthEast 10]: /images/20210827/6db0355658864556aa68596612a7902d.png
[SouthEast 11]: /images/20210827/6a5b7a60b8a94ab89ff86e88f8dfb585.png
[SouthEast 12]: /images/20210827/c7cab128200d4233a5fff136536dbcee.png
[SouthEast 13]: /images/20210827/c8047ba0e9e943a693a2820c85679e45.png
[SouthEast 14]: /images/20210827/398af10cdcee4b249011a9399e3639ce.png
[SouthEast 15]: /images/20210827/4666d851de684f1ba410e7a016a89ca8.png
[SouthEast 16]: /images/20210827/08b14c7ad9734458b7004003db1fe2bb.png
[SouthEast 17]: /images/20210827/3b89fd4dc5b24e7da37127eb86636906.png
[SouthEast 18]: /images/20210827/5a899b5195144e2684f9eef4f4df60f1.png
[SouthEast 19]: /images/20210827/39dc995a30d64b5d801b73a5026a5293.png
[SouthEast 20]: /images/20210827/b6297557a8dc4bf69302f237c3522b7d.png
[Link 1]: https://my.oschina.net/wangyuefive/blog/683771