Hibernate本机SQL查询示例
欢迎使用Hibernate Native SQL Query示例教程。
我们在之前的文章中研究了Hibernate Query Language和Hibernate Criteria,今天我们将通过示例研究Hibernate Native SQL查询。
Hibernate SQL查询
Hibernate提供了通过使用SQLQuery对象执行本机SQL查询的选项。
当我们必须执行Hibernate API不支持的数据库供应商特定查询时,Hibernate SQL Query非常方便。
例如,查询提示或者Oracle数据库中的CONNECT关键字。
在正常情况下,不建议使用Hibernate SQL查询,因为我们失去了与Hibernate关联和Hibernate一级缓存有关的好处。
我将使用与HQL示例中使用的MySQL数据库以及相同的表和数据设置,因此您应该先检查一下以了解表和对应的模型类映射。
Hibernate本机SQL示例
对于Hibernate Native SQL Query,我们使用Session.createSQLQuery(String query)创建SQLQuery对象并执行它。
例如,如果您想从Employee表中读取所有记录,我们可以通过以下代码来完成。
//Prep work
SessionFactory sessionFactory = HibernateUtil.getSessionFactory();
Session session = sessionFactory.getCurrentSession();
//Get All Employees
Transaction tx = session.beginTransaction();
SQLQuery query = session.createSQLQuery("select emp_id, emp_name, emp_salary from Employee");
List<Object[]> rows = query.list();
for(Object[] row : rows){
Employee emp = new Employee();
emp.setId(Long.parseLong(row[0].toString()));
emp.setName(row[1].toString());
emp.setSalary(Double.parseDouble(row[2].toString()));
System.out.println(emp);
}
当我们执行上述代码进行数据设置时,将产生以下输出。
Hibernate: select emp_id, emp_name, emp_salary from Employee
Id= 1, Name= hyman, Salary= 100.0, {Address= null}
Id= 2, Name= David, Salary= 200.0, {Address= null}
Id= 3, Name= Lisa, Salary= 300.0, {Address= null}
Id= 4, Name= Hyman, Salary= 400.0, {Address= null}
注意,list()方法返回Object数组的List,我们需要显式地将它们解析为double,long等。
我们的Employee和Address类具有以下toString()方法的实现。
@Override
public String toString() {
return "Id= " + id + ", Name= " + name + ", Salary= " + salary
+ ", {Address= " + address + "}";
}
@Override
public String toString() {
return "AddressLine1= " + addressLine1 + ", City=" + city
+ ", Zipcode=" + zipcode;
}
请注意,我们的查询没有返回地址数据,但是如果我们使用HQL查询"来自雇员",它也会返回关联的表数据。
Hibernate SQL查询addScalar
Hibernate使用" ResultSetMetadata"来推断查询返回的列的类型,从性能的角度来看,我们可以使用" addScalar()"方法来定义列的数据类型。
但是,我们仍将以对象数组的形式获取数据。
//Get All Employees - addScalar example
query = session.createSQLQuery("select emp_id, emp_name, emp_salary from Employee")
.addScalar("emp_id", new LongType())
.addScalar("emp_name", new StringType())
.addScalar("emp_salary", new DoubleType());
rows = query.list();
for(Object[] row : rows){
Employee emp = new Employee();
emp.setId(Long.parseLong(row[0].toString()));
emp.setName(row[1].toString());
emp.setSalary(Double.parseDouble(row[2].toString()));
System.out.println(emp);
}
生成的输出将相同,但是当数据巨大时,我们将看到轻微的性能改进。
Hibernate本机SQL多表
如果我们想同时从Employee和Address表中获取数据,我们可以简单地为此编写SQL查询并解析结果集。
query = session.createSQLQuery("select e.emp_id, emp_name, emp_salary,address_line1, city,
zipcode from Employee e, Address a where a.emp_id=e.emp_id");
rows = query.list();
for(Object[] row : rows){
Employee emp = new Employee();
emp.setId(Long.parseLong(row[0].toString()));
emp.setName(row[1].toString());
emp.setSalary(Double.parseDouble(row[2].toString()));
Address address = new Address();
address.setAddressLine1(row[3].toString());
address.setCity(row[4].toString());
address.setZipcode(row[5].toString());
emp.setAddress(address);
System.out.println(emp);
}
对于上面的代码,产生的输出将如下所示。
Hibernate: select e.emp_id, emp_name, emp_salary,address_line1, city, zipcode from Employee e, Address a where a.emp_id=e.emp_id
Id= 1, Name= hyman, Salary= 100.0, {Address= AddressLine1= Albany Dr, City=San Jose, Zipcode=95129}
Id= 2, Name= David, Salary= 200.0, {Address= AddressLine1= Arques Ave, City=Santa Clara, Zipcode=95051}
Id= 3, Name= Lisa, Salary= 300.0, {Address= AddressLine1= BTM 1st Stage, City=Bangalore, Zipcode=560100}
Id= 4, Name= Hyman, Salary= 400.0, {Address= AddressLine1= City Centre, City=New Delhi, Zipcode=100100}
Hibernate本机SQL实体和联接
我们还可以使用addEntity()和addJoin()方法使用表连接从关联表中获取数据。
例如,上面的数据也可以如下检索。
//Join example with addEntity and addJoin
query = session.createSQLQuery("select {e.*}, {a.*} from Employee e join Address a ON e.emp_id=a.emp_id")
.addEntity("e",Employee.class)
.addJoin("a","e.address");
rows = query.list();
for (Object[] row : rows) {
for(Object obj : row) {
System.out.print(obj + "::");
}
System.out.println("\n");
}
//Above join returns both Employee and Address Objects in the array
for (Object[] row : rows) {
Employee e = (Employee) row[0];
System.out.println("Employee Info::"+e);
Address a = (Address) row[1];
System.out.println("Address Info::"+a);
}
{{aliasname].*}用于返回实体的所有属性。
当我们对上面的联接查询使用" addEntity()"和" addJoin()"时,它将返回两个对象,如上所示。
上面的代码产生的输出如下。
Hibernate: select e.emp_id as emp_id1_1_0_, e.emp_name as emp_name2_1_0_, e.emp_salary as emp_sala3_1_0_, a.emp_id as emp_id1_0_1_, a.address_line1 as address_2_0_1_, a.city as city3_0_1_, a.zipcode as zipcode4_0_1_ from Employee e join Address a ON e.emp_id=a.emp_id
Id= 1, Name= hyman, Salary= 100.0, {Address= AddressLine1= Albany Dr, City=San Jose, Zipcode=95129}::AddressLine1= Albany Dr, City=San Jose, Zipcode=95129::
Id= 2, Name= David, Salary= 200.0, {Address= AddressLine1= Arques Ave, City=Santa Clara, Zipcode=95051}::AddressLine1= Arques Ave, City=Santa Clara, Zipcode=95051::
Id= 3, Name= Lisa, Salary= 300.0, {Address= AddressLine1= BTM 1st Stage, City=Bangalore, Zipcode=560100}::AddressLine1= BTM 1st Stage, City=Bangalore, Zipcode=560100::
Id= 4, Name= Hyman, Salary= 400.0, {Address= AddressLine1= City Centre, City=New Delhi, Zipcode=100100}::AddressLine1= City Centre, City=New Delhi, Zipcode=100100::
Employee Info::Id= 1, Name= hyman, Salary= 100.0, {Address= AddressLine1= Albany Dr, City=San Jose, Zipcode=95129}
Address Info::AddressLine1= Albany Dr, City=San Jose, Zipcode=95129
Employee Info::Id= 2, Name= David, Salary= 200.0, {Address= AddressLine1= Arques Ave, City=Santa Clara, Zipcode=95051}
Address Info::AddressLine1= Arques Ave, City=Santa Clara, Zipcode=95051
Employee Info::Id= 3, Name= Lisa, Salary= 300.0, {Address= AddressLine1= BTM 1st Stage, City=Bangalore, Zipcode=560100}
Address Info::AddressLine1= BTM 1st Stage, City=Bangalore, Zipcode=560100
Employee Info::Id= 4, Name= Hyman, Salary= 400.0, {Address= AddressLine1= City Centre, City=New Delhi, Zipcode=100100}
Address Info::AddressLine1= City Centre, City=New Delhi, Zipcode=100100
您可以在mysql客户端中运行两个查询,并注意产生的输出是相同的。
mysql> select e.emp_id as emp_id1_1_0_, e.emp_name as emp_name2_1_0_, e.emp_salary as emp_sala3_1_0_, a.emp_id as emp_id1_0_1_, a.address_line1 as address_2_0_1_, a.city as city3_0_1_, a.zipcode as zipcode4_0_1_ from Employee e join Address a ON e.emp_id=a.emp_id; +--------------+----------------+----------------+--------------+----------------+-------------+---------------+ | emp_id1_1_0_ | emp_name2_1_0_ | emp_sala3_1_0_ | emp_id1_0_1_ | address_2_0_1_ | city3_0_1_ | zipcode4_0_1_ | +--------------+----------------+----------------+--------------+----------------+-------------+---------------+ | 1 | hyman | 100 | 1 | Albany Dr | San Jose | 95129 | | 2 | David | 200 | 2 | Arques Ave | Santa Clara | 95051 | | 3 | Lisa | 300 | 3 | BTM 1st Stage | Bangalore | 560100 | | 4 | Hyman | 400 | 4 | City Centre | New Delhi | 100100 | +--------------+----------------+----------------+--------------+----------------+-------------+---------------+ 4 rows in set (0.00 sec) mysql> select e.emp_id, emp_name, emp_salary,address_line1, city, zipcode from Employee e, Address a where a.emp_id=e.emp_id; +--------+----------+------------+---------------+-------------+---------+ | emp_id | emp_name | emp_salary | address_line1 | city | zipcode | +--------+----------+------------+---------------+-------------+---------+ | 1 | hyman | 100 | Albany Dr | San Jose | 95129 | | 2 | David | 200 | Arques Ave | Santa Clara | 95051 | | 3 | Lisa | 300 | BTM 1st Stage | Bangalore | 560100 | | 4 | Hyman | 400 | City Centre | New Delhi | 100100 | +--------+----------+------------+---------------+-------------+---------+ 4 rows in set (0.00 sec) mysql>
具有参数的Hibernate本机SQL查询
我们还可以将参数传递给Hibernate SQL查询,就像JDBC PreparedStatement一样。
可以使用名称和索引来设置参数,如下例所示。
query = session
.createSQLQuery("select emp_id, emp_name, emp_salary from Employee where emp_id = ?");
List<Object[]> empData = query.setLong(0, 1L).list();
for (Object[] row : empData) {
Employee emp = new Employee();
emp.setId(Long.parseLong(row[0].toString()));
emp.setName(row[1].toString());
emp.setSalary(Double.parseDouble(row[2].toString()));
System.out.println(emp);
}
query = session
.createSQLQuery("select emp_id, emp_name, emp_salary from Employee where emp_id = :id");
empData = query.setLong("id", 2L).list();
for (Object[] row : empData) {
Employee emp = new Employee();
emp.setId(Long.parseLong(row[0].toString()));
emp.setName(row[1].toString());
emp.setSalary(Double.parseDouble(row[2].toString()));
System.out.println(emp);
}
以上代码产生的输出为:
Hibernate: select emp_id, emp_name, emp_salary from Employee where emp_id = ?
Id= 1, Name= hyman, Salary= 100.0, {Address= null}
Hibernate: select emp_id, emp_name, emp_salary from Employee where emp_id = ?
Id= 2, Name= David, Salary= 200.0, {Address= null}
这就是Hibernate SQL查询的简要介绍,除非您要执行任何数据库特定的查询,否则应避免使用它。

