1、建moudle：cloud-provider-payment8001
子项目名：cloud-provider-payment8001
2、改pom
在子项目的pom.xml文件中添加依赖
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
<version>2.2.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.14</version>
</dependency>
<!--mysql-connector-java-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!--jdbc-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
<version>2.2.2.RELEASE</version>
</dependency>
<!--热部署-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<version>2.2.2.RELEASE</version>
<scope>test</scope>
</dependency>
</dependencies>
3、写yml
在resources目录下新建application.yml配置文件
server:
port: 8001
spring:
application:
name: cloud-payment-service
datasource:
type: com.alibaba.druid.pool.DruidDataSource #当前数据源操作类型
driver-class-name: com.mysql.cj.jdbc.Driver #mysql驱动包
url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=false
username: root
password: 123456
mybatis:
mapper-locations: classpath:mapper/*.xml
type-aliases-package: com.atyy.springcloud.entities #所有实体类（Entity）所在包
4、主启动
在java包下创建主启动类com.angenin.springcloud.PaymentMain8001
@SpringBootApplication
//主启动类
public class PaymentMain8001 {
public static void main(String[] args) {
SpringApplication.run(PaymentMain8001.class,args);
}
}
5、业务类
1、建表sql
CREATE TABLE `payment`(
`id` BIGINT(20) NOT NULL AUTO_INCREMENT COMMENT 'ID',
`serial` VARCHAR(200) DEFAULT '',
PRIMARY KEY(`id`)
)ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
INSERT INTO payment(`serial`)VALUES("1640");
2、entities
主实体Payment
/**
* 实体类
* 由于引入了lombok不需要自己再写setget等，直接用注解
* 后端使用
* @author gsy
* @create 2022-03-13 10:01
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Payment implements Serializable {//实现序列化
private Long id;
private String serial;
}
json封装体CommonResult，json封装体，传给前端的
@Data
@AllArgsConstructor
@NoArgsConstructor
public class CommonResult<T> {
private Integer code;//编码
private String message;//内容
private T data;
public CommonResult(Integer code,String message){
this(code,message,null);
}
}
3、dao
在springcloud包下新建Dao.PaymentDao接口
@Mapper
public interface PaymentDao {
//写操作
public int create(Payment payment);
//读操作
public Payment getPenmentById(@Param("id")Long id);
}
4、mapper
在resources目录下新建mapper目录，然后新建PaymentMapper.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.atyy.springcloud.dao.PaymentDao">
<!--写操作-->
<insert id="create" parameterType="Payment" useGeneratedKeys="true" keyProperty="id">
insert into payment(serial) values (#{serial});
</insert>
<!--读操作-->
<resultMap id="BaseResultMap" type="com.atyy.springcloud.entities.Payment">
<!-- column是数据库的， property是java的， javaType是数据库的jdbc -->
<id column="id" property="id" jdbcType="BIGINT"/>
<id column="serial" property="serial" jdbcType="VARCHAR"/>
</resultMap>
<!-- resultType直接写实体类，实际工作建议用接口及映射resultMap，防止字段命名不规范 -->
<select id="getPenmentById" parameterType="Long" resultMap="BaseResultMap">
select * from payment where id = #{id};
</select>
</mapper>
5、service
在springcloud包下新建service.PaymentService接口
public interface PaymentService {
//写操作
public int create(Payment payment);
//读操作
public Payment getPenmentById(@Param("id")Long id);
}
在service包下新建impl.PaymentServiceIpml实现类
@Service
public class PaymentServiceImpl implements PaymentService{
@Resource//使用@Resource而不使用@Autowired,因为@Autowired是spring里的,@Resource是Java自带的
private PaymentDao paymentDao;
//写操作
public int create(Payment payment){
return paymentDao.create(payment);
}
//读操作
public Payment getPenmentById(@Param("id")Long id){
return paymentDao.getPenmentById(id);
}
}
6、controller
在springcloud包下新建controller.PaymentController
@RestController
@Slf4j //打印日志
public class PaymentController {
@Resource
private PaymentService paymentService;
@PostMapping(value = "/payment/create") //写操作
public CommonResult create(Payment payment){
int result = paymentService.create(payment);
log.info("*****插入结果:" + result);//>0成功 <0失败
if (result>0){
return new CommonResult(200,"插入数据库成功",result);
}else {
return new CommonResult(444,"插入数据库失败",null);
}
}
@GetMapping(value = "/payment/get/{id}") //读操作
public CommonResult getPaymentById(@PathVariable("id")Long id){
Payment payment = paymentService.getPenmentById(id);
log.info("*****查询结果:" + payment);
if (payment !=null){//成功
return new CommonResult(200,"查询成功",payment);
}else {
return new CommonResult(444,"没有对应记录,查询ID:" + id,null);
}
}
}
6、测试
启动项目
浏览器输入http://localhost:8001/payment/get/1，查询成功
因为浏览器一般不支持直接发送post请求，所以，需要使用Postman进行测试。
