SpringBoot项目 使用Sprin Data Jpa 实现数据库的 增 ，删， 改， 查操作

1：首先建立查询接口类，该接口继承JpaRepository



2：在测试时最好是分三层进行测试，操作数据库放在Service



3:接下来就是具体的操作
/**
* 查询所有
*/
public List<User> queryList() {
List<UserEntity> listUser = userJpa.findAll();
List<User> list = new ArrayList<>( );
Iterator<UserEntity> iterator = listUser.iterator();
while (iterator.hasNext()) {
UserEntity userEntity = iterator.next();
User user = new User( );
BeanUtils.copyProperties( userEntity,user );
list.add( user );
}
return list;
}

/**
* 添加数据
* @return
*/
public String adduser() {
UserEntity userEntity = null;
Random random = new Random( );
for(int i = 0;i<100;++i) {
int aa = random.nextInt(100)+1;
userEntity = new UserEntity( );
userEntity.setName( "sd"+i );
userEntity.setAddress( "dgh"+i );
userEntity.setSex( aa );
UserEntity userEntity1 = userJpa.save( userEntity );
}
String s = "添加成功";
return s;
}

/**
* 删除
* @return
*/
public String deleteUser() {
userJpa.delete( 1L );
return "删除成功";
}

/**
* 更新
* @return
* @throws Exception
*/
public String updateUser() throws Exception{
UserEntity userEntity = userJpa.findOne( 2L );
userEntity.setAddress( "gghddddd" );
userJpa.save( userEntity );
return "成功";
}

4：建立controller层进行测试
package com.example.jpa.controller;
import com.example.jpa.entity.UserEntity;
import com.example.jpa.pojo.User;
import com.example.jpa.response.ResultClient;
import com.example.jpa.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
* com.xinguangnet.tuchao.merchant.manage
*
* @Author : Wukn
* @Date : 2018/2/5
*/
@RestController
public class UserController {

@Autowired
private UserService userService;

/**
* 全查询
* @return
*/
@PostMapping(value = "/user/list")
public ResultClient queryList() {
List<User> list = userService.queryList();
return new ResultClient( list );
}

/**
* 添加
* @return
*/
@PostMapping(value = "/user/add")
public ResultClient addUs() {
String s = userService.adduser();
return new ResultClient( s );
}

/**
* 删除
* @return
*/
@PostMapping(value = "/user/delete")
public ResultClient deleteUser() {
return new ResultClient( userService.deleteUser() );

}

/**
* 更新
* @return
*/
@PostMapping(value = "/user/update")
public ResultClient updateUser() throws Exception{
String s = userService.updateUser();
return new ResultClient( s );
}

/**
* 更新
* @return
*/
@PostMapping(value = "/user/findsex")
public ResultClient findbysex() throws Exception{
List<UserEntity> userEntities = userService.findBySex();
return new ResultClient( userEntities );
}

}

5：用postman测试



：2Query新建语句查询

package com.example.jpa.repotory;
import com.example.jpa.entity.UserEntity;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import javax.transaction.Transactional;
import java.lang.reflect.Modifier;
import java.util.List;

/**
* com.xinguangnet.tuchao.merchant.manage
*
* @Author : Wukn
* @Date : 2018/2/5
*/
public interface UserJpa extends JpaRepository<UserEntity,Long>{

@Query(value = "select c from UserEntity c where c.sex = :sex")
public List<UserEntity> findBySex(@Param( "sex" ) int sex);

/**
* 删除
* @param id
*/
@Modifying
@Query(value = "delete from t_user where id = :id",nativeQuery = true)
public void deleteUser(@Param( "id" ) int id);

/**
* 修改
* @param sex
* @param address
* @param id
*/
@Modifying
@Query(value = "update UserEntity c set c.sex = :sex, c.address = :address where c.id = :id" )
public void updateUser(@Param( "sex" ) Integer sex,@Param( "address" ) String address,@Param( "id" ) Long id);

}
1：nativeQuery = true
表示在使用语句查询时使用的是sql语法查询，sql语法面向的是数据库表，在书写语句时，一定要from  表名而不是对象名称



2：不写true默认是false说明语法是JPQL就是查询语言，具有与SQL 相类似的特征，JPQL是完全面向对象的，具备继承、多态和关联等特性，和hibernate HQL很相似。
@Modifying
@Query(value = "update Category c set c.isParent = :isParent where c.categoryId = :categoryId")
int updateIsParent(@Param("categoryId") Long categoryId,@Param("isParent") boolean isParent);

@Query("select c from Category c where c.parentId=:parentId and c.delFlag=:delFlag")
List<Category> findByParentIdAndDelFlagAndSort(@Param("parentId")Long parentId,@Param("delFlag")boolean delFlag, Sort sort);

@Modifying
@Query(value = "update Category c set c.delFlag=:delFlag where c.categoryId = :categoryId and c.platformId = :platformId")
int updateCategoryById(@Param("categoryId") Long categoryId,@Param("platformId") Integer platformId,
@Param("delFlag") boolean delFlag);

Category findByCategoryNameAndDelFlag(String categoryName,boolean delFlag);

Category findByCategoryIdAndDelFlag(Long categoryId, boolean delFlag);

@Query("select c from Category c where c.platformId=:platformId and c.parentId=:parentId and c.delFlag=:delFlag")
List<Category> findByPlatformIdAndSort(@Param("platformId") Integer platformId,
@Param("parentId") long parentId,@Param("delFlag") boolean delFlag,Sort sort);
}
3：在进行插入或者删除时需要事务处理
这是在Service



这是在Controller



也可以直接在语句出添加（个人不建议这么干）



4：@Modifying可以通过自定义的 JPQL 完成 UPDATE 和 DELETE 操作。 注意： JPQL 不支持使用 INSERT； 
在 @Query 注解中编写 JPQL 语句， 但必须使用 @Modifying 进行修饰. 以通知 SpringData， 这是一个 UPDATE 或 DELETE 操作 
UPDATE 或 DELETE 操作需要使用事务，此时需要定义 Service 层，在 Service 层的方法上添加事务操作； ）默认情况下， SpringData 的每个方法上有事务， 但都是一个只读事务。 他们不能完成修改操作。