详解Spring Boot实战之Rest接口开发及数据库基本操作

 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> 

spring.datasource.url = jdbc:mysql://127.0.0.1:3306/springlearn spring.datasource.username = root spring.datasource.password = root spring.datasource.driverClassName = com.mysql.jdbc.Driver   # 配置数据库 spring.jpa.database = MYSQL # 查询时是否显示日志 spring.jpa.show-sql = true # Hibernate ddl auto (create, create-drop, update) spring.jpa.hibernate.ddl-auto = update # Naming strategy spring.jpa.hibernate.naming-strategy = org.hibernate.cfg.ImprovedNamingStrategy # stripped before adding them to the entity manager) spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.MySQL5Dialect 

package com.xiaofangtech.sunt.bean;  import javax.persistence.Entity; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; import javax.persistence.Table; import javax.validation.constraints.NotNull;  @Entity @Table(name="t_user") public class UserInfo {   @Id   @GeneratedValue(strategy = GenerationType.AUTO)   private int id;   @NotNull   private String name;      private String password;      private String salt;      private String role;    public int getId() {     return id;   }    public void setId(int id) {     this.id = id;   }    public String getName() {     return name;   }    public void setName(String name) {     this.name = name;   }    public String getPassword() {     return password;   }    public void setPassword(String password) {     this.password = password;   }    public String getSalt() {     return salt;   }    public void setSalt(String salt) {     this.salt = salt;   }    public String getRole() {     return role;   }    public void setRole(String role) {     this.role = role;   } } 

package com.xiaofangtech.sunt.repository;  import java.util.List;  import org.springframework.data.jpa.repository.Query; import org.springframework.data.repository.CrudRepository;  import com.xiaofangtech.sunt.bean.UserInfo;  public interface UserInfoRepository extends CrudRepository<UserInfo, Integer>{   UserInfo findUserInfoById(int id);   List<UserInfo> findUserInfoByRole(String role);      @Query(value = "select * from t_user limit ?1", nativeQuery =true)   List<UserInfo> findAllUsersByCount(int count); } 

package com.xiaofangtech.sunt.controller;  import java.util.List;  import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.jpa.repository.Modifying; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController;  import com.xiaofangtech.sunt.bean.UserInfo; import com.xiaofangtech.sunt.repository.UserInfoRepository; import com.xiaofangtech.sunt.utils.ResultMsg; import com.xiaofangtech.sunt.utils.ResultStatusCode;  @RestController @RequestMapping("user") public class UserController {   @Autowired   private UserInfoRepository userRepositoy;      @RequestMapping("getuser")   public Object getUser(int id)   {     UserInfo userEntity = userRepositoy.findUserInfoById(id);     ResultMsg resultMsg = new ResultMsg(ResultStatusCode.OK.getErrcode(), ResultStatusCode.OK.getErrmsg(), userEntity);     return resultMsg;   }      @RequestMapping("getusers")   public Object getUsers(String role)   {     List<UserInfo> userEntities = userRepositoy.findUserInfoByRole(role);     ResultMsg resultMsg = new ResultMsg(ResultStatusCode.OK.getErrcode(), ResultStatusCode.OK.getErrmsg(), userEntities);     return resultMsg;   }      @Modifying   @RequestMapping("adduser")   public Object addUser(@RequestBody UserInfo userEntity)   {     userRepositoy.save(userEntity);     ResultMsg resultMsg = new ResultMsg(ResultStatusCode.OK.getErrcode(), ResultStatusCode.OK.getErrmsg(), userEntity);     return resultMsg;   }      @Modifying   @RequestMapping("updateuser")   public Object updateUser(@RequestBody UserInfo userEntity)   {     UserInfo user = userRepositoy.findUserInfoById(userEntity.getId());     if (user != null)     {       user.setName(userEntity.getName());       userRepositoy.save(user);     }     ResultMsg resultMsg = new ResultMsg(ResultStatusCode.OK.getErrcode(), ResultStatusCode.OK.getErrmsg(), null);     return resultMsg;   }      @Modifying   @RequestMapping("deleteuser")   public Object deleteUser(int id)   {     userRepositoy.delete(id);     ResultMsg resultMsg = new ResultMsg(ResultStatusCode.OK.getErrcode(), ResultStatusCode.OK.getErrmsg(), null);     return resultMsg;   } } 

package com.xiaofangtech.sunt.utils;  public class ResultMsg {   private int errcode;   private String errmsg;   private Object p2pdata;      public ResultMsg(int ErrCode, String ErrMsg, Object P2pData)   {     this.errcode = ErrCode;     this.errmsg = ErrMsg;     this.p2pdata = P2pData;   }   public int getErrcode() {     return errcode;   }   public void setErrcode(int errcode) {     this.errcode = errcode;   }   public String getErrmsg() {     return errmsg;   }   public void setErrmsg(String errmsg) {     this.errmsg = errmsg;   }   public Object getP2pdata() {     return p2pdata;   }   public void setP2pdata(Object p2pdata) {     this.p2pdata = p2pdata;   } } 

package com.xiaofangtech.sunt.utils;  public enum ResultStatusCode {   OK(0, "OK"),   SYSTEM_ERR(30001, "System error");      private int errcode;   private String errmsg;   public int getErrcode() {     return errcode;   }    public void setErrcode(int errcode) {     this.errcode = errcode;   }    public String getErrmsg() {     return errmsg;   }    public void setErrmsg(String errmsg) {     this.errmsg = errmsg;   }   private ResultStatusCode(int Errode, String ErrMsg)   {     this.errcode = Errode;     this.errmsg = ErrMsg;   } } 

Hibernate: insert into t_user (name, password, role, salt) values (?, ?, ?, ?)Hibernate: select userinfo0_.id as id1_0_, userinfo0_.name as name2_0_, userinfo0_.password as password3_0_, userinfo0_.role as role4_0_, userinfo0_.salt as salt5_0_ from t_user userinfo0_ where userinfo0_.id=?Hibernate: update t_user set name=?, password=?, role=?, salt=? where id=?Hibernate: select userinfo0_.id as id1_0_, userinfo0_.name as name2_0_, userinfo0_.password as password3_0_, userinfo0_.role as role4_0_, userinfo0_.salt as salt5_0_ from t_user userinfo0_ where userinfo0_.id=?Hibernate: select userinfo0_.id as id1_0_, userinfo0_.name as name2_0_, userinfo0_.password as password3_0_, userinfo0_.role as role4_0_, userinfo0_.salt as salt5_0_ from t_user userinfo0_ where userinfo0_.role=?Hibernate: select userinfo0_.id as id1_0_0_, userinfo0_.name as name2_0_0_, userinfo0_.password as password3_0_0_, userinfo0_.role as role4_0_0_, userinfo0_.salt as salt5_0_0_ from t_user userinfo0_ where userinfo0_.id=?Hibernate: delete from t_user where id=?

UserInfo findUserInfoById(int id);

List<UserInfo> findUserInfoByRole(String role);

@Query(value = "select * from t_user limit ?1", nativeQuery =true)List<UserInfo> findAllUsersByCount(int count);