首先确保代码已经集成了mybatis-plus
实体类
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
/**
* @Description: 图册类型实体
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("atlas")
public class Atlas implements Serializable {
private static final long serialVersionUID = 1L;
@TableId(type = IdType.AUTO)
private Integer id;
// 图册名称
private String atlasName;
// 图册类型(ls-联锁,zb自闭,jc-监测,lk-列控)
private String atlasType;
}
mapper接口
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface AtlasMapper extends BaseMapper<Atlas> {
}
不需要写任何方法,接下来直接在service中调用mapper
//无条件查询全部数据
List<Atlas> atlasList = atlasMapper.selectList(null);
//根据id查询数据
Atlas atlas = atlasMapper.selectById(id);
//根据条件查询数据
LambdaQueryWrapper<Command> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(Command::getCommandType, command.getCommandType());
queryWrapper.eq(Command::getCommand, command.getCommand()); //有多少个查询条件字段就写多少条
Command one = commandMapper.selectOne(queryWrapper);
//新增数据
DingXingTuDataJSONDO tuDataJSONDO = new DingXingTuDataJSONDO();
tuDataJSONDO.setTuzhiCode(code);
tuDataJSONDO.setTuzhiName(name);
tuDataJSONDO.setTuzhiDataJson(str);
boolean save = commandMapper.save(tuDataJSONDO);
//根据条件删除数据
LambdaQueryWrapper<DingXingTuDataJSONDO> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(DingXingTuDataJSONDO::getTuzhiCode, code);
DingXingTuDataJSONDO one = commandMapper.getOne(queryWrapper); //就是先查询出来再删除
boolean remove= commandMapper.removeById(one);
boolean b = dingXingTuDataJsonService.updateById(tuDataJSONDO);
//根据id更新数据
tuDataJSONDO.setTuzhiCode(code);
tuDataJSONDO.setTuzhiName(name);
tuDataJSONDO.setTuzhiDataJson(str);
boolean b = dingXingTuDataJsonService.updateById(tuDataJSONDO);
还有一种更快捷的方式就是直接继承service,连mapper也不需要了
import com.baomidou.mybatisplus.extension.service.IService;
public interface DingXingTuDataJsonService extends IService<DingXingTuDataJSONDO> {
}
然后直接在controller里面调用,调用service和mapper方法一样
/**
* 查询定型图数据
*
* @return
*/
@PostMapping("/list")
@ResponseBody
public AjaxResult listDingXingTuDataJson() {
List<DingXingTuDataJSONDO> list = dingXingTuDataJsonService.list();
return AjaxResult.success("查询数据成功", list);
}
/**
* 根据id查询定型图数据
* @param id id
* @return
*/
@PostMapping("/getOneById")
@ResponseBody
public AjaxResult getOneById(@RequestParam("id") Integer id) {
DingXingTuDataJSONDO dataJSONDO = dingXingTuDataJsonService.getById(id);
return AjaxResult.success("查询数据成功", dataJSONDO);
}
/**
* 根据code查询定型图数据
* @param
* @return
*/
@PostMapping("/getOneByCode")
@ResponseBody
public AjaxResult getOneByCode(@RequestBody DingXingTuDataJSONDO dataJSONDO) {
LambdaQueryWrapper<DingXingTuDataJSONDO> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(DingXingTuDataJSONDO::getTuzhiCode, dataJSONDO.getTuzhiCode());
DingXingTuDataJSONDO one = dingXingTuDataJsonService.getOne(queryWrapper);
return AjaxResult.success("查询数据成功", one);
}
/**
* 添加定型图图纸数据
* @param tuDataJSONDO 定型图do
* @return
*/
@PostMapping("/addTuZhiData")
@ResponseBody
public AjaxResult addOne(@RequestBody DingXingTuDataJSONDO tuDataJSONDO) {
boolean save = dingXingTuDataJsonService.save(tuDataJSONDO);
return AjaxResult.success("添加成功");
}
/**
* 更新图纸数据
* @param tuDataJSONDO 图纸数据
* @return
*/
@PostMapping("/updateTuZhiData")
@ResponseBody
public AjaxResult updateOne(@RequestBody DingXingTuDataJSONDO tuDataJSONDO) {
String tuzhiSpecialChar = dingXingTuDataJsonService.resolvingDrawDataJson(tuDataJSONDO.getTuzhiDataJson());
tuDataJSONDO.setTuzhiSpecialChar(tuzhiSpecialChar);
boolean b = dingXingTuDataJsonService.updateById(tuDataJSONDO);
return AjaxResult.success("更新成功",1);
}
/**
* 删除图纸数据
* @param id 主键id
* @return
*/
@PostMapping("/deleteTuZhiData")
@ResponseBody
public AjaxResult deleteOne(@RequestParam("id") Integer id) {
boolean b = dingXingTuDataJsonService.removeById(id);
return AjaxResult.success("更新成功");
}