1 Commits

Author SHA1 Message Date
cuianbing
c46463dce2 🚧 数据库相关功能 2026-01-20 17:35:33 +08:00
15 changed files with 342 additions and 257 deletions

View File

@@ -1 +1,87 @@
# Springboot3和JDK17的基础脚手架
# Springboot3和JDK17的基础脚手架 - 数据库分支
## 基础依赖
- MySQL
- MyBatis-Plus 3.5.15 这个版本是SpringBoot3支持的最高版本
- jsqlparser 在MyBatis-Plus 3.5.9以后的版本,插件部分开始修改为可选依赖,所以这里手动增加。
> 引入 MyBatis-Plus 之后请不要再次引入 MyBatis 以及 mybatis-spring-boot-starter和MyBatis-Spring以避免因版本差异导致的问题。
```xml
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-spring-boot3-starter</artifactId>
<version>3.5.15</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-jsqlparser</artifactId>
<version>3.5.14</version>
<scope>compile</scope>
</dependency>
```
## Druid数据源配置详解
- [官方WIKI](https://github.com/alibaba/druid/wiki/%E9%A6%96%E9%A1%B5)
### Druid多数据源说明
添加配置
```properties
spring.datasource.url=
spring.datasource.username=
spring.datasource.password=
# Druid 数据源配置继承spring.datasource.* 配置,相同则覆盖
spring.datasource.druid.initial-size=5
spring.datasource.druid.max-active=5
# Druid 数据源 1 配置继承spring.datasource.druid.* 配置,相同则覆盖
spring.datasource.druid.one.max-active=10
spring.datasource.druid.one.max-wait=10000
# Druid 数据源 2 配置继承spring.datasource.druid.* 配置,相同则覆盖
spring.datasource.druid.two.max-active=20
spring.datasource.druid.two.max-wait=20000
```
# Druid 数据源配置继承spring.datasource.* 配置,相同则覆盖
```properties
spring.datasource.druid.initial-size=5
spring.datasource.druid.max-active=5
```
# Druid 数据源 1 配置继承spring.datasource.druid.* 配置,相同则覆盖
```properties
spring.datasource.druid.one.max-active=10
spring.datasource.druid.one.max-wait=10000
```
# Druid 数据源 2 配置继承spring.datasource.druid.* 配置,相同则覆盖
```properties
spring.datasource.druid.two.max-active=20
spring.datasource.druid.two.max-wait=20000
```
强烈注意:**Spring Boot 2.X** 版本不再支持配置继承,多数据源的话每个数据源的所有配置都需要单独配置,否则配置不会生效
## MyBatis-Plus配置详解
- [官网文档](https://baomidou.com/introduce/)

69
pom.xml
View File

@@ -14,22 +14,15 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<spring-boot.version>3.5.9</spring-boot.version>
<rockermq.version>2.2.3</rockermq.version>
<druid.version>1.2.27</druid.version>
<mybatis-plus.version>3.5.15</mybatis-plus.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<exclusions>
<!-- 排除SpringBoot默认的日志依赖 -->
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-logging</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
@@ -44,66 +37,40 @@
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- 引入Log4j2依赖包含SLF4J桥接 -->
<!-- MySQL相关Maven依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-log4j2</artifactId>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
</dependency>
<!-- RocketMQ相关依赖 -->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>${rockermq.version}</version>
<exclusions>
<exclusion>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
</exclusion>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</exclusion>
</exclusions>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-spring-boot3-starter</artifactId>
<version>${mybatis-plus.version}</version>
</dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>4.7.1</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</exclusion>
<exclusion>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
</exclusion>
<exclusion>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-slf4j-impl</artifactId>
</exclusion>
</exclusions>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-jsqlparser</artifactId>
<version>${mybatis-plus.version}</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-3-starter</artifactId>
<version>${druid.version}</version>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>

View File

@@ -1,17 +1,14 @@
package com.yongfeng.lg.springboot3jdk17;
import org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Import;
@SpringBootApplication
@Import(RocketMQAutoConfiguration.class)
@MapperScan("com.yongfeng.lg.springboot3jdk17.mapper") // 必须配置扫描mapper包
public class Application {
public static void main(String[] args) {
// 配置RocketMQ使用SLf4j日志框架
System.setProperty("rocketmq.client.logUseSlf4j", "true");
SpringApplication.run(Application.class, args);
}

View File

@@ -1,23 +0,0 @@
package com.yongfeng.lg.springboot3jdk17.controller;
import com.yongfeng.lg.springboot3jdk17.mq.producer.RocketMQProducer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/test/mq")
public class RocketMQMessageTestController {
@Autowired
private RocketMQProducer rocketMQProducer;
@GetMapping("/send-message")
public String sendMessage(@RequestParam("msg") String msg) {
rocketMQProducer.sendMessage("cuianbing-test-topic", msg);
return "发送成功";
}
}

View File

@@ -0,0 +1,57 @@
package com.yongfeng.lg.springboot3jdk17.controller;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yongfeng.lg.springboot3jdk17.entity.User;
import com.yongfeng.lg.springboot3jdk17.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
@RequestMapping("/user")
public class UserController {
@Autowired
private UserService userService;
// 1. 新增用户
@PostMapping("/save")
public boolean save(@RequestBody User user) {
return userService.save(user);
}
// 2. 根据ID查询用户
@GetMapping("/{id}")
public User getById(@PathVariable Long id) {
return userService.getById(id);
}
// 3. 查询所有用户
@GetMapping("/list")
public List<User> list() {
return userService.list();
}
// 4. 分页查询用户 (MP分页插件生效)
@GetMapping("/page")
public Page<User> page(@RequestParam Integer current, @RequestParam Integer size) {
Page<User> page = new Page<>(current, size);
return userService.page(page);
}
// 5. 条件查询:根据年龄查询
@GetMapping("/listByAge/{age}")
public List<User> listByAge(@PathVariable Integer age) {
LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();
wrapper.gt(User::getAge, age); // 年龄大于指定值
return userService.list(wrapper);
}
// 6. 删除用户
@DeleteMapping("/{id}")
public boolean remove(@PathVariable Long id) {
return userService.removeById(id);
}
}

View File

@@ -0,0 +1,57 @@
package com.yongfeng.lg.springboot3jdk17.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.yongfeng.lg.springboot3jdk17.enums.SexEnum;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
/**
* 数据库表对应的实体类 (示例:用户表 user)
*/
@Data // lombok注解自动生成get/set/toString/equals等方法
@TableName("user") // 对应数据库的表名
public class User implements Serializable {
private static final long serialVersionUID = 1L;
// 自增主键
@TableId(type = IdType.AUTO)
private Long id;
// 用户名 (数据库字段user_name)
@TableField("user_name")
private String userName;
// 密码
@TableField("password")
private String password;
// 年龄
@TableField("age")
private Integer age;
// 性别 使用枚举值
@TableField("sex")
private SexEnum sex;
// 邮箱
@TableField("email")
private String email;
// 创建时间
@TableField("create_time")
private LocalDateTime createTime;
// 更新时间
@TableField("update_time")
private LocalDateTime updateTime;
// 逻辑删除字段 (0=未删除1=已删除)
@TableField("deleted")
private Integer deleted;
}

View File

@@ -0,0 +1,26 @@
package com.yongfeng.lg.springboot3jdk17.enums;
import com.baomidou.mybatisplus.annotation.EnumValue;
import lombok.AllArgsConstructor;
import lombok.Getter;
/**
* MyBatis-Plus使用枚举示例
*/
@Getter
@AllArgsConstructor
public enum SexEnum {
PRIMARY(1, "小学"),
SECONDARY(2, "中学"),
HIGH(3, "高中");
// 枚举属性使用 @EnumValue 注解,
// 指定枚举值在数据库中存储的实际值。
// 支持枚举类中的任意字段,如序号或编码。
// 标记数据库存的值是code
@EnumValue
private final int code;
private final String desc;
}

View File

@@ -0,0 +1,16 @@
package com.yongfeng.lg.springboot3jdk17.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yongfeng.lg.springboot3jdk17.entity.User;
import org.apache.ibatis.annotations.Mapper;
/**
* MP的Mapper接口继承BaseMapper即可无需写任何方法
* BaseMapper<User> 中的泛型是对应的实体类
*/
//@Mapper // 可选,因为主启动类加了@MapperScan二选一即可
public interface UserMapper extends BaseMapper<User> {
// 自定义的Mapper可以在这里面写对应Mapper XML文件
}

View File

@@ -1,25 +0,0 @@
package com.yongfeng.lg.springboot3jdk17.mq.consumer;
import org.apache.rocketmq.spring.annotation.ConsumeMode;
import org.apache.rocketmq.spring.annotation.MessageModel;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.annotation.SelectorType;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
@Component
@RocketMQMessageListener(topic = "cuianbing-test-topic",
consumerGroup = "cuianbing-test-topic-group",
selectorType = SelectorType.TAG,
selectorExpression = "*",
messageModel = MessageModel.CLUSTERING, //CLUSTERING集群消费多个实例负载均衡 BROADCASTING 广播消费模式,每个实例都全量消费
consumeMode = ConsumeMode.CONCURRENTLY, // CONCURRENTLY 并发消费 ORDERLY顺序消费消息。一个队列一个线程
consumeThreadMax = 64 , // 注意这个参数已废弃由下面的consumeThreadNumber替代
consumeThreadNumber = 20 // 消费者的最大线程数配置。 默认值是 20
)
public class RocketMQTestConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println("收到消息内容为:" + message);
}
}

View File

@@ -1,47 +0,0 @@
package com.yongfeng.lg.springboot3jdk17.mq.consumer;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.spring.annotation.ConsumeMode;
import org.apache.rocketmq.spring.annotation.MessageModel;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.annotation.SelectorType;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
import java.net.SocketAddress;
@Component
@RocketMQMessageListener(topic = "cuianbing-test-topic",
consumerGroup = "cuianbing-test-topic-group2",
selectorType = SelectorType.TAG,
selectorExpression = "*",
messageModel = MessageModel.CLUSTERING, //CLUSTERING集群消费多个实例负载均衡 BROADCASTING 广播消费模式,每个实例都全量消费
consumeMode = ConsumeMode.CONCURRENTLY, // CONCURRENTLY 并发消费 ORDERLY顺序消费消息。一个队列一个线程
consumeThreadMax = 64 , // 注意这个参数已废弃由下面的consumeThreadNumber替代
consumeThreadNumber = 20 // 消费者的最大线程数配置。 默认值是 20
)
/**
* 使用MessageExt原生对象可以获取更多的信息
*/
public class RocketMQTestMstConsumer implements RocketMQListener<MessageExt> {
@Override
public void onMessage(MessageExt message) {
// String brokerName;
// int queueId;
// int storeSize;
// long queueOffset;
// int sysFlag;
// long bornTimestamp;
// SocketAddress bornHost;
// long storeTimestamp;
// SocketAddress storeHost;
// String msgId;
// long commitLogOffset;
// int bodyCRC;
// int reconsumeTimes;
// long preparedTransactionOffset;
System.out.println("消息接收成功,消息的内容为:" +
new String(message.getBody()) +
"\n消息对象为" + message);
}
}

View File

@@ -1,18 +0,0 @@
package com.yongfeng.lg.springboot3jdk17.mq.producer;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
public class RocketMQProducer {
@Autowired
private RocketMQTemplate rocketMQTemplate;
// 发送简单消息
public void sendMessage(String topic, String message) {
rocketMQTemplate.convertAndSend(topic, message);
System.out.println("消息发送成功,发送内容为: " + message);
}
}

View File

@@ -0,0 +1,12 @@
package com.yongfeng.lg.springboot3jdk17.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yongfeng.lg.springboot3jdk17.entity.User;
/**
* 业务层接口继承MP的IService
*/
public interface UserService extends IService<User> {
}

View File

@@ -0,0 +1,16 @@
package com.yongfeng.lg.springboot3jdk17.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yongfeng.lg.springboot3jdk17.entity.User;
import com.yongfeng.lg.springboot3jdk17.mapper.UserMapper;
import com.yongfeng.lg.springboot3jdk17.service.UserService;
import org.springframework.stereotype.Service;
/**
* 业务层实现类继承ServiceImpl注入Mapper即可
*/
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
}

