博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
0107 spring操作数据库的3个架子
阅读量:4209 次
发布时间:2019-05-26

本文共 9801 字,大约阅读时间需要 32 分钟。

背景

数据库开发是java的核心内容之一,基础就是jdbc了;

然而直接使用jdbc,需要写大量的try-catch-finally模板代码;

管理系统使用hibernate作为orm框架比较方便,遵循jpa规范;

互联网时代使用Mybatis,因为灵活,方便进行sql优化;

此外spring也提供了jdbcTemplate的访问数据库的模式,不过没有被大量的企业使用;

使用这些ORM框架之前,必须先配置好数据源;

数据源

数据连接池,可以复用连接

常见数据库

数据库 说明
h2 内存数据库
derby 内存数据库
hqldb 内存数据库
mysql 商用数据库,开源免费
oracle 商用数据库,oracle
mssql 即sql server 微软提供

引入依赖:(spring-jdbc,mysql驱动)

org.springframework.boot
spring-boot-starter-jdbc
mysql
mysql-connector-java

springboot配置jdbc数据源:

spring.datasource.url = jdbc:mysql:localhost:3306/xxxspring.datasource.username = rootspring.datasource.password = rootspring.datasource.driver-class-name = com.mysql.jdbc.Driverspring.datasource.type = 配置数据连接池(org.apache.commons.dbp2.BasicDataSource)

默认使用的是hikaricp;

代码如下:

@SpringBootApplicationpublic class DemoDatasourceTomcatApplication {    public static void main(String[] args) {        final ConfigurableApplicationContext applicationContext = SpringApplication.run(DemoDatasourceTomcatApplication.class, args);        final DataSource dataSource = applicationContext.getBean(DataSource.class);        System.out.println(dataSource.getClass().getName());    }}

常见数据连接池

数据源 说明
tomcat tomcat内置,springboot自带了
dbcp2 外部经典数据源
druid 阿里开源的容易监控容易扩展的数据源
hikricp 日本开源的一个超快的数据源

验证配置的数据源:

JdbcTemplate

jdbcTemplate提供了标准的接口用来操作数据库;

增删改查都有;

在一条连接中执行多条sql语句,jdbcTemplate提供了两种方式,StatementCallback或者ConnectionCallback;

file

代码示例如下:

package com.springbootpractice.demo.demo_datasource_tomcat.dao.jdbc.impl;import com.springbootpractice.demo.demo_datasource_tomcat.dao.entity.UserLoginEntity;import com.springbootpractice.demo.demo_datasource_tomcat.dao.entity.enums.SexEnum;import com.springbootpractice.demo.demo_datasource_tomcat.dao.jdbc.IUserJdbcBiz;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.jdbc.core.RowMapper;import org.springframework.stereotype.Service;import java.sql.ResultSet;import java.util.Collections;import java.util.List;import java.util.Optional;/** * 说明:jdbc样板代码 * @author carter * 创建时间: 2020年01月07日 2:36 下午 **/@Servicepublic class UserJdbcBiz implements IUserJdbcBiz {    private final JdbcTemplate jdbcTemplate;    public UserJdbcBiz(JdbcTemplate jdbcTemplate) {        this.jdbcTemplate = jdbcTemplate;    }    @Override    public UserLoginEntity getUserLogin(Long id) {        String sql = "SELECT id,user_name,password,sex,note FROM user_login WHERE id=? ";        Object[] params = {id};        return jdbcTemplate.queryForObject(sql, params, getUserLoginMapper());    }    @Override    public List
findUserLogin(String userName, String note) { String sql = "SELECT id,user_name,password,sex,note FROM user_login WHERE user_name=? and note=?"; Object[] params = {userName, note}; return Optional.ofNullable(jdbcTemplate.query(sql, params, getUserLoginMapper())) .orElse(Collections.emptyList()); } @Override public long createUserLogin(UserLoginEntity entity) { String sql = "INSERT INTO user_login(user_name, password, sex, note) VALUES (?,?,?,?)"; Object[] params = {entity.getUserName(), entity.getPassword(), entity.getSex().getCode(), entity.getNote()}; return jdbcTemplate.update(sql, params); } @Override public long updateUserLogin(UserLoginEntity entity) { String sql = "UPDATE user_login SET user_name=? , password=? , sex=? , note=? WHERE id=? "; Object[] params = {entity.getUserName(), entity.getPassword(), entity.getSex().getCode(), entity.getNote(), entity.getId()}; return jdbcTemplate.update(sql, params); } @Override public long deleteUserLogin(Long id) { String sql = "DELETE FROM user_login WHERE id=? "; Object[] params = {id}; return jdbcTemplate.update(sql, params); } public static RowMapper
getUserLoginMapper() { return (ResultSet rs, int rowNum) -> UserLoginEntity.builder() .id(rs.getLong("id")) .userName(rs.getString("user_name")) .password(rs.getString("password")) .sex(SexEnum.getByCode(rs.getInt("sex"))) .note(rs.getString("note")) .build(); }}

