Java Mybatis
fastmybatis 是一个 mybatis 开发框架,其宗旨为:简单、快速、有效。零配置快速上手,无需编写 xml 文件即可完成 CRUD 操作。同时支持 mysql、sqlserver、oracle、postgresql、sqlite。
支持自定义 SQL,对于基本的增删改查不需要写 SQL,对于其它特殊 SQL(如统计 SQL )可写在 xml 中,支持与 Spring-Boot 集成,依赖 starter 即可,支持插件编写,支持 ActiveRecord 模式,提供通用 Service,轻量级,无侵入性,是官方 MyBatis 的一种扩展

快速开始(SpringBoot)

新建一个 Spring boot 项目

pom.xml 添加 fastmybatis-spring-boot-starter

  1. <dependency>
  2. <groupId>net.oschina.durcframework</groupId>
  3. <artifactId>fastmybatis-spring-boot-starter</artifactId>
  4. <version>最新版本</version>
  5. </dependency>

增删改查例子

假设数据库有张 t_user 表,添加对应的实体类 TUser.java和 Mapper 类TUserMapper.java

  1. /**
  2. * 增删改查例子
  3. */
  4. @RestController
  5. public class CrudController {
  6. @Autowired
  7. private UserService userService;
  8. /**
  9. * 分页查询
  10. * http://localhost:8080/user/page?id=10
  11. * http://localhost:8080/user/page?pageIndex=1&pageSize=5
  12. *
  13. * @param param
  14. * @return
  15. */
  16. @GetMapping("/user/page")
  17. public Result<PageInfo<TUser>> page(UserParam param) {
  18. Query query = param.toQuery();
  19. PageInfo<TUser> pageInfo = userService.page(query);
  20. return Result.ok(pageInfo);
  21. }
  22. /**
  23. * 新增记录,这里为了方便演示用了GET方法,实际上应该使用POST
  24. * http://localhost:8080/user/save?username=jim
  25. *
  26. * @param user
  27. * @return
  28. */
  29. @GetMapping("/user/save")
  30. public Result<Integer> save(TUser user) {
  31. userService.saveIgnoreNull(user);
  32. // 返回添加后的主键值
  33. return Result.ok(user.getId());
  34. }
  35. /**
  36. * 修改记录,这里为了方便演示用了GET方法,实际上应该使用POST
  37. * http://localhost:8080/user/update?id=10&username=jim
  38. *
  39. * @param user 表单数据
  40. * @return
  41. */
  42. @GetMapping("/user/update")
  43. public Result<?> update(TUser user) {
  44. userService.updateIgnoreNull(user);
  45. return Result.ok();
  46. }
  47. /**
  48. * 删除记录,这里为了方便演示用了GET方法,实际上应该使用DELETE
  49. * http://localhost:8080/user/delete?id=10
  50. *
  51. * @param id 主键id
  52. * @return
  53. */
  54. @GetMapping("/user/delete")
  55. public Result<?> delete(Integer id) {
  56. userService.deleteById(id);
  57. return Result.ok();
  58. }
  59. }

UserService.java

  1. // 实现通用接口
  2. @Service
  3. public class UserService implements IService<TUser/*实体类*/, Integer/*主键类型*/> {
  4. }

TUserMapper.java

  1. public interface TUserMapper extends CrudMapper<TUser/*实体类*/, Integer/*主键类型*/> {
  2. }

service和mapper不用写一行代码就能实现各种数据库操作,非常方便。

Mapper方法列表

