当前位置:首页 > 开发 > 系统架构 > 架构 > 正文

JPA之JPQL(三)

发表于: 2015-03-16   作者:frank1234   来源:转载   浏览:
摘要: 1 什么是JPQL JPQL是Java Persistence Query Language的简称,可以看成是JPA中的HQL, JPQL支持各种复杂查询。 2 检索单个对象 @Test public  void querySingleObject1() {     Query query = em.createQuery("sele
1 什么是JPQL
JPQL是Java Persistence Query Language的简称,可以看成是JPA中的HQL, JPQL支持各种复杂查询。

2 检索单个对象
@Test
public  void querySingleObject1() {
    Query query = em.createQuery("select * from Course where id=?1");
    query.setParameter(1,47);
    Course course = (Course)query.getSingleResult();
    System.out.println(course);

}

抛异常:
java.lang.IllegalArgumentException: org.hibernate.hql.ast.QuerySyntaxException: unexpected token: * near line 1, column 8

@Test
public  void querySingleObject2() {
    Query query = em.createQuery("select id,name from Course where id=?1");
    query.setParameter(1,47);
    Course course = (Course)query.getSingleResult();
    System.out.println(course);

}
抛异常:
java.lang.ClassCastException: [Ljava.lang.Object; cannot be cast to org.frank1234.jpa.helloworld.Course

正确的方式是:
@Test
public  void querySingleObject3() {
    Query query = em.createQuery("select c from Course c where id=?1");
    query.setParameter(1,47);
    Course course = (Course)query.getSingleResult();
    System.out.println(course);
}

或者:
@Test
public  void querySingleObject4() {
    Query query = em.createQuery(" from Course  where id=?1");
    query.setParameter(1,47);
    Course course = (Course)query.getSingleResult();
    System.out.println(course);
}


3 绑定参数
1)拼字符串方式
@Test
public  void bindparameter1() {
    int id = 47;
    Query query = em.createQuery("select c from Course c where id='"+id+"'");
    Course course = (Course)query.getSingleResult();
    System.out.println(course);
}


2)按参数名字绑定

@Test
public  void bindparameter2() {
    Query query = em.createQuery("select c from Course c where id=:id");
    query.setParameter("id",47);
    Course course = (Course)query.getSingleResult();
    System.out.println(course);
}


3)按参数位置绑定

@Test
public  void bindparameter3() {
    Query query = em.createQuery("select c from Course c where id=?1");
    query.setParameter(1,47);
    Course course = (Course)query.getSingleResult();
    System.out.println(course);
}


4 排序
@Test
public  void orderby() {
    Query query = em.createQuery("select c from Course c order by id desc");
    List<Course> courses = query.getResultList();
   for(Course course:courses){
       System.out.println(course);
   }
}


同SQL语法一致。

5 分页
@Test
public  void pagging() {
    Query query = em.createQuery("select c from Course c order by id desc");
    query.setFirstResult(0).setMaxResults(10);//从第一个开始取,取10个

    List<Course> courses = query.getResultList();
    for(Course course:courses){
        System.out.println(course);
    }
}


同hibernate一样,仍然支持方法链编程风格。


6 命名查询
<hibernate-mapping>
   ...
    <query name="getCourse">
      from Course where id=?1
    </query>
</hibernate-mapping>


@Test
public  void namedQuery() {
    Query query = em.createNamedQuery("getCourse");
    query.setParameter(1, 47);
    Course course = (Course)query.getSingleResult();
    System.out.println(course);
}



7 投影查询
@Test
public  void shadowQuery() {
    Query query = em.createQuery("select name from Course where id=?1");
    query.setParameter(1, 47);
    String courseName = (String)query.getSingleResult();
    System.out.println(courseName);
}


8 聚合函数
JPQL中可以使用count avg sum min max 这些聚合函数。
例如:
@Test
public  void count1() {
    Query query = em.createQuery("select count(*) from Course ");
    Long count = (Long)query.getSingleResult();
    System.out.println(count);
}

