C连接数据库2.Spring

Jdbc连接数据库(JdbcTemplate)二、JdbcTemplate源码分析1.update/save功能的实现源码分析入口(关键)基础方法execute1.获取数据库连接池2.应用用户设定的输入参数3.

调用回调函数处理4.

功能的实现源码分析入口1(关键)源码分析入口2(关键)3.queryForObject总结前言

本章主要以Spring提供的模板类’JdbcTemplate‘为例进行源代码分析。

如果有小伙伴对Spring如何支持持久化技术的理论知识感兴趣可以参考《精通Spring4.x

企业应用开发实战》第10章

文章中我们知道目前市场上连接MySQL数据库常用的几种持久化方式有五种JDBC、Mybatis、Hibernate、JTA、JDO。

然而Spring又分别对JDBC、Hibernate、JTA、JDO提供了模板类以便快速进行持久化连接开发。

其中Spring针对JDBC的模板类是’JdbcTemplate‘。

下面我们将分别对JDBC和JdbcTemplate数据库连接进行分析。

1.JDBC连接数据库

编写数据库应用程序并且可跨平台运行并且不受数据库供应商的限制。

JDBC

(1在开发环境中加载指定数据库的驱动程序。

接下来的实验中使用的数据库是

MySQL

mysal-conneetorjava-5.1.18-bin.jar)将下载得到的驱动程序加载进开发环境中开发环境是

(2在Java

程序中可以通过“Class.forName(“指定数据库的驱动程序”)”的方式来加载添加到开发环境中的驱动程序例如加载

MySQL

forName(“com.mysqljdbc.Driver”)。

DriverManager

驱动程序之间用于检查所加载的驱动程序是否可以建立连接然后通过它的

getConnection

DriverManager.getConnection(“连接数据库的

地址域名

端口数据库名称用户名和密码是指登录数据库时所使用的用户名和密码。

具体示例创建

MySQL

connection.createStatement()。

具体示例创建

Statement

execuUpdate()方法来对数据更新包括插入和删除等操作例如向

staff

表中插人一条数据的代码statement.excuteUpdate(

“INSERTINTO

321,“M’‘china’Personnel’3”3000’”通过调用

Statement

executeQuery()方法进行数据的查询而查询结果会得到

ResulSet对象ResuSet

next()方法使得指针指向下一行然后将数据以列号或者字段名取出。

如果当

next()方法返回

做了大量封裝消除了冗余代码使得开发量大大减小。

下面通过一个小例子让大家简单认识

JDBC

无论对哪种技术进行源码分析我们都应该先找到入口点然后顺藤摸瓜式的解读源码。

Spring

的支持首先寻找整个功能的切入点在示例中我们可以看到所有的数据库操作都封装在了

UserServicelmpl

UserServicelmpl中的所有数据库操作又以其内部属性

jdbcTemplate

可以作为源码分析的切人点我们一起看看它是如何实现又是如何被初始化的。

UserServicelmpl

函数开始的DataSource实例通过参数注入DataSource

的创建过程是引入第三方的连接池这里不做过多介绍。

DataSource

是整个数据库操作的基础里面封装了整个数据库的连接信息。

我们首先以保存实体类为例进行代码跟踪。

SQL

newArgTypePreparedStatementSetter(args,

int

SimplePreparedStatementCreator(sql),

pss);}

PreparedStatementCallback作为回调函数。

execute

query

ArgumentTypePreparedStatementSetter.setValue:

将参数赋值给对应的参数类型pss.setValues(ps);}//

ps.executeUpdate():

功能描述作为公用的method被具有个性化的方法(增删改查)调用。

*

execute

作为数据库操作的核心人口將大多数数据库操作相同的步骤统一封装而将个性化的操作使用参数

param

DataAccessException*/Nullableprivate

execute(PreparedStatementCreator

psc,

getSql(psc);logger.debug(Executing

prepared

DataSourceUtils.getConnection(obtainDataSource());PreparedStatement

null;try

psc.createPreparedStatement(con);applyStatementSettings(ps);//

result

action.doInPreparedStatement(ps);handleWarnings(ps);return

result;}catch

psc).cleanupParameters();}String

sql

null;JdbcUtils.closeStatement(ps);ps

null;//

方法。

考虑到存在事务的情况如果当前线程存在事务那么说明在当前线程中存在共用数据库连接这种情况下直接使用

ConnectionHolder

方法进行连接数减一面不是真正的释放连接。

DataSourceUtils.releaseConnection(con,

getDataSource());con

translateException(PreparedStatementCallback,

sql,

psc).cleanupParameters();}JdbcUtils.closeStatement(ps);DataSourceUtils.releaseConnection(con,

getDataSource());}}}下面我们对execute代码中重要的几个关键点进行分析。

