准备工作
1)创建测试表
jobitem
CREATE TABLE "jobitem" ( "id" bigint(20) NOT NULL AUTO_INCREMENT COMMENT '唯一键 pk', "appId" varchar(32) NOT NULL COMMENT 'yarn任务id(applicationId)', "submitFilePath" varchar(256) NOT NULL COMMENT '提交脚本路径', "state" varchar(16) DEFAULT NULL COMMENT '任务状态', "monitorType" varchar(512) DEFAULT NULL COMMENT '监控列表', "createUserId" varchar(32) NOT NULL COMMENT '创建者关联Id', "createUserName" varchar(32) NOT NULL COMMENT '创建者用户名', "createTime" datetime NOT NULL COMMENT '创建时间', PRIMARY KEY ("id"), UNIQUE KEY "key" ("appId") ) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8 COMMENT='yarn任务持久化存储对象';
备注:这里mysql版本是5.7
2)使用mybatis-generator-plugin生成实体类:
Jobitem.java
package com.boco.jobmonitor.model; import java.util.Date; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; public class Jobitem { /** * 唯一键 pk<br> * 列名:id 类型:INTEGER(10) 允许空:false 缺省值:null */ @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Long id; /** * yarn任务id(applicationId)<br> * 列名:appId 类型:VARCHAR(32) 允许空:false 缺省值:null */ private String appid; /** * 提交脚本路径<br> * 列名:submitFilePath 类型:VARCHAR(256) 允许空:false 缺省值:null */ private String submitfilepath; /** * 任务状态<br> * 列名:state 类型:VARCHAR(16) 允许空:true 缺省值:null */ private String state; /** * 监控列表<br> * 列名:monitorType 类型:VARCHAR(512) 允许空:true 缺省值:null */ private String monitortype; /** * 创建者关联Id<br> * 列名:createUserId 类型:VARCHAR(32) 允许空:false 缺省值:null */ private String createuserid; /** * 创建者用户名<br> * 列名:createUserName 类型:VARCHAR(32) 允许空:false 缺省值:null */ private String createusername; /** * 创建时间<br> * 列名:createTime 类型:TIMESTAMP(19) 允许空:false 缺省值:null */ private Date createtime; public Jobitem() { } public Jobitem(String appid, String submitfilepath, String state, String monitortype, String createuserid, String createusername, Date createtime) { super(); this.appid = appid; this.submitfilepath = submitfilepath; this.state = state; this.monitortype = monitortype; this.createuserid = createuserid; this.createusername = createusername; this.createtime = createtime; } public Jobitem(Long id, String appid, String submitfilepath, String state, String monitortype, String createuserid, String createusername, Date createtime) { super(); this.id = id; this.appid = appid; this.submitfilepath = submitfilepath; this.state = state; this.monitortype = monitortype; this.createuserid = createuserid; this.createusername = createusername; this.createtime = createtime; } /** * 唯一键 pk * * @author boco * @return id 唯一键 pk */ public Long getId() { return id; } /** * 唯一键 pk * * @author boco * @param id * 唯一键 pk */ public void setId(Long id) { this.id = id; } /** * yarn任务id(applicationId) * * @author boco * @return appId yarn任务id(applicationId) */ public String getAppid() { return appid; } /** * yarn任务id(applicationId) * * @author boco * @param appid * yarn任务id(applicationId) */ public void setAppid(String appid) { this.appid = appid == null ? null : appid.trim(); } /** * 提交脚本路径 * * @author boco * @return submitFilePath 提交脚本路径 */ public String getSubmitfilepath() { return submitfilepath; } /** * 提交脚本路径 * * @author boco * @param submitfilepath * 提交脚本路径 */ public void setSubmitfilepath(String submitfilepath) { this.submitfilepath = submitfilepath == null ? null : submitfilepath.trim(); } /** * 任务状态 * * @author boco * @return state 任务状态 */ public String getState() { return state; } /** * 任务状态 * * @author boco * @param state * 任务状态 */ public void setState(String state) { this.state = state == null ? null : state.trim(); } /** * 监控列表 * * @author boco * @return monitorType 监控列表 */ public String getMonitortype() { return monitortype; } /** * 监控列表 * * @author boco * @param monitortype * 监控列表 */ public void setMonitortype(String monitortype) { this.monitortype = monitortype == null ? null : monitortype.trim(); } /** * 创建者关联Id * * @author boco * @return createUserId 创建者关联Id */ public String getCreateuserid() { return createuserid; } /** * 创建者关联Id * * @author boco * @param createuserid * 创建者关联Id */ public void setCreateuserid(String createuserid) { this.createuserid = createuserid == null ? null : createuserid.trim(); } /** * 创建者用户名 * * @author boco * @return createUserName 创建者用户名 */ public String getCreateusername() { return createusername; } /** * 创建者用户名 * * @author boco * @param createusername * 创建者用户名 */ public void setCreateusername(String createusername) { this.createusername = createusername == null ? null : createusername.trim(); } /** * 创建时间 * * @author boco * @return createTime 创建时间 */ public Date getCreatetime() { return createtime; } /** * 创建时间 * * @author boco * @param createtime * 创建时间 */ public void setCreatetime(Date createtime) { this.createtime = createtime; } }