Серия Springboot (10) Доступ к базе данных с использованием данных Spring jpa

Spring Boot задняя часть

Пишите статьи серьезно и не будьте участником заголовков.

Статья вошла вGitHub.com/Ниу Мух/Java…а такжеБлог программиста Аранга, обратите внимание, не потеряйтесь.

предисловие

Данные Springboot jpa и Spring jdbc принадлежат к организации с открытым исходным кодом Spring.После Spring jdbc была разработана структура уровня сохраняемости.Очевидно, что Spring data jpa более удобен и мощен, чем Spring jdbc, в противном случае нет необходимости в разработке. Начните испытывать прелести Spring data jpa по следующей статье.

1. Введение в Spring data jpa

Spring data jpa является частью серии данных Spring, которая может легко реализовать расширенную поддержку уровня доступа к данным.В течение долгого времени было очень сложно реализовать уровень доступа к данным приложения, и необходимо много шаблонного кода. быть написан код для выполнения простых запросов или операций разбиения на страницы. Целью Spring data jpa является минимизация фактического кодирования для улучшения работы уровня доступа к данным.

2. Зависимости jpa данных Spring

Этот эксперимент основан на экспериментальном коде из девятой статьи серии. Чтобы узнать о конфигурации кода, связанной с источником данных, вы также можете обратиться к девятой статье серии. Здесь демонстрируется только часть данных Spring jpa.

Создайте загрузочный проект Spring и импортируйте необходимые зависимости.

    <dependencies>
        <!-- Spring Boot web 开发整合 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>spring-boot-starter-json</artifactId>
                    <groupId>org.springframework.boot</groupId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!-- 阿里 fastjson -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.47</version>
        </dependency>

        <!-- Lombok 工具 -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

        <!-- 导入配置文件处理器,在配置springboot相关文件时候会有提示 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <optional>true</optional>
        </dependency>

        <!-- 单元测试 -->
        <dependency>
            <groupId>org.junit.jupiter</groupId>
            <artifactId>junit-jupiter-api</artifactId>
            <version>RELEASE</version>
            <scope>compile</scope>
        </dependency>

        <!-- 数据库访问 JPA-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>

        <!--添加数据库链接 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>

        <!-- 阿里 druid 数据源,Spring boot 中使用Druid要用这个  -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>
    </dependencies>

3. Конфигурация jpa данных Spring

Конфигурация источника данных Druid больше не объясняется, вы можете обратиться к девятой статье серии.

############################################################
# 服务启动端口号
server.port=8080
spring.profiles.active=dev
############################################################
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/springboot?characterEncoding=utf-8&serverTimezone=GMT%2B8
spring.datasource.driver-class-name= com.mysql.jdbc.Driver
spring.datasource.username=root
spring.datasource.password=123
# 使用 druid 数据源
spring.datasource.type: com.alibaba.druid.pool.DruidDataSource
spring.datasource.initialSize: 5
spring.datasource.minIdle: 5
spring.datasource.maxActive: 20
spring.datasource.maxWait: 60000
spring.datasource.timeBetweenEvictionRunsMillis: 60000
spring.datasource.minEvictableIdleTimeMillis: 300000
spring.datasource.validationQuery: SELECT 1 FROM DUAL
spring.datasource.testWhileIdle: true
spring.datasource.testOnBorrow: false
spring.datasource.testOnReturn: false
spring.datasource.poolPreparedStatements: true
spring.datasource.filters: stat
spring.datasource.maxPoolPreparedStatementPerConnectionSize: 20
spring.datasource.useGlobalDataSourceStat: true
spring.datasource.connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500
# SpringBoot JPA
spring.jpa.show-sql=true
# create 每次都重新创建表,update,表若存在则不重建
spring.jpa.hibernate.ddl-auto=update
spring.jpa.database-platform=org.hibernate.dialect.MySQL55Dialect

spring.jpa.show-sql=trueРаспечатайте операторы SQL.
spring.jpa.hibernate.ddl-auto=updateАвтоматически создавать таблицы данных в соответствии с Enity, Update означает не создавать заново таблицу, если она существует.