View File

@@ -1,10 +1,53 @@
# 端口号
# Web服务端口号
server.port=8080
# 配置数据源类型为Druid
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
# druid相关配置文件
# MySQL8.x 驱动类固定值如果是MySQL5.7,改成 com.mysql.jdbc.Driver
spring.datasource.druid.driver-class-name=com.mysql.cj.jdbc.Driver
# 数据库连接地址
spring.datasource.druid.url=jdbc:mysql://10.232.112.35:3306/springboot3-jdk17?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai
# 数据库名
spring.datasource.druid.username=root
# 数据库密码
spring.datasource.druid.password=-w9M627JZeYo5p^3lbH0mqDa
# 初始化连接数
spring.datasource.druid.initial-size=5
# 最小空闲连接数
spring.datasource.druid.min-idle=5
# 最大活跃连接数
spring.datasource.druid.max-active=20
# 获取连接的最大等待时间(ms)
spring.datasource.druid.max-wait=60000
# 检测空闲连接的间隔时间
spring.datasource.druid.time-between-eviction-runs-millis=60000
# 空闲连接的存活时间
spring.datasource.druid.min-evictable-idle-time-millis=300000
# 检测连接是否有效
spring.datasource.druid.validation-query=SELECT 1 FROM DUAL
# 空闲时检测连接有效性
spring.datasource.druid.test-while-idle=true
# 获取连接时不检测(提升性能)但是可能存在使用了废弃的会话
spring.datasource.druid.test-on-borrow=false
# 归还连接时不检测(提升性能)
spring.datasource.druid.test-on-return=false
# 开启PSCache
spring.datasource.druid.pool-prepared-statements=true
spring.datasource.druid.max-pool-prepared-statement-per-connection-size=20
rocketmq.name-server=10.232.12.251:9876;10.232.112.143:9876
rocketmq.producer.group=springboot3-jdk17--producer-group
rocketmq.producer.send-message-timeout=3000
rocketmq.producer.retry-times-when-send-failed=2
rocketmq.producer.retry-next-server=true
rocketmq.consumer.group=springboot-consumer-group
rocketmq.consumer.topic=test-topic
# MyBatis-Plus配置文件
# 配置Mapper.xml映射文件的路径
mybatis-plus.mapper-locations=classpath:mapper/**/*.xml
# 配置实体类的包别名简化Mapper中的实体类引用
mybatis-plus.type-aliases-package=com.example.demo.entity
# 主键策略AUTO(自增),也可以用雪花算法 (分布式唯一ID推荐)
mybatis-plus.global-config.db-config.id-type=AUTO
# 逻辑删除字段配置(可选)
mybatis-plus.global-config.db-config.logic-delete-field=deleted
# 配合逻辑删除字段 1代表删除
mybatis-plus.global-config.db-config.logic-delete-value=1
mybatis-plus.global-config.db-config.logic-not-delete-value=0
mybatis-plus.configuration.map-underscore-to-camel-case=true
mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
mybatis-plus.configuration.cache-enabled=false

