【SpringBoot實戰】數據訪問

来源:https://www.cnblogs.com/hjk-airl/archive/2022/04/05/16099888.html
-Advertisement-
Play Games

前言 在開發中我們通常會對資料庫的數據進行操作，SpringBoot對關係性和非關係型資料庫的訪問操作都提供了非常好的整合支持。SpringData是spring提供的一個用於簡化資料庫訪問、支持雲服務的開源框架。它是一個傘狀項目，包含大量關係型和非關係型資料庫數據訪問解決方案，讓我們快速簡單的使用 ...


前言

在開發中我們通常會對資料庫的數據進行操作，SpringBoot對關係性和非關係型資料庫的訪問操作都提供了非常好的整合支持。SpringData是spring提供的一個用於簡化資料庫訪問、支持雲服務的開源框架。它是一個傘狀項目，包含大量關係型和非關係型資料庫數據訪問解決方案，讓我們快速簡單的使用各種數據訪問技術，springboot預設採用整合springdata方式統一的訪問層，通過添加大量的自動配置，引入各種數據訪問模板Trmplate以及統一的Repository介面，從而達到簡化數據訪問操作。

這裡我們分別對MyBatis、Redis進行整合。

SpringBoot整合MyBatis

mybatis作為目前操作資料庫的流行框架，spingboot並沒有給出依賴支持，但是mybaitis開發團隊自己提供了啟動器mybatis-spring-boot-starter依賴。
MyBatis是一款優秀的持久層框架，它支持定製sql、存儲過程、高級映射、避免JDBC代碼和手動參數以及獲取結果集。mybatis不僅支持xml而且支持註解。

環境搭建

創建資料庫

我們創建一個簡單的資料庫並插入一些數據用於我們下麵的操作。

# 創建資料庫
CREATE DATABASE studentdata;
# 選擇使用資料庫
USE studentdata;
# 創建表並插入相關數據
DROP TABLE IF EXISTS `t_student`;
CREATE TABLE `t_student` (
  `id` int(20) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) DEFAULT NULL,
  `age` int(8),
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
INSERT INTO `t_student` VALUES ('1', 'hjk', '18');
INSERT INTO `t_student` VALUES ('2', '小何', '20');
創建項目並引入相關啟動器

按照之前的方式創建一個springboot項目，併在pom.xml里導入依賴。我們創建一個名為springboot-01的springboot項目。並且導入阿裡的數據源

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.2.2</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.28</version>
        </dependency>
       <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.8</version>
        </dependency>

我們可以在IDEA右邊連接上資料庫，便於我們可視化操作，這個不連接也不會影響我們程式的執行，只是方便我們可視化。
image

創建Student的實體類

package com.hjk.pojo;

public class Student {
    private Integer id;
    private String name;
    private Integer age;

    public Student(){

    }

    public Student(String name,Integer age){
        this.id = id;
        this.name = name;
        this.age = age;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "Student{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", age=" + age +
                '}';
    }
}

在application.properties里編寫資料庫連接配置。這裡我們使用druid數據源順便把如何配置數據源寫了，用戶名和密碼填寫自己的。使用其他數據源需要導入相關依賴，並且進行配置。springboot2.x版本預設使用的是hikari數據源。

## 選著資料庫驅動類型
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/studentdata?serverTimezone=UTC
## 用戶名
spring.datasource.username=root
## 密碼
spring.datasource.password=123456

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
## 初始化連接數
spring.datasource.druid.initial-size=20
## 最小空閑數
spring.datasource.druid.min-idle=10
## 最大連接數
spring.datasource.druid.max-active=100

然後我們編寫一個配置類，把durid數據源屬性值註入，並註入到spring容器中
創建一個config包，並創建名為DataSourceConfig類

package com.hjk.config;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;

@Configuration  //將該類標記為自定義配置類
public class DataSourceConfig {

    @Bean //註入一個Datasource對象
    @ConfigurationProperties(prefix = "spring.datasource") //註入屬性
    public DataSource getDruid(){
        return new DruidDataSource();
    }
}

目前整個包結構
image

註解方式整合mybatis

創建一個mapper包，並創建一個StudentMapper介面並編寫代碼。mapper其實就和MVC里的dao包差不多。

package com.hjk.mapper;

import com.hjk.pojo.Student;
import org.apache.ibatis.annotations.*;

import java.util.List;

