spring boot 整合spring data jpa

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

本文結構：
- 什麼是springdata jpa
- springboot 整合spring data jpa

這裡寫圖片描述

Spring Data Repository的核心介面是Repository(好像也沒什麼好驚訝的)。這個介面需要領域類(Domain Class)跟領域類的ID型別作為引數。這個介面主要是讓你能知道繼承這個類的介面的型別。CrudRepository 供了對被管理的實體類的一些常用CRUD方法。

這裡寫圖片描述

2. springboot 整合spring data jpa

2.1. 首先匯入jar 包

springboot 整合spring data jpa 首先要匯入依賴的jar包。pom.xml 檔案中新增如下依賴：

    <!-- spring-data-jpa -->
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>org.hibernate</groupId 
>
            <artifactId>hibernate-entitymanager</artifactId>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
        </dependency>


    <!--data source  spring data jpa 需要用c3p0 連線池--> 

        <dependency>
            <groupId>com.mchange</groupId>
            <artifactId>c3p0</artifactId>
            <version>0.9.5.2</version>
            <exclusions>
                <exclusion>
                    <groupId>commons-logging</groupId>
                    <artifactId>commons-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

2.2 配置datasource

新建DBConfig.java 檔案配置資料來源。

package com.example.config;

import java.beans.PropertyVetoException;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;

import com.mchange.v2.c3p0.ComboPooledDataSource;

@Configuration
public class DBConfig {
    @Autowired
    private Environment env;

    @Bean(name="dataSource")
    public ComboPooledDataSource dataSource() throws PropertyVetoException {
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        dataSource.setDriverClass(env.getProperty("ms.db.driverClassName"));
        dataSource.setJdbcUrl(env.getProperty("ms.db.url"));
        dataSource.setUser(env.getProperty("ms.db.username"));
        dataSource.setPassword(env.getProperty("ms.db.password"));
        dataSource.setMaxPoolSize(20);
        dataSource.setMinPoolSize(5);
        dataSource.setInitialPoolSize(10);
        dataSource.setMaxIdleTime(300);
        dataSource.setAcquireIncrement(5);
        dataSource.setIdleConnectionTestPeriod(60);

        return dataSource;
    }

}

2.3. 新增資料庫連線資訊

在配置檔案application.properties中新增資料庫連線資訊如下：

ms.db.driverClassName=com.mysql.jdbc.Driver
ms.db.url=jdbc:mysql://localhost:3306/msm?prepStmtCacheSize=517&cachePrepStmts=true&autoReconnect=true&characterEncoding=utf-8&allowMultiQueries=true
ms.db.username=root
ms.db.password=admin
ms.db.maxActive=500

2.4 配置JpaConfig

新建JpaConfig.java 檔案內容如下：

package com.example.config;

import java.util.HashMap;
import java.util.Map;

import javax.persistence.EntityManagerFactory;
import javax.sql.DataSource;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

@Configuration
//此處是你dao檔案所在的包名
@EnableJpaRepositories("com.example.*.dao")
@EnableTransactionManagement
public class JpaConfig {

    @Autowired
    private DataSource dataSource;

    @Bean
    public EntityManagerFactory entityManagerFactory() {
        HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();

        LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
        factory.setJpaVendorAdapter(vendorAdapter);
        //此處com.example.*.model是你的java bean所在的包名
        factory.setPackagesToScan("com.example.*.model");
        factory.setDataSource(dataSource);

        Map<String, Object> jpaProperties = new HashMap<String, Object>();
        jpaProperties.put("hibernate.ejb.naming_strategy","org.hibernate.cfg.ImprovedNamingStrategy");
        jpaProperties.put("hibernate.jdbc.batch_size",50);

        factory.setJpaPropertyMap(jpaProperties);
        factory.afterPropertiesSet();
        return factory.getObject();
    }

    @Bean
    public PlatformTransactionManager transactionManager() {

        JpaTransactionManager txManager = new JpaTransactionManager();
        txManager.setEntityManagerFactory(entityManagerFactory());
        return txManager;
    }
}

