From 09a5b41d9687154e64c23100c10b14f1a1068473 Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Fri, 25 Nov 2016 17:20:45 +0800 Subject: [PATCH] --- test/org/redkale/test/source/BaseEntity.java | 22 +++ test/org/redkale/test/source/LoginRecord.java | 138 ++++++++++++++++++ test/org/redkale/test/source/UserDetail.java | 113 ++++++++++++++ 3 files changed, 273 insertions(+) create mode 100644 test/org/redkale/test/source/BaseEntity.java create mode 100644 test/org/redkale/test/source/LoginRecord.java create mode 100644 test/org/redkale/test/source/UserDetail.java diff --git a/test/org/redkale/test/source/BaseEntity.java b/test/org/redkale/test/source/BaseEntity.java new file mode 100644 index 000000000..ee78d0676 --- /dev/null +++ b/test/org/redkale/test/source/BaseEntity.java @@ -0,0 +1,22 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ +package org.redkale.test.source; + +import java.io.Serializable; +import org.redkale.convert.json.*; + +/** + * + * @author zhangjx + */ +public abstract class BaseEntity implements Serializable { + + @Override + public String toString() { + return JsonConvert.root().convertTo(this); + } + +} diff --git a/test/org/redkale/test/source/LoginRecord.java b/test/org/redkale/test/source/LoginRecord.java new file mode 100644 index 000000000..74c577f73 --- /dev/null +++ b/test/org/redkale/test/source/LoginRecord.java @@ -0,0 +1,138 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ +package org.redkale.test.source; + +import java.io.Serializable; +import javax.persistence.*; +import org.redkale.source.*; + +/** + * + * @author zhangjx + */ +@DistributeTable(strategy = LoginRecord.TableStrategy.class) +public class LoginRecord extends BaseEntity { + + @Id + @GeneratedValue + @Column(comment = "UUID") + private String seqid = ""; //UUID + + @Column(updatable = false, comment = "C端用户ID") + private long userid; //C端用户ID + + @Column(updatable = false, comment = "登录网络类型; wifi/4g/3g") + private String netmode = ""; //登录网络类型; wifi/4g/3g + + @Column(updatable = false, comment = "APP版本信息") + private String appversion = ""; //APP版本信息 + + @Column(updatable = false, comment = "APP操作系统信息") + private String appos = ""; //APP操作系统信息 + + @Column(updatable = false, comment = "登录时客户端信息") + private String loginagent = ""; //登录时客户端信息 + + @Column(updatable = false, comment = "登录时的IP") + private String loginaddr = ""; //登录时的IP + + @Column(updatable = false, comment = "创建时间") + private long createtime; //创建时间 + + /** 以下省略getter setter方法 */ + // + public void setSeqid(String seqid) { + this.seqid = seqid; + } + + public String getSeqid() { + return this.seqid; + } + + public void setUserid(long userid) { + this.userid = userid; + } + + public long getUserid() { + return this.userid; + } + + public void setNetmode(String netmode) { + this.netmode = netmode; + } + + public String getNetmode() { + return this.netmode; + } + + public String getAppversion() { + return appversion; + } + + public void setAppversion(String appversion) { + this.appversion = appversion; + } + + public String getAppos() { + return appos; + } + + public void setAppos(String appos) { + this.appos = appos; + } + + public void setLoginagent(String loginagent) { + this.loginagent = loginagent; + } + + public String getLoginagent() { + return this.loginagent; + } + + public void setLoginaddr(String loginaddr) { + this.loginaddr = loginaddr; + } + + public String getLoginaddr() { + return this.loginaddr; + } + + public void setCreatetime(long createtime) { + this.createtime = createtime; + } + + public long getCreatetime() { + return this.createtime; + } + + public static class TableStrategy implements DistributeTableStrategy { + + private static final String dayformat = "%1$tY%1$tm%1$td"; + + private static final String yearformat = "%1$tY"; + + //过滤查询时调用本方法 + @Override + public String getTable(String table, FilterNode node) { + Serializable day = node.findValue("#day"); + if (day != null) getTable(table, (Integer) day, 0L); //存在#day参数则直接使用day值 + Serializable time = node.findValue("#createtime"); //存在createtime则使用最小时间，且createtime的范围必须在一天内，因为本表以天为单位建表 + return getTable(table, 0, (time == null ? 0L : (time instanceof Range ? ((Range.LongRange) time).getMin() : (Long) time))); + } + + //创建或单个查询时调用本方法 + @Override + public String getTable(String table, LoginRecord bean) { + return getTable(table, 0, bean.getCreatetime()); + } + + private String getTable(String table, int day, long createtime) { + int pos = table.indexOf('.'); + String year = (day > 0 ? "" + day / 10000 : String.format(yearformat, createtime)); + return "platf_login_" + year + "." + table.substring(pos + 1) + "_" + (day > 0 ? day : String.format(dayformat, createtime)); + } + } +} diff --git a/test/org/redkale/test/source/UserDetail.java b/test/org/redkale/test/source/UserDetail.java new file mode 100644 index 000000000..54f9030dd --- /dev/null +++ b/test/org/redkale/test/source/UserDetail.java @@ -0,0 +1,113 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ +package org.redkale.test.source; + +import java.io.Serializable; +import javax.persistence.*; +import org.redkale.convert.*; +import org.redkale.source.*; + +/** + * + * @author zhangjx + */ +@DistributeTable(strategy = UserDetail.TableStrategy.class) +public class UserDetail extends BaseEntity { + + @Id + private long userid; //用户ID + + @Column(length = 64, comment = "用户昵称") + private String username = ""; //用户昵称 + + @Column(length = 32, comment = "手机号码") + private String mobile = ""; //手机号码 + + @Column(length = 64, comment = "密码") + @ConvertColumn(ignore = true, type = ConvertType.ALL) + private String password = ""; //密码 + + @Column(length = 128, comment = "备注") + private String remark = ""; //备注 + + @Column(updatable = false, comment = "创建时间") + private long createtime; //创建时间 + + /** 以下省略getter setter方法 */ + public long getUserid() { + return userid; + } + + public void setUserid(long userid) { + this.userid = userid; + } + + public String getUsername() { + return username; + } + + public void setUsername(String username) { + this.username = username; + } + + public String getMobile() { + return mobile; + } + + public void setMobile(String mobile) { + this.mobile = mobile; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + this.password = password; + } + + public String getRemark() { + return remark; + } + + public void setRemark(String remark) { + this.remark = remark; + } + + public long getCreatetime() { + return createtime; + } + + public void setCreatetime(long createtime) { + this.createtime = createtime; + } + + public static class TableStrategy implements DistributeTableStrategy { + + @Override + public String getTable(String table, UserDetail bean) { + return getTable(table, bean.getUserid()); + } + + @Override + public String getTable(String table, FilterNode node) { + Serializable id = node.findValue("userid"); + if (id != null) return getTable(table, id); + return getHashTable(table, (Integer) node.findValue("#hash")); + } + + @Override + public String getTable(String table, Serializable userid) { + return getHashTable(table, (int) (((Long) userid) % 100)); + } + + private String getHashTable(String table, int hash) { + int pos = table.indexOf('.'); + return "platf_user." + table.substring(pos + 1) + "_" + (hash > 9 ? hash : ("0" + hash)); + } + + } +}