@Mapper  //這個註解是一個mybatis介面文件，能被spring掃描到容器中
public interface StudentMapper {

    @Select("select * from t_student where id = #{id}")
    public Student getStudentById(Integer id) ;

    @Select("select * from t_student")
    public List<Student> selectAllStudent();

    @Insert("insert into t_student values (#{id},#{name},#{age})")
    public int insertStudent(Student student);

    @Update("update t_student set name=#{name},age=#{age} where id = #{id}")
    public int updataStudent(Student student);

    @Delete("delete from t_student where id=#{id}")
    public int deleteStudent(Integer id);
}

編寫測試類進行測試

package com.hjk;

import com.hjk.mapper.StudentMapper;
import com.hjk.pojo.Student;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.List;

@SpringBootTest
class Springdata01ApplicationTests {

    @Autowired
    private StudentMapper studentMapper;

    @Test
    public void selectStudent(){
        Student studentById = studentMapper.getStudentById(1);
        System.out.println(studentById.toString());
    }



    @Test
    public void insertStudent(){
        Student student = new Student("你好",16);
        int i = studentMapper.insertStudent(student);
        List<Student> students = studentMapper.selectAllStudent();
        for (Student student1 : students) {
            System.out.println(student1.toString());
        }
    }

    @Test
    public void updateStudent(){
        Student student = new Student("我叫hjk",20);
        student.setId(1);
        int i = studentMapper.updataStudent(student);
        System.out.println(studentMapper.getStudentById(1).toString());
    }

    @Test
    public void deleteStudent(){
        studentMapper.deleteStudent(1);
        List<Student> students = studentMapper.selectAllStudent();
        for (Student student : students) {
            System.out.println(student.toString());
        }
    }


}
  • 在這裡如果你的實體類的屬性名如果和資料庫的屬性名不太一樣的可能返回結果可能為空，我們可以開器駝峰命名匹配映射。
    在application.properties添加配置。
## 開啟駝峰命名匹配映射
mybatis.configuration.map-underscore-to-camel-case=true

這裡使用註解實現了整合mybatis。mybatis雖然在寫一些簡單sql比較方便，但是寫一些複雜的sql還是需要xml配置。

使用xml配置Mybatis

我們使用xml要先在application.properties里配置一下,不然springboot識別不了。