2.5 新建對應資料庫表的實體類。（也就是java bean ）

注意 
@Entity
@Table(name = "sec_user")
標籤的使用，@Entity表示這個是一個實體類，@Table(name = "sec_user") 中sec_user 是資料庫中對應的表名

@Id
@GeneratedValue 對應ID 
@Column(name = "name") 對應資料庫中該列對應的列名，也就是屬性名

package com.example.base.model;

import java.util.Date;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.Table;

import com.fasterxml.jackson.annotation.JsonIgnore;

@Entity
@Table(name = "sec_user")
public class User {
    @Id
    @GeneratedValue
    private Integer id;
    @Column(name = "name")
    private String name;
    @Column(name = "password")
    private String password;
    @Column(name = "username")
    private String username;
    @Column(name = "division_id")
    private Integer divisionId;
    @Column(name = "email")
    private String email;
    @Column(name = "gender")
    private String gender;
    @Column(name = "mobilephone")
    private String mobilephone;
    @Column(name = "telephone")
    private String telephone;
    @Column(name = "user_type")
    private Integer userType;
    @Column(name = "create_by")
    private String createBy;
    @Column(name = "create_time")
    private Date createTime;
    @Column(name = "update_by")
    private String updateBy;
    @Column(name = "update_time")
    private Date updateTime;
    @Column(name = "disabled")
    private Integer disabled;
    @Column(name = "theme")
    private String theme;
    @Column(name = "is_ldap")
    private Integer isLdap;

    public String getName() {
        return name;
    }

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

    @JsonIgnore
    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public Integer getDivisionId() {
        return divisionId;
    }

    public void setDivisionId(Integer divisionId) {
        this.divisionId = divisionId;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    public String getGender() {
        return gender;
    }

    public void setGender(String gender) {
        this.gender = gender;
    }

    public String getMobilephone() {
        return mobilephone;
    }

    public void setMobilephone(String mobilephone) {
        this.mobilephone = mobilephone;
    }

    public String getTelephone() {
        return telephone;
    }

    public void setTelephone(String telephone) {
        this.telephone = telephone;
    }

    public Integer getUserType() {
        return userType;
    }

    public void setUserType(Integer userType) {
        this.userType = userType;
    }

    public String getCreateBy() {
        return createBy;
    }

    public void setCreateBy(String createBy) {
        this.createBy = createBy;
    }

    public Date getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    public String getUpdateBy() {
        return updateBy;
    }

    public void setUpdateBy(String updateBy) {
        this.updateBy = updateBy;
    }

    public Date getUpdateTime() {
        return updateTime;
    }

    public void setUpdateTime(Date updateTime) {
        this.updateTime = updateTime;
    }

    public Integer getDisabled() {
        return disabled;
    }

    public void setDisabled(Integer disabled) {
        this.disabled = disabled;
    }

    public String getTheme() {
        return theme;
    }

    public void setTheme(String theme) {
        this.theme = theme;
    }

    public Integer getIsLdap() {
        return isLdap;
    }

    public void setIsLdap(Integer isLdap) {
        this.isLdap = isLdap;
    }

    public Integer getId() {
        return id;
    }

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

2.5 編寫spring data jpa 的dao層（重頭戲哦）

首先我們先了解一下 spring data jpa 的命名規範，然後再開始編寫一個簡單的測試例子。
這裡寫圖片描述

例子：
新建UserJpaDao類繼承 JpaRepository

package com.example.base.dao;

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import com.example.base.model.User;

/**
 * The Interface UserJpaDao.
 * @author abel
 */
public interface UserJpaDao extends JpaRepository<User, Long> {

    /**
     * Find by name.
     *
     * @param name the name
     * @return the user
     */
    User findByName(String name);

    /**
     * Find by name and user name.
     * 如果引數名為多個字母組成，請首字母大寫。勿使用駝峰命名，jpa不識別駝峰
     * @param name the name
     * @param age the age
     * @return the user
     */
    User findByNameAndUsername(String name, Integer age);

    /**
     * Find user.
     * User為@Entity 的名字
     * @param name the name
     * @return the user
     */
    @Query("from User u where u.name=:name")
    User findUser(@Param("name") String name);
}

2.6 service 層的編寫（這一步和Spring mvc 已經沒有什麼差別的了。）

service 程式碼如下。（此處我就僅僅寫了dao的一個方法）

package com.example.base.service;
import com.example.base.model.User;

/**
 * The Interface UserService.
 */
public interface UserService {

    /**
     * Gets the user by name.
     *
     * @param username the user name
     * @return the user by name
     */
    public User getUserByName(String username);
}

實現如下：

package com.example.base.service.Impl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.example.base.dao.UserJpaDao;
import com.example.base.model.User;
import com.example.base.service.UserService;
/**
 * 
 * @ClassName UserServiceImpl
 * @author abel
 * @date 2016年11月10日
 */
@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserJpaDao userJpaDao;

    /**
     * 
     * @param UserName
     * @return
     */
    @Override
    public User getUserByName(String username) {
        return userJpaDao.findByName(username);
    }
}

2.7 controller 編寫

package com.example.base.controller;

import javax.servlet.http.HttpServletRequest;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;

import com.example.base.service.UserService;
import com.example.base.util.CommonUtil;

/**
 * 
 * @ClassName UserController
 * @author abel
 * @date 2016年11月10日
 */
@Controller
@RequestMapping(value = "/users")
public class UserController {

