Spring框架学习第二天（spring框架用法）

1.Spring JDBC

Spring的JDBC模块负责数据库资源管理和错误处理，大大简化了开发人员对数据库的操作，使得开发人员可以从烦琐的数据库操作中解脱出来，从而将更多的精力投入到编写业务逻辑中。接下来的两个小节，将针对Spring中的JDBC模块内容进行详细的讲解。

JdbcTemplate类的继承关系十分简单。它继承自抽象类JdbcAccessor，同时实现了JdbcOperations接口。

· DataSource：其主要功能是获取数据库连接，具体实现时还可以引入对数据库连接的缓冲池和分布式事务的支持，它可以作为访问数据库资源的标准接口。

·SQLExceptionTranslator:org.springframework.jdbc.support.SQLExceptionTranslator接口负责对SQLException进行转译工作。通过必要的设置或者获取SQLExceptionTranslator中的方法，可以使JdbcTemplate在需要处理SQLException时，委托SQLExceptionTranslator的实现类来完成相关的转译工作。JdbcOperations接口定义了在JdbcTemplate类中可以使用的操作集合，包括添加、修改、查询和删除等操作。

Spring JDBC模块主要由4个包组成，分别是core（核心包）、dataSource（数据源包）、object（对象包）和support（支持包），关于这4个包的具体说明如表

配置模板如下：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-4.3.xsd">

<!--1配置数据源 -->

<bean id="dataSource"

class="org.springframework.jdbc.datasource.DriverManagerDataSource">

<!-- 定义数据库驱动 -->

<property name="driverClassName" value="com.mysql.jdbc.Driver" />

<!-- 连接数据库的url -->

<property name="url" value="jdbc:mysql://localhost:3306/world" />

<!-- 连接数据库的用户名 -->

<property name="username" value="root" />

<!-- 连接数据库的密码 -->

<property name="password" value="caicai123" />

</bean>

<!-- 2配置JDBC模板 -->

<bean id="jdbcTemplate"

class="org.springframework.jdbc.core.JdbcTemplate">

<!-- 默认必须使用数据源 -->

<property name="dataSource" ref="dataSource" />

</bean>

</beans>

定义jdbcTemplate时，需要将dataSource注入到jdbcTemplate中，而其他需要使用jdbcTemplate的Bean，也需要将jdbcTemplate注入到该Bean中（通常注入到Dao类中，在Dao类中进行与数据库的相关操作）。

2 Spring JdbcTemplate的常用方法

execute()方法

execute(String sql)方法能够完成执行SQL语句的功能。

ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");

// 获取JdbcTemplate实例

JdbcTemplate jdTemplate = (JdbcTemplate) applicationContext.getBean("jdbcTemplate");

// 使用execute()方法执行SQL语句，创建用户账户管理表account

jdTemplate.execute("create table account(" + "id int primary key auto_increment, " + "username varchar(50), "

+ "balance double)");

使用JUnit测试

@Test就是Junit4用于测试的注解，要测试哪个方法，只需要在相应测试的方法上添加此注解即可。

在执行程序时，只需使用鼠标右键单击mainTest()方法，在弹出的快捷菜单中选择Run As→JUnit Test选项来运行测试方法即可。

package com.itheima.jdbc;

import org.junit.Test;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import org.springframework.jdbc.core.JdbcTemplate;

public class JdbcTemplateTest {

/**

* 使用execute()方法建表

*/

@Test

public void mainTest() {

// 加载配置文件

ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");

// 获取JdbcTemplate实例

JdbcTemplate jdTemplate = (JdbcTemplate) applicationContext.getBean("jdbcTemplate");

// 使用execute()方法执行SQL语句，创建用户账户管理表account

jdTemplate.execute("create table account(" + "id int primary key auto_increment, " + "username varchar(50), "

+ "balance double)");

System.out.println("账户表account创建成功！");

}

}

可在测试类中建立多个test方法一块测试。

update()方法

update()方法可以完成插入、更新和删除数据的操作。

query()

JdbcTemplate类中还提供了大量的query()方法来处理各种对数据库表的查询操作。

举例如下——

package com.itheima.jdbc;

import java.util.List;

import org.springframework.jdbc.core.BeanPropertyRowMapper;

import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.jdbc.core.RowMapper;