4. Spring JPA-кодирование данных

Springboot Data JPA — это полная реализация ORM, классы сущностей и отношения таблиц данных находятся во взаимно-однозначном соответствии, поэтому классы сущностей также являются структурами таблиц данных.spring.jpa.hibernate.ddl-auto=updateбудет автоматически создан в таблице данных при запуске JPA@EntityАннотированная таблица данных объекта. Если таблица уже существует, она не будет создана.

4.1 Класс объекта данных

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;

import javax.persistence.*;
import javax.validation.constraints.NotNull;
import java.util.Date;

/**
 * <p>
 *
 * @Entity JPA实体
 * @Data GET SET TOSTRING
 * @NoArgsConstructor 无参构造
 * @AllArgsConstructor 全参构造
 * @Author niujinpeng
 * @Date 2018/12/19 17:13
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
@Entity
@Table(name = "user")
public class User {

    /**
     * 用户ID
     *
     * @Id 主键
     * @GeneratedValue 自增主键
     */
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;

    /**
     * 用户名
     */
    @Column(name = "username", length = 32, nullable = false)
    @NotNull(message = "用户名不能为空")
    private String username;
    /**
     * 密码
     */
    @Column(name = "password", length = 32, nullable = false)
    @NotNull(message = "密码不能为空")
    private String password;
    /**
     * 年龄
     */
    @Column(name = "age", length = 3)
    private Integer age;
    /**
     * 生日
     */
    @DateTimeFormat(pattern = "yyyy-MM-dd hh:mm:ss")
    private Date birthday;
    /**
     * 技能
     */
    private String skills;
}

4.2 Рабочий интерфейс JPA

Операционный интерфейс JPA должен только наследовать JpaRepository. JpaRepository инкапсулирует общие методы, такие как добавление, удаление, изменение, разбиение по страницам и т. д., которые можно использовать напрямую. Если вам нужно настроить метод запроса, вы можете добавить его, создав метод имя. Следующее добавляет метод для запроса информации о пользователе на основе имени пользователя и пароля.

package net.codingme.boot.domain.repository;

import net.codingme.boot.domain.User;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

/**
 * <p>
 *
 * @Author niujinpeng
 * @Date 2019/1/1114:26
 */
@Repository
public interface UserRepository extends JpaRepository<User, Integer> {
     /**
     * 一个自定义方法,根据 username 和 password 查询 User 信息
     */
    User findByUsernameAndPassword(String username, String password);
}

На этом этапе функция Jpa может быть протестирована и использована, а сервисный уровень и контроллер не будут здесь публиковаться, а будут напрямую писать модульные тесты Springboot для тестирования Jpa.

5. Весенний тест jpa данных

Используя метод модульного тестирования Springboot, можно легко тестировать проекты Springboot, и те, кто не знает о модульном тестировании Springboot, могут обратиться к нему напрямую.официальная документацияКонечно, вы также можете непосредственно посмотреть пример кода ниже.
Следующие четыре метода тестирования написаны для проверки четырех функций запроса на основе идентификатора, запроса на подкачку, обновления данных и запроса на основе имени пользователя и пароля.

package net.codingme.boot.domain.repository;

import net.codingme.boot.domain.User;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.List;
import java.util.Optional;

/**
 * 单元测试
 */
@RunWith(SpringRunner.class)
@SpringBootTest
public class UserRepositoryTest {

    @Autowired
    private UserRepository userRepository;

    /**
     * id查询
     */
    @Test
    public void findByIdUserTest() {
        Optional<User> userOptional = userRepository.findById(1);
        User user = userOptional.orElseGet(null);
        System.out.println(user);
        Assert.assertNotNull(user);
    }

    /**
     * 分页查询
     */
    @Test
    public void findByPageTest() {
        PageRequest pageRequest = PageRequest.of(0, 2);
        Page<User> userPage = userRepository.findAll(pageRequest);
        List<User> userList = userPage.getContent();
        userList.forEach((user) -> System.out.println(user));
        Assert.assertNotNull(userList);
    }

