Hibernate 关于执行sql查询语句(转)

原文  http://www.yshjava.cn/post/543.html

主题 SQLHibernate

Hibernate对原生SQL查询的支持和控制是通过SQLQuery接口实现的。通过Session接口,我们能够很方便的创建一个SQLQuery(SQLQuery是一个接口,在Hibernate4.2.2之前,默认返回的是SQLQuery的实现类——SQLQueryImpl对象,在下文中出现的SQLQuery如非注明,都是指该子类)对象来进行原生SQL查询:

session.createSQLQuery(String sql);

SQLQuery实现了Query接口,因此你可以使用Query接口中提供的API来获取数据。

最简单的示例

//获取所有查询结果
session.createSQLQuery("select * from note").list();
//仅获取第一条结果
session.createSQLQuery("select * from note where id = 1").uniqueResult();

使用预处理SQL

预处理SQL的好处自然不必多说,除了众所周知的能够防止SQL注入攻击外,还能够在一定程度上提高SQL的查询效率。SQLQuery提供了众多的接口来分别设置不同类型的参数,诸如setBigDecimal、setBinary、setDouble等,详参SQLQuery的JavaDoc,此处不再赘述。这里仅重点说一下通用的SQL参数设置接口setParameter。

如下代码示范了如何使用SQLQuery执行预处理SQL:

SQLQuery query = session.createSQLQuery("select * from note where id = ?");
//设置第一个参数的值为12,即查询ID=12的note
query.setParameter(0, 12);
List list = query.list();
...

这里需要注明一点, 无论是通过不同类型参数的设置接口来设置SQL参数,还是通过setParameter来设置参数,下标都是从0开始的,而不是从1开始的 !

使用自定义的结果转换器处理查询结果

SQLQuery接口预留了setResultTransformer接口以实现使用用户自定义的ResultTransformer结果集转换器处理查询结果。ResultTransformer接口非常简单,只有两个方法,分别用来转换单行数据和所有结果数据。经过自定义ResultTransformer生成的实体,并未加入Session,因此是非受管实体。

如下代码,示范了如何将单行数据装入LinkedHashMap对象中:

query.setResultTransformer(new ResultTransformer() {

   @Override
   public Object transformTuple(Object[] values, String[] columns) {
      Map<String, Object> map = new LinkedHashMap<String, Object>(1);
      int i = 0;
      for(String column : columns){
         map.put(column, values[i++]);
      }
      return map;
   }

   @Override
   public List transformList(List list) {
      return list;
   }
});

如果不设置自定义的ResultTransformer转换器,则Hibernate将每行返回结果的数据按照结果列的顺序装入Object数组中。

这里介绍一个工具类: Transformers ,它提供了一些常用的转换器,能够帮助我们快速转换结果集,如 Transformers.aliasToBean(Note.class) 能够将查询结果依别名注入到Note实体中。

使用标量

使用SQLQuery执行原生SQL时,Hibernate会使用ResultSetMetadata来判定返回的标量值的实际顺序和类型。如果要避免过多的使用ResultSetMetadata,或者只是为了更加明确的指名返回值,可以使用addScalar()。

session.createSQLQuery("select * from note where id = 1")
 .addScalar("id", LongType.INSTANCE)
 .addScalar("name", StringType.INSTANCE)
 .addScalar("createtime", DateType.INSTANCE);

这个查询指定了SQL查询字符串,要返回的字段和类型.它仍然会返回Object数组,但是此时不再使用ResultSetMetdata,而是明确的将id,name和createtime按照Long, String和Date类型从resultset中取出。同时,也指明了就算query是使用*来查询的,可能获得超过列出的这三个字段,也仅仅会返回这三个字段。

对全部或者部分的标量值不设置类型信息也是可以的:

session.createSQLQuery("select * from note where id = 1")
 .addScalar("id")
 .addScalar("name")
 .addScalar("createtime", DateType.INSTANCE);

没有被指定类型的字段将仍然使用ResultSetMetdata获取其类型。 注意 ,字段不区分大小写,同时不能够指定不存在的字段 !

关于从ResultSetMetaData返回的java.sql.Types是如何映射到Hibernate类型,是由方言(Dialect)控制的。假若某个指定的类型没有被映射,或者不是你所预期的类型,你可以通过Dialet的registerHibernateType调用自行定义。

如果仅指定了一个scalar,那么...

Date createTime = (Date)session.createSQLQuery("select * from note where id = 1")
 .addScalar("createtime", DateType.INSTANCE)
 .uniqueResult();

如果我们的SQL语句使用了聚合函数,如count、max、min、avg等,且返回结果仅一个字段,那么Hibernate提供的这种提取标量结果的方式就非常便捷了。

实体查询

上面的查询都是返回标量值的,也就是从resultset中返回的“裸”数据。下面展示如何通过addEntity()让原生查询返回实体对象。

session.createSQLQuery("select * from note where id = 1").addEntity(Note.class);
session.createSQLQuery("select id,name,createtime from note where id = 1").addEntity(Note.class);

