diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TRiskRuleMapper.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TRiskRuleMapper.java
new file mode 100644
index 00000000..cb5f2062
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TRiskRuleMapper.java
@@ -0,0 +1,17 @@
+package com.infincash.statistics.risk.mapper;
+
+import com.infincash.statistics.risk.table.TRiskRule;
+
+public interface TRiskRuleMapper {
+    int deleteByPrimaryKey(String id);
+
+    int insert(TRiskRule record);
+
+    int insertSelective(TRiskRule record);
+
+    TRiskRule selectByPrimaryKey(String id);
+
+    int updateByPrimaryKeySelective(TRiskRule record);
+
+    int updateByPrimaryKey(TRiskRule record);
+}
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserMapper.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserMapper.java
new file mode 100644
index 00000000..823ac6d3
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserMapper.java
@@ -0,0 +1,17 @@
+package com.infincash.statistics.risk.mapper;
+
+import com.infincash.statistics.risk.table.TUser;
+
+public interface TUserMapper {
+    int deleteByPrimaryKey(String id);
+
+    int insert(TUser record);
+
+    int insertSelective(TUser record);
+
+    TUser selectByPrimaryKey(String id);
+
+    int updateByPrimaryKeySelective(TUser record);
+
+    int updateByPrimaryKey(TUser record);
+}
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserRiskMapper.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserRiskMapper.java
new file mode 100644
index 00000000..2873b503
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserRiskMapper.java
@@ -0,0 +1,17 @@
+package com.infincash.statistics.risk.mapper;
+
+import com.infincash.statistics.risk.table.TUserRisk;
+
+public interface TUserRiskMapper {
+    int deleteByPrimaryKey(String id);
+
+    int insert(TUserRisk record);
+
+    int insertSelective(TUserRisk record);
+
+    TUserRisk selectByPrimaryKey(String id);
+
+    int updateByPrimaryKeySelective(TUserRisk record);
+
+    int updateByPrimaryKey(TUserRisk record);
+}
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TRiskRule.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TRiskRule.java
index 8fc8607c..14bb9e03 100644
--- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TRiskRule.java
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TRiskRule.java
@@ -1,11 +1,93 @@
 package com.infincash.statistics.risk.table;
 
