mybatisFlex增强框架应用java源代码

/** * Copyright (c) 2022-2023, Mybatis-Flex (fuhai999@gmail.com). * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * <p> * http://www.apache.org/licenses/LICENSE-2.0 * <p> * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.mybatisflex.admin.controller; import com.mybatisflex.admin.manager.AccountService; import com.mybatisflex.admin.mapper.AccountMapper; import com.mybatisflex.admin.model.Account; import com.mybatisflex.admin.utils.Util; import com.mybatisflex.core.paginate.Page; import com.mybatisflex.core.query.QueryWrapper; import com.mybatisflex.core.row.Db; import com.mybatisflex.core.row.Row; import jakarta.annotation.Resource; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.util.Date; import java.util.List; import static com.mybatisflex.admin.model.table.AccountTableDef.ACCOUNT; @RestController @RequestMapping("/slave") public class AccountSlaveController { @Resource private AccountMapper accountMapper; @Resource private AccountService accountService; @GetMapping("/") List<Account> index() { return Util.switchDS("slave1", ()-> accountMapper.selectAll()); } @GetMapping("/all") List<Account> all() { return Util.switchDS("slave1", ()-> accountMapper.getAll()); } @GetMapping("/wrappers") List<Account> selectList() { return Util.switchDS("slave1", ()-> { //构造 QueryWrapper，也支持使用 QueryWrapper.create() 构造，效果相同 QueryWrapper query = new QueryWrapper(); query.where(ACCOUNT.ID.ge(1)); //通过 query 查询数据列表返回 return accountMapper.selectListByQuery(query); }); } /** * db+row 分页查询：每页 10 条数据，查询第 1 页的年龄大于或等于 18 的用户 * @return */ @GetMapping("/pages") Page<Row> getPage(){ return Util.switchDS("slave1", ()-> { QueryWrapper query=QueryWrapper.create() .where(ACCOUNT.AGE.ge(18)); Page<Row> rowPage= Db.paginate("tb_account",1,10,query); return rowPage; }); } @GetMapping("/save") @Transactional(rollbackFor = Exception.class) public void save() { Util.switchDS("slave1", ()-> { Account account2 = new Account(); account2.setUserName("用户slave"); account2.setAge(11); account2.setBirthday(new Date()); return accountMapper.insert(account2); }); } /** * IService 示例 */ @GetMapping("/services") @Transactional(rollbackFor = Exception.class) public void saveByService() { Util.switchDS("slave1", ()-> { Account account2 = new Account(); account2.setUserName("用户"); account2.setAge(1); account2.setBirthday(new Date()); accountService.saveOne(account2); return 0; }); } /** * 事务 */ @GetMapping("/tx") @Transactional(rollbackFor = Exception.class) public void saveTx() { Account account = new Account(); account.setUserName("用户master-tx"); account.setAge(1); account.setBirthday(new Date()); accountMapper.insert(account); Util.switchDS("slave1", ()-> { Account account2 = new Account(); account2.setUserName("用户slave-tx"); account2.setAge(11); account2.setBirthday(new Date()); accountMapper.insert(account2); throw new RuntimeException("模拟事务中抛出异常！"); }); } }