public class AccountDaoImpl implements AccountDao {

// 声明JdbcTemplate属性及其setter方法

private JdbcTemplate jdbcTemplate;

public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {

this.jdbcTemplate = jdbcTemplate;

}

// 添加账户

public int addAccount(Account account) {

// 定义SQL

String sql = "insert into account(username, balance) value(?, ? )";

// 定义数组来存储SQL语句中的参数

Object[] obj = new Object[] { account.getUsername(), account.getBalance() };

// 执行添加操作，返回的是受SQL语句影响的记录条数

int num = this.jdbcTemplate.update(sql, obj);

return num;

}

// 更新账户

public int updateAccount(Account account) {

// 定义SQL

String sql = "update account set username=? , balance=? where id = ? ";

// 定义数组来存储SQL语句中的参数

Object[] params = new Object[] { account.getUsername(), account.getBalance(), account.getId() };

// 执行更新操作，返回的是受SQL语句影响的记录条数

int num = this.jdbcTemplate.update(sql, params);

return num;

}

// 删除账户

public int deleteAccount(int id) {

// 定义SQL

String sql = "delete from account where id = ? ";

// 执行删除操作，返回的是受SQL语句影响的记录条数

int num = this.jdbcTemplate.update(sql, id);

return num;

}

// 通过id查询账户数据信息

public Account findAccountById(int id) {

//定义SQL语句

String sql = "select * from account where id = ? ";

// 创建一个新的BeanPropertyRowMapper对象

RowMapper<Account> rowMapper =

new BeanPropertyRowMapper<Account>(Account.class);

// 将id绑定到SQL语句中，并通过RowMapper返回一个Object类型的单行记录

return this.jdbcTemplate.queryForObject(sql, rowMapper, id);

}

// 查询所有账户信息

public List<Account> findAllAccount() {

// 定义SQL语句

String sql = "select * from account";

// 创建一个新的BeanPropertyRowMapper对象

RowMapper<Account> rowMapper =

new BeanPropertyRowMapper<Account>(Account.class);

// 执行静态的SQL查询，并通过RowMapper返回结果

return this.jdbcTemplate.query(sql, rowMapper);

}

}

applicationContext.xml配置：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-4.3.xsd">

<!--1配置数据源 -->

<bean id="dataSource"

class="org.springframework.jdbc.datasource.DriverManagerDataSource">

<!-- 定义数据库驱动 -->

<property name="driverClassName" value="com.mysql.jdbc.Driver" />

<!-- 连接数据库的url -->

<property name="url" value="jdbc:mysql://localhost:3306/world" />

<!-- 连接数据库的用户名 -->

<property name="username" value="root" />

<!-- 连接数据库的密码 -->

<property name="password" value="caicai123" />

</bean>

<!-- 2配置JDBC模板 -->

<bean id="jdbcTemplate"

class="org.springframework.jdbc.core.JdbcTemplate">

<!-- 默认必须使用数据源 -->

<property name="dataSource" ref="dataSource" />

</bean>

<bean id="accountDao" class="com.itheima.jdbc.AccountDaoImpl">

<!-- 将jdbctemplate注入到bean中 -->

<property name="jdbcTemplate" ref="jdbcTemplate"></property>

</bean>

</beans>

3 Spring事务管理

在Spring的所有JAR包中，包含一个名为spring-tx-4.3.6.RELEASE的JAR包，该包就是Spring提供的用于事务管理的依赖包。在该JAR包的org.springframework.transaction包中，我们可以找到3个接口文件PlatformTransactionManager、TransactionDefinition和TransactionStatus，

1.PlatformTransactionManagerPlatformTransactionManager接口是Spring提供的平台事务管理器，主要用于管理事务。该接口中提供了3个事务操作的方法，具体如下。· TransactionStatus getTransaction（TransactionDefinition definition）：用于获取事务状态信息。

· void commit（TransactionStatus status）：用于提交事务。

· void rollback（TransactionStatus status）：用于回滚事务。在上面的3个方法中，getTransaction（TransactionDefinition definition）方法会根据TransactionDefinition参数返回一个TransactionStatus对象，TransactionStatus对象就表示一个事务，它被关联在当前执行的线程上。

PlatformTransactionManager接口只是代表事务管理的接口，它并不知道底层是如何管理事务的，它只需要事务管理提供上面的3个方法，但具体如何管理事务则由它的实现类来完成。

