springboot整合mybatis增刪改查（四）：完善增刪改查及整合swgger2

SpringBoot MyBatis · 發表 2019-01-29 15:31:00

摘要：接下來就是完成增刪改查的功能了，首先在config包下配置Druid資料連線池,在配置之前先把相關配置在application.preperties中完善 application.preperties # 下面為連線池的補充設定，應用到上面所有資料來源中 # 初始化大小，最小，最大 s...

接下來就是完成增刪改查的功能了，首先在config包下配置Druid資料連線池,在配置之前先把相關配置在application.preperties中完善

application.preperties

# 下面為連線池的補充設定，應用到上面所有資料來源中
# 初始化大小，最小，最大
spring.datasource.initialSize=5
spring.datasource.minIdle=5
spring.datasource.maxActive=30
# 配置獲取連線等待超時的時間
spring.datasource.maxWait=60000
# 配置間隔多久才進行一次檢測，檢測需要關閉的空閒連線，單位是毫秒
spring.datasource.timeBetweenEvictionRunsMillis=60000
# 配置一個連線在池中最小生存的時間，單位是毫秒
spring.datasource.minEvictableIdleTimeMillis=300000
spring.datasource.validationQuery=SELECT 1 FROM DUAL
spring.datasource.testWhileIdle=true
spring.datasource.testOnBorrow=false
spring.datasource.testOnReturn=false
# 開啟PSCache，並且指定每個連線上PSCache的大小
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
# 配置監控統計攔截的filters，去掉後監控介面sql無法統計，'wall'用於防火牆
spring.datasource.filters=stat,wall,log4j
# 通過connectProperties屬性來開啟mergeSql功能；慢SQL記錄
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
# 合併多個DruidDataSource的監控資料
spring.datasource.useGlobalDataSourceStat=true
# Druid 監控 Servlet 配置引數
spring.datasource.druidRegistrationUrl: /druid/* 
spring.datasource.resetEnable: true 
spring.datasource.loginUsername: admin
spring.datasource.loginPassword: 1234
# Druid 監控過濾相關配置引數
spring.datasource.filtersUrlPatterns: /* 
spring.datasource.exclusions: '*.js,*.gif,*.jpg,*.jpeg,*.png,*.css,*.ico,*.jsp,/druid/*'
spring.datasource.sessionStatMaxCount: 2000 
spring.datasource.sessionStatEnable: true 
spring.datasource.principalSessionName: session_user_key 
spring.datasource.profileEnable: true
#druid datasouce database settings end

上面配置完之後開始完成Druid資料連線池配置

在config包->新建DruidDbConfig類

DruidDBConfig類

@Configuration
public class DruidDBConfig {
// private Logger logger = LoggerFactory.getLogger(DruidDBConfig.class);

@Value("${spring.datasource.driver-class-name}")
private String driverClassName;

@Value("${spring.datasource.url}")
private String dbUrl;

@Value("${spring.datasource.username}")
private String username;

@Value("${spring.datasource.password}")
private String password;

@Value("${spring.datasource.initialSize}")
private int initialSize;

@Value("${spring.datasource.minIdle}")
private int minIdle;

@Value("${spring.datasource.maxActive}")
private int maxActive;

@Value("${spring.datasource.maxWait}")
private int maxWait;

@Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
private int timeBetweenEvictionRunsMillis;

@Value("${spring.datasource.minEvictableIdleTimeMillis}")
private int minEvictableIdleTimeMillis;

@Value("${spring.datasource.validationQuery}")
private String validationQuery;

@Value("${spring.datasource.testWhileIdle}")
private boolean testWhileIdle;

@Value("${spring.datasource.testOnBorrow}")
private boolean testOnBorrow;

@Value("${spring.datasource.testOnReturn}")
private boolean testOnReturn;

@Value("${spring.datasource.poolPreparedStatements}")
private boolean poolPreparedStatements;

@Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
private int maxPoolPreparedStatementPerConnectionSize;

@Value("${spring.datasource.filters}")
private String filters;

@Value("{spring.datasource.connectionProperties}")
private String connectionProperties;

@Bean//宣告其為Bean例項
@Primary//在同樣的DataSource中，首先使用被標註的DataSource
public DataSource dataSource(){
DruidDataSource datasource = new DruidDataSource();

datasource.setUrl(this.dbUrl);
datasource.setUsername(username);
datasource.setPassword(password);
datasource.setDriverClassName(driverClassName);

//configuration
datasource.setInitialSize(initialSize);
datasource.setMinIdle(minIdle);
datasource.setMaxActive(maxActive);
datasource.setMaxWait(maxWait);
datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
datasource.setValidationQuery(validationQuery);
datasource.setTestWhileIdle(testWhileIdle);
datasource.setTestOnBorrow(testOnBorrow);
datasource.setTestOnReturn(testOnReturn);
datasource.setPoolPreparedStatements(poolPreparedStatements);
datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
try {
datasource.setFilters(filters);
} catch (SQLException e) {
//logger.error("druid configuration initialization filter", e);
}
datasource.setConnectionProperties(connectionProperties);

return datasource;
}
}

上述配置中的日誌已經註釋了，如果需要配置可以在resources中加入logback-spring.xml：

resources->logback-spring.xml

logback-spring.xml

<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<contextName>logback</contextName>
<!--自己定義一個log.path用於說明日誌的輸出目錄-->
<property name="log.path" value="/log/jiangfeixiang/"/>
<!--輸出到控制檯-->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<!-- <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
<level>ERROR</level>
</filter>-->
<encoder>
<pattern>%d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>

<!--輸出到檔案-->
<appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${log.path}/logback.%d{yyyy-MM-dd}.log</fileNamePattern>
</rollingPolicy>
<encoder>
<pattern>%d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>

<root level="debug">
<appender-ref ref="console"/>
<appender-ref ref="file"/>
</root>

<!-- logback為java中的包 -->
<logger name="com.example.springboootmybatis.controller"/>
</configuration>

UserServiec介面

public interface UserService {
/**
* 查詢所有使用者
*/
public List<User> getAllUser();

