弹簧启动休息控制器
在这个例子中,我将展示如何使用 JPA 以最简单和最少的代码来制定一个休息控制器来获取和发布数据到数据库。
在此示例中,我们将引用名为 buyerRequirement 的数据表。
BuyingRequirement.java
@Entity @Table(name =BUYINGREQUIREMENTS
)@NamedQueries({@NamedQuery(name =“BuyingRequirement.findAll”,query =SELECT b FROM BuyingRequirement b
)})public class BuyingRequirement extends Domain implements Serializable {private static final long serialVersionUID = 1L;
@Column(name = "PRODUCT_NAME", nullable = false)
private String productname;
@Column(name = "NAME", nullable = false)
private String name;
@Column(name = "MOBILE", nullable = false)
private String mobile;
@Column(name = "EMAIL", nullable = false)
private String email;
@Column(name = "CITY")
private String city;
public BuyingRequirement() {
}
public String getProductname() {
return productname;
}
public void setProductname(String productname) {
this.productname = productname;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getMobile() {
return mobile;
}
public void setMobile(String mobile) {
this.mobile = mobile;
}
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
public String getCity() {
return city;
}
public void setCity(String city) {
this.city = city;
}
}
这是实体类,它包含引用 byuingRequirement 表中的列及其 getter 和 setter 的参数。
IBuyingRequirementsRepository.java(JPA 接口)
@Repository
@RepositoryRestResource
public interface IBuyingRequirementsRepository extends JpaRepository<BuyingRequirement, UUID> {
// Page<BuyingRequirement> findAllByOrderByCreatedDesc(Pageable pageable);
Page<BuyingRequirement> findAllByOrderByCreatedDesc(Pageable pageable);
Page<BuyingRequirement> findByNameContainingIgnoreCase(@Param("name") String name, Pageable pageable);
}
BuyingRequirementController.java
@RestController
@RequestMapping("/api/v1")
public class BuyingRequirementController {
@Autowired
IBuyingRequirementsRepository iBuyingRequirementsRepository;
Email email = new Email();
BuyerRequirementTemplate buyerRequirementTemplate = new BuyerRequirementTemplate();
private String To = "support@pharmerz.com";
// private String To = "amigujarathi@gmail.com";
private String Subject = "Buyer Request From Pharmerz ";
@PostMapping(value = "/buyingRequirement")
public ResponseEntity<BuyingRequirement> CreateBuyingRequirement(@RequestBody BuyingRequirement buyingRequirements) {
String productname = buyingRequirements.getProductname();
String name = buyingRequirements.getName();
String mobile = buyingRequirements.getMobile();
String emails = buyingRequirements.getEmail();
String city = buyingRequirements.getCity();
if (city == null) {
city = "-";
}
String HTMLBODY = buyerRequirementTemplate.template(productname, name, emails, mobile, city);
email.SendMail(To, Subject, HTMLBODY);
iBuyingRequirementsRepository.save(buyingRequirements);
return new ResponseEntity<BuyingRequirement>(buyingRequirements, HttpStatus.CREATED);
}
@GetMapping(value = "/buyingRequirements")
public Page<BuyingRequirement> getAllBuyingRequirements(Pageable pageable) {
Page requirements = iBuyingRequirementsRepository.findAllByOrderByCreatedDesc(pageable);
return requirements;
}
@GetMapping(value = "/buyingRequirmentByName/{name}")
public Page<BuyingRequirement> getByName(@PathVariable String name,Pageable pageable){
Page buyersByName = iBuyingRequirementsRepository.findByNameContainingIgnoreCase(name,pageable);
return buyersByName;
}
}
它包括那里的方法
- 将数据发布到数据库的 post 方法。
- 获取从 purchaseRequirement 表获取所有记录的方法。
- 这也是一种 get 方法,可以通过此人的姓名找到购买要求。