    @Autowired
    private UserService userService;

    /**
     * 通過spring data jpa 呼叫方法 api :localhost:8099/users/byname?username=xxx
     * 
     * @param request
     * @return
     */
    @RequestMapping(value = "/byname", method = RequestMethod.GET)
    @ResponseBody
    public ResponseEntity<Object> getUser(HttpServletRequest request) {
        Map<String, Object> map = CommonUtil.getParameterMap(request);
        String username = (String) map.get("username");
        return new ResponseEntity<>(userService.getUserByName(username), HttpStatus.OK);
    }
}

Spring Boot整合Spirng-data-jpa及使用

Spring-data-jpa可根據實體類自動建立表結構，提供基本的增刪改查方法，資料訪問層非常簡潔，只是一層介面。 1.pom引進依賴  <dependency> <groupI

Spring boot 整合spring Data JPA+Spring Security+Thymeleaf框架(上)

current 不可 src rac 分享圖片正在 html AC ren 近期上班太忙所以耽擱了給大家分享實戰springboot 框架的使用。以下是spri

Spring Boot 整合 Spring Data Jpa 增刪改查示例

原文地址：https://renguangli.com/articles/spring-boot-jpa 使用 Spring Data Jpa 對資料庫進行操作 Jpa 與 Spring Data Jpa 的關係 JPA 是Java Persistence API 的簡稱，中

Spring Boot整合Spring MVC、Spring、Spring Data JPA(Hibernate)

一句話總結：Spring Boot不是新的功能框架，而是為了簡化如SSH、SSM等等多個框架的搭建、整合及配置。使用Spring Boot 10分鐘搭建起Spring MVC、Spring、Spring Data JPA(Hibernate)基礎後臺架構。基本零配置，全註解。步驟一：使用Sprin

Spring Boot整合Spring-data-JPA

一.整合Spring-data-JPA JPA(Java Persistence API的簡稱,中文名Java持久層API) 基於註解來去配置對映,實體類,資料庫表的規範(增刪改查的規範) 1.需求

spring boot 整合spring data jpa

本文結構： - 什麼是springdata jpa - springboot 整合spring data jpa Spring Data Repository的核心介面是Repository(好像也沒什麼好驚訝的)。這個介面需要領域類(Doma

Spring Boot 整合Spring Data JPA 資料介面開發測試(二)

核心介面程式碼: 1.實體類 package com.weichai.SpringDataJpaQuery.entity; import java.io.Serializable; import javax.persistence.Entity; import jav

spring boot 整合 spring data jpa

因為最近在實習過程中，需要學習jpa框架，所以在學習後，簡單總結一下 spring boot 和 spring data jpa的整合。因為之前學習了一下 spring boot ，所以這次就將二者整合一下，也是實踐一下spring boot吧

Spring Boot整合Spring Data

之前打算把Spring Data的整合放在前面給大家分享和交流，但實際操作的時候覺得這塊的知識雖然和之前的jpa有相似之處但用下來發現還是不一樣就找了Spring Data的視訊和資料學了一遍，就像之前說的學習Spring Boot需要懂得Spring體系的框架。一

Spring Boot整合Spring Data Elasticsearch 踩坑

首先來看官網給的版本要求：紅框這欄指的是：Elasticsearch安裝版本（windows安裝版本或Linux按照版本）最新因為專案需要elasticsearch，採用今天搞了好久，專案啟動就報如下錯誤： org.elasticsearch.transport

Spring Boot整合Spring Security

只開啟了簡單的登陸驗證新增依賴 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-star

高併發架構實戰(五) Spring Boot 整合 spring-cloud-config

一、配置config服務端新建配置服務專案，如config-server。 1. 在config-server專案中新增依賴 <dependencyManagement> <dependencies> <

spring boot整合spring security筆記

最近自己做了一個小專案，正在進行springboot和spring Security的整合，有一丟丟的感悟，在這裡分享一下：首先，spring boot整合spring security最好是使用Thymleaf，因為spring boot官方支援使用thymleaf,這樣的話

第七篇：Spring Boot整合Spring Cache

為了提高效能，減少資料庫的壓力，使用快取是非常好的手段之一。因此本文講解 Spring Boot 如何整合快取管理。宣告式快取 Spring 定義 CacheManager 和 Cache 介面用來統一不同的快取技術。例如 JCache、 EhCache、 Hazelcast、

spring-boot整合spring-security實現簡單登入(ajax登入實現)

平常再做一些專案時,有些專案並不需要複雜的登入許可權驗證只需要簡單登入許可權驗證(保證安全可靠的前提下)，找來找去只有spring-security最適合不過了，在spring-boot下配置簡單便捷快速能滿足基本的登入許可權控制需求。第一步：引入spring

Spring Boot 整合Spring Security

整合Spring Security 效果：訪問hello.html會被重定向到login.html，登入成功後，轉到hello，登入失敗，轉到error 一：新增依賴

spring-boot 整合spring-session redis

Spring Session 提供了一套用於管理使用者 session 資訊的API和實現。 Spring Session為企業級Java應用的session管理帶來了革新，使得以下的功能更加容易實現：編寫可水平擴充套件的原生雲應用。將session所儲存的狀態解除安裝到

Spring Boot 整合Spring Session 通過Redis實現分散式共享Session

一、首先我們要引入依賴，修改pom.xml新增： //引入spring session <dependency> <groupId>org.springframework.session</groupId> <artifactId>

Spring Boot（五）：Spring Boot 整合 Spring Security (I)

1. 新增Maven依賴在pom.xml引用spring security. <dependency> <groupId>org.springframework.boot</groupId> <artifac

Spring boot 整合Spring Security過程中的出現的關於Session scope的異常排查及解決方案

背景介紹最近做的一個專案，其一需要用到Spring 的oauth認證功能，其二需要對spring 的ContextRefreshedEvent 這個事件進行監聽，實現一部分自定義註解的功能（具體功能不作贅述），本來以為毫不相關的兩個功能，卻出現了一些意料之

spring boot 整合spring data jpa

2. springboot 整合spring data jpa

2.1. 首先匯入jar 包

2.2 配置datasource

2.3. 新增資料庫連線資訊

2.4 配置JpaConfig

2.5 新建對應資料庫表的實體類。（也就是java bean ）

2.5 編寫spring data jpa 的dao層（重頭戲哦）

2.6 service 層的編寫（這一步和Spring mvc 已經沒有什麼差別的了。）

2.7 controller 編寫

相關推薦