PlatformTransactionManager接口有许多不同的实现类，常见的几个实现类如下。

· org.springframework.jdbc.datasource.DataSourceTransactionManager：用于配置JDBC数据源的事务管理器。

· org.springframework.orm.hibernate4.HibernateTransactionManager：用于配置Hibernate的事务管理器。

· org.springframework.transaction.jta.JtaTransactionManager：用于配置全局事务管理器。当底层采用不同的持久层技术时，系统只需使用不同的PlatformTransactionManager实现类即可。

2.TransactionDefinitionTransactionDefinition接口是事务定义（描述）的对象，该对象中定义了事务规则，并提供了获取事务相关信息的方法，具体如下。

· String getName()：获取事务对象名称。

· int getIsolationLevel()：获取事务的隔离级别。

· int getPropagationBehavior()：获取事务的传播行为。

· int getTimeout()：获取事务的超时时间。

· boolean isReadOnly()：获取事务是否只读。

在事务管理过程中，传播行为可以控制是否需要创建事务以及如何创建事务，通常情况下，数据的查询不会影响原数据的改变，所以不需要进行事务管理，而对于数据的插入、更新和删除操作，必须进行事务管理。如果没有指定事务的传播行为，Spring默认传播行为是REQUIRED。

3.TransactionStatusTransactionStatus接口是事务的状态，它描述了某一时间点上事务的状态信息。该接口中包含6个方法，具体如下。

· void flush()：刷新事务。

· boolean hasSavepoint()：获取是否存在保存点。

· boolean isCompleted()：获取事务是否完成。

· boolean isNewTransaction()：获取是否是新事务。

· boolean isRollbackOnly()：获取是否回滚。

· void setRollbackOnly()：设置事务回滚。

事务用到的包如下：

4 基于XML方式的声明式事务

基于XML方式的声明式事务管理是通过在配置文件中配置事务规则的相关声明来实现的。Spring 2.0以后，提供了tx命名空间来配置事务，tx命名空间下提供了<tx:advice>元素来配置事务的通知（增强处理）。当使用<tx:advice>元素配置了事务的增强处理后，就可以通过编写的AOP配置，让Spring自动对目标生成代理。

配置<tx:advice>元素时，通常需要指定id和transaction-manager属性，其中id属性是配置文件中的唯一标识，transaction-manager属性用于指定事务管理器。除此之外，还需要配置一个<tx:attributes>子元素，该子元素可通过配置多个<tx:method>子元素来配置执行事务的细节。

举例如下：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:aop="http://www.springframework.org/schema/aop"

xmlns:tx="http://www.springframework.org/schema/tx"

xmlns:context="http://www.springframework.org/schema/context"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-4.3.xsd

http://www.springframework.org/schema/tx

http://www.springframework.org/schema/tx/spring-tx-4.3.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context-4.3.xsd

http://www.springframework.org/schema/aop

http://www.springframework.org/schema/aop/spring-aop-4.3.xsd">

<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">

<property name="driverClassName" value="com.mysql.jdbc.Driver" />

<property name="url" value="jdbc:mysql://localhost/world" />

<property name="username" value="root" />

<property name="password" value="caicai123" />

</bean>

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">

<property name="dataSource" ref="dataSource" />

</bean>

<bean id="accountDao" class="com.itheima.jdbc.AccountDaoImpl">

<property name="jdbcTemplate" ref="jdbcTemplate" />

</bean>

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

<property name="dataSource" ref="dataSource" />

</bean>

<tx:advice id="txAdvice" transaction-manager="transactionManager">

<tx:attributes>

<tx:method name="*" propagation="REQUIRED" isolation="DEFAULT" read-only="false" />

</tx:attributes>

</tx:advice>

<aop:config>

<!-- 切入点 -->

<aop:pointcut expression="execution(* com.itheima.jdbc.*.*(..))" id="txPointCut" />

<!-- 切入点与通知整合 -->

<aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut" />

</aop:config>

</beans>

5 基于Annotation方式的声明式事务

Spring的声明式事务管理还可以通过Annotation（注解）的方式来实现。这种方式的使用非常简单，开发者只需做两件事情：

① 在Spring容器中注册事务注解驱动，其代码如下。

<tx:annotation-driven transaction-manager="transactionManager"/>