/**
* 儲存使用者
* @param user
*/
void saveUser(User user);

/**
* 根據id查詢使用者
*/
User getById(Integer id);

/**
* 校驗使用者名稱
* @param userName
* @return
*/
Boolean checkUserName(String userName);

/**
* 修改使用者
* @param user
*/
void updateUser(User user);

/**
* 根據id刪除使用者
* @param id
*/
void deleteUser(Integer id);

/**
* 全選刪除
* @param useridList
*/
void deleteBatchUser(List<Integer> useridList);
}

UserServiceImpl實現類

@Service
@Transactional
public class UserServiceImpl implements UserService {
//注入
@Autowired
private UserMapper userMapper;

/**
* 查詢所有使用者
*/
@Override
public List<User> getAllUser() {
List<User> users = userMapper.selectByExample(null);
return users;
}

/**
* 根據id查詢使用者
*/
@Override
public User getById(Integer id) {
User user = userMapper.selectByPrimaryKey(id);
return user;
}

/**
* 新增使用者
* @param user
*/
@Override
public void saveUser(User user) {
userMapper.insertSelective(user);
}

/**
* 校驗使用者名稱是否存在
* @param userName
* @return
* 資料庫沒有這條記錄，count==0，返回true
*/
@Override
public Boolean checkUserName(String userName) {
UserExample example=new UserExample();
UserExample.Criteria criteria=example.createCriteria();
criteria.andUsernameEqualTo(userName);
long count=userMapper.countByExample(example);
if(count==0){
return true;
}
return false;
}

/**
* 修改使用者
* @param user
*/
@Override
public void updateUser(User user) {
userMapper.updateByPrimaryKeySelective(user);
}

/**
* 根據id刪除（單個）
* @param id
*/
@Override
public void deleteUser(Integer id) {
userMapper.deleteByPrimaryKey(id);
}


/**
* 批量刪除
* @param useridList
*/
@Override
public void deleteBatchUser(List<Integer> useridList) {
/*UserExample example=new UserExample();
UserExample.Criteria criteria=example.createCriteria();
criteria.andUseridIn(useridList);
userMapper.deleteByExample(example);*/

}
}

