Spring JdbcTemplate.queryForObject()
创始人
2024-04-02 01:27:16
0

Spring JdbcTemplate 是JDBC核心包中的中心类。它简化了 JDBC 与 Spring 的使用,并有助于避免常见错误。在此页面上,我们将学习使用queryForObject 方法。
JdbcTemplate.queryForObject不同参数的方法。
1. 

 T queryForObject(String sql, Class requiredType) throws DataAccessException 

执行给定的 SQL 并返回所需类型的对象。
2.

 T queryForObject(String sql, Class requiredType, @Nullable Object... args) throws DataAccessException 

查询给定的 SQL 以从 SQL 创建预准备语句和要绑定到查询的参数列表,需要一个结果对象。
3.

 T queryForObject(String sql, Object[] args, int[] argTypes, Class requiredType) throws DataAccessException 

查询给定的 SQL 以从 SQL 创建预准备语句和要绑定到查询的参数列表,需要一个结果对象。
4.

 T queryForObject(String sql, Object[] args, int[] argTypes, RowMapper rowMapper) throws DataAccessException 

查询给定的 SQL,用于从 SQL 创建预准备语句和要绑定到查询的参数列表,通过 RowMapper将单个结果行映射到结果对象

5.

 T queryForObject(String sql, RowMapper rowMapper) throws DataAccessException 

执行给定静态 SQL 的查询,通过RowMapper将单个结果行映射到结果对象

6.

 T queryForObject(String sql, RowMapper rowMapper, @Nullable Object... args) throws DataAccessException 

查询给定 SQL 以从 SQL 创建预准备语句和要绑定到查询的参数列表,通过RowMapper将单个结果行映射到结果对象

参数:

sql是要执行的 SQL 查询。
requiredType 是结果对象应匹配的类型。
args 是要绑定到查询的参数
argType是参数的 SQL 类型java.sql.Types。
rowMapper是一个回调,它将每行映射一个对象

返回:
结果对象,如果是 SQL NULL,则为 null。

抛出:
如果执行查询时遇到任何问题,则抛出DataAccessException。
 

使用Spring Boot的示例

PersonDAO.java

package com.concretepage;import java.sql.ResultSet;
import java.sql.SQLException;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Repository;@Repository
public class PersonDAO {@Autowiredprivate JdbcTemplate jdbcTemplate;// queryForObject(String sql, Class<T> requiredType)public int getPersonCount() {String sql = "select count(*) from person";return jdbcTemplate.queryForObject(sql, Integer.class);}// queryForObject(String sql, Class<T> requiredType, Object... args)public String getNameById(int id) {String sql = "select name from person where id = ?";return jdbcTemplate.queryForObject(sql, String.class, 1);}// queryForObject(String sql, Object[] args, int[] argTypes, Class<T> requiredType)public int getPersonCountByNameAndAge(String name, int age) {String sql = "select count(*) from person where name = ? and age = ?";Object[] args = {name, age};int[] argTypes = {java.sql.Types.CHAR, java.sql.Types.INTEGER};return jdbcTemplate.queryForObject(sql, args, argTypes, Integer.class);}// queryForObject(String sql, Object[] args, int[] argTypes, RowMapper<T> rowMapper)public Person getPersonsById(int id) {String sql = "select * from person where id = ?";Object[] args = {id};int[] argTypes = {java.sql.Types.INTEGER};return jdbcTemplate.queryForObject(sql, args, argTypes, new RowMapper() {@Overridepublic Person mapRow(ResultSet rs, int rowNum) throws SQLException {Person p = new Person(rs.getString(2), rs.getInt(3));p.setId(rs.getInt(1));return p;}});}// queryForObject(String sql, RowMapper<T> rowMapper)public Person getAdmin() {String sql = "select * from person where id = 1";return jdbcTemplate.queryForObject(sql, new RowMapper() {@Overridepublic Person mapRow(ResultSet rs, int rowNum) throws SQLException {Person p = new Person(rs.getString(2), rs.getInt(3));p.setId(rs.getInt(1));return p;}});}// queryForObject(String sql, RowMapper<T> rowMapper, Object... args)public int getPersonCount2(String name, int age) {String sql = "select count(*) from person where name = ? and age = ?";return jdbcTemplate.queryForObject(sql, new RowMapper() {@Overridepublic Integer mapRow(ResultSet rs, int rowNum) throws SQLException {return rs.getInt(1);}}, name, age);}
}

Person.java

package com.concretepage;public class Person {private int id;private String name;private int age;public Person(String name, int age) {this.name = name;this.age = age;}public int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public int getAge() {return age;}
}

application.properties

spring.datasource.url=jdbc:mysql://localhost:3306/concretepage?autoReconnect=true&useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

pom.xml


4.0.0com.concretepagesoap-ws0.0.1-SNAPSHOTjarspring-demoSpring Demo Applicationorg.springframework.bootspring-boot-starter-parent2.7.416org.springframework.bootspring-boot-starterorg.springframework.bootspring-boot-starter-jdbcmysqlmysql-connector-java8.0.30org.springframework.bootspring-boot-maven-plugin

MyApplication.java

package com.concretepage;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;@SpringBootApplication
public class MyApplication {public static void main(String[] args) {ApplicationContext ctx = SpringApplication.run(MyApplication.class, args);PersonDAO personDAO = ctx.getBean(PersonDAO.class);System.out.println("Total Count: " + personDAO.getPersonCount());System.out.println(personDAO.getNameById(1));System.out.println("Count: " + personDAO.getPersonCountByNameAndAge("Mohan", 25));Person p = personDAO.getPersonsById(1);System.out.println(p.getId() + " - " + p.getName() + " - " + p.getAge());Person admin = personDAO.getAdmin();System.out.println(admin.getId() + " - " + admin.getName() + " - " + admin.getAge());System.out.println("Count: " + personDAO.getPersonCount2("Mohan", 25));}
}

查找我们的演示中使用的 MySQL 表(人)屏幕截图。

输出。

Total Count: 3
Rakesh
Count: 2
1 - Rakesh - 30
1 - Rakesh - 30
Count: 2 

参考

类 Jdbc 模板

下载源代码

spring-jdbctemplate-queryforobject.zip

 

相关内容

热门资讯

监控摄像头接入GB28181平... 流程简介将监控摄像头的视频在网站和APP中直播,要解决的几个问题是:1&...
Windows10添加群晖磁盘... 在使用群晖NAS时,我们需要通过本地映射的方式把NAS映射成本地的一块磁盘使用。 通过...
protocol buffer... 目录 目录 什么是protocol buffer 1.protobuf 1.1安装  1.2使用...
在Word、WPS中插入AxM... 引言 我最近需要写一些文章,在排版时发现AxMath插入的公式竟然会导致行间距异常&#...
Fluent中创建监测点 1 概述某些仿真问题,需要创建监测点,用于获取空间定点的数据࿰...
educoder数据结构与算法...                                                   ...
MySQL下载和安装(Wind... 前言:刚换了一台电脑,里面所有东西都需要重新配置,习惯了所...
MFC文件操作  MFC提供了一个文件操作的基类CFile,这个类提供了一个没有缓存的二进制格式的磁盘...
有效的括号 一、题目 给定一个只包括 '(',')','{','}'...
【PdgCntEditor】解... 一、问题背景 大部分的图书对应的PDF,目录中的页码并非PDF中直接索引的页码...