在CRUD操作中与业务无关的SQL字段赋值的方法

数据库  /  管理员 发布于 5年前   137

提高效率一直是个永恒的话题，编程中有一项也是可以提到效率的，那就是专注做一件事情，让其它没有强紧密联系的与之分开。这里分享下我们做CRUD时遇到的常见数据处理场景：

•数据库表字段全部设计为非空，即使这个字段在业务上是可以为空的，之所以将数据库表字段全部设计为非空，这里有优点也有缺点，我们认为优点大于缺点，所以选择了它

优点：

1.获取值时，不用判断这个字段是否为null，直接可用于逻辑运算。

2.mysql DBA推荐此方案，可能是有利于性能，这里我并非求证过。

缺点：

1.业务含义没有null清楚，比如int字段默认值设置成0，0就没有null语义清晰。

2.在使用ORM插入数据时，需要处理非空字段值为null的问题。

• 系统字段的赋值，比如创建人，创建人id，创建时间，编辑人，编辑人id，编辑时间等，这些都需要在实际插入数据库前赋值给Model。这些系统字段与具体的业务一般没有太大的关联关系，只是起到标注数据被什么人在什么时间处理的，当这些非业务相关的代码充斥在代码中时，就显得有些多余，而且这类代码多了也会显示冗余，最后带来的结果就是非关键代码比例大。

上面关于默认值与null语义问题不需要解决，因为我们认为具有默认值带来的优点远大于可空字段带来的烦恼，我们来看默认值与系统字段一般情况下如何处理：

•在操作ORM时，将模型所有可空的字段都手动赋值成默认值，int的赋值为0等。

•在设计数据库时，将非空字段加上默认值，让数据库来处理这些未插入值的字段，如果使用mybatis的话，mapper中提到的插入操作有两个：insert,insertSelective，后面这个insertSelective就是处理非空字段的，即插入的模型对于不需要赋值的字段就保持null值，数据库在插入时生成的sql语句也不会包含这些字段，这样就可以利用上数据库的默认值了。如果正巧数据库的结构当初设计时没有设计默认值，又不能改的情况就比较糟糕了，情况回到上面手动赋值，可能会出现类似如下的代码：编写一个函数通过反射来解析每个字段，如果为null就修改为默认值：

public static <T> void emptyNullValue(final T model) {Class<?> tClass = model.getClass();List<Field> fields = Arrays.asList(tClass.getDeclaredFields());for (Field field : fields) {Type t = field.getType();field.setAccessible(true);try {if (t == String.class && field.get(model) == null) {field.set(model, "");} else if (t == BigDecimal.class && field.get(model) == null) {field.set(model, new BigDecimal(0));} else if (t == Long.class && field.get(model) == null) {field.set(model, new Long(0));} else if (t == Integer.class && field.get(model) == null) {field.set(model, new Integer(0));} else if (t == Date.class && field.get(model) == null) {field.set(model, TimeHelper.LocalDateTimeToDate(java.time.LocalDateTime.of(1990, 1, 1, 0, 0, 0, 0)));}} catch (IllegalAccessException e) {e.printStackTrace();}}} 

然后在代码调用insert前调用函数来解决：

ModelHelper.emptyNullValue(request); 

如何处理系统字段呢，在创建编辑数据时，需要获取当前用户，然后根据逻辑分别更新创建人信息以及编辑人信息，我们专门编写一个反射机制的函数来处理系统字段：

注：下面的系统字段的识别，是靠系统约定实现的，比如creator约定为创建人等，可根据不同的情况做数据兼容，如果系统设计的好，一般在一个系统下所有表的风格应该是相同的。

public static <T> void buildCreateAndModify(T model,ModifyModel modifyModel,boolean isCreate){Class<?> tClass = model.getClass();List<Field> fields = Arrays.asList(tClass.getDeclaredFields());for (Field field : fields) {Type t = field.getType();field.setAccessible(true);try {if(isCreate){if (field.getName().equals(modifyModel.getcId())) {field.set(model, modifyModel.getUserId());}if (field.getName().equals(modifyModel.getcName())) {field.set(model, modifyModel.getUserName());}if (field.getName().equals(modifyModel.getcTime())) {field.set(model, new Date());}}if (field.getName().equals(modifyModel.getmId())) {field.set(model, modifyModel.getUserId());}if (field.getName().equals(modifyModel.getmName())) {field.set(model, modifyModel.getUserName());}if (field.getName().equals(modifyModel.getmTime())) {field.set(model, new Date());}} catch (IllegalAccessException e) {e.printStackTrace();}}}

最后在数据处理前，根据创建或者编辑去调用函数来给系统字段赋值，这类代码都混杂在业务代码中。

ModifyModel modifyModel = new ModifyModel();modifyModel.setUserId(getCurrentEmployee().getId());modifyModel.setUserName(getCurrentEmployee().getName());if (request.getId() == 0) {ModelHelper.buildCreateAndModify(request, modifyModel, true);deptService.insert(request);} else {ModelHelper.buildCreateAndModify(request, modifyModel, false);deptService.updateByPrimaryKey(request);}

我们可以利用参数注入来解决。参数注入的理念就是在spring mvc接收到前台请求的参数后，进一步对接收到的参数做处理以达到预期的效果。我们来创建