-//FIXME mybatis自动生成模板
-//com.infincash.statistics.risk.table
 public class TRiskRule {
-	String id;
-	String type_code;
-	String name_code;
-	String value;
-	String express;
-}
+    private String id;
+
+    private String typeCode;
+
+    private String type;
+
+    private String nameCode;
+
+    private String value;
+
+    private String express;
+
+    private String status;
+
+    private String expressDesc;
+
+    private String expressType;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id == null ? null : id.trim();
+    }
+
+    public String getTypeCode() {
+        return typeCode;
+    }
+
+    public void setTypeCode(String typeCode) {
+        this.typeCode = typeCode == null ? null : typeCode.trim();
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type == null ? null : type.trim();
+    }
+
+    public String getNameCode() {
+        return nameCode;
+    }
+
+    public void setNameCode(String nameCode) {
+        this.nameCode = nameCode == null ? null : nameCode.trim();
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public void setValue(String value) {
+        this.value = value == null ? null : value.trim();
+    }
+
+    public String getExpress() {
+        return express;
+    }
+
+    public void setExpress(String express) {
+        this.express = express == null ? null : express.trim();
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status == null ? null : status.trim();
+    }
+
+    public String getExpressDesc() {
+        return expressDesc;
+    }
+
+    public void setExpressDesc(String expressDesc) {
+        this.expressDesc = expressDesc == null ? null : expressDesc.trim();
+    }
+
+    public String getExpressType() {
+        return expressType;
+    }
+
+    public void setExpressType(String expressType) {
+        this.expressType = expressType == null ? null : expressType.trim();
+    }
+}
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUser.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUser.java
new file mode 100644
index 00000000..88401a25
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUser.java
@@ -0,0 +1,276 @@
+package com.infincash.statistics.risk.table;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+public class TUser {
+    private String id;
+
+    private String userId;
+
+    private String userName;
+
+    private String loginName;
+
+    private String password;
+
+    private String tranPassword;
+
+    private String phone;
+
+    private String creditRuleId;
+
+    private String imageUrl;
+
+    private BigDecimal score;
+
+    private BigDecimal borrowingLines;
+
+    private BigDecimal creditLines;
+
+    private String source;
+
+    private String userType;
+
+    private Integer errrorNumber;
+
+    private Integer tranPwdErrorNum;
+
+    private String explains;
+
+    private String isLocked;
+
+    private String isBlacklist;
+
+    private String inviteCode;
+
+    private String registerIp;
+
+    private Date registerTime;
+
+    private String lastLoginIp;
+
+    private Date lastLoginTime;
+
+    private Date updateTime;
+
+    private String email;
+
+    private Date creditTime;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id == null ? null : id.trim();
+    }
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId == null ? null : userId.trim();
+    }
+
+    public String getUserName() {
+        return userName;
+    }
+
+    public void setUserName(String userName) {
+        this.userName = userName == null ? null : userName.trim();
+    }
+
+    public String getLoginName() {
+        return loginName;
+    }
+
+    public void setLoginName(String loginName) {
+        this.loginName = loginName == null ? null : loginName.trim();
+    }
+
+    public String getPassword() {
+        return password;
+    }
+
+    public void setPassword(String password) {
+        this.password = password == null ? null : password.trim();
+    }
+
+    public String getTranPassword() {
+        return tranPassword;
+    }
+
+    public void setTranPassword(String tranPassword) {
+        this.tranPassword = tranPassword == null ? null : tranPassword.trim();
+    }
+
+    public String getPhone() {
+        return phone;
+    }
+
+    public void setPhone(String phone) {
+        this.phone = phone == null ? null : phone.trim();
+    }
+
+    public String getCreditRuleId() {
+        return creditRuleId;
+    }
+
+    public void setCreditRuleId(String creditRuleId) {
+        this.creditRuleId = creditRuleId == null ? null : creditRuleId.trim();
+    }
+
+    public String getImageUrl() {
+        return imageUrl;
+    }
+
+    public void setImageUrl(String imageUrl) {
+        this.imageUrl = imageUrl == null ? null : imageUrl.trim();
+    }
+
+    public BigDecimal getScore() {
+        return score;
+    }
+
+    public void setScore(BigDecimal score) {
+        this.score = score;
+    }
+
+    public BigDecimal getBorrowingLines() {
+        return borrowingLines;
+    }
+
+    public void setBorrowingLines(BigDecimal borrowingLines) {
+        this.borrowingLines = borrowingLines;
+    }
+
+    public BigDecimal getCreditLines() {
+        return creditLines;
+    }
+
+    public void setCreditLines(BigDecimal creditLines) {
+        this.creditLines = creditLines;
+    }
+
+    public String getSource() {
+        return source;
+    }
+
+    public void setSource(String source) {
+        this.source = source == null ? null : source.trim();
+    }
+
+    public String getUserType() {
+        return userType;
+    }
+
+    public void setUserType(String userType) {
+        this.userType = userType == null ? null : userType.trim();
+    }
+
+    public Integer getErrrorNumber() {
+        return errrorNumber;
+    }
+
+    public void setErrrorNumber(Integer errrorNumber) {
+        this.errrorNumber = errrorNumber;
+    }
+
+    public Integer getTranPwdErrorNum() {
+        return tranPwdErrorNum;
+    }
+
+    public void setTranPwdErrorNum(Integer tranPwdErrorNum) {
+        this.tranPwdErrorNum = tranPwdErrorNum;
+    }
+
+    public String getExplains() {
+        return explains;
+    }
+
+    public void setExplains(String explains) {
+        this.explains = explains == null ? null : explains.trim();
+    }
+
+    public String getIsLocked() {
+        return isLocked;
+    }
+
+    public void setIsLocked(String isLocked) {
+        this.isLocked = isLocked == null ? null : isLocked.trim();
+    }
+
+    public String getIsBlacklist() {
+        return isBlacklist;
+    }
+
+    public void setIsBlacklist(String isBlacklist) {
+        this.isBlacklist = isBlacklist == null ? null : isBlacklist.trim();
+    }
+
+    public String getInviteCode() {
+        return inviteCode;
+    }
+
+    public void setInviteCode(String inviteCode) {
+        this.inviteCode = inviteCode == null ? null : inviteCode.trim();
+    }
+
+    public String getRegisterIp() {
+        return registerIp;
+    }
+
+    public void setRegisterIp(String registerIp) {
+        this.registerIp = registerIp == null ? null : registerIp.trim();
+    }
+
+    public Date getRegisterTime() {
+        return registerTime;
+    }
+
+    public void setRegisterTime(Date registerTime) {
+        this.registerTime = registerTime;
+    }
+
+    public String getLastLoginIp() {
+        return lastLoginIp;
+    }
+
+    public void setLastLoginIp(String lastLoginIp) {
+        this.lastLoginIp = lastLoginIp == null ? null : lastLoginIp.trim();
+    }
+
+    public Date getLastLoginTime() {
+        return lastLoginTime;
+    }
+
+    public void setLastLoginTime(Date lastLoginTime) {
+        this.lastLoginTime = lastLoginTime;
+    }
+
+    public Date getUpdateTime() {
+        return updateTime;
+    }
+
+    public void setUpdateTime(Date updateTime) {
+        this.updateTime = updateTime;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email == null ? null : email.trim();
+    }
+
+    public Date getCreditTime() {
+        return creditTime;
+    }
+
+    public void setCreditTime(Date creditTime) {
+        this.creditTime = creditTime;
+    }
+}
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUserRisk.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUserRisk.java
index a7f4da6a..0be2ea9b 100644
--- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUserRisk.java
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUserRisk.java
@@ -1,5 +1,43 @@
 package com.infincash.statistics.risk.table;
 
 public class TUserRisk {
+    private String id;
 
-}
+    private String userId;
+
+    private String riskRuleId;
+
+    private String checkId;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id == null ? null : id.trim();
+    }
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId == null ? null : userId.trim();
+    }
+
+    public String getRiskRuleId() {
+        return riskRuleId;
+    }
+
+    public void setRiskRuleId(String riskRuleId) {
+        this.riskRuleId = riskRuleId == null ? null : riskRuleId.trim();
+    }
+
+    public String getCheckId() {
+        return checkId;
+    }
+
+    public void setCheckId(String checkId) {
+        this.checkId = checkId == null ? null : checkId.trim();
+    }
+}
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/generator/generatorConfig.xml b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/generator/generatorConfig.xml
new file mode 100644
index 00000000..d15527aa
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/generator/generatorConfig.xml
@@ -0,0 +1,62 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE generatorConfiguration
+        PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
+        "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
+<generatorConfiguration>
+    <!-- 数据库驱动:选择你的本地硬盘上面的数据库驱动包-->
+    <classPathEntry  location="C:\mysql-connector-java-5.1.44.jar"/>
+    <context id="DB2Tables"  targetRuntime="MyBatis3">
+        <commentGenerator>
+            <property name="suppressDate" value="true"/>
+            <!-- 是否去除自动生成的注释 true：是 ： false:否 -->
+            <property name="suppressAllComments" value="true"/>
+        </commentGenerator>
+        <!--数据库链接URL，用户名、密码 -->
+        <jdbcConnection driverClass="com.mysql.jdbc.Driver" connectionURL="jdbc:mysql://192.168.0.165:3306/microfinance" userId="jobopr" password="jobopr666">
+        </jdbcConnection>
+        <javaTypeResolver>
+            <property name="forceBigDecimals" value="false"/>
+        </javaTypeResolver>
+        <!-- 生成模型的包名和位置-->
+        <javaModelGenerator targetPackage="com.infincash.statistics.risk.table" targetProject="src/main/java">
+            <property name="enableSubPackages" value="true"/>
+            <property name="trimStrings" value="true"/>
+        </javaModelGenerator>
+        <!-- 生成映射文件的包名和位置-->
+        <sqlMapGenerator targetPackage="main.resources.mapping" targetProject="src">
+            <property name="enableSubPackages" value="true"/>
+        </sqlMapGenerator>
+        <!-- 生成DAO的包名和位置-->
+        <javaClientGenerator type="XMLMAPPER" targetPackage="com.infincash.statistics.risk.mapper" targetProject="src/main/java">
+            <property name="enableSubPackages" value="true"/>
+        </javaClientGenerator>
+        <!-- 要生成的表 tableName是数据库中的表名或视图名 domainObjectName是实体类名-->
+        <table 
+            tableName="t_user" 
+            domainObjectName="TUser" 
+            enableCountByExample="false" 
+            enableUpdateByExample="false" 
+            enableDeleteByExample="false" 
+            enableSelectByExample="false" 
+            selectByExampleQueryId="false">
+        </table>
+        <table 
+            tableName="t_risk_rule" 
+            domainObjectName="TRiskRule" 
+            enableCountByExample="false" 
+            enableUpdateByExample="false" 
+            enableDeleteByExample="false" 
+            enableSelectByExample="false" 
+            selectByExampleQueryId="false">
+        </table>
+        <table 
+            tableName="t_user_risk" 
+            domainObjectName="TUserRisk" 
+            enableCountByExample="false" 
+            enableUpdateByExample="false" 
+            enableDeleteByExample="false" 
+            enableSelectByExample="false" 
+            selectByExampleQueryId="false">
+        </table>
+    </context>
+</generatorConfiguration>
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TRiskRuleMapper.xml b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TRiskRuleMapper.xml
new file mode 100644
index 00000000..189e6315
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TRiskRuleMapper.xml
@@ -0,0 +1,278 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.infincash.statistics.risk.mapper.TRiskRuleMapper">
+  <resultMap id="BaseResultMap" type="com.infincash.statistics.risk.table.TRiskRule">
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="type_code" jdbcType="VARCHAR" property="typeCode" />
+    <result column="type" jdbcType="VARCHAR" property="type" />
+    <result column="name_code" jdbcType="VARCHAR" property="nameCode" />
+    <result column="value" jdbcType="VARCHAR" property="value" />
+    <result column="express" jdbcType="VARCHAR" property="express" />
+    <result column="status" jdbcType="CHAR" property="status" />
+    <result column="express_desc" jdbcType="VARCHAR" property="expressDesc" />
+    <result column="express_type" jdbcType="CHAR" property="expressType" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, type_code, type, name_code, value, express, status, express_desc, express_type
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from t_risk_rule
+    where id = #{id,jdbcType=VARCHAR}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
+    delete from t_risk_rule
+    where id = #{id,jdbcType=VARCHAR}
+  </delete>
+  <insert id="insert" parameterType="com.infincash.statistics.risk.table.TRiskRule">
+    insert into t_risk_rule (id, type_code, type, 
+      name_code, value, express, 
+      status, express_desc, express_type
+      )
+    values (#{id,jdbcType=VARCHAR}, #{typeCode,jdbcType=VARCHAR}, #{type,jdbcType=VARCHAR}, 
+      #{nameCode,jdbcType=VARCHAR}, #{value,jdbcType=VARCHAR}, #{express,jdbcType=VARCHAR}, 
+      #{status,jdbcType=CHAR}, #{expressDesc,jdbcType=VARCHAR}, #{expressType,jdbcType=CHAR}
+      )
+  </insert>
+  <insert id="insertSelective" parameterType="com.infincash.statistics.risk.table.TRiskRule">
+    insert into t_risk_rule
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="typeCode != null">
+        type_code,
+      </if>
+      <if test="type != null">
+        type,
+      </if>
+      <if test="nameCode != null">
+        name_code,
+      </if>
+      <if test="value != null">
+        value,
+      </if>
+      <if test="express != null">
+        express,
+      </if>
+      <if test="status != null">
+        status,
+      </if>
+      <if test="expressDesc != null">
+        express_desc,
+      </if>
+      <if test="expressType != null">
+        express_type,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=VARCHAR},
+      </if>
+      <if test="typeCode != null">
+        #{typeCode,jdbcType=VARCHAR},
+      </if>
+      <if test="type != null">
+        #{type,jdbcType=VARCHAR},
+      </if>
+      <if test="nameCode != null">
+        #{nameCode,jdbcType=VARCHAR},
+      </if>
+      <if test="value != null">
+        #{value,jdbcType=VARCHAR},
+      </if>
+      <if test="express != null">
+        #{express,jdbcType=VARCHAR},
+      </if>
+      <if test="status != null">
+        #{status,jdbcType=CHAR},
+      </if>
+      <if test="expressDesc != null">
+        #{expressDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="expressType != null">
+        #{expressType,jdbcType=CHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.infincash.statistics.risk.table.TRiskRule">
+    update t_risk_rule
+    <set>
+      <if test="typeCode != null">
+        type_code = #{typeCode,jdbcType=VARCHAR},
+      </if>
+      <if test="type != null">
+        type = #{type,jdbcType=VARCHAR},
+      </if>
+      <if test="nameCode != null">
+        name_code = #{nameCode,jdbcType=VARCHAR},
+      </if>
+      <if test="value != null">
+        value = #{value,jdbcType=VARCHAR},
+      </if>
+      <if test="express != null">
+        express = #{express,jdbcType=VARCHAR},
+      </if>
+      <if test="status != null">
+        status = #{status,jdbcType=CHAR},
+      </if>
+      <if test="expressDesc != null">
+        express_desc = #{expressDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="expressType != null">
+        express_type = #{expressType,jdbcType=CHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.infincash.statistics.risk.table.TRiskRule">
+    update t_risk_rule
+    set type_code = #{typeCode,jdbcType=VARCHAR},
+      type = #{type,jdbcType=VARCHAR},
+      name_code = #{nameCode,jdbcType=VARCHAR},
+      value = #{value,jdbcType=VARCHAR},
+      express = #{express,jdbcType=VARCHAR},
+      status = #{status,jdbcType=CHAR},
+      express_desc = #{expressDesc,jdbcType=VARCHAR},
+      express_type = #{expressType,jdbcType=CHAR}
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <resultMap id="BaseResultMap" type="com.infincash.statistics.risk.table.TRiskRule">
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="type_code" jdbcType="VARCHAR" property="typeCode" />
+    <result column="type" jdbcType="VARCHAR" property="type" />
+    <result column="name_code" jdbcType="VARCHAR" property="nameCode" />
+    <result column="value" jdbcType="VARCHAR" property="value" />
+    <result column="express" jdbcType="VARCHAR" property="express" />
+    <result column="status" jdbcType="CHAR" property="status" />
+    <result column="express_desc" jdbcType="VARCHAR" property="expressDesc" />
+    <result column="express_type" jdbcType="CHAR" property="expressType" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, type_code, type, name_code, value, express, status, express_desc, express_type
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from t_risk_rule
+    where id = #{id,jdbcType=VARCHAR}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
+    delete from t_risk_rule
+    where id = #{id,jdbcType=VARCHAR}
+  </delete>
+  <insert id="insert" parameterType="com.infincash.statistics.risk.table.TRiskRule">
+    insert into t_risk_rule (id, type_code, type, 
+      name_code, value, express, 
+      status, express_desc, express_type
+      )
+    values (#{id,jdbcType=VARCHAR}, #{typeCode,jdbcType=VARCHAR}, #{type,jdbcType=VARCHAR}, 
+      #{nameCode,jdbcType=VARCHAR}, #{value,jdbcType=VARCHAR}, #{express,jdbcType=VARCHAR}, 
+      #{status,jdbcType=CHAR}, #{expressDesc,jdbcType=VARCHAR}, #{expressType,jdbcType=CHAR}
+      )
+  </insert>
+  <insert id="insertSelective" parameterType="com.infincash.statistics.risk.table.TRiskRule">
+    insert into t_risk_rule
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="typeCode != null">
+        type_code,
+      </if>
+      <if test="type != null">
+        type,
+      </if>
+      <if test="nameCode != null">
+        name_code,
+      </if>
+      <if test="value != null">
+        value,
+      </if>
+      <if test="express != null">
+        express,
+      </if>
+      <if test="status != null">
+        status,
+      </if>
+      <if test="expressDesc != null">
+        express_desc,
+      </if>
+      <if test="expressType != null">
+        express_type,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=VARCHAR},
+      </if>
+      <if test="typeCode != null">
+        #{typeCode,jdbcType=VARCHAR},
+      </if>
+      <if test="type != null">
+        #{type,jdbcType=VARCHAR},
+      </if>
+      <if test="nameCode != null">
+        #{nameCode,jdbcType=VARCHAR},
+      </if>
+      <if test="value != null">
+        #{value,jdbcType=VARCHAR},
+      </if>
+      <if test="express != null">
+        #{express,jdbcType=VARCHAR},
+      </if>
+      <if test="status != null">
+        #{status,jdbcType=CHAR},
+      </if>
+      <if test="expressDesc != null">
+        #{expressDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="expressType != null">
+        #{expressType,jdbcType=CHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.infincash.statistics.risk.table.TRiskRule">
+    update t_risk_rule
+    <set>
+      <if test="typeCode != null">
+        type_code = #{typeCode,jdbcType=VARCHAR},
+      </if>
+      <if test="type != null">
+        type = #{type,jdbcType=VARCHAR},
+      </if>
+      <if test="nameCode != null">
+        name_code = #{nameCode,jdbcType=VARCHAR},
+      </if>
+      <if test="value != null">
+        value = #{value,jdbcType=VARCHAR},
+      </if>
+      <if test="express != null">
+        express = #{express,jdbcType=VARCHAR},
+      </if>
+      <if test="status != null">
+        status = #{status,jdbcType=CHAR},
+      </if>
+      <if test="expressDesc != null">
+        express_desc = #{expressDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="expressType != null">
+        express_type = #{expressType,jdbcType=CHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.infincash.statistics.risk.table.TRiskRule">
+    update t_risk_rule
+    set type_code = #{typeCode,jdbcType=VARCHAR},
+      type = #{type,jdbcType=VARCHAR},
+      name_code = #{nameCode,jdbcType=VARCHAR},
+      value = #{value,jdbcType=VARCHAR},
+      express = #{express,jdbcType=VARCHAR},
+      status = #{status,jdbcType=CHAR},
+      express_desc = #{expressDesc,jdbcType=VARCHAR},
+      express_type = #{expressType,jdbcType=CHAR}
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+</mapper>
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserMapper.xml b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserMapper.xml
new file mode 100644
index 00000000..bbec7fa2
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserMapper.xml
@@ -0,0 +1,704 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.infincash.statistics.risk.mapper.TUserMapper">
+  <resultMap id="BaseResultMap" type="com.infincash.statistics.risk.table.TUser">
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="user_id" jdbcType="VARCHAR" property="userId" />
+    <result column="user_name" jdbcType="VARCHAR" property="userName" />
+    <result column="login_name" jdbcType="VARCHAR" property="loginName" />
+    <result column="password" jdbcType="VARCHAR" property="password" />
+    <result column="tran_password" jdbcType="VARCHAR" property="tranPassword" />
+    <result column="phone" jdbcType="VARCHAR" property="phone" />
+    <result column="credit_rule_id" jdbcType="VARCHAR" property="creditRuleId" />
+    <result column="image_url" jdbcType="VARCHAR" property="imageUrl" />
+    <result column="score" jdbcType="DECIMAL" property="score" />
+    <result column="borrowing_lines" jdbcType="DECIMAL" property="borrowingLines" />
+    <result column="credit_lines" jdbcType="DECIMAL" property="creditLines" />
+    <result column="source" jdbcType="CHAR" property="source" />
+    <result column="user_type" jdbcType="CHAR" property="userType" />
+    <result column="errror_number" jdbcType="INTEGER" property="errrorNumber" />
+    <result column="tran_pwd_error_num" jdbcType="INTEGER" property="tranPwdErrorNum" />
+    <result column="explains" jdbcType="VARCHAR" property="explains" />
+    <result column="is_locked" jdbcType="CHAR" property="isLocked" />
+    <result column="is_blacklist" jdbcType="CHAR" property="isBlacklist" />
+    <result column="invite_code" jdbcType="VARCHAR" property="inviteCode" />
+    <result column="register_ip" jdbcType="VARCHAR" property="registerIp" />
+    <result column="register_time" jdbcType="TIMESTAMP" property="registerTime" />
+    <result column="last_login_ip" jdbcType="VARCHAR" property="lastLoginIp" />
+    <result column="last_login_time" jdbcType="TIMESTAMP" property="lastLoginTime" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="email" jdbcType="VARCHAR" property="email" />
+    <result column="credit_time" jdbcType="TIMESTAMP" property="creditTime" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, user_id, user_name, login_name, password, tran_password, phone, credit_rule_id, 
+    image_url, score, borrowing_lines, credit_lines, source, user_type, errror_number, 
+    tran_pwd_error_num, explains, is_locked, is_blacklist, invite_code, register_ip, 
+    register_time, last_login_ip, last_login_time, update_time, email, credit_time
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from t_user
+    where id = #{id,jdbcType=VARCHAR}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
+    delete from t_user
+    where id = #{id,jdbcType=VARCHAR}
+  </delete>
+  <insert id="insert" parameterType="com.infincash.statistics.risk.table.TUser">
+    insert into t_user (id, user_id, user_name, 
+      login_name, password, tran_password, 
+      phone, credit_rule_id, image_url, 
+      score, borrowing_lines, credit_lines, 
+      source, user_type, errror_number, 
+      tran_pwd_error_num, explains, is_locked, 
+      is_blacklist, invite_code, register_ip, 
+      register_time, last_login_ip, last_login_time, 
+      update_time, email, credit_time
+      )
+    values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{userName,jdbcType=VARCHAR}, 
+      #{loginName,jdbcType=VARCHAR}, #{password,jdbcType=VARCHAR}, #{tranPassword,jdbcType=VARCHAR}, 
+      #{phone,jdbcType=VARCHAR}, #{creditRuleId,jdbcType=VARCHAR}, #{imageUrl,jdbcType=VARCHAR}, 
+      #{score,jdbcType=DECIMAL}, #{borrowingLines,jdbcType=DECIMAL}, #{creditLines,jdbcType=DECIMAL}, 
+      #{source,jdbcType=CHAR}, #{userType,jdbcType=CHAR}, #{errrorNumber,jdbcType=INTEGER}, 
+      #{tranPwdErrorNum,jdbcType=INTEGER}, #{explains,jdbcType=VARCHAR}, #{isLocked,jdbcType=CHAR}, 
+      #{isBlacklist,jdbcType=CHAR}, #{inviteCode,jdbcType=VARCHAR}, #{registerIp,jdbcType=VARCHAR}, 
+      #{registerTime,jdbcType=TIMESTAMP}, #{lastLoginIp,jdbcType=VARCHAR}, #{lastLoginTime,jdbcType=TIMESTAMP}, 
+      #{updateTime,jdbcType=TIMESTAMP}, #{email,jdbcType=VARCHAR}, #{creditTime,jdbcType=TIMESTAMP}
+      )
+  </insert>
+  <insert id="insertSelective" parameterType="com.infincash.statistics.risk.table.TUser">
+    insert into t_user
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="userId != null">
+        user_id,
+      </if>
+      <if test="userName != null">
+        user_name,
+      </if>
+      <if test="loginName != null">
+        login_name,
+      </if>
+      <if test="password != null">
+        password,
+      </if>
+      <if test="tranPassword != null">
+        tran_password,
+      </if>
+      <if test="phone != null">
+        phone,
+      </if>
+      <if test="creditRuleId != null">
+        credit_rule_id,
+      </if>
+      <if test="imageUrl != null">
+        image_url,
+      </if>
+      <if test="score != null">
+        score,
+      </if>
+      <if test="borrowingLines != null">
+        borrowing_lines,
+      </if>
+      <if test="creditLines != null">
+        credit_lines,
+      </if>
+      <if test="source != null">
+        source,
+      </if>
+      <if test="userType != null">
+        user_type,
+      </if>
+      <if test="errrorNumber != null">
+        errror_number,
+      </if>
+      <if test="tranPwdErrorNum != null">
+        tran_pwd_error_num,
+      </if>
+      <if test="explains != null">
+        explains,
+      </if>
+      <if test="isLocked != null">
+        is_locked,
+      </if>
+      <if test="isBlacklist != null">
+        is_blacklist,
+      </if>
+      <if test="inviteCode != null">
+        invite_code,
+      </if>
+      <if test="registerIp != null">
+        register_ip,
+      </if>
+      <if test="registerTime != null">
+        register_time,
+      </if>
+      <if test="lastLoginIp != null">
+        last_login_ip,
+      </if>
+      <if test="lastLoginTime != null">
+        last_login_time,
+      </if>
+      <if test="updateTime != null">
+        update_time,
+      </if>
+      <if test="email != null">
+        email,
+      </if>
+      <if test="creditTime != null">
+        credit_time,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=VARCHAR},
+      </if>
+      <if test="userId != null">
+        #{userId,jdbcType=VARCHAR},
+      </if>
+      <if test="userName != null">
+        #{userName,jdbcType=VARCHAR},
+      </if>
+      <if test="loginName != null">
+        #{loginName,jdbcType=VARCHAR},
+      </if>
+      <if test="password != null">
+        #{password,jdbcType=VARCHAR},
+      </if>
+      <if test="tranPassword != null">
+        #{tranPassword,jdbcType=VARCHAR},
+      </if>
+      <if test="phone != null">
+        #{phone,jdbcType=VARCHAR},
+      </if>
+      <if test="creditRuleId != null">
+        #{creditRuleId,jdbcType=VARCHAR},
+      </if>
+      <if test="imageUrl != null">
+        #{imageUrl,jdbcType=VARCHAR},
+      </if>
+      <if test="score != null">
+        #{score,jdbcType=DECIMAL},
+      </if>
+      <if test="borrowingLines != null">
+        #{borrowingLines,jdbcType=DECIMAL},
+      </if>
+      <if test="creditLines != null">
+        #{creditLines,jdbcType=DECIMAL},
+      </if>
+      <if test="source != null">
+        #{source,jdbcType=CHAR},
+      </if>
+      <if test="userType != null">
+        #{userType,jdbcType=CHAR},
+      </if>
+      <if test="errrorNumber != null">
+        #{errrorNumber,jdbcType=INTEGER},
+      </if>
+      <if test="tranPwdErrorNum != null">
+        #{tranPwdErrorNum,jdbcType=INTEGER},
+      </if>
+      <if test="explains != null">
+        #{explains,jdbcType=VARCHAR},
+      </if>
+      <if test="isLocked != null">
+        #{isLocked,jdbcType=CHAR},
+      </if>
+      <if test="isBlacklist != null">
+        #{isBlacklist,jdbcType=CHAR},
+      </if>
+      <if test="inviteCode != null">
+        #{inviteCode,jdbcType=VARCHAR},
+      </if>
+      <if test="registerIp != null">
+        #{registerIp,jdbcType=VARCHAR},
+      </if>
+      <if test="registerTime != null">
+        #{registerTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="lastLoginIp != null">
+        #{lastLoginIp,jdbcType=VARCHAR},
+      </if>
+      <if test="lastLoginTime != null">
+        #{lastLoginTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateTime != null">
+        #{updateTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="email != null">
+        #{email,jdbcType=VARCHAR},
+      </if>
+      <if test="creditTime != null">
+        #{creditTime,jdbcType=TIMESTAMP},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.infincash.statistics.risk.table.TUser">
+    update t_user
+    <set>
+      <if test="userId != null">
+        user_id = #{userId,jdbcType=VARCHAR},
+      </if>
+      <if test="userName != null">
+        user_name = #{userName,jdbcType=VARCHAR},
+      </if>
+      <if test="loginName != null">
+        login_name = #{loginName,jdbcType=VARCHAR},
+      </if>
+      <if test="password != null">
+        password = #{password,jdbcType=VARCHAR},
+      </if>
+      <if test="tranPassword != null">
+        tran_password = #{tranPassword,jdbcType=VARCHAR},
+      </if>
+      <if test="phone != null">
+        phone = #{phone,jdbcType=VARCHAR},
+      </if>
+      <if test="creditRuleId != null">
+        credit_rule_id = #{creditRuleId,jdbcType=VARCHAR},
+      </if>
+      <if test="imageUrl != null">
+        image_url = #{imageUrl,jdbcType=VARCHAR},
+      </if>
+      <if test="score != null">
+        score = #{score,jdbcType=DECIMAL},
+      </if>
+      <if test="borrowingLines != null">
+        borrowing_lines = #{borrowingLines,jdbcType=DECIMAL},
+      </if>
+      <if test="creditLines != null">
+        credit_lines = #{creditLines,jdbcType=DECIMAL},
+      </if>
+      <if test="source != null">
+        source = #{source,jdbcType=CHAR},
+      </if>
+      <if test="userType != null">
+        user_type = #{userType,jdbcType=CHAR},
+      </if>
+      <if test="errrorNumber != null">
+        errror_number = #{errrorNumber,jdbcType=INTEGER},
+      </if>
+      <if test="tranPwdErrorNum != null">
+        tran_pwd_error_num = #{tranPwdErrorNum,jdbcType=INTEGER},
+      </if>
+      <if test="explains != null">
+        explains = #{explains,jdbcType=VARCHAR},
+      </if>
+      <if test="isLocked != null">
+        is_locked = #{isLocked,jdbcType=CHAR},
+      </if>
+      <if test="isBlacklist != null">
+        is_blacklist = #{isBlacklist,jdbcType=CHAR},
+      </if>
+      <if test="inviteCode != null">
+        invite_code = #{inviteCode,jdbcType=VARCHAR},
+      </if>
+      <if test="registerIp != null">
+        register_ip = #{registerIp,jdbcType=VARCHAR},
+      </if>
+      <if test="registerTime != null">
+        register_time = #{registerTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="lastLoginIp != null">
+        last_login_ip = #{lastLoginIp,jdbcType=VARCHAR},
+      </if>
+      <if test="lastLoginTime != null">
+        last_login_time = #{lastLoginTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateTime != null">
+        update_time = #{updateTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="email != null">
+        email = #{email,jdbcType=VARCHAR},
+      </if>
+      <if test="creditTime != null">
+        credit_time = #{creditTime,jdbcType=TIMESTAMP},
+      </if>
+    </set>
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.infincash.statistics.risk.table.TUser">
+    update t_user
+    set user_id = #{userId,jdbcType=VARCHAR},
+      user_name = #{userName,jdbcType=VARCHAR},
+      login_name = #{loginName,jdbcType=VARCHAR},
+      password = #{password,jdbcType=VARCHAR},
+      tran_password = #{tranPassword,jdbcType=VARCHAR},
+      phone = #{phone,jdbcType=VARCHAR},
+      credit_rule_id = #{creditRuleId,jdbcType=VARCHAR},
+      image_url = #{imageUrl,jdbcType=VARCHAR},
+      score = #{score,jdbcType=DECIMAL},
+      borrowing_lines = #{borrowingLines,jdbcType=DECIMAL},
+      credit_lines = #{creditLines,jdbcType=DECIMAL},
+      source = #{source,jdbcType=CHAR},
+      user_type = #{userType,jdbcType=CHAR},
+      errror_number = #{errrorNumber,jdbcType=INTEGER},
+      tran_pwd_error_num = #{tranPwdErrorNum,jdbcType=INTEGER},
+      explains = #{explains,jdbcType=VARCHAR},
+      is_locked = #{isLocked,jdbcType=CHAR},
+      is_blacklist = #{isBlacklist,jdbcType=CHAR},
+      invite_code = #{inviteCode,jdbcType=VARCHAR},
+      register_ip = #{registerIp,jdbcType=VARCHAR},
+      register_time = #{registerTime,jdbcType=TIMESTAMP},
+      last_login_ip = #{lastLoginIp,jdbcType=VARCHAR},
+      last_login_time = #{lastLoginTime,jdbcType=TIMESTAMP},
+      update_time = #{updateTime,jdbcType=TIMESTAMP},
+      email = #{email,jdbcType=VARCHAR},
+      credit_time = #{creditTime,jdbcType=TIMESTAMP}
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <resultMap id="BaseResultMap" type="com.infincash.statistics.risk.table.TUser">
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="user_id" jdbcType="VARCHAR" property="userId" />
+    <result column="user_name" jdbcType="VARCHAR" property="userName" />
+    <result column="login_name" jdbcType="VARCHAR" property="loginName" />
+    <result column="password" jdbcType="VARCHAR" property="password" />
+    <result column="tran_password" jdbcType="VARCHAR" property="tranPassword" />
+    <result column="phone" jdbcType="VARCHAR" property="phone" />
+    <result column="credit_rule_id" jdbcType="VARCHAR" property="creditRuleId" />
+    <result column="image_url" jdbcType="VARCHAR" property="imageUrl" />
+    <result column="score" jdbcType="DECIMAL" property="score" />
+    <result column="borrowing_lines" jdbcType="DECIMAL" property="borrowingLines" />
+    <result column="credit_lines" jdbcType="DECIMAL" property="creditLines" />
+    <result column="source" jdbcType="CHAR" property="source" />
+    <result column="user_type" jdbcType="CHAR" property="userType" />
+    <result column="errror_number" jdbcType="INTEGER" property="errrorNumber" />
+    <result column="tran_pwd_error_num" jdbcType="INTEGER" property="tranPwdErrorNum" />
+    <result column="explains" jdbcType="VARCHAR" property="explains" />
+    <result column="is_locked" jdbcType="CHAR" property="isLocked" />
+    <result column="is_blacklist" jdbcType="CHAR" property="isBlacklist" />
+    <result column="invite_code" jdbcType="VARCHAR" property="inviteCode" />
+    <result column="register_ip" jdbcType="VARCHAR" property="registerIp" />
+    <result column="register_time" jdbcType="TIMESTAMP" property="registerTime" />
+    <result column="last_login_ip" jdbcType="VARCHAR" property="lastLoginIp" />
+    <result column="last_login_time" jdbcType="TIMESTAMP" property="lastLoginTime" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="email" jdbcType="VARCHAR" property="email" />
+    <result column="credit_time" jdbcType="TIMESTAMP" property="creditTime" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, user_id, user_name, login_name, password, tran_password, phone, credit_rule_id, 
+    image_url, score, borrowing_lines, credit_lines, source, user_type, errror_number, 
+    tran_pwd_error_num, explains, is_locked, is_blacklist, invite_code, register_ip, 
+    register_time, last_login_ip, last_login_time, update_time, email, credit_time
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from t_user
+    where id = #{id,jdbcType=VARCHAR}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
+    delete from t_user
+    where id = #{id,jdbcType=VARCHAR}
+  </delete>
+  <insert id="insert" parameterType="com.infincash.statistics.risk.table.TUser">
+    insert into t_user (id, user_id, user_name, 
+      login_name, password, tran_password, 
+      phone, credit_rule_id, image_url, 
+      score, borrowing_lines, credit_lines, 
+      source, user_type, errror_number, 
+      tran_pwd_error_num, explains, is_locked, 
+      is_blacklist, invite_code, register_ip, 
+      register_time, last_login_ip, last_login_time, 
+      update_time, email, credit_time
+      )
+    values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{userName,jdbcType=VARCHAR}, 
+      #{loginName,jdbcType=VARCHAR}, #{password,jdbcType=VARCHAR}, #{tranPassword,jdbcType=VARCHAR}, 
+      #{phone,jdbcType=VARCHAR}, #{creditRuleId,jdbcType=VARCHAR}, #{imageUrl,jdbcType=VARCHAR}, 
+      #{score,jdbcType=DECIMAL}, #{borrowingLines,jdbcType=DECIMAL}, #{creditLines,jdbcType=DECIMAL}, 
+      #{source,jdbcType=CHAR}, #{userType,jdbcType=CHAR}, #{errrorNumber,jdbcType=INTEGER}, 
+      #{tranPwdErrorNum,jdbcType=INTEGER}, #{explains,jdbcType=VARCHAR}, #{isLocked,jdbcType=CHAR}, 
+      #{isBlacklist,jdbcType=CHAR}, #{inviteCode,jdbcType=VARCHAR}, #{registerIp,jdbcType=VARCHAR}, 
+      #{registerTime,jdbcType=TIMESTAMP}, #{lastLoginIp,jdbcType=VARCHAR}, #{lastLoginTime,jdbcType=TIMESTAMP}, 
+      #{updateTime,jdbcType=TIMESTAMP}, #{email,jdbcType=VARCHAR}, #{creditTime,jdbcType=TIMESTAMP}
+      )
+  </insert>
+  <insert id="insertSelective" parameterType="com.infincash.statistics.risk.table.TUser">
+    insert into t_user
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="userId != null">
+        user_id,
+      </if>
+      <if test="userName != null">
+        user_name,
+      </if>
+      <if test="loginName != null">
+        login_name,
+      </if>
+      <if test="password != null">
+        password,
+      </if>
+      <if test="tranPassword != null">
+        tran_password,
+      </if>
+      <if test="phone != null">
+        phone,
+      </if>
+      <if test="creditRuleId != null">
+        credit_rule_id,
+      </if>
+      <if test="imageUrl != null">
+        image_url,
+      </if>
+      <if test="score != null">
+        score,
+      </if>
+      <if test="borrowingLines != null">
+        borrowing_lines,
+      </if>
+      <if test="creditLines != null">
+        credit_lines,
+      </if>
+      <if test="source != null">
+        source,
+      </if>
+      <if test="userType != null">
+        user_type,
+      </if>
+      <if test="errrorNumber != null">
+        errror_number,
+      </if>
+      <if test="tranPwdErrorNum != null">
+        tran_pwd_error_num,
+      </if>
+      <if test="explains != null">
+        explains,
+      </if>
+      <if test="isLocked != null">
+        is_locked,
+      </if>
+      <if test="isBlacklist != null">
+        is_blacklist,
+      </if>
+      <if test="inviteCode != null">
+        invite_code,
+      </if>
+      <if test="registerIp != null">
+        register_ip,
+      </if>
+      <if test="registerTime != null">
+        register_time,
+      </if>
+      <if test="lastLoginIp != null">
+        last_login_ip,
+      </if>
+      <if test="lastLoginTime != null">
+        last_login_time,
+      </if>
+      <if test="updateTime != null">
+        update_time,
+      </if>
+      <if test="email != null">
+        email,
+      </if>
+      <if test="creditTime != null">
+        credit_time,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=VARCHAR},
+      </if>
+      <if test="userId != null">
+        #{userId,jdbcType=VARCHAR},
+      </if>
+      <if test="userName != null">
+        #{userName,jdbcType=VARCHAR},
+      </if>
+      <if test="loginName != null">
+        #{loginName,jdbcType=VARCHAR},
+      </if>
+      <if test="password != null">
+        #{password,jdbcType=VARCHAR},
+      </if>
+      <if test="tranPassword != null">
+        #{tranPassword,jdbcType=VARCHAR},
+      </if>
+      <if test="phone != null">
+        #{phone,jdbcType=VARCHAR},
+      </if>
+      <if test="creditRuleId != null">
+        #{creditRuleId,jdbcType=VARCHAR},
+      </if>
+      <if test="imageUrl != null">
+        #{imageUrl,jdbcType=VARCHAR},
+      </if>
+      <if test="score != null">
+        #{score,jdbcType=DECIMAL},
+      </if>
+      <if test="borrowingLines != null">
+        #{borrowingLines,jdbcType=DECIMAL},
+      </if>
+      <if test="creditLines != null">
+        #{creditLines,jdbcType=DECIMAL},
+      </if>
+      <if test="source != null">
+        #{source,jdbcType=CHAR},
+      </if>
+      <if test="userType != null">
+        #{userType,jdbcType=CHAR},
+      </if>
+      <if test="errrorNumber != null">
+        #{errrorNumber,jdbcType=INTEGER},
+      </if>
+      <if test="tranPwdErrorNum != null">
+        #{tranPwdErrorNum,jdbcType=INTEGER},
+      </if>
+      <if test="explains != null">
+        #{explains,jdbcType=VARCHAR},
+      </if>
+      <if test="isLocked != null">
+        #{isLocked,jdbcType=CHAR},
+      </if>
+      <if test="isBlacklist != null">
+        #{isBlacklist,jdbcType=CHAR},
+      </if>
+      <if test="inviteCode != null">
+        #{inviteCode,jdbcType=VARCHAR},
+      </if>
+      <if test="registerIp != null">
+        #{registerIp,jdbcType=VARCHAR},
+      </if>
+      <if test="registerTime != null">
+        #{registerTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="lastLoginIp != null">
+        #{lastLoginIp,jdbcType=VARCHAR},
+      </if>
+      <if test="lastLoginTime != null">
+        #{lastLoginTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateTime != null">
+        #{updateTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="email != null">
+        #{email,jdbcType=VARCHAR},
+      </if>
+      <if test="creditTime != null">
+        #{creditTime,jdbcType=TIMESTAMP},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.infincash.statistics.risk.table.TUser">
+    update t_user
+    <set>
+      <if test="userId != null">
+        user_id = #{userId,jdbcType=VARCHAR},
+      </if>
+      <if test="userName != null">
+        user_name = #{userName,jdbcType=VARCHAR},
+      </if>
+      <if test="loginName != null">
+        login_name = #{loginName,jdbcType=VARCHAR},
+      </if>
+      <if test="password != null">
+        password = #{password,jdbcType=VARCHAR},
+      </if>
+      <if test="tranPassword != null">
+        tran_password = #{tranPassword,jdbcType=VARCHAR},
+      </if>
+      <if test="phone != null">
+        phone = #{phone,jdbcType=VARCHAR},
+      </if>
+      <if test="creditRuleId != null">
+        credit_rule_id = #{creditRuleId,jdbcType=VARCHAR},
+      </if>
+      <if test="imageUrl != null">
+        image_url = #{imageUrl,jdbcType=VARCHAR},
+      </if>
+      <if test="score != null">
+        score = #{score,jdbcType=DECIMAL},
+      </if>
+      <if test="borrowingLines != null">
+        borrowing_lines = #{borrowingLines,jdbcType=DECIMAL},
+      </if>
+      <if test="creditLines != null">
+        credit_lines = #{creditLines,jdbcType=DECIMAL},
+      </if>
+      <if test="source != null">
+        source = #{source,jdbcType=CHAR},
+      </if>
+      <if test="userType != null">
+        user_type = #{userType,jdbcType=CHAR},
+      </if>
+      <if test="errrorNumber != null">
+        errror_number = #{errrorNumber,jdbcType=INTEGER},
+      </if>
+      <if test="tranPwdErrorNum != null">
+        tran_pwd_error_num = #{tranPwdErrorNum,jdbcType=INTEGER},
+      </if>
+      <if test="explains != null">
+        explains = #{explains,jdbcType=VARCHAR},
+      </if>
+      <if test="isLocked != null">
+        is_locked = #{isLocked,jdbcType=CHAR},
+      </if>
+      <if test="isBlacklist != null">
+        is_blacklist = #{isBlacklist,jdbcType=CHAR},
+      </if>
+      <if test="inviteCode != null">
+        invite_code = #{inviteCode,jdbcType=VARCHAR},
+      </if>
+      <if test="registerIp != null">
+        register_ip = #{registerIp,jdbcType=VARCHAR},
+      </if>
+      <if test="registerTime != null">
+        register_time = #{registerTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="lastLoginIp != null">
+        last_login_ip = #{lastLoginIp,jdbcType=VARCHAR},
+      </if>
+      <if test="lastLoginTime != null">
+        last_login_time = #{lastLoginTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="updateTime != null">
+        update_time = #{updateTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="email != null">
+        email = #{email,jdbcType=VARCHAR},
+      </if>
+      <if test="creditTime != null">
+        credit_time = #{creditTime,jdbcType=TIMESTAMP},
+      </if>
+    </set>
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.infincash.statistics.risk.table.TUser">
+    update t_user
+    set user_id = #{userId,jdbcType=VARCHAR},
+      user_name = #{userName,jdbcType=VARCHAR},
+      login_name = #{loginName,jdbcType=VARCHAR},
+      password = #{password,jdbcType=VARCHAR},
+      tran_password = #{tranPassword,jdbcType=VARCHAR},
+      phone = #{phone,jdbcType=VARCHAR},
+      credit_rule_id = #{creditRuleId,jdbcType=VARCHAR},
+      image_url = #{imageUrl,jdbcType=VARCHAR},
+      score = #{score,jdbcType=DECIMAL},
+      borrowing_lines = #{borrowingLines,jdbcType=DECIMAL},
+      credit_lines = #{creditLines,jdbcType=DECIMAL},
+      source = #{source,jdbcType=CHAR},
+      user_type = #{userType,jdbcType=CHAR},
+      errror_number = #{errrorNumber,jdbcType=INTEGER},
+      tran_pwd_error_num = #{tranPwdErrorNum,jdbcType=INTEGER},
+      explains = #{explains,jdbcType=VARCHAR},
+      is_locked = #{isLocked,jdbcType=CHAR},
+      is_blacklist = #{isBlacklist,jdbcType=CHAR},
+      invite_code = #{inviteCode,jdbcType=VARCHAR},
+      register_ip = #{registerIp,jdbcType=VARCHAR},
+      register_time = #{registerTime,jdbcType=TIMESTAMP},
+      last_login_ip = #{lastLoginIp,jdbcType=VARCHAR},
+      last_login_time = #{lastLoginTime,jdbcType=TIMESTAMP},
+      update_time = #{updateTime,jdbcType=TIMESTAMP},
+      email = #{email,jdbcType=VARCHAR},
+      credit_time = #{creditTime,jdbcType=TIMESTAMP}
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+</mapper>
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserRiskMapper.xml b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserRiskMapper.xml
new file mode 100644
index 00000000..b8996b12
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserRiskMapper.xml
@@ -0,0 +1,160 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.infincash.statistics.risk.mapper.TUserRiskMapper">
+  <resultMap id="BaseResultMap" type="com.infincash.statistics.risk.table.TUserRisk">
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="user_id" jdbcType="VARCHAR" property="userId" />
+    <result column="risk_rule_id" jdbcType="VARCHAR" property="riskRuleId" />
+    <result column="check_id" jdbcType="VARCHAR" property="checkId" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, user_id, risk_rule_id, check_id
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from t_user_risk
+    where id = #{id,jdbcType=VARCHAR}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
+    delete from t_user_risk
+    where id = #{id,jdbcType=VARCHAR}
+  </delete>
+  <insert id="insert" parameterType="com.infincash.statistics.risk.table.TUserRisk">
+    insert into t_user_risk (id, user_id, risk_rule_id, 
+      check_id)
+    values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{riskRuleId,jdbcType=VARCHAR}, 
+      #{checkId,jdbcType=VARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.infincash.statistics.risk.table.TUserRisk">
+    insert into t_user_risk
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="userId != null">
+        user_id,
+      </if>
+      <if test="riskRuleId != null">
+        risk_rule_id,
+      </if>
+      <if test="checkId != null">
+        check_id,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=VARCHAR},
+      </if>
+      <if test="userId != null">
+        #{userId,jdbcType=VARCHAR},
+      </if>
+      <if test="riskRuleId != null">
+        #{riskRuleId,jdbcType=VARCHAR},
+      </if>
+      <if test="checkId != null">
+        #{checkId,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.infincash.statistics.risk.table.TUserRisk">
+    update t_user_risk
+    <set>
+      <if test="userId != null">
+        user_id = #{userId,jdbcType=VARCHAR},
+      </if>
+      <if test="riskRuleId != null">
+        risk_rule_id = #{riskRuleId,jdbcType=VARCHAR},
+      </if>
+      <if test="checkId != null">
+        check_id = #{checkId,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.infincash.statistics.risk.table.TUserRisk">
+    update t_user_risk
+    set user_id = #{userId,jdbcType=VARCHAR},
+      risk_rule_id = #{riskRuleId,jdbcType=VARCHAR},
+      check_id = #{checkId,jdbcType=VARCHAR}
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <resultMap id="BaseResultMap" type="com.infincash.statistics.risk.table.TUserRisk">
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="user_id" jdbcType="VARCHAR" property="userId" />
+    <result column="risk_rule_id" jdbcType="VARCHAR" property="riskRuleId" />
+    <result column="check_id" jdbcType="VARCHAR" property="checkId" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, user_id, risk_rule_id, check_id
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from t_user_risk
+    where id = #{id,jdbcType=VARCHAR}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
+    delete from t_user_risk
+    where id = #{id,jdbcType=VARCHAR}
+  </delete>
+  <insert id="insert" parameterType="com.infincash.statistics.risk.table.TUserRisk">
+    insert into t_user_risk (id, user_id, risk_rule_id, 
+      check_id)
+    values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{riskRuleId,jdbcType=VARCHAR}, 
+      #{checkId,jdbcType=VARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.infincash.statistics.risk.table.TUserRisk">
+    insert into t_user_risk
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="userId != null">
+        user_id,
+      </if>
+      <if test="riskRuleId != null">
+        risk_rule_id,
+      </if>
+      <if test="checkId != null">
+        check_id,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=VARCHAR},
+      </if>
+      <if test="userId != null">
+        #{userId,jdbcType=VARCHAR},
+      </if>
+      <if test="riskRuleId != null">
+        #{riskRuleId,jdbcType=VARCHAR},
+      </if>
+      <if test="checkId != null">
+        #{checkId,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.infincash.statistics.risk.table.TUserRisk">
+    update t_user_risk
+    <set>
+      <if test="userId != null">
+        user_id = #{userId,jdbcType=VARCHAR},
+      </if>
+      <if test="riskRuleId != null">
+        risk_rule_id = #{riskRuleId,jdbcType=VARCHAR},
+      </if>
+      <if test="checkId != null">
+        check_id = #{checkId,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.infincash.statistics.risk.table.TUserRisk">
+    update t_user_risk
+    set user_id = #{userId,jdbcType=VARCHAR},
+      risk_rule_id = #{riskRuleId,jdbcType=VARCHAR},
+      check_id = #{checkId,jdbcType=VARCHAR}
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+</mapper>
\ No newline at end of file