View File

@@ -1,79 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<!-- statusLog4j2自身的日志级别debug可排查配置问题monitorInterval自动刷新配置 -->
<Configuration status="WARN" monitorInterval="30">
<!-- 全局参数:定义日志存储路径、格式等 -->
<Properties>
<!-- 日志输出目录SpringBoot会自动识别classpath、user.dir等 -->
<Property name="LOG_PATH">./logs</Property>
<!-- 日志格式:时间 | 线程 | 级别 | 类名 | 日志内容 -->
<Property name="PATTERN">%d{yyyy-MM-dd HH:mm:ss.SSS} | %t | %-5level | %logger{50} | %msg%n</Property>
</Properties>
<!-- 输出源Appender定义日志输出到哪里、怎么输出 -->
<Appenders>
<!-- 1. 控制台输出 -->
<Console name="Console" target="SYSTEM_OUT">
<!-- 日志格式编码 -->
<PatternLayout pattern="${PATTERN}" charset="UTF-8"/>
<!-- 过滤器只输出INFO及以上级别 -->
<ThresholdFilter level="INFO" onMatch="ACCEPT" onMismatch="DENY"/>
</Console>
<!-- 2. 所有日志文件输出(按天滚动) -->
<RollingFile name="AllFile" fileName="${LOG_PATH}/all.log"
filePattern="${LOG_PATH}/all-%d{yyyy-MM-dd}.log">
<PatternLayout pattern="${PATTERN}" charset="UTF-8"/>
<!-- 滚动策略按天滚动保留30天单个文件最大100MB -->
<Policies>
<TimeBasedTriggeringPolicy interval="1" modulate="true"/>
<SizeBasedTriggeringPolicy size="100MB"/>
</Policies>
<DefaultRolloverStrategy max="30"/>
</RollingFile>
<!-- 3. 错误日志单独输出(按天滚动) -->
<RollingFile name="ErrorFile" fileName="${LOG_PATH}/error.log"
filePattern="${LOG_PATH}/error-%d{yyyy-MM-dd}.log">
<PatternLayout pattern="${PATTERN}" charset="UTF-8"/>
<!-- 只输出ERROR及以上级别 -->
<ThresholdFilter level="ERROR" onMatch="ACCEPT" onMismatch="DENY"/>
<Policies>
<TimeBasedTriggeringPolicy interval="1" modulate="true"/>
<SizeBasedTriggeringPolicy size="50MB"/>
</Policies>
<DefaultRolloverStrategy max="30"/>
</RollingFile>
</Appenders>
<!-- 日志记录器Logger定义不同包/类的日志级别 -->
<Loggers>
<!-- 自定义包日志级别例如你的业务代码包DEBUG级别 -->
<Logger name="com.yongfeng.lg.springboot3jdk17" level="DEBUG" additivity="false">
<AppenderRef ref="Console"/>
<!-- <AppenderRef ref="AllFile"/>-->
<!-- <AppenderRef ref="ErrorFile"/>-->
</Logger>
<Logger name="io.netty.util.concurrent.GlobalEventExecutor" level="DEBUG" additivity="false">
<AppenderRef ref="Console"/>
<!-- <AppenderRef ref="AllFile"/>-->
<!-- <AppenderRef ref="ErrorFile"/>-->
</Logger>
<!-- 第三方框架日志级别例如Spring、MyBatis避免日志过多 -->
<Logger name="org.springframework" level="INFO" additivity="false">
<AppenderRef ref="Console"/>
<!-- <AppenderRef ref="AllFile"/>-->
</Logger>
<Logger name="com.baomidou.mybatisplus" level="INFO" additivity="false">
<AppenderRef ref="Console"/>
<!-- <AppenderRef ref="AllFile"/>-->
</Logger>
<!-- 根日志:默认级别,所有未单独配置的日志都走这里 -->
<Root level="INFO">
<AppenderRef ref="Console"/>
<!-- <AppenderRef ref="AllFile"/>-->
<!-- <AppenderRef ref="ErrorFile"/>-->
</Root>
</Loggers>
</Configuration>