对于最新的稳定版本,请使用 Spring Framework 6.2.0! |
使用SimpleJdbc
类
这SimpleJdbcInsert
和SimpleJdbcCall
类提供简化的配置
通过利用可通过 JDBC 驱动程序检索的数据库元数据。
这意味着您需要预先配置的更少,尽管您可以覆盖或关闭
元数据处理(如果您希望在代码中提供所有详细信息)。
使用 插入数据SimpleJdbcInsert
我们首先查看SimpleJdbcInsert
类,且
配置选项。您应该实例化SimpleJdbcInsert
在数据访问
图层的初始化方法。在此示例中,初始化方法是setDataSource
方法。您不需要将SimpleJdbcInsert
类。相反
您可以创建新实例并使用withTableName
方法。
此类的配置方法遵循fluid
样式返回实例
的SimpleJdbcInsert
,它允许您链接所有配置方法。以下内容
example 仅使用一种配置方法(我们稍后将展示多种方法的示例):
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcInsert insertActor;
public void setDataSource(DataSource dataSource) {
this.insertActor = new SimpleJdbcInsert(dataSource).withTableName("t_actor");
}
public void add(Actor actor) {
Map<String, Object> parameters = new HashMap<>(3);
parameters.put("id", actor.getId());
parameters.put("first_name", actor.getFirstName());
parameters.put("last_name", actor.getLastName());
insertActor.execute(parameters);
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val insertActor = SimpleJdbcInsert(dataSource).withTableName("t_actor")
fun add(actor: Actor) {
val parameters = mutableMapOf<String, Any>()
parameters["id"] = actor.id
parameters["first_name"] = actor.firstName
parameters["last_name"] = actor.lastName
insertActor.execute(parameters)
}
// ... additional methods
}
这execute
这里使用的方法采用一个普通的java.util.Map
作为其唯一参数。这
这里需要注意的重要一点是,用于Map
必须与列匹配
表的名称,如数据库中所定义。这是因为我们读取了元数据
构造实际的 INSERT 语句。
使用 检索自动生成的密钥SimpleJdbcInsert
下一个示例使用与上一个示例相同的 insert,但是,不是传入id
它
检索自动生成的 key 并将其设置在新的Actor
对象。当它创建
这SimpleJdbcInsert
,除了指定表名外,它还指定名称
生成的键列的usingGeneratedKeyColumns
方法。以下内容
清单显示了它是如何工作的:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcInsert insertActor;
public void setDataSource(DataSource dataSource) {
this.insertActor = new SimpleJdbcInsert(dataSource)
.withTableName("t_actor")
.usingGeneratedKeyColumns("id");
}
public void add(Actor actor) {
Map<String, Object> parameters = new HashMap<>(2);
parameters.put("first_name", actor.getFirstName());
parameters.put("last_name", actor.getLastName());
Number newId = insertActor.executeAndReturnKey(parameters);
actor.setId(newId.longValue());
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val insertActor = SimpleJdbcInsert(dataSource)
.withTableName("t_actor").usingGeneratedKeyColumns("id")
fun add(actor: Actor): Actor {
val parameters = mapOf(
"first_name" to actor.firstName,
"last_name" to actor.lastName)
val newId = insertActor.executeAndReturnKey(parameters);
return actor.copy(id = newId.toLong())
}
// ... additional methods
}
使用第二种方法运行 insert 时的主要区别在于,您不会
添加id
到Map
,然后调用executeAndReturnKey
方法。这将返回一个java.lang.Number
Object 中,您可以使用该实例创建 Numerical 类型的实例,该实例
用于 domain 类。您不能依赖所有数据库都返回特定的 Java
类。java.lang.Number
是您可以依赖的基类。如果你有
多个自动生成的列或生成的值为非数值,则可以
使用KeyHolder
从executeAndReturnKeyHolder
方法。
为 指定列SimpleJdbcInsert
您可以通过使用usingColumns
方法,如下例所示:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcInsert insertActor;
public void setDataSource(DataSource dataSource) {
this.insertActor = new SimpleJdbcInsert(dataSource)
.withTableName("t_actor")
.usingColumns("first_name", "last_name")
.usingGeneratedKeyColumns("id");
}
public void add(Actor actor) {
Map<String, Object> parameters = new HashMap<>(2);
parameters.put("first_name", actor.getFirstName());
parameters.put("last_name", actor.getLastName());
Number newId = insertActor.executeAndReturnKey(parameters);
actor.setId(newId.longValue());
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val insertActor = SimpleJdbcInsert(dataSource)
.withTableName("t_actor")
.usingColumns("first_name", "last_name")
.usingGeneratedKeyColumns("id")
fun add(actor: Actor): Actor {
val parameters = mapOf(
"first_name" to actor.firstName,
"last_name" to actor.lastName)
val newId = insertActor.executeAndReturnKey(parameters);
return actor.copy(id = newId.toLong())
}
// ... additional methods
}
插入的执行与依赖元数据来确定的执行相同 要使用的列。
用SqlParameterSource
提供参数值
使用Map
提供参数值可以正常工作,但这不是最方便的
类来使用。Spring 提供了SqlParameterSource
接口。第一个是BeanPropertySqlParameterSource
,
如果您有一个符合 JavaBean 的类,并且包含
你的价值观。它使用相应的 getter 方法提取参数
值。以下示例演示如何使用BeanPropertySqlParameterSource
:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcInsert insertActor;
public void setDataSource(DataSource dataSource) {
this.insertActor = new SimpleJdbcInsert(dataSource)
.withTableName("t_actor")
.usingGeneratedKeyColumns("id");
}
public void add(Actor actor) {
SqlParameterSource parameters = new BeanPropertySqlParameterSource(actor);
Number newId = insertActor.executeAndReturnKey(parameters);
actor.setId(newId.longValue());
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val insertActor = SimpleJdbcInsert(dataSource)
.withTableName("t_actor")
.usingGeneratedKeyColumns("id")
fun add(actor: Actor): Actor {
val parameters = BeanPropertySqlParameterSource(actor)
val newId = insertActor.executeAndReturnKey(parameters)
return actor.copy(id = newId.toLong())
}
// ... additional methods
}
另一个选项是MapSqlParameterSource
类似于Map
但提供了更多的
方便addValue
方法可以链接。以下示例演示如何使用它:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcInsert insertActor;
public void setDataSource(DataSource dataSource) {
this.insertActor = new SimpleJdbcInsert(dataSource)
.withTableName("t_actor")
.usingGeneratedKeyColumns("id");
}
public void add(Actor actor) {
SqlParameterSource parameters = new MapSqlParameterSource()
.addValue("first_name", actor.getFirstName())
.addValue("last_name", actor.getLastName());
Number newId = insertActor.executeAndReturnKey(parameters);
actor.setId(newId.longValue());
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val insertActor = SimpleJdbcInsert(dataSource)
.withTableName("t_actor")
.usingGeneratedKeyColumns("id")
fun add(actor: Actor): Actor {
val parameters = MapSqlParameterSource()
.addValue("first_name", actor.firstName)
.addValue("last_name", actor.lastName)
val newId = insertActor.executeAndReturnKey(parameters)
return actor.copy(id = newId.toLong())
}
// ... additional methods
}
如您所见,配置是相同的。只有执行代码必须更改为 使用这些替代输入类。
使用 调用 Stored ProcedureSimpleJdbcCall
这SimpleJdbcCall
类使用数据库中的元数据来查找in
和out
参数,这样就不必显式声明它们。您可以
declare parameters (声明参数)ARRAY
或STRUCT
),这些类没有自动映射到 Java 类。第一个例子
显示了一个简单的过程,该过程仅返回VARCHAR
和DATE
格式
从 MySQL 数据库。示例过程读取指定的 actor 条目并返回first_name
,last_name
和birth_date
列的形式为out
参数。
下面的清单显示了第一个示例:
CREATE PROCEDURE read_actor (
IN in_id INTEGER,
OUT out_first_name VARCHAR(100),
OUT out_last_name VARCHAR(100),
OUT out_birth_date DATE)
BEGIN
SELECT first_name, last_name, birth_date
INTO out_first_name, out_last_name, out_birth_date
FROM t_actor where id = in_id;
END;
这in_id
参数包含id
您正在查找的 actor 中。这out
parameters 返回从表中读取的数据。
您可以声明SimpleJdbcCall
以类似于声明的方式SimpleJdbcInsert
.你
应在 data-access 的 initialization method 中实例化和配置类
层。与StoredProcedure
class 时,您无需创建子类
并且无需声明可在数据库元数据中查找的参数。
以下示例SimpleJdbcCall
配置使用前面存储的
过程(唯一的配置选项,除了DataSource
,是名称
的存储过程):
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcCall procReadActor;
public void setDataSource(DataSource dataSource) {
this.procReadActor = new SimpleJdbcCall(dataSource)
.withProcedureName("read_actor");
}
public Actor readActor(Long id) {
SqlParameterSource in = new MapSqlParameterSource()
.addValue("in_id", id);
Map out = procReadActor.execute(in);
Actor actor = new Actor();
actor.setId(id);
actor.setFirstName((String) out.get("out_first_name"));
actor.setLastName((String) out.get("out_last_name"));
actor.setBirthDate((Date) out.get("out_birth_date"));
return actor;
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val procReadActor = SimpleJdbcCall(dataSource)
.withProcedureName("read_actor")
fun readActor(id: Long): Actor {
val source = MapSqlParameterSource().addValue("in_id", id)
val output = procReadActor.execute(source)
return Actor(
id,
output["out_first_name"] as String,
output["out_last_name"] as String,
output["out_birth_date"] as Date)
}
// ... additional methods
}
您为执行调用编写的代码涉及创建一个SqlParameterSource
包含 IN 参数。您必须与为 input 值提供的名称匹配
替换为存储过程中声明的参数名称。case 没有
匹配,因为您使用元数据来确定应如何引用数据库对象
在存储过程中。在存储过程的源中指定的内容不是
必然是它在数据库中的存储方式。一些数据库将名称转换为所有
大写,而其他 Cookie 则使用 Lower Case 或使用指定的大小写。
这execute
method 接受 IN 参数并返回一个Map
,其中包含任何out
参数,由存储过程中指定的名称作为键。在这种情况下,它们是out_first_name
,out_last_name
和out_birth_date
.
最后一部分execute
方法创建一个Actor
实例以用于返回
检索到的数据。同样,使用out
参数作为
在存储过程中声明。此外,名称中的大小写out
存储在结果映射中的参数与out
parameter names 在
数据库,这可能因数据库而异。为了使您的代码更具可移植性,您应该
执行不区分大小写的查找或指示 Spring 使用LinkedCaseInsensitiveMap
.
要执行后者,您可以创建自己的JdbcTemplate
并设置setResultsMapCaseInsensitive
property 设置为true
.然后,您可以传递此自定义的JdbcTemplate
实例转换为
你的SimpleJdbcCall
.以下示例显示了此配置:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcCall procReadActor;
public void setDataSource(DataSource dataSource) {
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
jdbcTemplate.setResultsMapCaseInsensitive(true);
this.procReadActor = new SimpleJdbcCall(jdbcTemplate)
.withProcedureName("read_actor");
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private var procReadActor = SimpleJdbcCall(JdbcTemplate(dataSource).apply {
isResultsMapCaseInsensitive = true
}).withProcedureName("read_actor")
// ... additional methods
}
通过执行此作,您可以避免用于
返回out
参数。
显式声明要用于SimpleJdbcCall
在本章的前面,我们介绍了如何从元数据中推导出参数,但您可以声明它们
如果你愿意的话,明确地。您可以通过创建和配置SimpleJdbcCall
跟
这declareParameters
方法,该方法采用可变数量的SqlParameter
对象
作为输入。有关如何定义SqlParameter
.
如果您使用的数据库不支持 Spring,则显式声明是必需的 数据库。目前, Spring 支持对 以下数据库:Apache Derby、DB2、MySQL、Microsoft SQL Server、Oracle 和 Sybase。 我们还支持 MySQL、Microsoft SQL Server、 和 Oracle。 |
您可以选择显式声明一个、部分或所有参数。参数
在未显式声明参数的情况下,仍使用 metadata。要绕过所有
处理元数据查找潜在参数,并仅使用声明的
parameters 中,你可以调用withoutProcedureColumnMetaDataAccess
作为
声明。假设您为
database 函数。在这种情况下,您可以调用useInParameterNames
指定列表
要为给定签名包含的 IN 参数名称。
以下示例显示了一个完全声明的过程调用,并使用 前面的示例:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcCall procReadActor;
public void setDataSource(DataSource dataSource) {
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
jdbcTemplate.setResultsMapCaseInsensitive(true);
this.procReadActor = new SimpleJdbcCall(jdbcTemplate)
.withProcedureName("read_actor")
.withoutProcedureColumnMetaDataAccess()
.useInParameterNames("in_id")
.declareParameters(
new SqlParameter("in_id", Types.NUMERIC),
new SqlOutParameter("out_first_name", Types.VARCHAR),
new SqlOutParameter("out_last_name", Types.VARCHAR),
new SqlOutParameter("out_birth_date", Types.DATE)
);
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val procReadActor = SimpleJdbcCall(JdbcTemplate(dataSource).apply {
isResultsMapCaseInsensitive = true
}).withProcedureName("read_actor")
.withoutProcedureColumnMetaDataAccess()
.useInParameterNames("in_id")
.declareParameters(
SqlParameter("in_id", Types.NUMERIC),
SqlOutParameter("out_first_name", Types.VARCHAR),
SqlOutParameter("out_last_name", Types.VARCHAR),
SqlOutParameter("out_birth_date", Types.DATE)
)
// ... additional methods
}
两个示例的执行和最终结果是相同的。第二个示例指定所有 details 而不是依赖元数据。
如何定义SqlParameters
要为SimpleJdbc
类以及 RDBMS作
类(在 将 JDBC作建模为 Java 对象中介绍)中,您可以使用的SqlParameter
或其子类之一。
为此,您通常在构造函数中指定参数名称和 SQL 类型。SQL 类型
通过使用java.sql.Types
常数。在本章的前面,我们看到了声明
类似于以下内容:
-
Java
-
Kotlin
new SqlParameter("in_id", Types.NUMERIC),
new SqlOutParameter("out_first_name", Types.VARCHAR),
SqlParameter("in_id", Types.NUMERIC),
SqlOutParameter("out_first_name", Types.VARCHAR),
第一行带有SqlParameter
声明 IN 参数。您可以使用 IN 参数
对于存储过程调用和查询,请使用SqlQuery
及其
子类(包括理解SqlQuery
).
第二行(带有SqlOutParameter
) 声明out
参数在
stored procedure 调用。还有一个SqlInOutParameter
为InOut
参数
(为过程提供 IN 值并返回值的参数)。
仅声明为SqlParameter 和SqlInOutParameter 习惯于
提供输入值。这与StoredProcedure 类中,其中(对于
向后兼容性原因)允许为参数提供输入值
声明为SqlOutParameter . |
对于 IN 参数,除了名称和 SQL 类型之外,您还可以为
数字数据或自定义数据库类型的类型名称。为out
参数,您可以
提供RowMapper
要处理从REF
光标。另一个
选项来指定SqlReturnType
这提供了一个定义
自定义返回值的处理。
使用 Called a stored FunctionSimpleJdbcCall
您可以采用与调用存储过程几乎相同的方式调用存储函数,但
提供函数名称而不是过程名称。您可以使用withFunctionName
方法作为配置的一部分,以指示您希望将
对函数的调用,以及函数调用的相应字符串。一个
专用调用 (executeFunction
) 用于运行函数,而
将函数返回值作为指定类型的对象,这意味着您执行
不必从 Results Map 中检索返回值。类似的便捷方法
(命名为executeObject
) 也可用于只有一个out
参数。以下示例(适用于 MySQL)基于名为get_actor_name
返回 Actor 的全名:
CREATE FUNCTION get_actor_name (in_id INTEGER)
RETURNS VARCHAR(200) READS SQL DATA
BEGIN
DECLARE out_name VARCHAR(200);
SELECT concat(first_name, ' ', last_name)
INTO out_name
FROM t_actor where id = in_id;
RETURN out_name;
END;
为了调用这个函数,我们再次创建一个SimpleJdbcCall
在初始化方法中,
如下例所示:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcCall funcGetActorName;
public void setDataSource(DataSource dataSource) {
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
jdbcTemplate.setResultsMapCaseInsensitive(true);
this.funcGetActorName = new SimpleJdbcCall(jdbcTemplate)
.withFunctionName("get_actor_name");
}
public String getActorName(Long id) {
SqlParameterSource in = new MapSqlParameterSource()
.addValue("in_id", id);
String name = funcGetActorName.executeFunction(String.class, in);
return name;
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val jdbcTemplate = JdbcTemplate(dataSource).apply {
isResultsMapCaseInsensitive = true
}
private val funcGetActorName = SimpleJdbcCall(jdbcTemplate)
.withFunctionName("get_actor_name")
fun getActorName(id: Long): String {
val source = MapSqlParameterSource().addValue("in_id", id)
return funcGetActorName.executeFunction(String::class.java, source)
}
// ... additional methods
}
这executeFunction
method used 返回一个String
,其中包含来自
函数调用。
返回ResultSet
或 REF Cursor 从SimpleJdbcCall
调用返回结果集的存储过程或函数有点棘手。一些
数据库在 JDBC 结果处理期间返回结果集,而其他数据库需要
显式注册out
特定类型的参数。这两种方法都需要
additional processing 循环结果集并处理返回的行。跟
这SimpleJdbcCall
中,您可以使用returningResultSet
方法并声明一个RowMapper
实现以用于特定参数。如果结果集为
返回,则没有定义名称,因此返回的
结果必须与您声明RowMapper
实现。指定的名称仍用于存储已处理的结果列表
在从execute
陈述。
下一个示例(对于 MySQL)使用一个不采用 IN 参数并返回
来自t_actor
桌子:
CREATE PROCEDURE read_all_actors()
BEGIN
SELECT a.id, a.first_name, a.last_name, a.birth_date FROM t_actor a;
END;
要调用此过程,您可以声明RowMapper
.因为您想要的类
要映射遵循 JavaBean 规则,您可以使用BeanPropertyRowMapper
由
传入 Map 到newInstance
方法。
以下示例显示了如何执行此作:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private SimpleJdbcCall procReadAllActors;
public void setDataSource(DataSource dataSource) {
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
jdbcTemplate.setResultsMapCaseInsensitive(true);
this.procReadAllActors = new SimpleJdbcCall(jdbcTemplate)
.withProcedureName("read_all_actors")
.returningResultSet("actors",
BeanPropertyRowMapper.newInstance(Actor.class));
}
public List getActorsList() {
Map m = procReadAllActors.execute(new HashMap<String, Object>(0));
return (List) m.get("actors");
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val procReadAllActors = SimpleJdbcCall(JdbcTemplate(dataSource).apply {
isResultsMapCaseInsensitive = true
}).withProcedureName("read_all_actors")
.returningResultSet("actors",
BeanPropertyRowMapper.newInstance(Actor::class.java))
fun getActorsList(): List<Actor> {
val m = procReadAllActors.execute(mapOf<String, Any>())
return m["actors"] as List<Actor>
}
// ... additional methods
}
这execute
呼叫传递为空Map
,因为此调用不采用任何参数。
然后,从结果映射中检索参与者列表并将其返回给调用者。