第八章 Hibernate数据操作技巧
8.1 分组统计数据
语法：[select]... from ...[where] [group by...[having...]] [order by...]
8.1.1 聚合函数
1、count():统计记录数
例：Long count=(Long) session.createQuery("select count(*) from Dept d").uniqueResult();
System.out.println("记录条数:"+count);
2、sum():求和
例：Double salSum=(Double) session.createQuery("select sum(e.sal) from Emp e ").uniqueResult();
System.out.println("求和:"+salSum);
3、min():求最小值
例：Double sal1=(Double) session.createQuery("select min(e.sal) from Emp e").uniqueResult();
System.out.println("最小值:"+sal1);
4、max():求最大值
例：Double sal2=(Double) session.createQuery("select max(e.sal) from Emp e").uniqueResult();
System.out.println("最大值:"+sal2);
5、avg():求平均值
例：Double sal3=(Double) session.createQuery("select avg(e.sal) from Emp e").uniqueResult();
System.out.println("平均值:"+sal3);
8.1.2 分组查询
GROUP BY...HAVING...
例1 ：按职位统计员工个数
List<Object[]> list=session.createQuery("select job,count(e) from Emp e group by job").list();
for(Object[] obj:list){
System.out.println(obj[0]+","+obj[1]);
}
例2： 统计各个部门的平均工资
Iterator<Object[]> it=session.createQuery
("select e.dept.dname,avg(e.sal) from Emp e group by e.dept.dname").list().iterator();
Object[] obj=null;
while(it.hasNext()){
obj=it.next();
System.out.println(obj[0]+","+obj[1]);
}
8.2 子查询
8.2.1 子查询关键字
all 子查询语句返回所有记录
any 子查询语句返回任意一条记录
some 与any相同
in 与=any相同
exists 子查询语句知识返回一条记录
例1：查询所有员工工资都小于5000的部门
List<Dept> list=session.createQuery("from Dept d where 5000>all(select e.sal from d.emps e)").list();
for(Dept dept:list){
System.out.println(dept.getDname());
}
例2：查询至少有一位职员工资低于5000的部门
List<Dept> list=session.createQuery("from Dept d where 5000>any(select e.sal from d.emps e)").list();
for(Dept dept:list){
System.out.println(dept.getDname());
}
例3： 查询所有员工工资正好是5000的部门
List<Dept> list=session.createQuery("from Dept d where 5000=any(select e.sal from d.emps e)").list();
for(Dept dept:list){
System.out.println(dept.getDname());
}
例4：查询至少有一位员工的部门
List<Dept> list=session.createQuery("from Dept d where exists (from d.emps)").list();
for(Dept dept:list){
System.out.println(dept.getDname());
}
8.2.2 操作集合的函数或属性
size(),size 获取集合中元素的个数
minIndex(),minIndex 对于建立了索引的集合，获得最小的索引
maxIndex(),maxIndex 对于建立了索引的集合，获得最大的索引
minElement(),minElement 对于包含基本类型元素的集合，获得集合中取值最小的元素
maxElement(),maxElement 对于包含基本类型元素的集合，获得集合中取值最大的元素
elements() 获取集合中所有的元素
例1：查询指定员工所在部门
Emp emp=new Emp();
emp.setEmpno(1);
List<Dept> list=session.createQuery("from Dept d where ? in elements(d.emps)")
.setParameter(0, emp).list();
for(Dept dept:list){
System.out.println(dept.getDname());
}
例2： 查询员工个数大于5的部门
List<Dept> list=session.createQuery("from Dept d where d.emps.size>5").list();
for(Dept dept:list){
System.out.println(dept.getDname());
}
8.3 原生SQL查询和命名查询
8.3.1 原生SQL查询
例：查询指定工作Job和包含E字母的员工编号和姓名
Query query=session.createSQLQuery(
"select * from EMP where ENAME like :ename and JOB=:job").setString("ename", "%E%").setString("job", "SALESMAN");
List<Object[]> list=query.list();
for(Object[] obj:list){
System.out.println(obj[0]+","+obj[1]);
}
addEntity()方法
例：查询指定工作Job和包含E字母的员工编号和姓名
Query query=session.createSQLQuery(
"select * from EMP where ENAME like :ename and JOB = :job").addEntity(Emp.class).setString("ename", "%E%").setString("job", "SALESMAN");
List<Object[]> list=query.list();
for(Object[] obj:list){
System.out.println(obj[0]+","+obj[1]);
}
addJoin()方法
例：查询指定职位的员工，输出员工姓名和部门名称
String sql="select {e.*},{d.*} from EMP e join DEPT d on d.DEPTNO=e.DEPTNO where e.JOB=:job";
Query query=session.createSQLQuery(sql).addEntity("e",Emp.class).addJoin("d", "e.dept").setString("job", "SALESMAN");
List<Object[]> list=query.list();
Emp emp=null;
Dept dept=null;
for(Object[] obj:list){
System.out.println(obj[0]+","+obj[1]);
emp=(Emp) obj[0];
dept=(Dept) obj[1];
System.out.println(emp.getEname()+","+dept.getDname());
}
8.3.2 命名查询
8.3.2.1 HQL查询语句的命名查询
例：Emp.hbm.xml
<query name="findEmpByJob">
<![CDATA[
from Emp e where e.job=:job
]]>
</query>
测试代码：
List<Emp> list=session.getNamedQuery("findEmpByJob").setString("job", "SALESMAN").list();
for(Emp emp:list){
System.out.println(emp.getEname()+","+emp.getJob());
}
8.3.2.2 原生SQL查询语句的命名查询
例1：Emp.hbm.xml
<sql-query name="selectEmpByJob">
<return alias="e" class="com.entity.Emp"></return>
select {e.*} from EMP e where e.job=:job
</sql-query>
测试代码：
List<Emp> list=session.getNamedQuery("selectEmpByJob").setString("job", "SALESMAN").list();
for(Emp emp:list){
System.out.println(emp.getEname()+","+emp.getJob());
}
例2：Emp.hbm.xml
<sql-query name="selectEmpByJobJoinDept">
<return alias="e" class="com.entity.Emp"></return>
<return-join alias="d" property="e.dept"></return-join><!--return-join用于持久化类之间的连接 alias用于指定别名 property用于指定属性名称 -->
select {e.*},{d.*} from EMP e join DEPT d on d.DEPTNO=e.DEPTNO where e.JOB=:job
</sql-query>
测试代码：
List<Object[]> list=session.getNamedQuery("selectEmpByJobJoinDept").setString("job", "SALESMAN").list();
Emp emp=null;
Dept dept=null;
for(Object[] obj:list){
System.out.println(obj[0]+","+obj[1]);
emp=(Emp) obj[0];
dept=(Dept) obj[1];
System.out.println(emp.getEname()+","+dept.getDname());
}
8.4 BLOB和CLOB类型
8.4.1 映射方法
大对象类型映射
byte[] BLOB
java.lang.String CLOB
java.sql.Clob CLOB
java.sql.BLOB BLOB
1、字符串大对象声明为java.lang.String,二进制大对象声明为byte[]类型
创建实体类和映射文件
在类路劲下创建一个为file.txt的文件
使用setTclob("插入文本")方法赋值 ，把二进制对象BLOB类型映射为java类型的byte[]，需要准备字节数组使用setTblob(byteArray)方法赋值
查询使用obj.getTblob方法获取字节数组，通过文件输出流FileOutputStream把字节数组输出到文件中
2、字符串大对象声明为java.sql.Clob,二进制大对象声明为java.lang.Blob类型
创建实体类和映射文件
在类路劲下创建一个为file.txt的文件
从表中按主键读取一天记录
例：Bigobject_2 big=(Bigobject_2) session.get(Bigobject_2.class, 28);
if(big.getTclob()!=null){
try {
Reader reader = big.getTclob().getCharacterStream();
char[] charray=new char[1];
StringBuffer builder=new StringBuffer();
while(reader.read(charray)!=-1){
builder.append(new String(charray));
}
System.out.println(builder.toString().trim());
reader.close();
} catch (IOException e) {
e.printStackTrace();
} catch (SQLException e1) {
e1.printStackTrace();
}
}
if(big.getTblob()!=null){
try {
InputStream in=big.getTblob().getBinaryStream();
FileOutputStream fos=new FileOutputStream("file.txt");
int b=-1;
while((b=in.read()) !=-1){
fos.write(b);
}
fos.close();
in.close();
} catch (SQLException e) {
e.printStackTrace();
} catch (FileNotFoundException e) {
e.printStackTrace();
}catch (IOException e) {
e.printStackTrace();
}
}