方法 说明
E getByColumn(String column, Object value) 根据字段查询一条记录
E getById(I id) 根据主键查询
E getByQuery(Query query) 根据条件查找单条记录
E getBySpecifiedColumns(List<String> columns, Query query) 查询单条数据并返回指定字段
<T> T getBySpecifiedColumns(List<String> columns, Query query, Class<T> clazz) 查询单条数据返回指定字段并转换到指定类中
<T> T getColumnValue(String column, Query query, Class<T> clazz) 查询某一行某个字段值
long getCount(Query query) 查询总记录数
List<E> list(Query query) 查询结果集
List<E> listByArray(String column, Object[] values) 根据多个字段值查询结果集
List<E> listByCollection(String column, Collection<?> values) 根据字段多个值查询结果集
List<E> listByColumn(String column, Object value) 根据字段查询结果集
List<E> listByIds(Collection<I> ids) 根据多个主键查询
List<E> listBySpecifiedColumns(List<String> columns, Query query) 查询返回指定的列,返回实体类集合
<T> List<T> listBySpecifiedColumns(List<String> columns, Query query, Class<T> clazz) 查询返回指定的列,返指定类集合
<T> List<T> listColumnValues(String column, Query query, Class<T> clazz) 查询指定列,返指定列集合
PageInfo<E> page(Query query) 分页查询
<R> PageInfo<R> page(Query query, Function<E, R> converter) 查询结果集,并转换结果集中的记录,转换处理每一行
<R> PageInfo<R> page(Query query, Supplier<R> target, Consumer<R> format) 查询结果集,并转换结果集中的记录,并对记录进行额外处理
<T> PageInfo<T> page(Query query, Supplier<T> target) 查询结果集,并转换结果集中的记录
<R> PageInfo<R> pageAndConvert(Query query, Function<List<E>, List<R>> converter) 查询结果集,并转换结果集中的记录,转换处理list
<T> PageInfo<T> pageBySpecifiedColumns(List<String> columns, Query query, Class<T> clazz) 查询返回指定的列,返回分页数据
PageEasyui<E> pageEasyui(Query query) 查询返回easyui结果集
<T> PageEasyui<T> pageEasyui(Query query, Class<T> clazz) 查询返回easyui结果集,并转换结果集中的记录
E forceById(I id) 根据主键查询强制查询,忽略逻辑删除字段
int save(E entity) 保存,保存所有字段
int saveBatch(Collection<E> entitys) 批量保存
int saveIgnoreNull(E entity) 保存,忽略null字段
int saveMultiSet(Collection<E> entitys) 批量保存,兼容更多的数据库版本,忽略重复行,此方式采用union的方式批量insert
int saveOrUpdate(E entity) 保存或修改,当数据库存在记录执行UPDATE,否则执行INSERT
int saveOrUpdateIgnoreNull(E entity) 保存或修改,忽略null字段,当数据库存在记录执行UPDATE,否则执行INSERT
int saveUnique(Collection<E> entitys) 批量保存,去除重复行,通过对象是否相对判断重复数据,实体类需要实现equals方法
int saveUnique(Collection<E> entitys, Comparator<E> comparator) 批量保存,去除重复行,指定比较器判断
int update(E entity) 更新,更新所有字段
int updateByQuery(E entity, Query query) 根据条件更新
int updateIgnoreNull(E entity) 更新,忽略null字段
int updateByMap(Map<String, Object> map, Query query) 根据条件更新,map中的数据转化成update语句set部分,key为数据库字段名
int delete(E entity) 删除,在有逻辑删除字段的情况下,做UPDATE操作
int deleteByColumn(String column, Object value) 根据指定字段值删除,在有逻辑删除字段的情况下,做UPDATE操作
int deleteById(I id) 根据id删除,在有逻辑删除字段的情况下,做UPDATE操作
int deleteByIds(Collection<I> ids) 根据多个主键id删除,在有逻辑删除字段的情况下,做UPDATE操作
int deleteByQuery(Query query) 根据条件删除,在有逻辑删除字段的情况下,做UPDATE操作
int forceDelete(E entity) 强制删除(底层根据id删除),忽略逻辑删除字段,执行DELETE语句
int forceDeleteById(I id) 根据id强制删除,忽略逻辑删除字段,执行DELETE语句
int forceDeleteByQuery(Query query) 根据条件强制删除,忽略逻辑删除字段,执行DELETE语句

Query查询对象

查询姓名为张三,并且年龄为22岁的用户:

  1. Query query = new Query().eq("username","张三").eq("age",22);
  2. List<User> users = mapper.list(query);

查询年龄为10,20,30的用户:

  1. Query query = new Query().in("age",Arrays.asList(10,20,30));
  2. List<User> users = mapper.list(query);

查询注册日期大于2017-11-11的用户:

  1. Date regDate = ...
  2. Query query = new Query().gt("reg_date",regDate);
  3. List<User> users = mapper.list(query);

查询性别为男的,年龄大于等于20岁的用户,按年龄降序:

  1. Query query = new Query().eq("gender",1).ge("age",20).orderby("age",Sort.DESC);
  2. List<User> users = mapper.list(query);

分页查询:

  1. Query query = new Query().eq("age",10).page(1,10); // 第一页,每页10条数据
  2. List<User> users = mapper.list(query);

查询总记录数:

  1. Query query = new Query().eq("age",10).page(1,10); // 第一页,每页10条数据
  2. long total = mapper.getCount(query); // 该条件下总记录数