SpringBoot + MybatisPlus 实现实体类转成数据库表结构，可直接运行

package com.gitee.sunchenbin.mybatis.actable.manager.common; import com.gitee.sunchenbin.mybatis.actable.command.PageResultCommand; import com.gitee.sunchenbin.mybatis.actable.command.SaveOrUpdateDataCommand; import com.gitee.sunchenbin.mybatis.actable.dao.common.BaseCRUDMapper; import com.gitee.sunchenbin.mybatis.actable.utils.ColumnUtils; import com.gitee.sunchenbin.mybatis.actable.utils.FieldUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; import java.lang.reflect.Field; import java.sql.Date; import java.sql.Time; import java.sql.Timestamp; import java.util.*; /** * 通用增删改查方法 */ @Service @Transactional public class BaseCRUDManagerImpl implements BaseCRUDManager { private static final Logger log = LoggerFactory.getLogger(BaseCRUDManagerImpl.class); private static final String KEYFIELDMAP = "keyFieldMap"; @Autowired private BaseCRUDMapper baseCRUDMapper; /** * 根据实体对象的非Null字段作为Where条件查询结果集，如果对象的属性值都为null则返回全部数据等同于selectAll * * @param t 实体对象 * @param <T> 实体类型 * @return List实体对象列表 */ @Override public <T> List<T> select(T t) { // 得到表名 String tableName = ColumnUtils.getTableName(t.getClass()); if (StringUtils.isEmpty(tableName)) { log.error("必须使用model中的对象！"); throw new RuntimeException("必须使用model中的对象！"); } Field[] declaredFields = FieldUtils.getAllFields(t); Map<Object, Object> tableMap = new HashMap<Object, Object>(); Map<Object, Object> dataMap = new HashMap<Object, Object>(); for (Field field : declaredFields){ // 设置访问权限 field.setAccessible(true); if (!ColumnUtils.hasColumnAnnotation(field,t.getClass())) { log.debug("该field没有配置注解不是表中在字段！"); continue; } try{ dataMap.put(ColumnUtils.getColumnName(field,t.getClass()), field.get(t)); }catch (Exception e){ log.error("操作对象的Field出现异常",e); throw new RuntimeException("操作对象的Field出现异常"); } } tableMap.put(tableName, dataMap); List<Map<String, Object>> query = baseCRUDMapper.select(tableMap); List<T> list = new ArrayList<T>(); try{ for (Map<String, Object> map : query){ T newInstance = (T) t.getClass().newInstance(); Field[] declaredFields2 = FieldUtils.getAllFields(newInstance); for (Field field : declaredFields2){ field.setAccessible(true); if (!ColumnUtils.hasColumnAnnotation(field,t.getClass())) { log.debug("该field没有配置注解不是表中在字段！"); continue; } String name = ColumnUtils.getColumnName(field,t.getClass()); buildFieldValue(map, newInstance, field, name); } list.add(newInstance); } return list; }catch (Exception e){ log.error("结果集转对象失败",e); throw new RuntimeException("结果集转对象失败"); } } /** * 根据实体对象的@IsKey主键字段的值作为Where条件查询结果，主键字段不能为null * * @param t 实体对象(只设置主键值即可，其他字段值不会读取) * @param <T> 实体类型 * @return 实体对象 */ @Override public <T> T selectByPrimaryKey(T t) { // 得到表名 String tableName = ColumnUtils.getTableName(t.getClass()); if (StringUtils.isEmpty(tableName)) { log.error("必须使用model中的对象！"); throw new RuntimeException("必须使用model中的对象！"); } Field keyField = FieldUtils.getKeyField(t); if (null == keyField){ throw new RuntimeException("当前对象没有主键不能使用该方法！"); } Map<Object, Object> tableMap = new HashMap<Object, Object>(); Map<Object, Object> dataMap = new HashMap<Object, Object>(); try { // 设置访问权限 keyField.setAccessible(true); Object keyValue = keyField.get(t); if (null == keyValue){ throw new RuntimeException("主键字段不能为null"); } dataMap.put(ColumnUtils.getColumnName(keyField,t.getClass()), keyField.get(t)); } catch (IllegalAccessException e) { log.error("操作对象的Field出现异常",e); throw new RuntimeException("操作对象的Field出现异常"); } tableMap.put(tableName, dataMap); List<Map<String, Object>> query = baseCRUDMapper.select(tableMap); if (query == null || query.size() == 0){ return null; } Map<String, Object> stringObjectMap = query.get(0); try{ T newInstance = (T) t.getClass().newInstance(); Field[] declaredFields2 = FieldUtils.getAllFields(newInstance); for (Field field : declaredFields2){ field.setAccessible(true); if (!ColumnUtils.hasColumnAnnotation(field,t.getClass())) { log.debug("该field没有配置注解不是表中在字段！"); continue; } String name = ColumnUtils.getColumnName(field,t.getClass()); buildFieldValue(stringObjectMap, newInstance, field, name); } return newInstance; }catch (Exception e){ log.error("结果集转对象失败",e); throw new RuntimeException("结果集转对象失败"); } } /** * 查询表全部数据 * * @param clasz 实体对象的class * @param <T> 实体类型 * @return List实体对象列表 */ @Override public <T> List<T> selectAll(Class<T> clasz) { // 得到表名 String tableName = ColumnUtils.getTableName(clasz); if (StringUtils.isEmpty(tableName)) { log.error("必须使用model中的对象！"); throw new RuntimeException("必须使用model中的对象！"); } Map<Object, Object> tableMap = new HashMap<Object, Object>(); Map<Object, Object> dataMap = new HashMap<Object, Object>(); tableMap.put(tableName, dataMap); List<Map<String, Object>> query = baseCRUDMapper.select(tableMap); List<T> list = new ArrayList<T>(); try{ for (Map<String, Object> map : query){ T newInstance = (T) clasz.newInstance(); Field[] declaredFields2 = FieldUtils.getAllFields(newInstance); for (Field field : declaredFields2){ field.setAccessible(true); if (!ColumnUtils.hasColumnAnnotation(field,clasz)) { log.debug("该field没有配置注解不是表中在字段！"); continue; } String name = ColumnUtils.getColumnName(field,clasz); buildFieldValue(map, newInstance, field, name); } list.add(newInstance); } return list; }catch (Exception e){ log.error("结果集转对象失败",e); throw new RuntimeException("结果集转对象失败"); } } /** * 根据实体对象的