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

asp.Net 前端之家
前端之家收集整理的这篇文章主要介绍了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,note FROM user_login WHERE user_name=? and note=?";
        Object[] params = {userName,note};
        return Optional.ofNullable(jdbcTemplate.query(sql,getUserLoginMapper()))
                .orElse(Collections.emptyList());
    }

    @Override
    public long createUserLogin(UserLoginEntity entity) {
        String sql = "INSERT INTO user_login(user_name,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.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,note) VALUES ('gemini.he','abc123456',2,'我是美女！')");

			//然后查询
			final ResultSet resultSet = statement.executeQuery("SELECT id,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映射为数据库中的记录。

高性能，灵活，方便

    @H_404_226@支持驼峰映射，sql跟pojo之间，减少了开发者的工作量； @H_404_226@没有屏蔽sql，提供了灵活性，可以最大限度的优化sql; @H_404_226@支持动态sql，适应需求变化

配置文件

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

    @H_404_226@基础配置文件；mybatis.config-location指定，里面配置底层的mybatis @H_404_226@映射配置文件；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代码；

@L_301_2@

小结

    @H_404_226@掌握了常见的数据连接池有哪些？并简单应用了DBCP2; @H_404_226@spring-jdbc操作数据库的完整过程； @H_404_226@spring-jpa操作数据库的完整过程； @H_404_226@spring-mybatis操作数据库的完整过程；
    实际工作中可以灵活选择，不过一般一个团队中只选择一个架子，大部分是mybatis;
    原创不易，转载请注明出处。

猜你在找的asp.Net相关文章

.NetCore+WebUploader实现大文件分片上传
项目要求通过网站上传大文件，比如视频文件，通过摸索实现了文件分片来上传，然后后台进行...
CentOS7下让Asp.Net Core的网站自动运行
安装新版本的Nginx（vim /etc/yum.repos.d/nginx.repo） [nginx-stable] name=nginx stabl...
使用SignalR ASP.NET Core来简单实现一个后台实时推送数据给Echarts展示图表的功能
什么是 SignalR&#160;ASP.NET Core ASP.NET Core SignalR 是一种开放源代码库，可简化...
.NETCore项目在Windows下构建Docker镜像并本地导出分发到CentOS系统下
在Windows下使用Docker，我们选择Docker Desktop这个软件，非常方便。 ## Docker Desktop介...
C#编写运行在Linux环境下的采用Mediainfo来获取多媒体文件信息的代码
项目开始设计的是运行在windows下，所以一开始采用的是windows服务模式来获取多媒体文件信...
Blazor Server App Cannot find the fallback endpoint specified by route values
github官方issues中提到的解决方案，CreateBuilder时指定项目绝对路径可以解决。 1 // 指定...
ASP.NET CORE使用WebUploader对大文件分片上传，并通过ASP.NET CORE SignalR实时反馈后台处理进度给前端展示
本次，我们来实现一个单个大文件上传，并且把后台对上传文件的处理进度通过ASP.NET CORE S...
解决WPF+Avalonia在openKylin系统下默认字体问题
一、openKylin简介 openKylin（开放麒麟） 社区是在开源、自愿、平等和协作的基础上，由基...
WTM的项目中EFCore如何适配人大金仓数据库
一、WTM是什么 WalkingTec.Mvvm框架（简称WTM）最早开发与2013年，基于Asp.net MVC3 和 最...
实现ASP.Net Core3.1运行在DockeDesktop下并用Nginx实现负载均衡
一、首先去https://docs.docker.com/get-docker/下载Windows版本的Docker Desktop并安装（...
PHPJavaJava SEPythonC#C&C++RubyVBasp.NetGoPerlnettyDjangoDelphiJsp.NET CoreSpringFlaskSpringbootSpringMVCLuaLaravelMybatisAspGroovyThinkPHPYiiswoole
文件时间pythonm相等性PHP Warning时间问题问题解决pcntl_signal采样点wav模块动态文本调用频率限制对外暴露多个访问请求更新数据表模型结构type()方法比较速度手写体sobel算子保存模型Image类nn.Conv2dpytorch1.0kaggleDCGAN交并比range()用法打印模型反卷积卷积