文档章节

程序中设置MySQL的默认值

l
 laolin23
发布于 2018/12/16 21:05
字数 1042
阅读 13
收藏 0
import com.alibaba.fastjson.JSON;
import java.beans.PropertyDescriptor;
import java.lang.annotation.*;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.util.*;

/**
 * mysql 参数
 */
public interface MysqlConstants {

    /**
     * 数据库中varchar类型为null时,用该值表示,程序中进行转换
     * 字段='NONE' <=> 字段 is null
     */
    String NULL_VARCHAR = "NONE";

    /**
     * 数据库中datetime类型时为空,用该值表示,程序中进行转换
     * 如果需要查找为空的为,只需要令 字段=NULL_DATE即可走索引,避免IS NULL ,IS NOT NULL的效率问题
     * 该日期为 8888-12-31 23:59:59,距离现在还有6000多年,6000年以后的系统就让6000年以后的人去维护就行了
     * 由于Date类型不是安全类型,有可能会被程序不小心改变值,所以程序中通过new Date(NULL_DATE_MILLS)来设置默认值,
     * 从而避免NULL_DATE的值会被改变
     */
    long NULL_DATE_MILLS = LocalDateTime.of(8888, 12, 31, 23, 59, 59).toInstant(ZoneOffset.of("+8")).toEpochMilli();

    /**
     * 时间字符串最大值,避免将空值取出,比空值少一秒
     */
    String MAX_DATETIME_STR = "8888-12-31 23:59:58";

    /**
     * tinyint
     */
    Byte DEF_BYTE = 0;

    /**
     * short
     */
    Short DEF_SHORT = 0;

    /**
     * int
     */
    Integer DEF_INT = 0;

    /**
     * bigint
     */
    Long DEF_LONG = 0L;

    /**
     * float
     */
    Float DEF_FLOAT = 0F;

    /**
     * double
     */
    Double DEF_DOUBLE = 0D;

    /**
     * decimal
     */
    BigDecimal DEF_DECIMAL = BigDecimal.valueOf(0);

    /**
     * tinyint(1)
     */
    Boolean DEF_BOOLEAN = Boolean.FALSE;

    /**
     * mysql 默认值跟空值的转换
     * 对应的field必须有可访问的setter getter 方法
     */
    @Target({ElementType.FIELD})
    @Retention(RetentionPolicy.RUNTIME)
    @Documented
    @interface CastMysqlDefaultNullValue {

        /**
         * 默认使用MysqlConstants中的默认值
         * @return
         */
        String defaultValue() default "";

        /**
         * 将默认值字符串转成特定的数据类型
         * @return
         */
        Class<? extends MysqlConstantsCast> cast() default MysqlConstantsCast.MysqlConstantsDefaultCast.MysqlConstantsDefaultCast.class;
    }

    interface MysqlConstantsCast {

        /**
         * 将默认值转换为特别值
         * @param defaultValue
         * @param target 目标类型
         * @return
         */
        <T> T cast(String defaultValue, Class<T> target);

        class MysqlConstantsDefaultCast implements MysqlConstantsCast {
            @Override
            public <T> T cast(String defaultValue, Class<T> target) {
                if (target == String.class) {
                    return (T)(defaultValue.isEmpty() ? MysqlConstants.NULL_VARCHAR : defaultValue);
                }
                if (target == Byte.class) {
                    return (T)(defaultValue.isEmpty() ? MysqlConstants.DEF_BYTE : Byte.valueOf(defaultValue));
                }
                if (target == Short.class) {
                    return (T)(defaultValue.isEmpty() ? MysqlConstants.DEF_SHORT : Short.valueOf(defaultValue));
                }
                if (target == Integer.class) {
                    return (T)(defaultValue.isEmpty() ? MysqlConstants.DEF_INT : Integer.valueOf(defaultValue));
                }
                if (target == Long.class) {
                    return (T)(defaultValue.isEmpty() ? MysqlConstants.DEF_LONG : Long.valueOf(defaultValue));
                }
                if (target == Float.class) {
                    return (T)(defaultValue.isEmpty() ? MysqlConstants.DEF_FLOAT : Float.valueOf(defaultValue));
                }
                if (target == Double.class) {
                    return (T)(defaultValue.isEmpty() ? MysqlConstants.DEF_DOUBLE : Double.valueOf(defaultValue));
                }
                if (target == BigDecimal.class) {
                    return (T)(defaultValue.isEmpty() ? MysqlConstants.DEF_DECIMAL : BigDecimal.valueOf(Double.valueOf(defaultValue)));
                }
                if (target == Boolean.class) {
                    return (T)(defaultValue.isEmpty() ? MysqlConstants.DEF_BOOLEAN : Boolean.valueOf(defaultValue));
                }
                if (target == Date.class) {
                    try {
                        return (T)(defaultValue.isEmpty() ? new Date(MysqlConstants.NULL_DATE_MILLS) : new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(defaultValue));
                    } catch (ParseException e) {
                        throw new RuntimeException(e);
                    }
                }
                throw new RuntimeException("无法将默认值[" + defaultValue + "]转换成" + target.getName() + "类型");
            }
        }

    }