    /**
     * 更新
     */
    @Test
    public void updateUserTest() {
        Optional<User> userOptional = userRepository.findById(1);
        User user = userOptional.orElseThrow(() -> new RuntimeException("用户信息没有取到"));
        System.out.println(user.getAge());
        ;
        user.setAge(user.getAge() + 1);
        User updateResult = userRepository.save(user);
        Assert.assertNotNull(updateResult);
    }

    /**
     * 根据 Username 和 Password 查询
     */
    @Test
    public void findByUsernameAndPasswordTest() {
        User user = userRepository.findByUsernameAndPassword("Darcy", "123");
        System.out.println(user);
        Assert.assertNotNull(user);
    }
}

Сначала убедитесь, что все четыре метода выполняются.单元测试Запрос пейджинга находит две части данных в базе данных.

Hibernate: select user0_.id as id1_0_, user0_.age as age2_0_, user0_.birthday as birthday3_0_, user0_.password as password4_0_, user0_.skills as skills5_0_, user0_.username as username6_0_ from user user0_ limit ?
Hibernate: select count(user0_.id) as col_0_0_ from user user0_
User(id=1, username=Darcy, password=123, age=18, birthday=2019-01-12 21:02:30.0, skills=Go)
User(id=3, username=Chris, password=456, age=23, birthday=2019-01-01 00:11:22.0, skills=Java)

Также нет проблем с запросом по Id.

Hibernate: select user0_.id as id1_0_0_, user0_.age as age2_0_0_, user0_.birthday as birthday3_0_0_, user0_.password as password4_0_0_, user0_.skills as skills5_0_0_, user0_.username as username6_0_0_ from user user0_ where user0_.id=?
User(id=1, username=Darcy, password=123, age=18, birthday=2019-01-12 21:02:30.0, skills=Go)

Операция обновления также выводит SQL в обычном режиме без каких-либо исключений.

Hibernate: select user0_.id as id1_0_0_, user0_.age as age2_0_0_, user0_.birthday as birthday3_0_0_, user0_.password as password4_0_0_, user0_.skills as skills5_0_0_, user0_.username as username6_0_0_ from user user0_ where user0_.id=?
18
Hibernate: select user0_.id as id1_0_0_, user0_.age as age2_0_0_, user0_.birthday as birthday3_0_0_, user0_.password as password4_0_0_, user0_.skills as skills5_0_0_, user0_.username as username6_0_0_ from user user0_ where user0_.id=?
Hibernate: update user set age=?, birthday=?, password=?, skills=?, username=? where id=?

Последним является операция пользовательского запроса.В выходных данных трех вышеприведенных методов возраст, соответствующий пользователю Darcy, равен 18, а после обновления он должен стать 19 + 1. Ниже приведен результат пользовательского запроса.

Hibernate: select user0_.id as id1_0_, user0_.age as age2_0_, user0_.birthday as birthday3_0_, user0_.password as password4_0_, user0_.skills as skills5_0_, user0_.username as username6_0_ from user user0_ where user0_.username=? and user0_.password=?
User(id=1, username=Darcy, password=123, age=19, birthday=2019-01-12 21:02:30.0, skills=Go)

Видно, что проблем нет.
Код статьи загружен наGitHub.
Некоторые функции JDK8 используются в тестовом коде, напримерOptionalИспользование классов, о новых возможностях JDK я напишу отдельную статью в будущем, добро пожаловать на сканирование кода и обратите внимание на публичный аккаунт.

Hello world :)

Я Аланг, яркая луна и чистый ветер, человек с техническими инструментами, который каждый день передвигает кирпичи.
Персональный сайт:www.wdbyte.com
Если вы хотите подписаться, вы можете подписатьсяНет публики»Программист Аранг",илиБлог программиста Аранга,илиДобавьте меня в WeChat (wn8398).

Эта статья также была организована вGitHub.com/Ниу Мух/Java…, добро пожаловать Звезда.