012

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns=".0.0"xmlns:xsi=""xsi:schemaLocation=".0.0 .0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId&ytest</groupId><artifactId>springboot</artifactId><version>1.0-SNAPSHOT</version><packaging>jar</packaging><!-- spring-boot-starter-parent是一个特殊的启动器，他可以使我们在下面定义jar依赖时，不用提供版本标签 version --><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.5.1</version></parent><dependencies><!-- 添加web依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- spring jdbc相关依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jdbc</artifactId></dependency><!-- MySQL驱动 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>6.0.6</version></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

可以看到与我们之前的依赖相比，就只多了spring-boot-starter-jdbc依赖和mysql的驱动依赖

Properties文件

jdbcUrl=jdbc:mysql://localhost:3306/数据库名?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
username=用户名
password=密码
driverClassName&#sql.cj.jdbc.Driver

中间汉字部分请自行替换

创建数据库表

我们使用mysql创建如下两张表，用于示例展示

表名：t_test，有3个字段。

表名：t_demo，有3个字段

配置HikariCP数据源

boot.dao;import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import org.springframework.beans.factory.annotation.Value;
import t.annotation.Bean;
import t.annotation.ComponentScan;
import t.annotation.Configuration;
import io.Resource;import javax.sql.DataSource;
import java.io.IOException;@Configuration
@ComponentScan(&#boot.dao")
public class DaoConfig {@Value("classpath:dao.properties")private Resource configResource;@Beanpublic DataSource getDriverManagerDataSource() throws IOException {//-- 此处使用了Resource ，请查看Resource章节String propertiesPath = File().getAbsolutePath();HikariConfig hikariConfig = new HikariConfig(propertiesPath);HikariDataSource ds = new HikariDataSource(hikariConfig);return ds;}}

测试代码（先验证数据源）

boot.dao;import org.junit.Test;
import t.annotation.AnnotationConfigApplicationContext;import javax.sql.DataSource;public class Demo1 {@Testpublic void test(){AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();ister(DaoConfig.class);fresh();isterShutdownHook();DataSource dataSource = Bean(DataSource.class);System.out.println(dataSource);}}

建议在架构搭建的过程中进行分段验证，避免一次写完所有配置，再执行。否则如果出现错误或问题，你的架构代码半天也启动不起来。

注意&#isterShutdownHook();的作用，如果没有该语句，spring在程序执行完成（容器关闭时）不会回调关闭相应的资源（如：连接池的释放等）。所以isterShutdownHook();还是十分有必要的。

配置JdbcTemplate

在配置类中添加JdbcTemplate的配置

boot.dao;import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import org.springframework.beans.factory.annotation.Value;
import t.annotation.Bean;
import t.annotation.ComponentScan;
import t.annotation.Configuration;
import io.Resource;
import org.JdbcTemplate;import javax.sql.DataSource;
import java.io.IOException;@Configuration
@ComponentScan(&#boot.dao")
public class DaoConfig {@Value("classpath:dao.properties")private Resource configResource;@Beanpublic DataSource getDriverManagerDataSource() throws IOException {String propertiesPath = File().getAbsolutePath();HikariConfig hikariConfig = new HikariConfig(propertiesPath);HikariDataSource ds = new HikariDataSource(hikariConfig);return ds;}/**** 因为JdbcTemplate一旦创建就是线程安全的，所以我们可以将它定义为一个单例的bean**/@Beanpublic JdbcTemplate getJdbcTemplate(DataSource dataSource){return new JdbcTemplate(dataSource);}}

JdbcTemplate用了ThreadLocal，使各线程能够保持各自独立的一个对象，其实就是一个变量副本，实现了线程安全。 JdbcTemplate类的实例是线程安全的实例。这一点非常重要，正因为如此，你可以配置一个简单的JdbcTemplate实例，并将这个“共享的”、“安全的”实例注入到不同的DAO类中去。 另外， JdbcTemplate 是有状态的，因为他所维护的DataSource 实例是有状态的，但是这种状态是无法变化的。 一旦JdbcTemplate被创建，他是一个线程安全的对象。 一个你需要创建多次JdbcTemplate实例的理由可能在于，你的应用需要访问多个不同的数据库，从而需要不同的DataSources来创建不同的JdbcTemplates实例。

编写dao类

TestDao和TestDaoImpl

boot.dao.dao;boot.dao.beans.TestBean;public interface TestDao {int insert(TestBean bean);int update(TestBean bean);TestBean getTestBeanById(int id);}

boot.dao.dao;boot.dao.beans.TestBean;
import org.JdbcTemplate;
import org.springframework.stereotype.Repository;import javax.annotation.Resource;@Repository
public class TestDaoImpl implements TestDao {@Resourceprivate JdbcTemplate jdbcTemplate;@Overridepublic int insert(TestBean bean) {return jdbcTemplate.update("insert into t_test(id,name,remark) values(?,?,?)",Id(),Name(),Remark());}@Overridepublic int update(TestBean bean) {return jdbcTemplate.update("update set t_test name = ?,remark=? where id = ?",Id(),Name(),Remark());}@Overridepublic TestBean getTestBeanById(int id) {return jdbcTemplate.queryForObject("select id,name,remark from t_test where id = "+id,TestBean.class);}
}

DemoDao和DemoDaoImpl

boot.dao.dao;boot.dao.beans.DemoBean;public interface DemoDao {int insert(DemoBean bean);int update(DemoBean bean);DemoBean getTestBeanById(int id);}

boot.dao.dao;boot.dao.beans.DemoBean;
boot.dao.beans.TestBean;
import org.JdbcTemplate;
import org.springframework.stereotype.Repository;import javax.annotation.Resource;@Repository
public class DemoDaoImpl implements DemoDao {@Resourceprivate JdbcTemplate jdbcTemplate;@Overridepublic int insert(DemoBean bean) {return jdbcTemplate.update("insert into t_demo(id,`key`,`value`) values(?,?,?)",Id(),Key(),Value());}@Overridepublic int update(DemoBean bean) {return jdbcTemplate.update("update set t_demo `key` = ?,`value`=? where id = ?",Id(),Key(),Value());}@Overridepublic DemoBean getTestBeanById(int id) {return jdbcTemplate.queryForObject("select id,`key`,`value` from t_demo where id = "+id, DemoBean.class);}
}

注：

1. key、value是保留关键字，我们的sql字符串使用了反引号，如果不使用JdbcTemplate会报错。
2. 我们看到两个Dao实现类都使用了 @Resource 注入了一个JdbcTemplate引用。其实我们可以定义一个BaseDao和BaseDaoImpl，在BaseDaoImpl中注入一次JdbcTemplate引用即可，其他的DaoImpl继承该BaseDaoImpl即可。

定义一个测试Service

boot.dao.service;boot.dao.beans.DemoBean;
boot.dao.beans.TestBean;public interface MyService {void insert(TestBean test, DemoBean demo);}

boot.dao.service;boot.dao.beans.DemoBean;
boot.dao.beans.TestBean;
boot.dao.dao.DemoDao;
boot.dao.dao.TestDao;
import org.springframework.stereotype.Service;import javax.annotation.Resource;@Service
public class MyServiceImpl implements MyService {@Resourceprivate TestDao test1Dao;@Resourceprivate DemoDao demoDao;@Overridepublic void insert(TestBean test, DemoBean demo) {test1Dao.insert(test);demoDao.insert(demo);}
}

我们此处只定义了一个insert方法，方法中同事insert了两个表，个一条数据。如要验证其他Dao方法，请自己补全把。

测试demo

boot.dao;boot.dao.beans.DemoBean;
boot.dao.beans.TestBean;
boot.dao.service.MyService;
import org.junit.Test;
import t.annotation.AnnotationConfigApplicationContext;import javax.sql.DataSource;public class Demo1 {@Testpublic void test(){AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();ister(DaoConfig.class);fresh();isterShutdownHook();DataSource dataSource = Bean(DataSource.class);System.out.println(dataSource);MyService service = Bean(MyService.class);TestBean bean = new TestBean();bean.setId(1);bean.setName("测试名称");bean.setRemark("测试备注");DemoBean demo = new DemoBean();demo.setId(1);demo.setKey("demokey");demo.setValue("demovalue");service.insert(bean,demo);}}

完整的代码结构

示例Service中，如果 test1Dao.insert(test); 之后demoDao.insert(demo);之前有其它业务逻辑代码，而且在这些逻辑代码中出现了异常，我们目前的代码会出现t_test表插入成功而t_demo表插入失败的问题。这显然是不符合业务逻辑的。我们将在下一章介绍此涉及到的事务问题。

上一篇：011-Spring AOP入门
下一篇：013-Spring事务管理