未在Hibernate中工作的联接查询

Question

我正在使用inner-join执行hibernate-session.createQuery()查询，得到了以下错误：

Feb 21, 2014 5:22:07 PM org.hibernate.hql.internal.ast.ErrorCounter reportError
ERROR: line 1:151: unexpected token: on
Feb 21, 2014 5:22:07 PM org.hibernate.hql.internal.ast.ErrorCounter reportError
ERROR: line 1:151: unexpected token: on
line 1:151: unexpected token: on
    at org.hibernate.hql.internal.antlr.HqlBaseParser.fromJoin(HqlBaseParser.java:1693)
    at org.hibernate.hql.internal.antlr.HqlBaseParser.fromClause(HqlBaseParser.java:1348)
    at org.hibernate.hql.internal.antlr.HqlBaseParser.selectFrom(HqlBaseParser.java:1054)
    at org.hibernate.hql.internal.antlr.HqlBaseParser.queryRule(HqlBaseParser.java:700)
    at org.hibernate.hql.internal.antlr.HqlBaseParser.selectStatement(HqlBaseParser.java:294)
    at org.hibernate.hql.internal.antlr.HqlBaseParser.statement(HqlBaseParser.java:157)
    at org.hibernate.hql.internal.ast.QueryTranslatorImpl.parse(QueryTranslatorImpl.java:266)
    at org.hibernate.hql.internal.ast.QueryTranslatorImpl.doCompile(QueryTranslatorImpl.java:180)
    at org.hibernate.hql.internal.ast.QueryTranslatorImpl.compile(QueryTranslatorImpl.java:136)
    at org.hibernate.engine.query.spi.HQLQueryPlan.<init>(HQLQueryPlan.java:106)
    at org.hibernate.engine.query.spi.HQLQueryPlan.<init>(HQLQueryPlan.java:81)
    at org.hibernate.engine.query.spi.QueryPlanCache.getHQLQueryPlan(QueryPlanCache.java:167)
    at org.hibernate.internal.AbstractSessionImpl.getHQLQueryPlan(AbstractSessionImpl.java:217)
    at org.hibernate.internal.AbstractSessionImpl.createQuery(AbstractSessionImpl.java:195)
    at org.hibernate.internal.SessionImpl.createQuery(SessionImpl.java:1649)
    at com.sanyasi.masterDataActions.ModifyDistrictsAction.display(ModifyDistrictsAction.java:41)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at com.opensymphony.xwork2.DefaultActionInvocation.invokeAction(DefaultActionInvocation.java:453)
    at com.opensymphony.xwork2.DefaultActionInvocation.invokeActionOnly(DefaultActionInvocation.java:292)
    at com.opensymphony.xwork2.DefaultActionInvocation.invoke(DefaultActionInvocation.java:255)
    at org.apache.struts2.interceptor.debugging.DebuggingInterceptor.intercept(DebuggingInterceptor.java:256)

我的问题是：

select dist.districtName, dist.status, stat.stateName from sa_district_master dist inner join sa_state_master stat on dist.stateId = stat.stateId

但是，如果我在-sql控制台上执行相同的查询，则它执行得非常完美，并提供了O/P：

+--------------+--------+-----------+
| districtName | status | stateName |
+--------------+--------+-----------+
| Hisar        | 0      | HARYANA   |
| Gurgaon      | 0      | HARYANA   |
| Ambala       | 0      | HARYANA   |
| Rohtak       | 0      | HARYANA   |
| Sirsa        | 0      | HARYANA   |
+--------------+--------+-----------+

我的Hibernate代码

try{
        hibernateSession = HibernateUtil.getSession();
        if(hibernateSession != null){
            Query query = hibernateSession.createQuery("select dist.districtName, dist.status, stat.stateName from sa_district_master dist inner join sa_state_master stat on dist.stateId = stat.stateId");
            List list = query.list();
            for (Object object : list) {
                Object[] objArray = (Object[])object;
                System.out.println("Obj : " + objArray[0]);
            }
        }
    } catch (Exception e){
        e.printStackTrace();
    }finally {
        hibernateSession.flush();
        hibernateSession.close();
    }

我不明白为什么我会犯错..。

plzzz帮助..。

(如果你还想要什么，请告诉我)

Answer 1

您的查询似乎更像是标准SQL查询，而不是HQL查询。使用Session#createSQLQuery(String sqlQuery)方法创建如下所示的SQL查询。

Query query = hibernateSession.createSQLQuery("select dist.districtName, dist.status, stat.stateName from sa_district_master dist inner join sa_state_master stat on dist.stateId = stat.stateId");

Answer 2

Query query = hibernateSession.createSQLQuery("select dist.districtName, dist.status, stat.stateName from sa_district_master dist inner join sa_state_master stat on dist.stateId = stat.stateId");

mysql使用.createSQLQuery方法

Answer 3

您使用的是SQL查询，因此需要创建一个SQLQuery。

try{
    hibernateSession = HibernateUtil.getSession();
    if(hibernateSession != null){
        Query query = hibernateSession.createSQLQuery("select dist.districtName, dist.status, stat.stateName from sa_district_master dist inner join sa_state_master stat on dist.stateId = stat.stateId");
        List list = query.list();
        for (Object object : list) {
            Object[] objArray = (Object[])object;
            System.out.println("Obj : " + objArray[0]);
        }
    }
} catch (Exception e){
    e.printStackTrace();
}finally {
    hibernateSession.flush();
    hibernateSession.close();
}