2. 程式人生 > >04 SpringBoot對資料庫的支援

04 SpringBoot對資料庫的支援

阿新 • • 發佈：2019-01-02

文章目錄

簡介

Spring Data專案是Spring用來解決資料訪問問題的一攬子解決方案

Spring Data提供了統一的API，對資料儲存技術進行支援

不同的持久層技術，有不同的Spring Data子專案

這些子專案都通過Spring Data Commons專案來實現

Spring DataCommons讓我們在使用關係型或非關係型資料庫技術時，都使用基於Spring的統一標準

包含：CRUD、查詢、排序、分頁

常用子專案

  • Spring Data JPA
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-jpa -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-jpa</
 
artifactId>
    <version>1.11.10.RELEASE</version>
</dependency>
  • Spring Data MongoDB
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-mongodb -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-mongodb</artifactId>
    <version>1.10.10.RELEASE</version>
</dependency>
  • Spring Data Neo4J
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-neo4j -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-neo4j</artifactId>
    <version>5.0.3.RELEASE</version>
</dependency>
  • Spring Data Redis
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-redis -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-redis</artifactId>
    <version>2.0.3.RELEASE</version>
</dependency>
  • Spring Data Solr
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-solr -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-solr</artifactId>
    <version>3.0.3.RELEASE</version>
</dependency>
  • Spring For Apache Hadoop
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-hadoop -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-hadoop</artifactId>
    <version>2.5.0.RELEASE</version>
</dependency>
  • Spring Data GemFire
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-gemfire -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-gemfire</artifactId>
    <version>2.0.3.RELEASE</version>
</dependency>
  • Spring Data REST WebMVC
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-rest-webmvc -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-rest-webmvc</artifactId>
    <version>3.0.3.RELEASE</version>
</dependency>
  • Spring Data Couchbase
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-couchbase -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-couchbase</artifactId>
    <version>3.0.3.RELEASE</version>
</dependency>
  • Spring Data Elasticsearch
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-elasticsearch -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-elasticsearch</artifactId>
    <version>3.0.3.RELEASE</version>
</dependency>
  • Spring Data For Apache Cassandra Core
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-cassandra -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-cassandra</artifactId>
    <version>2.0.3.RELEASE</version>
</dependency>

Repository介面

package org.springframework.data.repository;

import java.io.Serializable;
public interface Repository<T, ID extends Serializable> {

}

Repository根介面接收JPA領域類和領域類的id型別作為型別引數

CrudRepository

CrudRepository子介面定義了和CRUD相關操作的內容


package org.springframework.data.repository;

import java.io.Serializable;


@NoRepositoryBean
public interface CrudRepository<T, ID extends Serializable> extends Repository<T, ID> {


	<S extends T> S save(S entity);


	<S extends T> Iterable<S> save(Iterable<S> entities);


	T findOne(ID id);

	boolean exists(ID id);

	Iterable<T> findAll();


	Iterable<T> findAll(Iterable<ID> ids);

	long count();


	void delete(ID id);


	void delete(T entity);


	void delete(Iterable<? extends T> entities);


	void deleteAll();
}

PagingAndSortingRepository

PagingAndSortingRepository子介面定義了分頁、排序相關的內容


package org.springframework.data.repository;

import java.io.Serializable;

import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;

/**
 * Extension of {@link CrudRepository} to provide additional methods to retrieve entities using the pagination and
 * sorting abstraction.
 * 
 * @author Oliver Gierke
 * @see Sort
 * @see Pageable
 * @see Page
 */
@NoRepositoryBean
public interface PagingAndSortingRepository<T, ID extends Serializable> extends CrudRepository<T, ID> {

	/**
	 * Returns all entities sorted by the given options.
	 * 
	 * @param sort
	 * @return all entities sorted by the given options
	 */
	Iterable<T> findAll(Sort sort);