UserController

@RestController
@RequestMapping(value = "/user")
public class UserController {
//注入
@Autowired
private UserService userService;

/**
* 查詢所有使用者
*/
@ApiOperation(value="獲取使用者列表")
@RequestMapping(value = "/user",method = RequestMethod.GET)
public List<User> getListAll(){
List<User> listAll = userService.getAllUser();
return listAll;
}

/**
* 使用者儲存
* @return
*/
@ApiOperation(value = "新增使用者",notes = "根據user新增使用者")
@ApiImplicitParam(name = "user",value = "使用者user",required = true,dataType = "User")
@RequestMapping(value = "/users",method = RequestMethod.POST)
public String saveUser(@RequestBody User user){
userService.saveUser(user);
return "success";
}

/**
* 根據id查詢
*/
@ApiOperation(value = "根據id查詢")
@ApiImplicitParam(name = "id",value = "使用者id")
@RequestMapping(value = "/{id}",method = RequestMethod.GET)
public User getById(@PathVariable("id") Integer id){
User user = userService.getById(id);
return user;
}

/**
* 校驗使用者名稱
* @param username
* @return
*/
@ApiOperation(value = "校驗使用者名稱")
@ApiImplicitParam(name = "userName",value = "使用者名稱",required = true,dataType = "String")
@RequestMapping(value = "/{username}",method = RequestMethod.POST)
public Boolean checkUserName(@PathVariable("username")String username){
Boolean aboolean = userService.checkUserName(username);
if (aboolean){
return true;
}else {
return false;
}
}

/**
* 修改使用者
* @param user
*/
@ApiOperation(value = "修改使用者")
@ApiImplicitParam(name = "user",value = "使用者",required = true,dataType = "User")
@RequestMapping(value = "/user",method = RequestMethod.PUT)
public String updateUser(@RequestBody User user){
userService.updateUser(user);
return "success";
}

/**
* 根據id刪除使用者
*/
@ApiOperation(value = "根據id刪除使用者")
@ApiImplicitParam(name = "id",value = "使用者id",required = true,dataType = "Integer")
@RequestMapping(value = "/{id}",method = RequestMethod.DELETE)
public String deleteUser(@PathVariable Integer id){
userService.deleteUser(id);
return "success";
}
}

controller類中使用了swgger2如下：

springboot中整合swgger2

pom.xml

<!--swgger2-->
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.2.2</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.2.2</version>
</dependency>

springbootmybatis包下建立SwaggerConfig.java

SwaggerConfig

@Configuration
@EnableSwagger2
public class SwaggerConfig {
@Bean
public Docket createRestApi() {
ApiInfo apiInfo = new ApiInfoBuilder()
.title("使用Swagger2構建RESTful APIs") //標題
.description("客戶端與服務端介面文件") //描述
.termsOfServiceUrl("http://localost:8080") //域名地址
.contact("姜飛祥") //作者
.version("1.0.0") //版本號
.build();

return new Docket(DocumentationType.SWAGGER_2)
.apiInfo(apiInfo)
.select()
.apis(RequestHandlerSelectors.basePackage("com.example.springbootmybatis"))
.paths(PathSelectors.any())
.build();
}

}

以上就算完成了，寫的不好請見諒。具體測試請參考下面的springboot整合swgger2,之後訪問http://localhost:8080/swagger-ui.html即可，和

備註：

springboot整合swgger2參考:https://www.jianshu.com/p/57a4381a2b45
MyBatis的Mapper介面以及Example的例項函式及詳解：https://blog.csdn.net/biandous/article/details/65630783
Mybatis Generator最完整配置詳解：https://www.jianshu.com/p/e09d2370b796