0107 spring操作数据库的3个架子

背景

数据库开发是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驱动)

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
</dependency>

springboot配置jdbc数据源:

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

默认使用的是hikaricp;

代码如下:

@SpringBootApplication
public 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 下午
 **/
@Service
public 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<UserLoginEntity> 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<UserLoginEntity> 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;

@SpringBootTest
class 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<UserLoginEntity>) 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()),"先插入后查询失败");

    }
}

dbcp2和spring-jdb代码路径点我!

JPA(Hibernate)

JPA:java persistence API ,定义了对象关系映射以及实体对象持久化接口,不局限于EJB,可以脱离容器独立运行,开发,测试,依赖Hibernate的支持;
JPA所维护的核心是实体(EntityBean),通过一个持久化上下文来使用,持久化上下文包括三个部分;
组件 说明
ORM关系描述 支持注解或者xml两种形式描述,springboot中使用注解来描述
实体操作API 通过规范可以实现对实体的CRUD操作
JPQL查询语言 约定了面向对象的查询语言,可以实现灵活的查询

jpaRepository的功能体系如下:

sequenceDiagram
JpaReporsitory->>QueryByExampleExecutor: 查询功能?
JpaReporsitory-->>PageingAndSortingRepository: 分页和排序功能
JpaReporsitory-->>CrudRepository: 增删改查功能
可以灵活的通过注解定义新的查询方法;也可以按照规则直接写一个空方法和签名

依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

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

依赖

社区最新版本
<dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>2.1.1</version>
</dependency>

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/*.xml
mybatis.type-aliases-package= com.springbootpractice.demo.mybatis.dao.entity
mybatis.type-handlers-package= com.springbootpractice.demo.mybatis.dao.entity.handler
mybatis.config-location= classpath:mybatis.xml
mybatis.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 下午
 **/
@Repository
public interface UserLoginMapper {

    /**
     * 通过id查询用户信息
     * @param id id
     * @return 用户信息
     */
    UserLoginEntity getById(@Param("id") Long id);

}

sql和domain的映射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="com.springbootpractice.demo.mybatis.dao.mapper.UserLoginMapper">

    <select id="getById" parameterType="java.lang.Long" resultType="userLogin">
        SELECT * FROM user_login where id=#{id}
    </select>

</mapper>

底层的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>
    <plugins>
        <plugin interceptor="com.springbootpractice.demo.mybatis.dao.plugin.MyPlugin">
            <property name="a" value="a"/>
        </plugin>
    </plugins>
</configuration>

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

Mybatis_demo运行代码点我!

小结

  1. 掌握了常见的数据连接池有哪些?并简单应用了DBCP2;
  2. spring-jdbc操作数据库的完整过程;
  3. spring-jpa操作数据库的完整过程;
  4. spring-mybatis操作数据库的完整过程;

实际工作中可以灵活选择,不过一般一个团队中只选择一个架子,大部分是mybatis;
原创不易,转载请注明出处,欢迎沟通交流。

Image placeholder
Corn_without_sugar
未设置
  31人点赞

没有讨论,发表一下自己的看法吧

推荐文章
Spring-SpringAOP原理,手写Spring事务框架

一、Spring核心知识Spring是一个开源框架,Spring是于2003年兴起的一个轻量级的Java开发框架,由RodJohnson在其著作ExpertOne-On-OneJ2EEDevelopm

lavavel 中操作数据库查找别名

一、总结(点击显示或隐藏总结内容)一句话总结:当有表前缀的时候:DB::table('usersastable1')->select(DB::raw('table1.id'))->get();对应sq

敏捷开发流程之Scrum:3个角色、5个会议、12原则

本文主要从Scrum的定义和目的、敏捷宣言、Scrum中的人员角色、Scrum开发流程、敏捷的12原则等几方面帮助大家理解Scrum敏捷开发的全过程。一、Scrum的定义和目的Scrum是一个用于开发

Redis为什么是单线程、及高并发快的3大原因详解

Redis的高并发和快速原因 1.redis是基于内存的,内存的读写速度非常快; 2.redis是单线程的,省去了很多上下文切换线程的时间; 3.redis使用多路复用技术,可以处理并发的连接。非阻塞

关于工业物联网,你应该了解的3件事

世界各地的基础设施日益紧密。我们应该感谢工业物联网(IIoT)带来的这种连通性,它将交通、制造业、医疗保健等行业的机器和设备连接起来,并远远超出了预期范围。IIoT的潜力仍然很高,但风险也是如此。你需

opcode 操作数 5 中不同的类型