② 在需要使用事务的Spring Bean类或者Bean类的方法上添加注解@Transactional。如果将注解添加在Bean类上，则表示事务的设置对整个Bean类的所有方法都起作用；如果将注解添加在Bean类中的某个方法上，则表示事务的设置只对该方法有效。

使用@Transactional注解时，可以通过其参数配置事务详情。

举例：

@Transactional(propagation = Propagation.REQUIRED,

isolation = Isolation.DEFAULT, readOnly = false)

public void transfer(String outUser, String inUser, Double money) {

// 收款时，收款用户的余额=现有余额+所汇金额

this.jdbcTemplate.update("update account set balance = balance +? "

+ "where username = ? ", money, inUser);

// 模拟系统运行时的突发性问题

//int i = 1/0;

// 汇款时，汇款用户的余额=现有余额-所汇金额

this.jdbcTemplate.update("update account set balance = balance-? "

+ "where username = ? ", money, outUser);

}

4 MyBatis的下载和使用

下载地址——https://github.com/mybatis/mybatis-3/releases

使用MyBatis框架非常简单，只需在应用程序中引入MyBatis的核心包和lib目录中的依赖包即可。

如果底层采用的是MySQL数据库，那么还需要将MySQL数据库的驱动JAR包添加到应用程序的类路径中；如果采用其他类型的数据库，则同样需要将对应类型的数据库驱动包添加到应用程序的类路径中。

5 MyBatis的工作原理

MyBatis框架在操作数据库时，大体经过了8个步骤。

（1）读取MyBatis配置文件mybatis-config.xml。mybatis-config.xml作为MyBatis的全局配置文件，配置了MyBatis的运行环境等信息，其中主要内容是获取数据库连接。

（2）加载映射文件Mapper.xml。Mapper.xml文件即SQL映射文件，该文件中配置了操作数据库的SQL语句，需要在mybatis-config.xml中加载才能执行。mybatis-config.xml可以加载多个配置文件，每个配置文件对应数据库中的一张表。

（3）构建会话工厂。通过MyBatis的环境等配置信息构建会话工厂SqlSessionFactory。

（4）创建SqlSession对象。由会话工厂创建SqlSession对象，该对象中包含了执行SQL的所有方法。

（5）MyBatis底层定义了一个Executor接口来操作数据库，它会根据SqlSession传递的参数动态地生成需要执行的SQL语句，同时负责查询缓存的维护。

（6）在Executor接口的执行方法中，包含一个MappedStatement类型的参数，该参数是对映射信息的封装，用于存储要映射的SQL语句的id、参数等。Mapper.xml文件中一个SQL对应一个MappedStatement对象，SQL的id即是MappedStatement的id。

（7）输入参数映射。在执行方法时，MappedStatement对象会对用户执行SQL语句的输入参数进行定义（可以定义为Map、List类型、基本类型和POJO类型）,Executor执行器会通过MappedStatement对象在执行SQL前，将输入的Java对象映射到SQL语句中。这里对输入参数的映射过程就类似于JDBC编程中对preparedStatement对象设置参数的过程。

（8）输出结果映射。在数据库中执行完SQL语句后，MappedStatement对象会对SQL执行输出的结果进行定义（可以定义为Map和List类型、基本类型、POJO类型）, Executor执行器会通过MappedStatement对象在执行SQL语句后，将输出结果映射至Java对象中。这种将输出结果映射到Java对象的过程就类似于JDBC编程中对结果的解析处理过程。

MyBatis简单例子——

1.引入mybatis包

2.在项目的src目录下创建log4j.properties文件

由于MyBatis默认使用log4j输出日志信息，所以如果要查看控制台的输出SQL语句，那么就需要在classpath路径下配置其日志文件。在项目的src目录下创建log4j.properties文件

# Global logging configuration

log4j.rootLogger=ERROR, stdout

# MyBatis logging configuration...

log4j.logger.com.itheima=DEBUG

# Console output...

log4j.appender.stdout=org.apache.log4j.ConsoleAppender

log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

3.在src目录下，创建一个com.itheima.po包，在该包下创建持久化类Customer，并在类中声明id、username、jobs和phone属性，及其对应的getter/setter方法。