package com.springbootpractice.demo.demo_datasource_tomcat;import com.springbootpractice.demo.demo_datasource_tomcat.dao.entity.UserLoginEntity;import com.springbootpractice.demo.demo_datasource_tomcat.dao.entity.enums.SexEnum;import com.springbootpractice.demo.demo_datasource_tomcat.dao.jdbc.IUserJdbcBiz;import com.springbootpractice.demo.demo_datasource_tomcat.dao.jdbc.impl.UserJdbcBiz;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.dao.DataAccessException;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.jdbc.core.StatementCallback;import org.springframework.util.Assert;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.Objects;@SpringBootTestclass DemoDatasourceTomcatApplicationTests {    @Autowired    private IUserJdbcBiz userJdbcBiz;    @Test    void crateUserLoginTest() {        final long id = userJdbcBiz.createUserLogin(UserLoginEntity.builder()                .userName("carter.li")                .password("abc123")                .sex(SexEnum.MALE)                .note("第一个账号")                .build());        final UserLoginEntity userLogin = userJdbcBiz.getUserLogin(id);        Assert.isTrue(Objects.equals(id,userLogin.getId()),"插入失败");    }    @Autowired    private JdbcTemplate jdbcTemplate;    @Test    void twoOperationOneConnectionTest() {        final UserLoginEntity result = jdbcTemplate.execute((StatementCallback
) statement -> { //先插入 final int i = statement.executeUpdate("INSERT INTO user_login(user_name, password, sex, note) VALUES ('gemini.he','abc123456',2,'我是美女!')"); //然后查询 final ResultSet resultSet = statement.executeQuery("SELECT id,user_name,password,sex,note FROM user_login WHERE user_name='gemini.he'"); UserLoginEntity userLoginEntity =null; while (resultSet.next()){ userLoginEntity = UserJdbcBiz.getUserLoginMapper().mapRow(resultSet, resultSet.getRow()); } return userLoginEntity; }); Assert.isTrue(Objects.equals("gemini.he",result.getUserName()),"先插入后查询失败"); }}

JPA(Hibernate)

JPA:java persistence API ,定义了对象关系映射以及实体对象持久化接口,不局限于EJB,可以脱离容器独立运行,开发,测试,依赖Hibernate的支持;

JPA所维护的核心是实体(EntityBean),通过一个持久化上下文来使用,持久化上下文包括三个部分;

组件 说明
ORM关系描述 支持注解或者xml两种形式描述,springboot中使用注解来描述
实体操作API 通过规范可以实现对实体的CRUD操作
JPQL查询语言 约定了面向对象的查询语言,可以实现灵活的查询

jpaRepository的功能体系如下:

sequenceDiagramJpaReporsitory->>QueryByExampleExecutor: 查询功能?JpaReporsitory-->>PageingAndSortingRepository: 分页和排序功能JpaReporsitory-->>CrudRepository: 增删改查功能

可以灵活的通过注解定义新的查询方法;也可以按照规则直接写一个空方法和签名

依赖

org.springframework.boot
spring-boot-starter-data-jpa

Mybatis

不屏蔽sql并且提供动态sql,接口式编程和简易sql绑定pojo的半自动化框架;

目前java的持久层技术最为主流的就是mybatis,它比jpa更易用和灵活;

适用于当前互联网环境业务比较简单,但是数据量大,高并发,性能问题敏感;

官方定义:支持定制化的sql,存储过程,高级映射的优秀持久层框架。

几乎避免了所有的jdbc代码和手动设置参数以及获取结果集。

mybatis通过xml或者注解把接口和POJO映射为数据库中的记录。

高性能,灵活,方便

1. 支持驼峰映射,sql跟pojo之间,减少了开发者的工作量;

2. 没有屏蔽sql,提供了灵活性,可以最大限度的优化sql;

3. 支持动态sql,适应需求变化

配置文件

因为注解的功能和可读性限制,实际使用的较多的是xml来进行配置;

1. 基础配置文件;mybatis.config-location指定,里面配置底层的mybatis

2. 映射配置文件;mybatis.mapper-locations=classpath:mapper/*.xml

依赖

社区最新版本

org.mybatis.spring.boot
mybatis-spring-boot-starter
2.1.1

mybatis的配置

核心类:

SqlSessionFactory 应用内部唯一

SqlSession 操作的核心类,一般在应用中做了擦除,即无感,转而使用各种XMapper接口;

Configuration: mybatis的核心配置

配置项目 说明
settings 设置mybatis的低层行为,比如驼峰映射,执行器类型,缓存等
typeAliases 类型别名,@Alias("aa")
typeHandlers 类型处理器,处理支持的类型,比如枚举,LocalDate等
plugins 插件,拦截器,mybatis最强大也是最危险的组件,通过代理和责任链模式完成,可以修改底层的实现功能,见代码
mappers 映射器,核心组件,定义了sql和pojo的映射关系,可以使用生成器生成

整合springboot

采用@MapperScan注解

@MapperScan(basePackages = "com.springbootpractice.demo.mybatis.dao",        annotationClass = Repository.class)

属性配置:

mybatis.mapper-locations= classpath:mapper/*.xmlmybatis.type-aliases-package= com.springbootpractice.demo.mybatis.dao.entitymybatis.type-handlers-package= com.springbootpractice.demo.mybatis.dao.entity.handlermybatis.config-location= classpath:mybatis.xmlmybatis.executor-type= reuse

实体代码,mapper接口,xml配置比较常见,这里给出作为一个例子:

domain实体

package com.springbootpractice.demo.mybatis.dao.entity;import com.springbootpractice.demo.mybatis.dao.entity.enums.SexEnum;import lombok.Data;import org.apache.ibatis.type.Alias;import java.io.Serializable;/** * 说明:TODO * @author carter * 创建时间: 2020年01月07日 5:06 下午 **/@Data@Alias("userLogin")public class UserLoginEntity implements Serializable {    private Long id;    private String userName;    private String password;    private SexEnum sex;    private String  note;}

mapper接口

package com.springbootpractice.demo.mybatis.dao.mapper;import com.springbootpractice.demo.mybatis.dao.entity.UserLoginEntity;import org.apache.ibatis.annotations.Param;import org.springframework.stereotype.Repository;/** * 说明:TODO * @author carter * 创建时间: 2020年01月07日 5:17 下午 **/@Repositorypublic interface UserLoginMapper {    /**     * 通过id查询用户信息     * @param id id     * @return 用户信息     */    UserLoginEntity getById(@Param("id") Long id);}

sql和domain的映射xml

底层的mybatis配置文件:

代码生成工具很多,可以下一个idea插件或引入maven插件来生成domain,mapper,xml代码;

小结

1. 掌握了常见的数据连接池有哪些?并简单应用了DBCP2;

2. spring-jdbc操作数据库的完整过程;

3. spring-jpa操作数据库的完整过程;

4. spring-mybatis操作数据库的完整过程;

实际工作中可以灵活选择,不过一般一个团队中只选择一个架子,大部分是mybatis;

原创不易,转载请注明出处,欢迎多沟通交流

你可能感兴趣的文章
UNIX网络编程卷1:套接字联网-第16章:非阻塞式I/O
查看>>
Linux源码解析-进程-进程
查看>>
Linux源码解析-进程-进程状态
查看>>
Linux源码解析-内核栈与thread_info结构详解
查看>>
Linux源码解析-内存描述符(mm_struct)
查看>>
进程的存储空间布局
查看>>
c函数调用过程原理及函数栈帧分析
查看>>
C语言函数调用及栈帧分析
查看>>
unix环境高级编程-进程控制
查看>>
Linux源码解析-task_struct中关于文件的字段解析
查看>>
file结构体详解
查看>>
unix环境高级编程-线程解析
查看>>
unix环境高级编程-互斥量机制
查看>>
unix环境高级编程-读写锁
查看>>
unix环境高级编程-条件变量
查看>>
unix环境高级编程-自旋锁
查看>>
linux源码解析-fork
查看>>
linux源码解析-copy_process函数
查看>>
linux源码解析-dup_task_struct函数
查看>>
Linux源码解析-信号机制相关数据结构
查看>>