    /**
     * 目前只处理 String Date Integer 的默认值,其他的通过接口提供
     */
    class MysqlConstantsUtil {

        private static final Map<Class<?>, Member[]> classMembers = new HashMap<>();

        /**
         * 将目标方法中的空值换成默认值
         */
        public static void castNullToDefaultValue(Object dest) {
            try {
                Member[] members = getMembers(dest.getClass());
                if (members != null && members.length > 0) {
                    for (Member member : members) {
                        if (member.getMethod.invoke(dest) == null) {
                            member.setMethod.invoke(dest, new Object[]{member.defaultValue});//设置默认值
                        }
                    }
                }
            } catch (Throwable e) {
                throw new RuntimeException(e);
            }
        }

        /**
         * 将默认值转成null,主要给前端展示用
         * @param dest
         */
        public static void castDefaultValueToNull(Object dest) {
            try {
                Member[] members = getMembers(dest.getClass());
                if (members != null && members.length > 0) {
                    for (Member member : members) {
                        Object value = member.getMethod.invoke(dest);
                        //等于默认值
                        if (value != null && value.equals(member.defaultValue)) {
                            member.setMethod.invoke(dest, new Object[]{null});
                        }
                    }
                }
            } catch (Throwable e) {
                throw new RuntimeException(e);
            }
        }

        private static Member[] getMembers(Class<?> target) {
            Member[] members = classMembers.get(target);
            if (members == null) {
                synchronized (target) {
                    members = classMembers.get(target);
                    if (members == null) {
                        try {
                            members = parseMembers(target);
                        } catch (Exception e) {
                            throw new RuntimeException(e);
                        }
                        classMembers.put(target, members);
                    }
                }
            }
            return members;
        }

        private static Member[] parseMembers(Class<?> target) throws Exception {
            List<Member> members = new ArrayList<>();
            List<Field> fieldList = new ArrayList<>();
            Class<?> clazz = target;
            while (clazz != null && clazz != Object.class) {
                fieldList.addAll(Arrays.asList(clazz.getDeclaredFields()));
                clazz = clazz.getSuperclass();
            }
            for (Field field : fieldList) {
                field.setAccessible(true);
                CastMysqlDefaultNullValue castMysqlDefaultNullValue = field.getAnnotation(CastMysqlDefaultNullValue.class);
                if (castMysqlDefaultNullValue != null) {
                    PropertyDescriptor pd = new PropertyDescriptor(field.getName(), target);
                    Method getMethod = pd.getReadMethod();
                    Method setMethod = pd.getWriteMethod();
                    if (getMethod == null || setMethod == null) {
                        throw new RuntimeException(target.getName() + "." + field.getName() + "没有相应的setter/getter方法");
                    }
                    if (getMethod.getReturnType().isPrimitive()) {
                        throw new RuntimeException("注解" + CastMysqlDefaultNullValue.class.getName() + "不支持基本类型");
                    }
                    Object defaultValue = castMysqlDefaultNullValue.cast().newInstance().cast(castMysqlDefaultNullValue.defaultValue(), field.getType());
                    members.add(new Member(defaultValue, field, getMethod, setMethod));
                }
            }
            return members.toArray(new Member[members.size()]);
        }

        //测试效果用的
        static class CastTest {
            @CastMysqlDefaultNullValue
            Byte byte1;
            @CastMysqlDefaultNullValue
            Short short1;
            @CastMysqlDefaultNullValue
            Integer integer;
            @CastMysqlDefaultNullValue
            Long long1;
            @CastMysqlDefaultNullValue
            String string;
            @CastMysqlDefaultNullValue
            Float float1;
            @CastMysqlDefaultNullValue
            Double double1;
            @CastMysqlDefaultNullValue
            Date date;
            @CastMysqlDefaultNullValue
            BigDecimal bigDecimal;
            @CastMysqlDefaultNullValue
            Boolean boolean1;

            public Byte getByte1() {
                return byte1;
            }

            public void setByte1(Byte byte1) {
                this.byte1 = byte1;
            }

            public Short getShort1() {
                return short1;
            }

            public void setShort1(Short short1) {
                this.short1 = short1;
            }

            public Integer getInteger() {
                return integer;
            }

            public void setInteger(Integer integer) {
                this.integer = integer;
            }

            public Long getLong1() {
                return long1;
            }

            public void setLong1(Long long1) {
                this.long1 = long1;
            }

            public String getString() {
                return string;
            }

            public void setString(String string) {
                this.string = string;
            }

            public Float getFloat1() {
                return float1;
            }

            public void setFloat1(Float float1) {
                this.float1 = float1;
            }