## 配置Mybatis的XML配置路徑
mybatis.mapper-locations=classpath:mapper/*.xml
## 配置XML指定實體類別名
mybatis.type-aliases-package=com.hjk.pojo

我們重新書寫StudentMapper類，然後使用xml實現數據訪問。這裡我們就寫兩個方法，剩下的基本一樣。

package com.hjk.mapper;


import com.hjk.pojo.Student;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

@Mapper  //這個註解是一個mybatis介面文件，能被spring掃描到容器中
public interface StudentMapper {

    public Student getStudentById(Integer id) ;

    public List<Student> selectAllStudent();

}

我們在resources目錄下創建一個mapper包，併在該包下編寫StudentMapper.xml文件。
我們在寫的時候可以去mybatis文檔中哪複製模板，然後再寫也可以記錄下來，方便下次寫

<?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.hjk.mapper.StudentMapper"><!--這裡namespace寫對應mapper的全路徑名-->

    <select id="getStudentById" resultType="Student">
        select * from t_student where id = #{id}
    </select>

    <select id="selectAllStudent" resultType="Student">
        select * from t_student;
    </select>

</mapper>

編寫測試

package com.hjk;

import com.hjk.mapper.StudentMapper;
import com.hjk.pojo.Student;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.List;

@SpringBootTest
class Springdata01ApplicationTests {

    @Autowired
    private StudentMapper studentMapper;

    @Test
    public void selectStudent(){
        Student studentById = studentMapper.getStudentById(2);
        System.out.println(studentById.toString());
    }

    @Test
    public void selectAllStudent(){
        List<Student> students = studentMapper.selectAllStudent();
        for (Student student : students) {
            System.out.println(student.toString());
        }
    }

}

註解和xml優缺點

註解方便，書寫簡單，但是不方便寫複雜的sql。
xml雖然比較麻煩，但是它的可定製化強，能夠實現複雜的sql語言。
兩者結合使用會有比較好的結果。

整合Redis

Redis是一個開源的、記憶體中的數據結構存儲系統，它可以作用於資料庫、緩存、消息中間件，並提供多種語言的API。redis支持多種數據結構，String、hasher、lists、sets、等。同時內置了複本replication、LUA腳本LUA scripting、LRU驅動時間LRU eviction、事務Transaction和不同級別的磁碟持久化persistence、並且通過Redis Sentinel和自動分區提供高可用性。

  • 我們添加Redis依賴。
	<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
            <version>2.6.6</version>
        </dependency>
  • 我們在創建三個實體類用於整合，在pojo包中。

Family類

package com.hjk.pojo;

import org.springframework.data.redis.core.index.Indexed;

public class Family {

    @Indexed
    private String type;

    @Indexed
    private String userName;

    public String getType() {
        return type;
    }

    public void setType(String type) {
        this.type = type;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    @Override
    public String toString() {
        return "Family{" +
                "type='" + type + '\'' +
                ", userName='" + userName + '\'' +
                '}';
    }
}

Adderss類

package com.hjk.pojo;

import org.springframework.data.redis.core.index.Indexed;

public class Address {

    @Indexed
    private String city;

    @Indexed
    private String country;

    public String getCity() {
        return city;
    }

    public void setCity(String city) {
        this.city = city;
    }

    public String getCountry() {
        return country;
    }

    public void setCountry(String country) {
        this.country = country;
    }

    @Override
    public String toString() {
        return "Address{" +
                "city='" + city + '\'' +
                ", country='" + country + '\'' +
                '}';
    }
}

Person類

package com.hjk.pojo;

import org.springframework.data.annotation.Id;
import org.springframework.data.redis.core.RedisHash;
import org.springframework.data.redis.core.index.Indexed;

import java.util.List;

@RedisHash("person")
public class Person {

    @Id
    private String id;

    @Indexed
    private String firstName;

    @Indexed
    private String lastName;

    private Address address;

    private List<Family> familyList;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getFirstName() {
        return firstName;
    }

    public void setFirstName(String firstName) {
        this.firstName = firstName;
    }

    public String getLastName() {
        return lastName;
    }

    public void setLastName(String lastName) {
        this.lastName = lastName;
    }

    public Address getAddress() {
        return address;
    }

    public void setAddress(Address address) {
        this.address = address;
    }

    public List<Family> getFamilyList() {
        return familyList;
    }

    public void setFamilyList(List<Family> familyList) {
        this.familyList = familyList;
    }

    @Override
    public String toString() {
        return "Person{" +
                "id='" + id + '\'' +
                ", firstName='" + firstName + '\'' +
                ", lastName='" + lastName + '\'' +
                ", address=" + address +
                ", familyList=" + familyList +
                '}';
    }
}
  • RedisHash("person")用於指定操作實體類對象在Redis資料庫中的儲存空間，表示Person實體類的數據操作都儲存在Redis資料庫中名為person的存儲下
  • @Id用標識實體類主鍵。在Redis中會預設生成字元串形式的HasHKey表使唯一的實體對象id，也可以手動設置id。
  • Indexed 用於標識對應屬性在Redis資料庫中的二級索引。索引名稱就是屬性名。

介面整合

編寫Repository介面，創建repository包並創建PersonRepository類

package com.hjk.repository;

import com.hjk.pojo.Person;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.repository.CrudRepository;

import java.util.List;

public interface PersonRepository extends CrudRepository<Person,String> {
    
    List<Person> findByLastName(String lastName);
    Page<Person> findPersonByLastName(String lastName, Pageable pageable);
    List<Person> findByFirstNameAndLastName(String firstName,String lastName);
    List<Person> findByAddress_City(String city);
    List<Person> findByFamilyList_UserName(String userName);
}
  • 這裡介面繼承的使CurdRepository介面，也可以繼承JpaRepository，但是需要導入相關包。

添加配置文件
在application.properties中添加redis資料庫連接配置。


## redis伺服器地址
spring.redis.host=127.0.0.1
## redis伺服器練級埠
spring.redis.port=6379
## redis伺服器密碼預設為空
spring.redis.password=

測試

編寫測試類，在測試文件下創建一個名為RedisTests的類

package com.hjk;

import com.hjk.pojo.Address;
import com.hjk.pojo.Family;
import com.hjk.pojo.Person;
import com.hjk.repository.PersonRepository;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.ArrayList;
import java.util.List;

@SpringBootTest
public class RedisTests {

    @Autowired
    private PersonRepository repository;

    @Test
    public void redisPerson(){

        //創建按對象
        Person person = new Person();
        person.setFirstName("王");
        person.setLastName("nihao");
        Address address = new Address();
        address.setCity("北京");
        address.setCountry("china");
        person.setAddress(address);
        ArrayList<Family> list = new ArrayList<>();
        Family family = new Family();
        family.setType("父親");
        family.setUserName("你爸爸");
        list.add(family);
        person.setFamilyList(list);

        //向redis資料庫添加數據
        Person save = repository.save(person);
        System.out.println(save);
    }

    @Test
    public void selectPerson(){
        List<Person> list = repository.findByAddress_City("北京");
        for (Person person : list) {
            System.out.println(person);
        }
    }

    @Test
    public void updatePerson(){
        Person person = repository.findByFirstNameAndLastName("王", "nihao").get(0);
        person.setLastName("小明");
        Person save = repository.save(person);
        System.out.println(save);
    }


    @Test
    public void deletePerson(){
        Person person = repository.findByFirstNameAndLastName("王", "小明").get(0);
        repository.delete(person);

    }

}

總結

我們分別對mybatis和redis進行整合。
mybaitis：
註解：導入依賴->創建實體類->屬性配置->編寫配置類->編寫mapper介面->進行測試。
xml：導入依賴->創建實體類->屬性配置（配置資料庫等，配置xml路徑）->mapper介面->xml實現->測試
redis：導入依賴->實體類->實現介面->配置redis屬性->測試


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 如何使用Python處理Missing Data
    前言 現實世界的數據中常常包含缺失的數據。原因很多，比如觀察結果沒有記錄，或數據損壞。處理缺失的數據很重要，因為許多機器學習演算法不支持具有缺失值的資料庫。 本教程將討論如何使用Python處理缺失的數據來進行機器學習。 您將瞭解到： •如何在數據集中標記無效或損壞的值。 •如何從數據集中刪除缺失數據 ...
  • 使用 Java Swing 編寫 IpChat, 基於 IP Messenger 協議，支持 IPv6
    最近一段時間居家辦公，使用 Java Swing 編寫 IpChat, 基於 IP Messenger 協議，支持 IPv6。可實現簡單的文本信息傳輸，點對點直接通訊，無需中間伺服器。 ...
  • 多線程（線程組【ThreadGroup】）
    線程組： 把多個線程組合到一起。 * 它可以對一批線程進行分類管理，Java允許程式直接對線程組進行控制。 package cn.itcast_06; public class MyRunnable implements Runnable { @Override public void run() ...
  • Qt QComboBox之setEditable和currentTextChanged及其源碼分析
    Qt QComboBox之setEditable和currentTextChanged以及其源碼分析 前言 最近做了一個QComboBox里有選項，然後選中選項之後就會自動觸發條件搜索。然後我發現，在我初始化comboBox時，由於信號連接的原因會觸發這個currentTextChanged信號。代 ...
  • IDEA小技巧：Debug條件斷點
    今天給大家分享一個IDEA調試過程中的一個小技巧。 先來說說場景，你有沒有碰到類似的情況，一個迴圈結構里，中間某一個情況可能會出錯。比如下麵的代碼結果中，可能執行到第27次的時候，會出現問題。 for(int i = 0; i < 100; i++) { // 業務邏輯 System.out.pri ...
  • 多線程（生產者和消費者問題【死鎖--解決線程安全--等待喚醒機制---線程狀態轉換圖】）
    Lock： 鎖對象 * void lock()： 獲取鎖。 * void unlock():釋放鎖。 * ReentrantLock是Lock的實現類、 package cn.itcast_01; import java.util.concurrent.locks.Lock; import java ...
  • 20212218 實驗二《Python程式設計》實驗報告
    獲取python的源碼 3.x及最新版本的源碼：https://github.com/python/cpython python2.7分支的源碼：https://github.com/python/cpython/tree/v2.7.18 python官網也提供源碼下載：https://www.py ...
  • 輸入/輸出流
    《零基礎學Java》 輸入/輸出流 Java語言把與輸入/輸出流有關的類都放在了java.io包中。其中，所有與輸入流有關的類都是抽象類InputStream（位元組輸入流）或抽象類Reader（字元輸入流）的子類；而所有與輸出流有關的類都是抽象類OutputStream（位元組輸出流）或抽象類Writ ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類