SpringBoot学集（第七章）数据访问

tech2025-09-01 58

文章目录

数据访问一、JDBC自动配置原理：二、整合Druid数据源1、导入Druid依赖三、整合Mybatis（一）、Mybatis 增删改查1、创建mapper接口2、创建Controller （二）、Mybatis配置1、开启驼峰命名法2、Mapper扫描3、业务代码编写四、整合SpringData与JPA简介1、实体类2、Dao接口3、配置4、Controller类常见异常及其原因①JDBC 连接数据库出错②引入SQL 文件报错

数据访问

官网地址参考

一、JDBC

1、pom.xml 中的相关配置如下 2、在applicatiom.yml 进行连接配置

spring: datasource: username: root password: 1******** url: jdbc:mysql://1*******08/jdbc driver-class-name: com.mysql.jdbc.Driver

3、测试 4、实际输出：

注意：

默认是用org.apache.tomcat.jdbc.pool.DataSource作为数据源；

数据源的相关配置都在DataSourceProperties里面；

自动配置原理：

org.springframework.boot.autoconfigure.jdbc

1、参考DataSourceConfiguration，根据配置创建数据源，默认使用Tomcat连接池；可以使用spring.datasource.type指定自定义的数据源类型；

2、SpringBoot默认可以支持；

org.apache.tomcat.jdbc.pool.DataSource、HikariDataSource、BasicDataSource、

3、自定义数据源类型