            public Double getDouble1() {
                return double1;
            }

            public void setDouble1(Double double1) {
                this.double1 = double1;
            }

            public Date getDate() {
                return date;
            }

            public void setDate(Date date) {
                this.date = date;
            }

            public BigDecimal getBigDecimal() {
                return bigDecimal;
            }

            public void setBigDecimal(BigDecimal bigDecimal) {
                this.bigDecimal = bigDecimal;
            }

            public Boolean getBoolean1() {
                return boolean1;
            }

            public void setBoolean1(Boolean boolean1) {
                this.boolean1 = boolean1;
            }
        }

        public static void main(String[] args) {
            CastTest castTest = new CastTest();
            castNullToDefaultValue(castTest);
            System.out.println(JSON.toJSONString(castTest));
            castDefaultValueToNull(castTest);
            System.out.println(JSON.toJSONString(castTest));
        }

    }

    class Member {

        Object defaultValue;

        Field field;

        Method getMethod;

        Method setMethod;

        Member(Object defaultValue, Field field, Method getMethod, Method setMethod) {
            this.defaultValue = defaultValue;
            this.field = field;
            this.getMethod = getMethod;
            this.setMethod = setMethod;
        }

    }

}

 

© 著作权归作者所有

共有 人打赏支持
下一篇: spring 手动事务
l
粉丝 0
博文 25
码字总数 20659
作品 0
广州
程序员
私信 提问
Atlas安装与部署

1.简介 Atlas是由 Qihoo 360公司Web平台部基础架构团队开发维护的一个基于MySQL协议的数据中间层项目。它在MySQL官方推出的MySQL-Proxy 0.8.2版本的基础上,修改了大量bug,添加了很多功能特...

charles_shang
2016/02/26
216
0
安装完 MySQL 后必须调整的 10 项配置

当我们被人雇来监测MySQL性能时,人们希望我们能够检视一下MySQL配置然后给出一些提高建议。许多人在事后都非常惊讶,因为我们建议他们仅仅改动几个设置,即使是这里有好几百个配置项。这篇文...

Weidao
2014/08/21
27
0
安装完 MySQL 后必须调整的 10 项配置

当我们被人雇来监测MySQL性能时,人们希望我们能够检视一下MySQL配置然后给出一些提高建议。许多人在事后都非常惊讶,因为我们建议他们仅仅改动几个设置,即使是这里有好几百个配置项。这篇文...

oschina
2014/01/29
16.9K
42
MySQL优化必须调整的10项配置

这篇文章主要介绍了MySQL优化必须调整的10项配置,使用这些方法可以让你快速地获得一个稳健的MySQL配置,需要的朋友可以参考下 当我们被人雇来监测MySQL性能时,人们希望我们能够检视一下MySQL...

人情世故
2016/05/22
12
0
[mysql] timestamp自动更新和初始化

[mysql] timestamp自动更新和初始化 1.概述 在我们设计表的时候,考虑将行数据的创建时间和最后更新时间记录下来是很好的实践。尤其是可能需要做数据同步或者对数据新鲜度有要求的表。举些应...

as007012012
2017/01/13
0
0

没有更多内容

加载失败,请刷新页面

加载更多

开始看《JSP&Servlet学习笔记》

1:WEB应用简介。其中1.2.1对Web容器的工作流程写得不错 2:编写Servlet。搞清楚了Java的Web目录结构,以及Web.xml的一些配置作用。特别是讲了@WebServlet标签 3:请求与响应。更细致的讲了从...

max佩恩
33分钟前
0
0
mysql分区功能详细介绍,以及实例

一,什么是数据库分区 前段时间写过一篇关于mysql分表的的文章,下面来说一下什么是数据库分区,以mysql为例。mysql数据库中的数据是以文件的形势存在磁盘上的,默认放在/mysql/data下面(可...

吴伟祥
33分钟前
0
0
SQL语句查询

1.1 排序 通过order by语句,可以将查询出的结果进行排序。放置在select语句的最后。 格式: SELECT * FROM 表名 ORDER BY 排序字段ASC|DESC; ASC 升序 (默认) DESC 降序 1.查询所有商品信息,...

stars永恒
50分钟前
2
0
IntelliJ IDEA 第一个 Scala 程序

IntelliJ 安装完成 Scala 插件后,你需要尝试使用 IntelliJ 来创建并且运行第一个程序。 通常这个程序只是简单的输出 Hello World。 创建一个新工程 在文件下面选择新建,然后选择创建工程。...

honeymose
54分钟前
2
0
csapp 习题 - 如何实现异或 exclusive-or

阅读 csapp v3 时,练习题 2.13 很有意思。练习题描述如下。 位设置是对于参数 mask 中每一个为 1 的位,那么参数 x 中相应位则被设置为 1 ;位清除是对于参数 mask 中每一个为 1 的位,那么...

ylme
昨天
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部