	/**
	 * Returns a {@link Page} of entities meeting the paging restriction provided in the {@code Pageable} object.
	 * 
	 * @param pageable
	 * @return a page of entities
	 */
	Page<T> findAll(Pageable pageable);
}

小結

不同的資料訪問技術提供了不同的Repository

如：Spring Data JPA有JpaRepository；Spring Data MongoDB有MongoRepository

Spring Data專案有一個激動人心的功能，可以根據屬性名進行計數、刪除、查詢等方法的操作

關鍵字 方法命名 sql where字句
And findByNameAndPwd where name= ? and pwd =?
Or findByNameOrSex where name= ? or sex=?
Is,Equals findById,findByIdEquals where id= ?
Between findByIdBetween where id between ? and ?
LessThan findByIdLessThan where id < ?
LessThanEquals findByIdLessThanEquals where id <= ?
GreaterThan findByIdGreaterThan where id > ?
GreaterThanEquals findByIdGreaterThanEquals where id > = ?
After findByIdAfter where id > ?
Before findByIdBefore where id < ?
IsNull findByNameIsNull where name is null
isNotNull,NotNull findByNameNotNull where name is not null
Like findByNameLike where name like ?
NotLike findByNameNotLike where name not like ?
StartingWith findByNameStartingWith where name like ‘?%’
EndingWith findByNameEndingWith where name like ‘%?’
Containing findByNameContaining where name like ‘%?%’
OrderBy findByIdOrderByXDesc where id=? order by x desc
Not findByNameNot where name <> ?
In findByIdIn(Collection<?> c) where id in (?)
NotIn findByIdNotIn(Collection<?> c) where id not in (?)
True findByAaaTue where aaa = true
False findByAaaFalse where aaa = false
IgnoreCase findByNameIgnoreCase where UPPER(name)=UPPER(?

find方法是查詢，如果是計數，則為count，刪除，則為delete

限制結果數量：top和first關鍵字，如，findFirst10ByName，findTop10ByName

Spring Data JPA

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-jpa</artifactId>
		</dependency>
  • 資料來源
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/tdk?useSSL=false&useUnicode=true&characterEncoding=utf8
    username: root
    password: 123456
    driver-class-name: com.mysql.jdbc.Driver
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true
  jackson:
    serialization: true

自動配置

SpringBoot自動開啟了註解事務的支援（@EnableTransactionManagement）

還配置了一個JdbcTemplate

Spring還提供了一個初始化資料的功能，放在類路徑下的schema.sql自動初始化表結構，data.sql自動填充表資料

SpringData對JPA的自動配置放在org.springframework.boot.autoconfigure.orm.jpa

預設的JPA實現是Hibernate

配置JPA的字首為：spring.jpa

自動掃描註解有@Entity的實體類

在Web專案中，我們經常遇到控制器或頁面訪問資料的時候出現會話連線關閉的錯誤

這個時候，我們會配置一個Open EntityManager（Session）In View這個過濾器

SpringBoot為我們自動配置了OpenEntityManagerInViewInterceptor這個Bean，

並且已經註冊到SpringMVC攔截器。

無需手動開啟

@EnableJpaRepositories

案例

  • pom

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-jpa</artifactId>
		</dependency>
		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
			<scope>runtime</scope>
		</dependency>
  • domain
package org.zln.spb.demo01.domain;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.NamedQuery;

/**
 * @Author 張柳寧
 * @Description
 * @Date Create in 2018/1/31
 * @Modified By:
 */
@Entity
@Data
@NoArgsConstructor
@AllArgsConstructor
@NamedQuery(name = "Person.withNameAndAddressNamedQuery",
        query = "select p from Person p where p.name = ?1 and p.address = ?2")
public class Person {
    @Id
    @GeneratedValue
    private Long id;

    private String name;
    private Integer age;
    private String address;
}
  • dao
package org.zln.spb.demo01.dao;

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.zln.spb.demo01.domain.Person;

import java.util.List;

/**
 * @Author 張柳寧
 * @Description
 * @Date Create in 2018/1/31
 * @Modified By:
 */

public interface PersonDao extends JpaRepository<Person,Long> {

    List<Person> findByAddress(String address);

    Person findByNameAndAddress(String name,String address);

    @Query("select p from Person p where p.name = :name and p.address = :address")
    Person withNameAndAddressQuery(@Param("name") String name,@Param("address") String address);

    Person withNameAndAddressNamedQuery(String name,String address);

    List<Person> findByNameLike(String name);



}
  • 測試
package org.zln.spb.demo01.dao;

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.test.context.junit4.SpringRunner;
import org.zln.spb.demo01.domain.Person;

import java.util.List;

import static org.junit.Assert.*;

/**
 * @Author 張柳寧
 * @Description
 * @Date Create in 2018/1/31
 * @Modified By:
 */
@RunWith(SpringRunner.class)
@SpringBootTest
public class PersonDaoTest {

    @Autowired
    private PersonDao personDao;

    @Test
    public void findByAddress() {
        personDao.findByAddress("地址");
    }

    @Test
    public void findByNameAndAddress() {
        personDao.findByNameAndAddress("姓名","地址");
    }

    @Test
    public void withNameAndAddressQuery() {
        personDao.withNameAndAddressQuery("姓名","地址");
    }

    @Test
    public void withNameAndAddressNamedQuery() {
        personDao.withNameAndAddressNamedQuery("姓名","地址");
    }

    @Test
    public void findByNameLike() {
        List<Person> personList = personDao.findByNameLike("%name%");
        System.out.println(personList);
    }
}
  • 排序
personList = personDao.findAll(new Sort(Sort.Direction.DESC,"age"));
  • 分頁查詢
Page<Person> people = personDao.findAll(new PageRequest(2,3));
for (Person person:people){
  System.out.println(person);
}

小結

對於大多數的SQL，其實都是非常簡單的單表查詢

這個時候使用IDEA對Hibernate的自動生成程式碼，非常方便的

對於一些複雜SQL，再考慮使用MyBatis或者JdbcTemplate

整合H2資料庫

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
	<groupId>com.h2database</groupId>
	<artifactId>h2</artifactId>
</dependency>


server:
  port: 8000
spring:
  jpa:
    generate-ddl: false
    show-sql: true
    hibernate:
      ddl-auto: none
  datasource:                           # 指定資料來源
    platform: h2                        # 指定資料來源型別
    schema: classpath:schema.sql        # 指定h2資料庫的建表指令碼
    data: classpath:data.sql            # 指定h2資料庫的資料指令碼
logging:                                # 配置日誌級別，讓hibernate打印出執行的SQL
  level:
    root: INFO
    org.hibernate: INFO
    org.hibernate.type.descriptor.sql.BasicBinder: TRACE
    org.hibernate.type.descriptor.sql.BasicExtractor: TRACE

HikariDataSource資料來源

配置

# jdbc_config   datasource
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/datebook?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&zeroDateTimeBehavior=convertToNull
spring.datasource.username=root
spring.datasource.password=root
# Hikari will use the above plus the following to setup connection pooling
spring.datasource.type=com.zaxxer.hikari.HikariDataSource
spring.datasource.hikari.minimum-idle=5
spring.datasource.hikari.maximum-pool-size=15
spring.datasource.hikari.auto-commit=true
spring.datasource.hikari.idle-timeout=30000
spring.datasource.hikari.pool-name=DatebookHikariCP
spring.datasource.hikari.max-lifetime=1800000
spring.datasource.hikari.connection-timeout=30000
spring.datasource.hikari.connection-test-query=SELECT 1

spring:
  profiles:
    active: prod
  datasource:
  #  使用高效能資料來源
    type: com.zaxxer.hikari.HikariDataSource
    driver-class-name: com.mysql.jdbc.Driver
    hikari:
      minimum-idle: 15
      maximum-pool-size: 50
      idle-timeout: 30000
      pool-name: DatebookHikariCP
      maxLifetime: 40000 # 這個值要配置的比mysql的wait_timeout小，預設值是30分鐘。但是不得配置少於30秒，佛足額就會重置回預設值
      connection-timeout: 30000
      connection-test-query: SELECT 1
      connection-init-sql: set names utf8mb4
      validation-timeout: 5000

springboot 2.0 預設連線池就是Hikari了，所以引用parents後不用專門加依賴

java配置

Java配置資料來源

    public HikariDataSource dataSourceConf(MutiDataSourceProperties dataSource) {
        //資料來源配置資訊
        HikariConfig hikariConfig = new HikariConfig();
        hikariConfig.setJdbcUrl(dataSource.getUrl());
        hikariConfig.setUsername(dataSource.getUsername());
        hikariConfig.setPassword(dataSource.getPassword());
        hikariConfi

相關推薦

04 SpringBoot對資料庫的支援

文章目錄 簡介 常用子專案 Repository介面 CrudRepository PagingAndSortingRepository 小結 Spring Data JPA 自

5.04-springboot連線資料庫啟動報錯

   部分異常資訊如下： 2018-12-05 17:00:19.810 ERROR 10908 --- [eate-1708786164] com.alibaba.druid.pool.DruidDataSource : create connection SQLExceptio

SpringBoot對非關係型資料庫NoSql的支援

NoSql是對於所有不使用關係作為資料管理的資料庫系統的總稱，NoSql的特點主要是不使用sql作為查詢語言。資料儲存也不是固定的表和欄位 NoSql資料庫主要有文件儲存型（MongoDB），圖形關係儲存型（Neo4j），鍵值對儲存型（Redis） Sp

使用SSM 或者 springboot +mybatis時，對資料庫的認證資訊（使用者名稱，密碼）進行加密。

通常情況下，為了提高安全性，我們需要對資料庫的認證資訊進行加密操作，然後在啟動專案的時候，會自動解密來核對資訊是否正確。下面介紹在SSM和springboot專案中分別是怎樣實現的。 無論是使用SSM還是springboot，首先我們需要一個加密工具，這裡我採用的是AES 高階加

SpringBoot對快取的支援

頁面快取是否有必要？      幾乎所有的網站的首頁都是訪問率最高的，而首頁上的資料來源又是非常廣泛的，大多數來自不同的物件，而且有可能來自不同的db ，所以給首頁做快取是很必要的。那麼主頁的快取策略應該怎樣設計呢？我認為應該是某個固定時間之內不變的，比如

Springboot中使用Mybatis框架對資料庫進行聯表查詢，踩坑填坑

因為mybatis使用的基本是原生sql語句 所以首先從資料庫開始說 以mysql資料庫為例，對錶的連線查詢分為四種 內連線，外連線，交叉連線，和聯合連線 內連線使用比較運算子根據每個表共有的列的值匹配兩個表中的行 sql語句舉例：聯接查詢user，order表

springboot整合jpa實現對資料庫的增刪改查

在實際開發中，spring整合mybatis或者jpa對資料庫操作的情況都存在，這兩者的區別或關係就不在贅述了，簡單來說呢，就是jpa實現起來比較簡單，很方便上手。下面看一下我們的專案如何配置jpa實現對資料庫的操作吧。 首先在pom中引入依賴了，這裡可以在建立專案時選擇j

springboot對velocity的支援

最近在使用springboot中，用velocity作為檢視模板的時候，一直出現問題，無法返回頁面。 通過查詢資料得知，springboot預設是不支援velocity的，需要新增而外配置。 並且在高版本的springboot中是不支援velocity了。最高只到1.4.x版本支援，1.

EasyDSS流媒體伺服器軟體對資料庫Sqlite3和MySQL的同時支援說明

EasyDSS流媒體音視訊直播與點播伺服器軟體，是一套提供一站式的轉碼、點播、直播、檢索、回放、錄影下載服務的高效能RTMP/HLS/HTTP-FLV流媒體服務，極大地簡化了流媒體相關業務的開發和整合的工作。 其中，點播功能主要包含：上傳、轉碼、分發。直播功能，主要包含：直播、錄影， 直

SpringBoot之攔截器對資料庫的訪問

    在專案中遇到了需要在攔截器中對資料庫進行查詢！     在網上查了一些方法，像@Bean或者@Service等都沒有得到想要的結果。但是還是找到了一種方法進行解決。     忘記了是在那個網頁看到的了！！！抱歉！     解決方案如下：     第一步： @Con

03 SpringBoot對Web的支援

文章目錄 支援 Thymealeaf模板引擎 配置Thymeleaf 首頁 小結 自動配置的Formatter和Converter 接管Spring Boot 的Web配置 註冊Servlet、F

SpringBoot對訊息佇列(MQ)的支援

1.非同步訊息的定義   非同步訊息的主要目的是為了系統與系統之間的通訊，所謂非同步訊息即訊息傳送者無需等待訊息接收者的處理以及返回，甚至無需關心訊息是否傳送成功   在非同步訊息中有兩個很重要的概念，即訊息代理和目的地，當訊息傳送者傳送訊息之後，訊息將由訊

Ubuntu16.04下apache2開啟對.htaccess支援

具體操作是： sudo a2enmod 終端提示可以使用的模組名稱，此時輸入 rewrite 提示成功載入rewrite模組，然後修改apache2的配置檔案 cd /etc/apache2 sudo vim apache2.conf 然後將 <Directory /var

Hibernate對資料庫連線池的支援

前言 對於一個簡單的資料庫應用，由於資料庫的訪問不是很頻繁，那麼如果需要資料庫操作，則建立一個連線，不需要則關閉連線。這很簡單。但是，對於一個複雜的資料庫應用，情況就完全不同了。頻繁的建立、關閉連線，會極大的減低系統的效能，以此連線池應運而生。本文主要介紹Hi

springboot+springmvc+mybatis 使用註解對資料庫的增、改和查操作

@Insert("INSERT INTO mstb_crm_customer_field(ID,BID,CBID," +"MD5,OWNERADA,STATUS,FIELD_NAME,FIELD_INDEX,FIELD_CONTENT," +"CREATE_TIME,UPDATE_TIME,SPARE1,SP

SpringBoot 對Future模式的支援

  我們在實際專案中有些複雜運算、耗時操作，就可以利用多執行緒來充分利用CPU，提高系統吞吐量。SpringBoot對多執行緒支援非常好，對我們的開發非常便捷。   Future模式是多執行緒開發中非常常見的一種設計模式。核心思想是非同步呼叫。當我們執行一個方法時，方法中有多個耗時任務需要同時去做，而且又不著

利用支援ODBC的CRecordset類實現對資料庫的操作

1.MFC中的ODBC類 主要有CDatabase、CRecordset、CRecordview、CDBException、CFieldExchange。這些類封裝了ODBC SDK函式，可以很方便的操作支援ODBC的資料庫。 (1)CDatabase類：封裝應用程式與需

mysql模糊查詢unicode編碼的欄位的解決方案——mybatis查資料庫mysql時對unicode支援問題

1.mysql資料庫裡的nickname欄位內容是經過unicode編碼處理後儲存的， 如：\u73\u74\u61\u72\u7a\u6d\ud83d\udc7f\u20\ud83d\ude04\u20\ud83d\ude03\u20\ud83d\ude13 實際明文：

SpringBoot 對Restful的支援

一、RESTful風格API的好處 RESTful是基於http方法的API設計風格，而不是一種新的技術. url和http的

條款04 確定對象被使用前已先被初始化

clas local 定義 被調用 private 對象 引用 動作 style 一、概述 手工初始化內置類型對象 構造函數的成員初始化列表 static對象的初始化：包括non-local static和local static 二、細節 1. 你的構造函數使用了成員