ManageModelConfigMethodArgumentResolver，它需要实现HandlerMethodArgumentResolver，这个接口看起来比较简单，包含两个核心方法：

• 判断是否是需要注入的参数，一般通过判断参数上是否有特殊的注解来实现，也可以增加一个其它的参数判断，可根据具体的业务做调整，我这里只以是否有特殊注释来判定是否需要参数注入。

@Overridepublic boolean supportsParameter(MethodParameter parameter) {return parameter.hasParameterAnnotation(ManageModelConfig.class);}

• 参数注入，它提供了一个扩展入口，让我们有机会对接收到的参数做进一步的处理。

@Overridepublic Object resolveArgument(MethodParameter parameter, ModelAndViewContainer mavContainer,NativeWebRequest webRequest, WebDataBinderFactory binderFactory) throws Exception {Object manageModel =getRequestResponseBodyMethodProcessor().resolveArgument(parameter, mavContainer, webRequest, binderFactory);ServletRequest servletRequest = webRequest.getNativeRequest(ServletRequest.class);Employee currentUser = (Employee) servletRequest.getAttribute(DEFAULT_ATTRIBUTE_GET_USER_FROM_REQUEST);if (null == currentUser){return manageModel;}ManageModelConfig parameterAnnotation = parameter.getParameterAnnotation(ManageModelConfig.class);ModelHelper.setDefaultAndSystemFieldsValue(manageModel, currentUser,parameterAnnotation.isSetDefaultFieldsValue());return manageModel;}

这段函数有几处核心逻辑：

•取得参数对象，因为我们处理的是ajax请求的参数，最简单的注入方法就是得到实际参数通过反射去处理默认字段以及系统的值。ajax请求与form表单post提交的数据绑定略有不同，可参考之前文章分享的列表页动态搜索的参数注入(列表页的动态条件搜索)。获取当前请求参数对象，我们可以借助如下两个对象配合来完成：

•RequestMappingHandlerAdapter

•RequestResponseBodyMethodProcessor

private RequestMappingHandlerAdapter requestMappingHandlerAdapter=null;private RequestResponseBodyMethodProcessor requestResponseBodyMethodProcessor = null;private RequestResponseBodyMethodProcessor getRequestResponseBodyMethodProcessor() {if(null==requestMappingHandlerAdapter){requestMappingHandlerAdapter=new RequestMappingHandlerAdapter();}if (null==requestResponseBodyMethodProcessor) {List<HttpMessageConverter<?>> messageConverters = requestMappingHandlerAdapter.getMessageConverters();messageConverters.add(new MappingJackson2HttpMessageConverter());requestResponseBodyMethodProcessor = new RequestResponseBodyMethodProcessor(messageConverters);}return requestResponseBodyMethodProcessor;} 

通过如下代码就可以取到参数对象了，其实就是让spring mvc重新解析了一遍参数。

Object manageModel =getRequestResponseBodyMethodProcessor().resolveArgument(parameter, mavContainer, webRequest, binderFactory); 

•如何获取当前用户，我们在成功登录系统后，将当前用户的信息存储在request中，然后就可以在函数中获取当前用户，也可以采用其它方案，比如ThreadLocal，缓存等等。

ServletRequest servletRequest = webRequest.getNativeRequest(ServletRequest.class);Employee currentUser = (Employee) servletRequest.getAttribute(DEFAULT_ATTRIBUTE_GET_USER_FROM_REQUEST); 

•调用处理函数解决默认字段以及系统的赋值，可以根据配置来决定是否处理字段默认值。

ManageModelConfig parameterAnnotation = parameter.getParameterAnnotation(ManageModelConfig.class);ModelHelper.setDefaultAndSystemFieldsValue(manageModel, currentUser,parameterAnnotation.isSetDefaultFieldsValue());

最后将我们的参数注入逻辑启动起来，这里选择在xml中配置：

<mvc:annotation-driven content-negotiation-manager="contentNegotiationManager"><mvc:argument-resolvers><bean class="cn.wanmei.party.management.common.mvc.method.annotation.ManageModelConfigMethodArgumentResolver"/></mvc:argument-resolvers></mvc:annotation-driven> 

再看action中的调用：只需要在参数前面增加注解@ManageModelConfig，如果需要处理默认值，则将启用默认值的选项设置成true即可，下面的实现部分完全看不到任何与业务无关的代码。

@RequestMapping(value = "/addOrUpdateUser")@ResponseBodypublic Map<String, Object> addOrUpdateUser(@ManageModelConfig(isSetDefaultFieldsValue=true) EmployeeDto request) {Map<String, Object> ret = new HashMap<>();ValidateUtil.ValidateResult result= new ValidateUtil().ValidateModel(request);boolean isCreate=request.getId() == 0;try {if (isCreate){employeeService.insert(request);}else{employeeService.updateByPrimaryKey(request);}ret.put("data", "ok");}catch (Exception e){ret.put("err", e.getMessage());}return ret;}

通过自定义实现HandlerMethodArgumentResolver，来捕获ajax请求的参数，利用反射机制动态的将系统字段以及需要处理默认值的字段自动赋值，避免人工干预，起到了代码精简，逻辑干净，问题统一处理的目的。需要注意的是这些实现都是结合当前系统设计的，比如我们认为id字段>0就代表是更新操作，为空或者等于小于0就代表是创建，系统字段也是约定名称的等等。