/** * Generic DataSource configuration. */ @ConditionalOnMissingBean(DataSource.class) @ConditionalOnProperty(name = "spring.datasource.type") static class Generic { @Bean public DataSource dataSource(DataSourceProperties properties) { //使用DataSourceBuilder创建数据源，利用反射创建响应type的数据源，并且绑定相关属性 return properties.initializeDataSourceBuilder().build(); } }

4、DataSourceInitializer：ApplicationListener；

作用：

（1）runSchemaScripts();运行建表语句；

（2）runDataScripts();运行插入数据的sql语句；

默认只需要将文件命名为：

schema-*.sql、data-*.sql 默认规则：schema.sql，schema-all.sql；可以使用 schema: - classpath:department.sql 指定位置

5、操作数据库：自动配置了JdbcTemplate操作数据库

二、整合Druid数据源

1、导入Druid依赖

<dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.1.8</version> </dependency> @Configuration public class DruidConfig { @ConfigurationProperties(prefix = "spring.datasource") @Bean public DataSource druid(){ return new DruidDataSource(); } //配置Druid的监控 //1、配置一个管理后台的Servlet @Bean public ServletRegistrationBean statViewServlet(){ ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*"); Map<String,String> initParams = new HashMap<>(); initParams.put("loginUsername","admin"); initParams.put("loginPassword","123456"); initParams.put("allow","");//默认就是允许所有访问 initParams.put("deny","192.168.15.21"); bean.setInitParameters(initParams); return bean; } //2、配置一个web监控的filter @Bean public FilterRegistrationBean webStatFilter(){ FilterRegistrationBean bean = new FilterRegistrationBean(); bean.setFilter(new WebStatFilter()); Map<String,String> initParams = new HashMap<>(); initParams.put("exclusions","*.js,*.css,/druid/*"); bean.setInitParameters(initParams); bean.setUrlPatterns(Arrays.asList("/*")); return bean; } }

三、整合Mybatis

依赖关系图如下

（一）、Mybatis 增删改查

1、创建mapper接口

@Mapper public interface DepartmentMapper { @Select("select * from department") public List<Department> selectAll(); @Select("select * from department where id=#{id}") public Department selectById(Integer id); @Options(useGeneratedKeys = true, keyProperty = "id") @Insert("insert into department(departmentName) values(#{departmentName})") public int save(Department department); @Update("update department set departmentName=#{departmentName}") public int update(Department department); @Delete("delete from department where id =#{id}") public int delete(Integer id); }

2、创建Controller

@RestController public class DepartmentController { @Autowired private DepartmentMapper departmentMapper; @RequestMapping("/dep/{id}") public List<Department> getDepById(@PathVariable Integer id) { return departmentMapper.selectAll(); } @RequestMapping("/dep") public Department getDepById(Department department) { departmentMapper.save(department); return department; } }

访问：http://localhost:8080/dep?departmentName=PeppaPig 添加一条数据

访问：http://localhost:8080/dep/1获取数据

（二）、Mybatis配置

1、开启驼峰命名法

我们的实体类和表中的列名一致，把department表的departmentName列名改为department_name看看现象

访问：http://localhost:8080/dep/1获取数据

[{"id":1,"departmentName":null}] Copy to clipboardErrorCopied

由于列表和属性名不一致，所以就没有封装进去，我们表中的列名和实体类属性名都是遵循驼峰命名规则的，可以开启mybatis的开启驼峰命名配置

在application.yml中进行学习

mybatis: configuration: map-underscore-to-camel-case: true

然后重启项目，重新插入数据，再查询就发现可以封装进去了

也可以通过向spring容器中注入org.mybatis.spring.boot.autoconfigure.ConfigurationCustomizer的方法设置mybatis参数

@Configuration public class MybatisConfig { @Bean public ConfigurationCustomizer mybatisConfigurationCustomizer() { return new ConfigurationCustomizer() { @Override public void customize(org.apache.ibatis.session.Configuration configuration) { configuration.setMapUnderscoreToCamelCase(true); } }; } }

2、Mapper扫描

使用@mapper注解的类可以被扫描到容器中，但是每个Mapper都要加上这个注解就是一个繁琐的工作，能不能直接扫描某个包下的所有Mapper接口–>在springboot启动类上加上@MapperScan

@MapperScan("cn.clboy.springbootmybatis.mapper") @SpringBootApplication public class SpringbootMybatisApplication { public static void main(String[] args) { SpringApplication.run(SpringbootMybatisApplication.class, args); } }

使用xml配置文件创建mybatis全局配置文件

<?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> <typeAliases> <package name="cn.clboy.springbootmybatis.model"/> </typeAliases> </configuration>

3、业务代码编写

创建EmployeeMapper接口

public interface EmployeeMapper { List<Employee> selectAll(); int save(Employee employee); }

创建EmployeeMapper.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"> <mapper namespace="cn.clboy.springbootmybatis.mapper.EmployeeMapper"> <select id="selectAll" resultType="employee"> SELECT * FROM employee </select> <insert id="save" parameterType="employee" useGeneratedKeys="true" keyProperty="id"> INSERT INTO employee(lastName,email,gender,d_id) VALUES (#{lastName},#{email},#{gender},#{d_id}) </insert> </mapper>

配置文件(application.yaml)中指定配置文件和映射文件的位置

mybatis: config-location: classpath:mybatis/mybatis-config.xml mapper-locations: classpath:mybatis/mapper/*.xml

创建EmployeeController

@RestController public class EmployeeController { @Autowired private EmployeeMapper employeeMapper; @RequestMapping("/emp/list") public List<Employee> getALl() { return employeeMapper.selectAll(); } @RequestMapping("/emp/{id}") public Employee save(Employee employee) { employeeMapper.save(employee); return employee; } }

Copy to clipboardErrorCopiedJPA 访问：http://localhost:8080/emp/list

四、整合SpringData与JPA

简介

Spring Data项目的目的是为了简化构建基于 Spring框架应用的数据访技术，包括非关系数据库、 Map- Reduce框架、云数据服务等等；另外也包含对关系数据厍的访问支持

JPA ----> Java持久化规范

依赖关系图： JPA:ORM（Object Relational Mapping）

层级关系图如下：

1、实体类

编写一个实体类（bean）和数据表进行映射，并且配置好映射关系；

//使用JPA注解配置映射关系 @Entity //告诉JPA这是一个实体类（和数据表映射的类） @Table(name = "tbl_user") //@Table来指定和哪个数据表对应;如果省略默认表名就是user； public class User { @Id //这是一个主键 @GeneratedValue(strategy = GenerationType.IDENTITY)//自增主键 private Integer id; @Column(name = "last_name",length = 50) //这是和数据表对应的一个列 private String lastName; @Column //省略默认列名就是属性名 private String email;

2、Dao接口

编写一个Dao接口来操作实体类对应的数据表（Repository）

//继承JpaRepository来完成对数据库的操作 public interface UserRepository extends JpaRepository<User,Integer> { }

3、配置

基本的配置JpaProperties

spring: jpa: hibernate: # 更新或者创建数据表结构 ddl-auto: update # 控制台显示SQL show-sql: true

4、Controller类

@RestController public class UserController { @Autowired UserRepository userRepository; @GetMapping("/user/{id}") public Optional<User> getUser(@PathVariable("id") Integer id){ Optional<User> user = userRepository.findById(id); return user ; } @GetMapping("/user") public User insertUser(User user){ User save = userRepository.save(user); return save; } }

http://localhost:8080/user?lastName=zhangsan&email=123456@qq.com

http://localhost:8080/user?lastName=lisi&email=78215646@qq.com

查询用户访问：

http://localhost:8080/user/1，然后会发现抛出500错误，原因是getOne方法使用的懒加载，获取到的只是代理对象，转换为json时会报错

解决方法：

1、法一：关闭懒加载，在实体类上加@Proxy(lazy = false)注解

@Entity @Table(name = "tbl_user") @Proxy(lazy = false) public class User

2、法二：转json的时候忽略hibernateLazyInitializer和handler属性

@Entity @Table(name = "tbl_user") @JsonIgnoreProperties(value = {"hibernateLazyInitializer", "handler"}) public class User

常见异常及其原因

①JDBC 连接数据库出错

java.sql.SQLException: Access denied for user ‘’@‘117.42.26.254’ (using pass 1、没有权限、信息错误（密码，主机名等） 2、yml文件格式错误（下为正解）