这个查询指定SQL查询字符串,要返回的实体。假设Note被映射为拥有id,name和createtime三个字段的类,以上的两个查询都返回一个List,每个元素都是一个Note实体。

假若实体在映射时有一个many-to-one的关联指向另外一个实体,在查询时必须也返回那个实体,否则会导致发生一个"column not found"的数据库错误。这些附加的字段可以使用*标注来自动返回,但我们希望还是明确指明,看下面这个具有指向Dog的many-to-one的例子:

session.createSQLQuery("select id,note,createtime,author from note where id = ?").addEntity(Note.class);

author字段即为Note实体和Author实体的关联字段,只需在查询时得到该字段的值,Hibernate即可使用该值找到对应的关联实体。如上例中,note.getAuthor()即可返回当前Note所属的Author对象。

处理关联和集合类

通过提前抓取将Author连接获得,而避免初始化proxy带来的额外开销也是可能的。这是通过addJoin()方法进行的,这个方法可以让你将关联或集合连接进来。

session.createSQLQuery("select {note.*}, {author.*} from note note, user author where note.author = author.id")
 .addEntity("note", Note.class)
 .addJoin("author", "note.author");

上面的例子是多对一的关联查询,反过来做一对多的关联查询也是可以的。如下的例子中,author.notes表示该用户发表的所有日记(Note),Set集合类型:

session.createSQLQuery("select {author.*},{note.*} from note note, user author where author.id = ? and note.author = author.id")
 .addEntity("author", User.class)
 .addJoin("note", "author.notes");

注意 : join查询会在每行返回多个实体对象,处理时需要注意 。

别名和属性引用

假若SQL查询连接了多个表,同一个字段名可能在多个表中出现多次,这会导致SQL错误。不过在我们可以通过使用占位符来完美地解决这一问题。

其实在上例中已经用到了占位符:

session.createSQLQuery("select {note.*}, {author.*} from note note, user author where note.author = author.id")
 .addEntity("note", Note.class)
 .addJoin("author", "note.author");

这个查询指明SQL查询语句,其中包含占位附来让Hibernate注入字段别名,查询并返回的实体。

上面使用的{note.*}和{author.*}标记是作为“所有属性”的简写形式出现的,当然你也可以明确地罗列出字段名。但如下的范例代码中我们让Hibernate来为每个属性注入SQL字段别名,字段别名的占位符是表别名 + . + 属性名。

注意 : 属性名区分大小写,而且不能够在where子句中使用占位符 。

SQLQuery query = session.createSQLQuery("select note.id as {note.id},note as {note.note},createtime as {note.createTime},author as {note.author}, {author.*} from note, user author where note.id = ? and note.author = author.id");
query.addEntity("note", Note.class);
query.addJoin("author", "note.author");

大多数情况下,上面的别名注入方式可以满足需要,但在使用更加复杂的映射,比如复合属性、通过标识符构造继承树,以及集合类等等情况下,则需要更加复杂的别名注入方式。