1.获取数据库连接池

dataSource.getConnection()方法那么简单同样也考虑了诸多情况。

在数据库连接方面Spring

主要考虑的是关于事务方面的处理。

基于事务处理的特殊性Spring

public

TransactionSynchronizationManager.getResource(dataSource);if

(conHolder

conHolder.isSynchronizedWithTransaction()))

resumed

DataSource);conHolder.setConnection(fetchConnection(dataSource));}return

Else

目的spring需要保证线程下的数据库操作都使用同一个事务连接。

那么当事务回滚的时候可以一次性回滚所有的数据库操作。

if

(TransactionSynchronizationManager.isSynchronizationActive())

{try

在事务中使用同一个数据库连接。

ConnectionHolder

holderToUse

{holderToUse.setConnection(con);}holderToUse.requested();TransactionSynchronizationManager.registerSynchronization(new

ConnectionSynchronization(holderToUse,

dataSource));holderToUse.setSynchronizedWithTransaction(true);if

(holderToUse

{TransactionSynchronizationManager.bindResource(dataSource,

holderToUse);}}catch

applyStatementSettings(Statement

stmt)

{stmt.setFetchSize(fetchSize);}int

maxRows

{stmt.setMaxRows(maxRows);}DataSourceUtils.applyTimeout(stmt,

getDataSource(),

时如果它每次只从服务器上读取一行数据则会产生大量的开销。

setFetchSize

rs.next

时ResultSet会一次性从服务器上取得多少行数据回来这样在下次

rs.next

时它可以直接从内存中获取数据而不需要网络交互提高了效率。

这个设置可能会被某些

JDBC

方法。

考虑到存在事务的情况如果当前线程存在事务那么说明在当前线程中存在共用数据库连接这种情况下直接使用

ConnectionHolder

方法进行连接数减一而不是真正的释放连接。

ConnectionHolder

conHolder

TransactionSynchronizationManager.getResource(dataSource);if

(conHolder

it.conHolder.released();return;}}//

直接使用Connection的API调用close方法释放连接doCloseConnection(con,

作为一个接口其中只有一个函数

doInPreparedStatement这个函数是用于调用通用方法

execute

PreparedStatementCallback作为回调函数。

execute

query

ArgumentTypePreparedStatementSetter.setValue:

将参数赋值给对应的参数类型pss.setValues(ps);}//

ps.executeUpdate():

方式进行调用的时候会经常使用此方法。

但是对于设置输人参数的函数

pss.set

Values(ps)我们有必要去深人研究一下。

在没有分析源码之前我们至少可以知道其功能不妨再回顾下

Spring

pss.setValues(ps)为入口的。

还记得我们之前的分析路程吗这个pss

setValues

方法的功能实现那么在数据库操作中查找操作也是使用率非常高的函数同样我们也需要了解它的实现过程。

使用方法如下

Overridepublic

RowMapperResultSetExtractor(rowMapper)));}OverrideNullablepublic

query(String

newArgTypePreparedStatementSetter。

return

query(sql,

newArgTypePreparedStatementSetter(args,

argTypes),

SimplePreparedStatementCreator(sql),

pss,

doInPreparedStatement(PreparedStatement

ps)

ArgumentTypePreparedStatementSetter.setValuepss.setValues(ps);}//

ps.executeQuery():JDBC-API的基本操作rs

ps.executeQuery();//

rse.extractData(rsToUse)方法负责将结果进行封装并转换至

POJO

当前代表的类为RowMapperResultSetExtractor而在构造

rowMapper

{JdbcUtils.closeResultSet(rs);if

(pss

ps.executeQuery()执行查询操作而且在返回方法上也做了一些额外的处理。

源码分析入口2(关键)

都是带有参数的也就是带有“”的那么还有另一种情况是不带有“?”的Spring

Listuser

RowMapperResultSetExtractor(rowMapper)));}核心源码

/***

results*/OverrideNullablepublic

query(final

{JdbcUtils.closeResultSet(rs);}}Overridepublic

String

DataAccessException*/Nullableprivate

action,

DataSourceUtils.getConnection(obtainDataSource());Statement

stmt

con.createStatement();applyStatementSettings(stmt);T

result

action.doInStatement(stmt);handleWarnings(stmt);return

result;}catch

getSql(action);JdbcUtils.closeStatement(stmt);stmt

null;DataSourceUtils.releaseConnection(con,

getDataSource());con

translateException(StatementCallback,

sql,

{JdbcUtils.closeStatement(stmt);DataSourceUtils.releaseConnection(con,

getDataSource());}}}PreparedStatement

接口继承

语句这就是使语向“准备好”。

包含于PreparedStatement

SQL

参数保留一个问号“2”作为占位符。

每个问号的值必须在该语句执行之前通过适当的

setXXX