持久化类Customer与普通的JavaBean并没有什么区别，只是其属性字段与数据库中的表字段相对应。实际上，Customer就是一个POJO（普通Java对象）, MyBatis就是采用POJO作为持久化类来完成对数据库操作的。

4.在src目录下，创建一个com.itheima.mapper包，并在包中创建映射文件CustomerMapper. xml。

<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<!-- namespace表示命名空间 -->

<mapper namespace="com.itheima.mapper.CustomerMapper">

<!--根据客户编号获取客户信息 -->

<select id="findCustomerById" parameterType="Integer"

resultType="com.itheima.po.Customer">

select * from t_customer where id = #{id}

</select>

</mapper>

第2~3行是MyBatis的约束配置，第5~11行是需要程序员编写的映射信息。

其中，<mapper>元素是配置文件的根元素，它包含一个namespace属性，该属性为这个<mapper>指定了唯一的命名空间，通常会设置成“包名+SQL映射文件名”的形式。

子元素<select>中的信息是用于执行查询操作的配置，其id属性是<select>元素在映射文件中的唯一标识。

parameterType属性用于指定传入参数的类型，这里表示传递给执行SQL的是一个Integer类型的参数；resultType属性用于指定返回结果的类型，这里表示返回的数据是Customer类型。在定义的查询SQL语句中，“#{}”用于表示一个占位符，相当于“? ”，而“#{id}”表示该占位符待接收参数的名称为id。

多学一招：快速获取配置文件的约束信息在MyBatis的映射文件中，包含了一些约束信息，初学者如果自己动手去编写，不但浪费时间，还容易出错。

其实，在MyBatis使用手册中，就可以找到这些约束信息，具体的获取方法如下。打开MyBatis的使用手册mybatis-3.4.2.pdf，在第2小节Getting started（入门指南）下的2.1.5小节Exploring Mapped SQL Statements中，即可找到映射文件的约束信息

5.创建MyBatis的核心配置文件mybatis-config.xml

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>

<environments default="mysql">

<!--1.2．配置id为mysql的数据库环境 -->

<environment id="mysql">

<!-- 使用JDBC的事务管理 -->

<transactionManager type="JDBC" />

<!--数据库连接池 -->

<dataSource type="POOLED">

<property name="driver" value="com.mysql.jdbc.Driver" />

<property name="url"

value="jdbc:mysql://localhost:3306/mybatis" />

<property name="username" value="root" />

<property name="password" value="root" />

</dataSource>

</environment>

</environments>

<!--2．配置Mapper的位置-->

<mappers>

<mapper resource="com/itheima/mapper/CustomerMapper.xml" />

</mappers>

</configuration>

在文件6-3中，第2~3行是MyBatis的配置文件的约束信息，下面<configuration>元素中的内容就是开发人员需要编写的配置信息。这里按照<configuration>子元素的功能不同，将配置分为了两个步骤：第1步配置了环境，第2步配置了Mapper的位置。关于上述代码中各个元素的详细配置信息将在下一章进行详细讲解，此案例中读者只需要按照上述代码配置即可。

上述配置文件在MyBatis使用手册mybatis-3.4.2.pdf的2.1.2小节中，已经给出了配置模板（包含约束信息），读者只需要复制过来，依照自己的项目需求修改即可。

6 MyBatis测试实例

package com.itheima.test;

import java.io.InputStream;

import org.apache.ibatis.io.Resources;

import org.apache.ibatis.session.SqlSession;

import org.apache.ibatis.session.SqlSessionFactory;

import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import org.junit.Test;

import com.itheima.po.Customer;

/**

* 入门程序测试类

*/

public class MybatisTest {

/**

* 根据客户编号查询客户信息

*/

@Test

public void findCustomerByIdTest() throws Exception {

// 1．读取配置文件

String resource = "mybatis-config.xml";

InputStream inputStream = Resources.getResourceAsStream(resource);

// 2．根据配置文件构建SqlSessionFactory

SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

// 3．通过SqlSessionFactory创建SqlSession

SqlSession sqlSession = sqlSessionFactory.openSession();

// 4.SqlSession执行映射文件中定义的SQL，并返回映射结果

Customer customer = sqlSession.selectOne("com.itheima.mapper" + ".CustomerMapper.findCustomerById", 1);

// 打印输出结果

System.out.println(customer.toString());

// 5、关闭SqlSession

sqlSession.close();

}

}