SpringBoot 学集 (第七章) 数据访问

目录

数据访问

官网地址参考

SpringBoot 学集 (第七章) 数据访问

一、JDBC

1、pom.xml 中的相关配置如下
SpringBoot 学集 (第七章) 数据访问
2、在applicatiom.yml 进行连接配置

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

SpringBoot 学集 (第七章) 数据访问

3、测试
SpringBoot 学集 (第七章) 数据访问
4、实际输出:
SpringBoot 学集 (第七章) 数据访问

注意:

​ 默认是用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

依赖关系图如下
SpringBoot 学集 (第七章) 数据访问

(一)、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

SpringBoot 学集 (第七章) 数据访问

简介

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

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

SpringBoot 学集 (第七章) 数据访问
SpringBoot 学集 (第七章) 数据访问
依赖关系图:
SpringBoot 学集 (第七章) 数据访问
JPA:ORM(Object Relational Mapping)

层级关系图如下:

SpringBoot 学集 (第七章) 数据访问

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文件格式错误(下为正解)

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

②引入SQL 文件报错

java.lang.IllegalStateException: Failed to load ApplicationContext

SpringBoot 学集 (第七章) 数据访问
解决:1、在resource 文件夹下新建 文件夹sql
SpringBoot 学集 (第七章) 数据访问
2、或者是yml 文件格式(内容)错误

3、数据库是否打开
SpringBoot 学集 (第七章) 数据访问
4、参考链接

上一篇:大数据第43天—Mysql练习题14-至少有5名直接下属的经理-杨大伟


下一篇:迭代器模式