@Test
public  void count2() {
    Query query = em.createQuery("select max(name),min(name) from Course ");
    Object[] count = (Object[])query.getSingleResult();
    System.out.println(count[0]+","+count[1]);
}



9 分组
示例:
@Test
public  void groupby() {
    Query query  = em.createQuery("select name,count(*) from Course group by name");
    Iterator it = query.getResultList().iterator();
    while(it.hasNext()){
        Object[] obj = (Object[])it.next();
        System.out.println("obj[0]="+obj[0]+",obj[1]="+obj[1]);
    }
}

10 关联查询
Clazz对象和Student对象是1:N的双向关联关系,类的源码及表结构请参见:[url]http://frank1234.iteye.com/blog/2172205 [/url]

@Test
public  void join1() {
    Query query  = em.createQuery("from Clazz a , Student b where a.id= b.clazz");
    List list = query.getResultList();
    Iterator it = list.iterator();
    while(it.hasNext()){
        Object[] obj = (Object[])it.next();
        Clazz clazz = (Clazz) obj[0];
        System.out.println("clazz="+clazz);
        Student student = (Student)obj[1];
        System.out.println("student="+student);
    }
}


或者:
@Test
public  void join2() {
    Query query  = em.createQuery("from Clazz a join a.students");
    List list = query.getResultList();
    Iterator it = list.iterator();
    while(it.hasNext()){
        Object[] obj = (Object[])it.next();
        Clazz clazz = (Clazz) obj[0];
        System.out.println("clazz="+clazz);
        Student student = (Student)obj[1];
        System.out.println("student="+student);
    }
}






11 批量更新
@Test
public  void batchupdate() {
    em.getTransaction().begin();
    try {
        Query query  = em.createQuery("update Course  set name='batchupdate' where id > 50");
        query.executeUpdate();
        em.getTransaction().commit();
    }catch (Exception e){
        e.printStackTrace();
        em.getTransaction().rollback();
    }
}

12.获取Connection
Connection conn =  ((HibernateEntityManager)em).getSession().connection();



13.悲观锁
@Test
    public  void lock() {
        em.getTransaction().begin();
        Query query = em.createQuery("from Course c where id=?1");
        query.setParameter(1,47);
//        query.setLockMode(LockModeType.WRITE);
        query.setLockMode(LockModeType.PESSIMISTIC_WRITE);//这个和下面的放开任何一个。
        query.setLockMode(LockModeType.PESSIMISTIC_READ);
        Course course = (Course)query.getSingleResult();
            System.out.println(course);
            em.getTransaction().commit();//提交之前,其他事务的写会被阻塞。
    }

JPA之JPQL(三)

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
1 JPA概述 JPA是 Java Persistence API的简称,是Sun推出的J2EE规范之一,是ORM规范,Hibernate,TOP
1 JPA概述 JPA是 Java Persistence API的简称,是Sun推出的J2EE规范之一,是ORM规范,Hibernate,TOP
1 JPA概述 JPA是 Java Persistence API的简称,是Sun推出的J2EE规范之一,是ORM规范,Hibernate,TOP
1 JPA概述 JPA是 Java Persistence API的简称,是Sun推出的J2EE规范之一,是ORM规范,Hibernate,TOP
1 JPA概述 JPA是 Java Persistence API的简称,是Sun推出的J2EE规范之一,是ORM规范,Hibernate,TOP
1 JPA状态转换图 要理解JPA的核心接口,这个图必须牢记。 分为4种状态: 1)New状态:未有id,未与Pe
1 JPA状态转换图 要理解JPA的核心接口,这个图必须牢记。 分为4种状态: 1)New状态:未有id,未与Pe
1 JPA状态转换图 要理解JPA的核心接口,这个图必须牢记。 分为4种状态: 1)New状态:未有id,未与Pe
一、项目结构图 二、pom文件 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="h
1 JPA状态转换图 要理解JPA的核心接口,这个图必须牢记。 分为4种状态: 1)New状态:未有id,未与Pe
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号