下表列出了使用别名注射参数的不同方式:

 别名注入(alias injection names) 描述  语法  示例
 简单属性  {[aliasname].[propertyname]  A_NAME as {item.name}
 复合属性  {[aliasname].[componentname].[propertyname]}  CURRENCY as {item.amount.currency}, VALUE as {item.amount.value}
 实体辨别器  {[aliasname].class}  DISC as {item.class}
 实体的所有属性  {[aliasname].*}  {item.*}
 集合键(collection key)  {[aliasname].key}  ORGID as {coll.key}
 集合id  {[aliasname].id}  EMPID as {coll.id}
 集合元素  {[aliasname].element}  XID as {coll.element}
 集合元素的属性  {[aliasname].element.[propertyname]}  NAME as {coll.element.name}
 集合元素的所有属性  {[aliasname].element.*}  {coll.element.*}
 集合的所有属性  {[aliasname].*}  {coll.*}

在hbm文件中描述结果集映射信息,并在查询中使用

对于一些复杂的结果集映射,往往需要像MyBatis那样在文件中手动配置好,然后在程序中使用。幸运的是Hibernate也提供了类似的功能,你可以使用自己配置的结果集映射来处理返回的结果集数据:

SQLQuery query = session.createSQLQuery("select note.id as {note.id},note as {note.note},createtime as {note.createTime},author as {note.author}, {author.*} from note, user author where note.id = ? and note.author = author.id");
//使用在hbm文件中配置的自定义结果集映射
query.setResultSetMapping("noteAnduthor");
query.list();

执行更新操作

使用SQLQuery执行数据库更新操作比较容易,除了像查询时那样需要指定SQL语句(如有需要还需设置SQL参数)外,仅需调用executeUpdate()方法,即可提交更新操作。代码如下所示:

session.createSQLQuery("update createtime = ? from note where note.id = ?");
query.setDate(0, new Date());
query.setLong(1, 1L);
query.executeUpdate();

executeUpdate方法的返回结果为改变的数据库记录的行数。

时间: 2024-10-23 18:55:05

Hibernate 关于执行sql查询语句(转)的相关文章

EF5中 执行 sql语句使用Database.ExecuteSqlCommand 返回影响的行数 ; EF5执行sql查询语句 Database.SqlQuery 带返回值

一: 执行sql语句,返回受影响的行数 在mysql里面,如果没有影响,那么返回行数为  -1 ,sqlserver 里面  还没有测试过 using (var ctx = new MyDbContext()) { ctx.Database.ExecuteSqlCommand("UPDATE Person SET Name = 'Michael' WHERE PersonID = 1"); } 二 : Database.SqlQuery<T>   EF5执行sql查询语句

oracle新建用户执行sql查询语句出现错误ORA-00942:表或视图不存在

oracle创建新用户后客户端执行SQL查询后出现错误提示如下: 执行查询语句如下: select * from sm_sales_order; ORA-00942:表或视图不存在 创建新用户并指定表空间和临时表空间 CREATE USER xxx IDENTIFIED BY xxxx DEFAULT TABLESPACE LMS TEMPORARY TABLESPACE TEMP; 授予系统权限connect grant connect to xxx; 授予对象权限,只限查询 grant se

Oracle执行SQL查询语句的步骤

sql语句的执行主要由用户进程与服务器进程来完成,其他的一些进程可能要辅助完成这一过程. 查询语句与其他的sql语句有所不同,如果一个查询语句执行成功,就要返回查询结果,而其他的sql语句只是返回执行成功或失败的信息. 查询语句的主要 SQL语句的执行主要由用户进程与服务器进程来完成,其他的一些进程可能要辅助完成这一些过程. 查询语句与其他的SQL语句有所不同,如果一个查询语句执行成功,就要返回查询结果,而其他的SQL语句只是返回执行成功或执行失败的信息. 查询语句的处理主要包括以下3个阶段:编

C# 简单连接数据库并执行SQL查询语句

留着备用 private void button1_Click(object sender, EventArgs e) { SqlConnection conn = new SqlConnection(); conn.ConnectionString = "Data Source=.;Password=123456;User ID=sa;Initial Catalog=guo;database=guo"; conn.Open(); SqlCommand cmd = new SqlCom

浅谈SQL优化入门:1、SQL查询语句的执行顺序

1.SQL查询语句的执行顺序 (7) SELECT (8) DISTINCT <select_list> (1) FROM <left_table> (3) <join_type> JOIN <right_table> (2) ON <join_condition> (4) WHERE <where_condition> (5) GROUP BY <group_by_list> (6) HAVING <having_

关于用Hibernate执行sql查询,字符字段类型只返回第一个字节的问题

关于用Hibernate执行sql查询,字符字段类型只返回第一个字节的问题 今天遇到了一个问题,就是在Hibernate中,我用sql去查询mysql数据库里面的user表里面的username字段,但是发现查出来的数据都是只有第一个字,例如:在user表里面的username字段中有一条数据是:"Chen chiwei",查询后返回的结果却是这条数据的第一个字母:"C":于是乎,我查了一下user这张表的设计,发现username这个字段的类型是'char'类型,

一条SQL查询语句是如何执行的

一条SQL查询语句是如何执行的 下面是MySql的基本架构示意图,从图中可以清楚地看到SQL语句在MySQL的各个功能模块中的执行过程. 大体来讲,MySQL可以分为Server层和存储引擎层两部分. Server层 Server层包括连接器.查询缓存.分析器.优化器.执行器等,涵盖了MySql的大多数核心服务功能以及所有的内置函数,所有跨存储引擎的功能都在这一层实现,比如存储过程.触发器.视图等. 存储引擎层 而存储引擎层负责数据的存储与提取.其架构模式是插件式的,支持InnoDB.MyISA

sql查询语句并不是最先执行SELECT

很多的SQL查询语句都是以SELECT关键字开始的,所以我们很容易会以为SQL查询语句就是最先执行的SELECT.不过,当我尝试跟别人解释什么是窗口函数的时候,针对是否可以对窗口函数返回的结果进行过滤这个问题,最终得出的结论是窗口函数的执行必须在WHERE子句和GROUP BY子句之后,所以不能对窗口函数返回的结果进行再次过滤.于是我又想到了另一个问题:SQL查询的执行顺序究竟是怎样的? 这个问题好像应该很好回答,毕竟自己已经写了成千上万个SQL查询了,其中的一些还很复杂.但事实是,我仍然很难确

(转)经典SQL查询语句大全

一.基础 1.说明:创建数据库 CREATE DATABASE database-name 2.说明:删除数据库 drop database dbname 3.说明:备份sql server --- 创建 备份数据的 device USE master EXEC sp_addumpdevice 'disk', 'testBack', 'c:\mssql7backup\MyNwind_1.dat' --- 开始 备份 BACKUP DATABASE pubs TO testBack 4.说明:创建