zend_op_array.opcodes指向指令列表,具体每条指令的结构如下: struct_zend_op{//*opline*opcodes constvoid*handler;//指令执行ha

如何在JavaScript中操作数组?

JavaScript中的数组是什么?在开始之前,你需要先了解数组的真正含义。在JavaScript中,数组是一个用于存储不同数据类型的变量。它将不同的元素存储在一个盒子中,供以后使用。声明一个数组:l

盘点2019:对国产数据库的一点观察和总结

“想,都是问题,做,才有答案”—–华东师范大学副校长、CCF数据库专委会副主任周傲英。之所以开篇引用周教授这句话,是因为笔者觉得,这短短10个字,是对国产数据库发展的最好诠释。中国能否翻越数据库这座大

20200107pm

 20200107 html html中有哪些块级元素?有哪些行内元素? \- 行内元素 一个行内元素只占据它对应标签的边框所包含的空间 一般情况下,行内元素只能包含数据和其他行内元素

SpringBoot个人应用开发框架(SpringBoot版本2.1)+IDEA

前言: 此笔记为本人首个SpringBoot项目框架学习实践记录,期间参考了许多大神的笔记和心得。 参考文档如下: 项目git地址: 一、创建SpringBoot工程 1.1创建父POM工程结

搭建 Spring+SpringMVC+MyBatis 框架

SSM框架整合 pom中添加依赖 添加编辑Spring配置文件 添加编辑SpringMVC配置文件 添加编辑Mybatis配置文件 配置web.xml 1、pom中添加依赖 junit ju

再见 Spring Boot 1.X ,Spring Boot 2.X 走向舞台中心

2019年8月6日,Spring官方在其博客宣布,SpringBoot1.x停止维护,SpringBoot1.x生命周期正式结束。其实早在2018年7月30号,Spring官方就已经在博客进行过预告,

面试问烂的 Spring AOP 原理、SpringMVC 过程

  正文  SpringAOP,SpringMVC,这两个应该是国内面试必问题,网上有很多答案,其实背背就可以。但今天笔者带大家一起深入浅出源码,看看他的原理。以期让印象更加深刻,面试的时候游刃有余。

BAT大牛推荐开发人员必备Spring源码剖析文档,深度剖析Spring

为什么学习读源码我们每天都和代码打交道。经过数年的基础教育和职业培训,大部分程序员都会「写」代码,或者至少会抄代码和改代码。但是,会读代码的并不在多数,会读代码又真正读懂一些大项目的源码的,少之又少。

0103-springmvc的基本流程

背景现在的it研发,已经从管理系统时代迈入了互联网系统时代。页面开发已经从基于JSP+struts转变为为前后端分离的方式(springMVC+JS);思想MVCmvc框架不仅适用于java的开发,也

GoWeb教程_07.5. 文件操作

在任何计算机设备中,文件是都是必须的对象,而在Web编程中,文件的操作一直是Web程序员经常遇到的问题,文件操作在Web应用中是必须的,非常有用的,我们经常遇到生成文件目录,文件(夹)编辑等操作,现在

Nebula 架构剖析系列(二)图数据库的查询引擎设计

摘要上文(存储篇)说到数据库重要的两部分为存储和计算,本篇内容为你解读图数据库Nebula在查询引擎QueryEngine方面的设计实践。在Nebula中,QueryEngine是用来处理Nebula

如何保证缓存与数据库的双写一致性?

分布式缓存是现在很多分布式应用中必不可少的组件,但是用到了分布式缓存,就可能会涉及到缓存与数据库双存储双写,你只要是双写,就一定会有数据一致性的问题,那么你如何解决一致性问题?CacheAsidePa

合理建立Hadoop数据库的7个步骤

数据湖的概念起源于大数据的出现——且数据已成为企业的核心资产,Hadoop则是作为存储和管理数据的平台而出现。但是,盲目地投入Hadoop数据湖建设并不一定会使您的企业进入大数据时代——至少不是以一种

中兴数据库的决心

摘要:在数据库方面,中兴有着17年的相关技术积累储备,早在2002年,中兴就启动了数据库相关技术的研发,最近5年,中兴更是加强数据库投入,累计投入10个亿。目前,中兴拥有一支超过500人的数据库研发团

时序数据库的秘密 —— 快速检索

Elasticsearch是通过Lucene的倒排索引技术实现比关系型数据库更快的过滤。特别是它对多条件的过滤支持非常好,比如年龄在18和30之间,性别为女性这样的组合查询。倒排索引很多地方都有介绍,

面试官问:请介绍一下MySQL数据库的锁机制?

为什么要加锁问题背景当多个用户并发地存取数据时,在数据库中就会产生多个事务同时存取同一数据的情况。若对并发操作不加控制就可能会读取和存储不正确的数据,破坏数据库的一致性。要解决的问题多用户环境下保证数

阿里面试题:如何保证缓存与数据库的双写一致性?

作者:你是我的海啸出处:https://blog.csdn.net/chang384915878/article/details/86756463只要用缓存,就可能会涉及到缓存与数据库双存储双写,你只

DTCC观察:华为云数据库的优势积累与技术选择

摘要:作为公有云市场的重磅参与者,华为云数据库相比竞争对手有哪些优势?这可能是很多不了解华为云数据库人的第一反应。华为云数据库产品架构如何布局?作为第一个基于MySQL8.0开发的云原生分布式数据库,

腾讯林晓斌:数据库的高易用性如何实现?

腾讯云基于QQ、微信、腾讯游戏等海量业务的技术锤炼,从基础架构到精细化运营,从平台实力到生态能力建设,腾讯云将之整合并面向市场,使之能够为企业和创业者提供集云计算、云数据、云运营于一体的云端服务体验。

{