From a9ef70be909c406946f790c5b1d477b52b7fa6f5 Mon Sep 17 00:00:00 2001 From: andy Date: Tue, 20 Jul 2021 19:54:44 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81flink?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/bean/models/DevopsDoris.java | 218 +- .../bean/models/DevopsDorisExample.java | 1865 ++++++++--------- .../controller/bean/models/DevopsFlink.java | 137 +- .../bean/models/DevopsFlinkExample.java | 350 ++++ .../config/constant/DevOpsType.java | 40 +- .../controller/dao/DevopsDorisMapper.java | 201 +- .../controller/dao/DevopsFlinkMapper.java | 23 +- .../duckula/ops/pages/devops/FlinkConfig.java | 97 +- .../primary/sqlmap/DevopsFlinkMapper.xml | 73 +- .../duckula/ops/pages/devops/FlinkConfig.tml | 2 +- 10 files changed, 1737 insertions(+), 1269 deletions(-) diff --git a/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsDoris.java b/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsDoris.java index 6565e0e..05a3ebd 100644 --- a/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsDoris.java +++ b/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsDoris.java @@ -14,117 +14,67 @@ import net.wicp.tams.common.constant.dic.YesOrNo; */ @TamsBean(title = "doris运维配置") public class DevopsDoris { + /** - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.id - * + * This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.id * @mbg.generated */ private Long id; - /** - * Database Column Remarks: 客户名 - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.name - * + * Database Column Remarks: 客户名 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.name * @mbg.generated */ @TamsCol(value = "租户名", save = 1, query = 1, showWidth = 100) private String name; - /** - * Database Column Remarks: ip1地址 - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.ip - * + * Database Column Remarks: ip1地址 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.ip * @mbg.generated */ @TamsCol(value = "IP地址", save = 1, query = 1, showWidth = 150) private String ip; - /** - * Database Column Remarks: 集群 - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.cluster - * + * Database Column Remarks: 集群 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.cluster * @mbg.generated */ @TamsCol(value = "集群", save = 1, query = 0, showWidth = 150) private String cluster; - /** - * Database Column Remarks: 服务器的角色 - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.roles - * + * Database Column Remarks: 服务器的角色 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.roles * @mbg.generated */ @TamsCol(value = "角色", save = 1, query = -1, showWidth = 150, multiple = true, enumClass = DorisRole.class) private String roles; - /** - * Database Column Remarks: 存储磁盘 - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.fs - * + * Database Column Remarks: 存储磁盘 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.fs * @mbg.generated */ - // ,comboxurl = "/devops/dorisconfig:listFs"不好实现 @TamsCol(value = "存储磁盘", save = 1, query = -1, showWidth = 150) private String fs; - /** - * Database Column Remarks: root密码 - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.root_pwd - * + * Database Column Remarks: root密码 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.root_pwd * @mbg.generated */ @TamsCol(value = "root密码", save = 1, query = -1) private String rootPwd; - /** - * Database Column Remarks: 是否初始化，yes:已初始化 no:未初始化 创建duckula用户，创建环境变量创建目录 - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.is_init - * + * Database Column Remarks: 是否初始化，yes:已初始化 no:未初始化 创建duckula用户，创建环境变量创建目录 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.is_init * @mbg.generated */ @TamsCol(value = "初始化", save = 1, query = 0, enumClass = YesOrNo.class, showWidth = 100) private String isInit; - /** - * Database Column Remarks: 创建时间 - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.create_time - * + * Database Column Remarks: 创建时间 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.create_time * @mbg.generated */ private Date createTime; - /** - * Database Column Remarks: 创建时间 - * - * This field was generated by MyBatis Generator. This field corresponds to the - * database column devops_doris.update_time - * + * Database Column Remarks: 创建时间 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.update_time * @mbg.generated */ private Date updateTime; /** - * This method was generated by MyBatis Generator. This method corresponds to - * the database table devops_doris - * + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris * @mbg.generated */ public DevopsDoris(Long id, String name, String ip, String cluster, String roles, String fs, String rootPwd, @@ -142,9 +92,7 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method corresponds to - * the database table devops_doris - * + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris * @mbg.generated */ public DevopsDoris() { @@ -152,11 +100,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.id - * - * @return the value of devops_doris.id - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.id + * @return the value of devops_doris.id * @mbg.generated */ public Long getId() { @@ -164,11 +109,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.id - * - * @param id the value for devops_doris.id - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.id + * @param id the value for devops_doris.id * @mbg.generated */ public void setId(Long id) { @@ -176,11 +118,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.name - * - * @return the value of devops_doris.name - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.name + * @return the value of devops_doris.name * @mbg.generated */ public String getName() { @@ -188,11 +127,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.name - * - * @param name the value for devops_doris.name - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.name + * @param name the value for devops_doris.name * @mbg.generated */ public void setName(String name) { @@ -200,11 +136,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.ip - * - * @return the value of devops_doris.ip - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.ip + * @return the value of devops_doris.ip * @mbg.generated */ public String getIp() { @@ -212,11 +145,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.ip - * - * @param ip the value for devops_doris.ip - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.ip + * @param ip the value for devops_doris.ip * @mbg.generated */ public void setIp(String ip) { @@ -224,11 +154,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.cluster - * - * @return the value of devops_doris.cluster - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.cluster + * @return the value of devops_doris.cluster * @mbg.generated */ public String getCluster() { @@ -236,11 +163,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.cluster - * - * @param cluster the value for devops_doris.cluster - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.cluster + * @param cluster the value for devops_doris.cluster * @mbg.generated */ public void setCluster(String cluster) { @@ -248,11 +172,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.roles - * - * @return the value of devops_doris.roles - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.roles + * @return the value of devops_doris.roles * @mbg.generated */ public String getRoles() { @@ -260,11 +181,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.roles - * - * @param roles the value for devops_doris.roles - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.roles + * @param roles the value for devops_doris.roles * @mbg.generated */ public void setRoles(String roles) { @@ -272,11 +190,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.fs - * - * @return the value of devops_doris.fs - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.fs + * @return the value of devops_doris.fs * @mbg.generated */ public String getFs() { @@ -284,11 +199,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.fs - * - * @param fs the value for devops_doris.fs - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.fs + * @param fs the value for devops_doris.fs * @mbg.generated */ public void setFs(String fs) { @@ -296,11 +208,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.root_pwd - * - * @return the value of devops_doris.root_pwd - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.root_pwd + * @return the value of devops_doris.root_pwd * @mbg.generated */ public String getRootPwd() { @@ -308,11 +217,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.root_pwd - * - * @param rootPwd the value for devops_doris.root_pwd - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.root_pwd + * @param rootPwd the value for devops_doris.root_pwd * @mbg.generated */ public void setRootPwd(String rootPwd) { @@ -320,11 +226,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.is_init - * - * @return the value of devops_doris.is_init - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.is_init + * @return the value of devops_doris.is_init * @mbg.generated */ public String getIsInit() { @@ -332,11 +235,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.is_init - * - * @param isInit the value for devops_doris.is_init - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.is_init + * @param isInit the value for devops_doris.is_init * @mbg.generated */ public void setIsInit(String isInit) { @@ -344,11 +244,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.create_time - * - * @return the value of devops_doris.create_time - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.create_time + * @return the value of devops_doris.create_time * @mbg.generated */ public Date getCreateTime() { @@ -356,11 +253,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.create_time - * - * @param createTime the value for devops_doris.create_time - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.create_time + * @param createTime the value for devops_doris.create_time * @mbg.generated */ public void setCreateTime(Date createTime) { @@ -368,11 +262,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method returns the value - * of the database column devops_doris.update_time - * - * @return the value of devops_doris.update_time - * + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.update_time + * @return the value of devops_doris.update_time * @mbg.generated */ public Date getUpdateTime() { @@ -380,11 +271,8 @@ public class DevopsDoris { } /** - * This method was generated by MyBatis Generator. This method sets the value of - * the database column devops_doris.update_time - * - * @param updateTime the value for devops_doris.update_time - * + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.update_time + * @param updateTime the value for devops_doris.update_time * @mbg.generated */ public void setUpdateTime(Date updateTime) { diff --git a/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsDorisExample.java b/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsDorisExample.java index c2f8718..0830cab 100644 --- a/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsDorisExample.java +++ b/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsDorisExample.java @@ -6,867 +6,918 @@ import java.util.List; public class DevopsDorisExample { /** - * This field was generated by MyBatis Generator. - * This field corresponds to the database table devops_doris - * - * @mbg.generated - */ - protected String orderByClause; - - /** - * This field was generated by MyBatis Generator. - * This field corresponds to the database table devops_doris - * - * @mbg.generated - */ - protected boolean distinct; - - /** - * This field was generated by MyBatis Generator. - * This field corresponds to the database table devops_doris - * - * @mbg.generated - */ - protected List oredCriteria; - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public DevopsDorisExample() { - oredCriteria = new ArrayList<>(); - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public void setOrderByClause(String orderByClause) { - this.orderByClause = orderByClause; - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public String getOrderByClause() { - return orderByClause; - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public void setDistinct(boolean distinct) { - this.distinct = distinct; - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public boolean isDistinct() { - return distinct; - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public List getOredCriteria() { - return oredCriteria; - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public void or(Criteria criteria) { - oredCriteria.add(criteria); - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public Criteria or() { - Criteria criteria = createCriteriaInternal(); - oredCriteria.add(criteria); - return criteria; - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public Criteria createCriteria() { - Criteria criteria = createCriteriaInternal(); - if (oredCriteria.size() == 0) { - oredCriteria.add(criteria); - } - return criteria; - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - protected Criteria createCriteriaInternal() { - Criteria criteria = new Criteria(); - return criteria; - } - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - public void clear() { - oredCriteria.clear(); - orderByClause = null; - distinct = false; - } - - /** - * This class was generated by MyBatis Generator. - * This class corresponds to the database table devops_doris - * - * @mbg.generated - */ - protected abstract static class GeneratedCriteria { - protected List criteria; - - protected GeneratedCriteria() { - super(); - criteria = new ArrayList<>(); - } - - public boolean isValid() { - return criteria.size() > 0; - } - - public List getAllCriteria() { - return criteria; - } - - public List getCriteria() { - return criteria; - } - - protected void addCriterion(String condition) { - if (condition == null) { - throw new RuntimeException("Value for condition cannot be null"); - } - criteria.add(new Criterion(condition)); - } - - protected void addCriterion(String condition, Object value, String property) { - if (value == null) { - throw new RuntimeException("Value for " + property + " cannot be null"); - } - criteria.add(new Criterion(condition, value)); - } - - protected void addCriterion(String condition, Object value1, Object value2, String property) { - if (value1 == null || value2 == null) { - throw new RuntimeException("Between values for " + property + " cannot be null"); - } - criteria.add(new Criterion(condition, value1, value2)); - } - - public Criteria andIdIsNull() { - addCriterion("id is null"); - return (Criteria) this; - } - - public Criteria andIdIsNotNull() { - addCriterion("id is not null"); - return (Criteria) this; - } - - public Criteria andIdEqualTo(Long value) { - addCriterion("id =", value, "id"); - return (Criteria) this; - } - - public Criteria andIdNotEqualTo(Long value) { - addCriterion("id <>", value, "id"); - return (Criteria) this; - } - - public Criteria andIdGreaterThan(Long value) { - addCriterion("id >", value, "id"); - return (Criteria) this; - } - - public Criteria andIdGreaterThanOrEqualTo(Long value) { - addCriterion("id >=", value, "id"); - return (Criteria) this; - } - - public Criteria andIdLessThan(Long value) { - addCriterion("id <", value, "id"); - return (Criteria) this; - } - - public Criteria andIdLessThanOrEqualTo(Long value) { - addCriterion("id <=", value, "id"); - return (Criteria) this; - } - - public Criteria andIdIn(List values) { - addCriterion("id in", values, "id"); - return (Criteria) this; - } - - public Criteria andIdNotIn(List values) { - addCriterion("id not in", values, "id"); - return (Criteria) this; - } - - public Criteria andIdBetween(Long value1, Long value2) { - addCriterion("id between", value1, value2, "id"); - return (Criteria) this; - } - - public Criteria andIdNotBetween(Long value1, Long value2) { - addCriterion("id not between", value1, value2, "id"); - return (Criteria) this; - } - - public Criteria andNameIsNull() { - addCriterion("name is null"); - return (Criteria) this; - } - - public Criteria andNameIsNotNull() { - addCriterion("name is not null"); - return (Criteria) this; - } - - public Criteria andNameEqualTo(String value) { - addCriterion("name =", value, "name"); - return (Criteria) this; - } - - public Criteria andNameNotEqualTo(String value) { - addCriterion("name <>", value, "name"); - return (Criteria) this; - } - - public Criteria andNameGreaterThan(String value) { - addCriterion("name >", value, "name"); - return (Criteria) this; - } - - public Criteria andNameGreaterThanOrEqualTo(String value) { - addCriterion("name >=", value, "name"); - return (Criteria) this; - } - - public Criteria andNameLessThan(String value) { - addCriterion("name <", value, "name"); - return (Criteria) this; - } - - public Criteria andNameLessThanOrEqualTo(String value) { - addCriterion("name <=", value, "name"); - return (Criteria) this; - } - - public Criteria andNameLike(String value) { - addCriterion("name like", value, "name"); - return (Criteria) this; - } - - public Criteria andNameNotLike(String value) { - addCriterion("name not like", value, "name"); - return (Criteria) this; - } - - public Criteria andNameIn(List values) { - addCriterion("name in", values, "name"); - return (Criteria) this; - } - - public Criteria andNameNotIn(List values) { - addCriterion("name not in", values, "name"); - return (Criteria) this; - } - - public Criteria andNameBetween(String value1, String value2) { - addCriterion("name between", value1, value2, "name"); - return (Criteria) this; - } - - public Criteria andNameNotBetween(String value1, String value2) { - addCriterion("name not between", value1, value2, "name"); - return (Criteria) this; - } - - public Criteria andIpIsNull() { - addCriterion("ip is null"); - return (Criteria) this; - } - - public Criteria andIpIsNotNull() { - addCriterion("ip is not null"); - return (Criteria) this; - } - - public Criteria andIpEqualTo(String value) { - addCriterion("ip =", value, "ip"); - return (Criteria) this; - } - - public Criteria andIpNotEqualTo(String value) { - addCriterion("ip <>", value, "ip"); - return (Criteria) this; - } - - public Criteria andIpGreaterThan(String value) { - addCriterion("ip >", value, "ip"); - return (Criteria) this; - } - - public Criteria andIpGreaterThanOrEqualTo(String value) { - addCriterion("ip >=", value, "ip"); - return (Criteria) this; - } - - public Criteria andIpLessThan(String value) { - addCriterion("ip <", value, "ip"); - return (Criteria) this; - } - - public Criteria andIpLessThanOrEqualTo(String value) { - addCriterion("ip <=", value, "ip"); - return (Criteria) this; - } - - public Criteria andIpLike(String value) { - addCriterion("ip like", value, "ip"); - return (Criteria) this; - } - - public Criteria andIpNotLike(String value) { - addCriterion("ip not like", value, "ip"); - return (Criteria) this; - } - - public Criteria andIpIn(List values) { - addCriterion("ip in", values, "ip"); - return (Criteria) this; - } - - public Criteria andIpNotIn(List values) { - addCriterion("ip not in", values, "ip"); - return (Criteria) this; - } - - public Criteria andIpBetween(String value1, String value2) { - addCriterion("ip between", value1, value2, "ip"); - return (Criteria) this; - } - - public Criteria andIpNotBetween(String value1, String value2) { - addCriterion("ip not between", value1, value2, "ip"); - return (Criteria) this; - } - - public Criteria andClusterIsNull() { - addCriterion("cluster is null"); - return (Criteria) this; - } - - public Criteria andClusterIsNotNull() { - addCriterion("cluster is not null"); - return (Criteria) this; - } - - public Criteria andClusterEqualTo(String value) { - addCriterion("cluster =", value, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterNotEqualTo(String value) { - addCriterion("cluster <>", value, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterGreaterThan(String value) { - addCriterion("cluster >", value, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterGreaterThanOrEqualTo(String value) { - addCriterion("cluster >=", value, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterLessThan(String value) { - addCriterion("cluster <", value, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterLessThanOrEqualTo(String value) { - addCriterion("cluster <=", value, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterLike(String value) { - addCriterion("cluster like", value, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterNotLike(String value) { - addCriterion("cluster not like", value, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterIn(List values) { - addCriterion("cluster in", values, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterNotIn(List values) { - addCriterion("cluster not in", values, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterBetween(String value1, String value2) { - addCriterion("cluster between", value1, value2, "cluster"); - return (Criteria) this; - } - - public Criteria andClusterNotBetween(String value1, String value2) { - addCriterion("cluster not between", value1, value2, "cluster"); - return (Criteria) this; - } - - public Criteria andRolesIsNull() { - addCriterion("roles is null"); - return (Criteria) this; - } - - public Criteria andRolesIsNotNull() { - addCriterion("roles is not null"); - return (Criteria) this; - } - - public Criteria andRolesEqualTo(String value) { - addCriterion("roles =", value, "roles"); - return (Criteria) this; - } - - public Criteria andRolesNotEqualTo(String value) { - addCriterion("roles <>", value, "roles"); - return (Criteria) this; - } - - public Criteria andRolesGreaterThan(String value) { - addCriterion("roles >", value, "roles"); - return (Criteria) this; - } - - public Criteria andRolesGreaterThanOrEqualTo(String value) { - addCriterion("roles >=", value, "roles"); - return (Criteria) this; - } - - public Criteria andRolesLessThan(String value) { - addCriterion("roles <", value, "roles"); - return (Criteria) this; - } - - public Criteria andRolesLessThanOrEqualTo(String value) { - addCriterion("roles <=", value, "roles"); - return (Criteria) this; - } - - public Criteria andRolesLike(String value) { - addCriterion("roles like", value, "roles"); - return (Criteria) this; - } - - public Criteria andRolesNotLike(String value) { - addCriterion("roles not like", value, "roles"); - return (Criteria) this; - } - - public Criteria andRolesIn(List values) { - addCriterion("roles in", values, "roles"); - return (Criteria) this; - } - - public Criteria andRolesNotIn(List values) { - addCriterion("roles not in", values, "roles"); - return (Criteria) this; - } - - public Criteria andRolesBetween(String value1, String value2) { - addCriterion("roles between", value1, value2, "roles"); - return (Criteria) this; - } - - public Criteria andRolesNotBetween(String value1, String value2) { - addCriterion("roles not between", value1, value2, "roles"); - return (Criteria) this; - } - - public Criteria andFsIsNull() { - addCriterion("fs is null"); - return (Criteria) this; - } - - public Criteria andFsIsNotNull() { - addCriterion("fs is not null"); - return (Criteria) this; - } - - public Criteria andFsEqualTo(String value) { - addCriterion("fs =", value, "fs"); - return (Criteria) this; - } - - public Criteria andFsNotEqualTo(String value) { - addCriterion("fs <>", value, "fs"); - return (Criteria) this; - } - - public Criteria andFsGreaterThan(String value) { - addCriterion("fs >", value, "fs"); - return (Criteria) this; - } - - public Criteria andFsGreaterThanOrEqualTo(String value) { - addCriterion("fs >=", value, "fs"); - return (Criteria) this; - } - - public Criteria andFsLessThan(String value) { - addCriterion("fs <", value, "fs"); - return (Criteria) this; - } - - public Criteria andFsLessThanOrEqualTo(String value) { - addCriterion("fs <=", value, "fs"); - return (Criteria) this; - } - - public Criteria andFsLike(String value) { - addCriterion("fs like", value, "fs"); - return (Criteria) this; - } - - public Criteria andFsNotLike(String value) { - addCriterion("fs not like", value, "fs"); - return (Criteria) this; - } - - public Criteria andFsIn(List values) { - addCriterion("fs in", values, "fs"); - return (Criteria) this; - } - - public Criteria andFsNotIn(List values) { - addCriterion("fs not in", values, "fs"); - return (Criteria) this; - } - - public Criteria andFsBetween(String value1, String value2) { - addCriterion("fs between", value1, value2, "fs"); - return (Criteria) this; - } - - public Criteria andFsNotBetween(String value1, String value2) { - addCriterion("fs not between", value1, value2, "fs"); - return (Criteria) this; - } - - public Criteria andRootPwdIsNull() { - addCriterion("root_pwd is null"); - return (Criteria) this; - } - - public Criteria andRootPwdIsNotNull() { - addCriterion("root_pwd is not null"); - return (Criteria) this; - } - - public Criteria andRootPwdEqualTo(String value) { - addCriterion("root_pwd =", value, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdNotEqualTo(String value) { - addCriterion("root_pwd <>", value, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdGreaterThan(String value) { - addCriterion("root_pwd >", value, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdGreaterThanOrEqualTo(String value) { - addCriterion("root_pwd >=", value, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdLessThan(String value) { - addCriterion("root_pwd <", value, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdLessThanOrEqualTo(String value) { - addCriterion("root_pwd <=", value, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdLike(String value) { - addCriterion("root_pwd like", value, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdNotLike(String value) { - addCriterion("root_pwd not like", value, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdIn(List values) { - addCriterion("root_pwd in", values, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdNotIn(List values) { - addCriterion("root_pwd not in", values, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdBetween(String value1, String value2) { - addCriterion("root_pwd between", value1, value2, "rootPwd"); - return (Criteria) this; - } - - public Criteria andRootPwdNotBetween(String value1, String value2) { - addCriterion("root_pwd not between", value1, value2, "rootPwd"); - return (Criteria) this; - } - - public Criteria andIsInitIsNull() { - addCriterion("is_init is null"); - return (Criteria) this; - } - - public Criteria andIsInitIsNotNull() { - addCriterion("is_init is not null"); - return (Criteria) this; - } - - public Criteria andIsInitEqualTo(String value) { - addCriterion("is_init =", value, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitNotEqualTo(String value) { - addCriterion("is_init <>", value, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitGreaterThan(String value) { - addCriterion("is_init >", value, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitGreaterThanOrEqualTo(String value) { - addCriterion("is_init >=", value, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitLessThan(String value) { - addCriterion("is_init <", value, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitLessThanOrEqualTo(String value) { - addCriterion("is_init <=", value, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitLike(String value) { - addCriterion("is_init like", value, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitNotLike(String value) { - addCriterion("is_init not like", value, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitIn(List values) { - addCriterion("is_init in", values, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitNotIn(List values) { - addCriterion("is_init not in", values, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitBetween(String value1, String value2) { - addCriterion("is_init between", value1, value2, "isInit"); - return (Criteria) this; - } - - public Criteria andIsInitNotBetween(String value1, String value2) { - addCriterion("is_init not between", value1, value2, "isInit"); - return (Criteria) this; - } - - public Criteria andCreateTimeIsNull() { - addCriterion("create_time is null"); - return (Criteria) this; - } - - public Criteria andCreateTimeIsNotNull() { - addCriterion("create_time is not null"); - return (Criteria) this; - } - - public Criteria andCreateTimeEqualTo(Date value) { - addCriterion("create_time =", value, "createTime"); - return (Criteria) this; - } - - public Criteria andCreateTimeNotEqualTo(Date value) { - addCriterion("create_time <>", value, "createTime"); - return (Criteria) this; - } - - public Criteria andCreateTimeGreaterThan(Date value) { - addCriterion("create_time >", value, "createTime"); - return (Criteria) this; - } - - public Criteria andCreateTimeGreaterThanOrEqualTo(Date value) { - addCriterion("create_time >=", value, "createTime"); - return (Criteria) this; - } - - public Criteria andCreateTimeLessThan(Date value) { - addCriterion("create_time <", value, "createTime"); - return (Criteria) this; - } - - public Criteria andCreateTimeLessThanOrEqualTo(Date value) { - addCriterion("create_time <=", value, "createTime"); - return (Criteria) this; - } - - public Criteria andCreateTimeIn(List values) { - addCriterion("create_time in", values, "createTime"); - return (Criteria) this; - } - - public Criteria andCreateTimeNotIn(List values) { - addCriterion("create_time not in", values, "createTime"); - return (Criteria) this; - } - - public Criteria andCreateTimeBetween(Date value1, Date value2) { - addCriterion("create_time between", value1, value2, "createTime"); - return (Criteria) this; - } - - public Criteria andCreateTimeNotBetween(Date value1, Date value2) { - addCriterion("create_time not between", value1, value2, "createTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeIsNull() { - addCriterion("update_time is null"); - return (Criteria) this; - } - - public Criteria andUpdateTimeIsNotNull() { - addCriterion("update_time is not null"); - return (Criteria) this; - } - - public Criteria andUpdateTimeEqualTo(Date value) { - addCriterion("update_time =", value, "updateTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeNotEqualTo(Date value) { - addCriterion("update_time <>", value, "updateTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeGreaterThan(Date value) { - addCriterion("update_time >", value, "updateTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeGreaterThanOrEqualTo(Date value) { - addCriterion("update_time >=", value, "updateTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeLessThan(Date value) { - addCriterion("update_time <", value, "updateTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeLessThanOrEqualTo(Date value) { - addCriterion("update_time <=", value, "updateTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeIn(List values) { - addCriterion("update_time in", values, "updateTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeNotIn(List values) { - addCriterion("update_time not in", values, "updateTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeBetween(Date value1, Date value2) { - addCriterion("update_time between", value1, value2, "updateTime"); - return (Criteria) this; - } - - public Criteria andUpdateTimeNotBetween(Date value1, Date value2) { - addCriterion("update_time not between", value1, value2, "updateTime"); - return (Criteria) this; - } - } - - /** + * This field was generated by MyBatis Generator. This field corresponds to the database table devops_doris + * @mbg.generated + */ + protected String orderByClause; + /** + * This field was generated by MyBatis Generator. This field corresponds to the database table devops_doris + * @mbg.generated + */ + protected boolean distinct; + /** + * This field was generated by MyBatis Generator. This field corresponds to the database table devops_doris + * @mbg.generated + */ + protected List oredCriteria; + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public DevopsDorisExample() { + oredCriteria = new ArrayList<>(); + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public void setOrderByClause(String orderByClause) { + this.orderByClause = orderByClause; + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public String getOrderByClause() { + return orderByClause; + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public void setDistinct(boolean distinct) { + this.distinct = distinct; + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public boolean isDistinct() { + return distinct; + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public List getOredCriteria() { + return oredCriteria; + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public void or(Criteria criteria) { + oredCriteria.add(criteria); + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public Criteria or() { + Criteria criteria = createCriteriaInternal(); + oredCriteria.add(criteria); + return criteria; + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public Criteria createCriteria() { + Criteria criteria = createCriteriaInternal(); + if (oredCriteria.size() == 0) { + oredCriteria.add(criteria); + } + return criteria; + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + protected Criteria createCriteriaInternal() { + Criteria criteria = new Criteria(); + return criteria; + } + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + public void clear() { + oredCriteria.clear(); + orderByClause = null; + distinct = false; + } + + /** + * This class was generated by MyBatis Generator. This class corresponds to the database table devops_doris + * @mbg.generated + */ + protected abstract static class GeneratedCriteria { + protected List criteria; + + protected GeneratedCriteria() { + super(); + criteria = new ArrayList<>(); + } + + public boolean isValid() { + return criteria.size() > 0; + } + + public List getAllCriteria() { + return criteria; + } + + public List getCriteria() { + return criteria; + } + + protected void addCriterion(String condition) { + if (condition == null) { + throw new RuntimeException("Value for condition cannot be null"); + } + criteria.add(new Criterion(condition)); + } + + protected void addCriterion(String condition, Object value, String property) { + if (value == null) { + throw new RuntimeException("Value for " + property + " cannot be null"); + } + criteria.add(new Criterion(condition, value)); + } + + protected void addCriterion(String condition, Object value1, Object value2, String property) { + if (value1 == null || value2 == null) { + throw new RuntimeException("Between values for " + property + " cannot be null"); + } + criteria.add(new Criterion(condition, value1, value2)); + } + + public Criteria andIdIsNull() { + addCriterion("id is null"); + return (Criteria) this; + } + + public Criteria andIdIsNotNull() { + addCriterion("id is not null"); + return (Criteria) this; + } + + public Criteria andIdEqualTo(Long value) { + addCriterion("id =", value, "id"); + return (Criteria) this; + } + + public Criteria andIdNotEqualTo(Long value) { + addCriterion("id <>", value, "id"); + return (Criteria) this; + } + + public Criteria andIdGreaterThan(Long value) { + addCriterion("id >", value, "id"); + return (Criteria) this; + } + + public Criteria andIdGreaterThanOrEqualTo(Long value) { + addCriterion("id >=", value, "id"); + return (Criteria) this; + } + + public Criteria andIdLessThan(Long value) { + addCriterion("id <", value, "id"); + return (Criteria) this; + } + + public Criteria andIdLessThanOrEqualTo(Long value) { + addCriterion("id <=", value, "id"); + return (Criteria) this; + } + + public Criteria andIdIn(List values) { + addCriterion("id in", values, "id"); + return (Criteria) this; + } + + public Criteria andIdNotIn(List values) { + addCriterion("id not in", values, "id"); + return (Criteria) this; + } + + public Criteria andIdBetween(Long value1, Long value2) { + addCriterion("id between", value1, value2, "id"); + return (Criteria) this; + } + + public Criteria andIdNotBetween(Long value1, Long value2) { + addCriterion("id not between", value1, value2, "id"); + return (Criteria) this; + } + + public Criteria andNameIsNull() { + addCriterion("name is null"); + return (Criteria) this; + } + + public Criteria andNameIsNotNull() { + addCriterion("name is not null"); + return (Criteria) this; + } + + public Criteria andNameEqualTo(String value) { + addCriterion("name =", value, "name"); + return (Criteria) this; + } + + public Criteria andNameNotEqualTo(String value) { + addCriterion("name <>", value, "name"); + return (Criteria) this; + } + + public Criteria andNameGreaterThan(String value) { + addCriterion("name >", value, "name"); + return (Criteria) this; + } + + public Criteria andNameGreaterThanOrEqualTo(String value) { + addCriterion("name >=", value, "name"); + return (Criteria) this; + } + + public Criteria andNameLessThan(String value) { + addCriterion("name <", value, "name"); + return (Criteria) this; + } + + public Criteria andNameLessThanOrEqualTo(String value) { + addCriterion("name <=", value, "name"); + return (Criteria) this; + } + + public Criteria andNameLike(String value) { + addCriterion("name like", value, "name"); + return (Criteria) this; + } + + public Criteria andNameNotLike(String value) { + addCriterion("name not like", value, "name"); + return (Criteria) this; + } + + public Criteria andNameIn(List values) { + addCriterion("name in", values, "name"); + return (Criteria) this; + } + + public Criteria andNameNotIn(List values) { + addCriterion("name not in", values, "name"); + return (Criteria) this; + } + + public Criteria andNameBetween(String value1, String value2) { + addCriterion("name between", value1, value2, "name"); + return (Criteria) this; + } + + public Criteria andNameNotBetween(String value1, String value2) { + addCriterion("name not between", value1, value2, "name"); + return (Criteria) this; + } + + public Criteria andIpIsNull() { + addCriterion("ip is null"); + return (Criteria) this; + } + + public Criteria andIpIsNotNull() { + addCriterion("ip is not null"); + return (Criteria) this; + } + + public Criteria andIpEqualTo(String value) { + addCriterion("ip =", value, "ip"); + return (Criteria) this; + } + + public Criteria andIpNotEqualTo(String value) { + addCriterion("ip <>", value, "ip"); + return (Criteria) this; + } + + public Criteria andIpGreaterThan(String value) { + addCriterion("ip >", value, "ip"); + return (Criteria) this; + } + + public Criteria andIpGreaterThanOrEqualTo(String value) { + addCriterion("ip >=", value, "ip"); + return (Criteria) this; + } + + public Criteria andIpLessThan(String value) { + addCriterion("ip <", value, "ip"); + return (Criteria) this; + } + + public Criteria andIpLessThanOrEqualTo(String value) { + addCriterion("ip <=", value, "ip"); + return (Criteria) this; + } + + public Criteria andIpLike(String value) { + addCriterion("ip like", value, "ip"); + return (Criteria) this; + } + + public Criteria andIpNotLike(String value) { + addCriterion("ip not like", value, "ip"); + return (Criteria) this; + } + + public Criteria andIpIn(List values) { + addCriterion("ip in", values, "ip"); + return (Criteria) this; + } + + public Criteria andIpNotIn(List values) { + addCriterion("ip not in", values, "ip"); + return (Criteria) this; + } + + public Criteria andIpBetween(String value1, String value2) { + addCriterion("ip between", value1, value2, "ip"); + return (Criteria) this; + } + + public Criteria andIpNotBetween(String value1, String value2) { + addCriterion("ip not between", value1, value2, "ip"); + return (Criteria) this; + } + + public Criteria andClusterIsNull() { + addCriterion("cluster is null"); + return (Criteria) this; + } + + public Criteria andClusterIsNotNull() { + addCriterion("cluster is not null"); + return (Criteria) this; + } + + public Criteria andClusterEqualTo(String value) { + addCriterion("cluster =", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterNotEqualTo(String value) { + addCriterion("cluster <>", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterGreaterThan(String value) { + addCriterion("cluster >", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterGreaterThanOrEqualTo(String value) { + addCriterion("cluster >=", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterLessThan(String value) { + addCriterion("cluster <", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterLessThanOrEqualTo(String value) { + addCriterion("cluster <=", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterLike(String value) { + addCriterion("cluster like", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterNotLike(String value) { + addCriterion("cluster not like", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterIn(List values) { + addCriterion("cluster in", values, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterNotIn(List values) { + addCriterion("cluster not in", values, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterBetween(String value1, String value2) { + addCriterion("cluster between", value1, value2, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterNotBetween(String value1, String value2) { + addCriterion("cluster not between", value1, value2, "cluster"); + return (Criteria) this; + } + + public Criteria andRolesIsNull() { + addCriterion("roles is null"); + return (Criteria) this; + } + + public Criteria andRolesIsNotNull() { + addCriterion("roles is not null"); + return (Criteria) this; + } + + public Criteria andRolesEqualTo(String value) { + addCriterion("roles =", value, "roles"); + return (Criteria) this; + } + + public Criteria andRolesNotEqualTo(String value) { + addCriterion("roles <>", value, "roles"); + return (Criteria) this; + } + + public Criteria andRolesGreaterThan(String value) { + addCriterion("roles >", value, "roles"); + return (Criteria) this; + } + + public Criteria andRolesGreaterThanOrEqualTo(String value) { + addCriterion("roles >=", value, "roles"); + return (Criteria) this; + } + + public Criteria andRolesLessThan(String value) { + addCriterion("roles <", value, "roles"); + return (Criteria) this; + } + + public Criteria andRolesLessThanOrEqualTo(String value) { + addCriterion("roles <=", value, "roles"); + return (Criteria) this; + } + + public Criteria andRolesLike(String value) { + addCriterion("roles like", value, "roles"); + return (Criteria) this; + } + + public Criteria andRolesNotLike(String value) { + addCriterion("roles not like", value, "roles"); + return (Criteria) this; + } + + public Criteria andRolesIn(List values) { + addCriterion("roles in", values, "roles"); + return (Criteria) this; + } + + public Criteria andRolesNotIn(List values) { + addCriterion("roles not in", values, "roles"); + return (Criteria) this; + } + + public Criteria andRolesBetween(String value1, String value2) { + addCriterion("roles between", value1, value2, "roles"); + return (Criteria) this; + } + + public Criteria andRolesNotBetween(String value1, String value2) { + addCriterion("roles not between", value1, value2, "roles"); + return (Criteria) this; + } + + public Criteria andFsIsNull() { + addCriterion("fs is null"); + return (Criteria) this; + } + + public Criteria andFsIsNotNull() { + addCriterion("fs is not null"); + return (Criteria) this; + } + + public Criteria andFsEqualTo(String value) { + addCriterion("fs =", value, "fs"); + return (Criteria) this; + } + + public Criteria andFsNotEqualTo(String value) { + addCriterion("fs <>", value, "fs"); + return (Criteria) this; + } + + public Criteria andFsGreaterThan(String value) { + addCriterion("fs >", value, "fs"); + return (Criteria) this; + } + + public Criteria andFsGreaterThanOrEqualTo(String value) { + addCriterion("fs >=", value, "fs"); + return (Criteria) this; + } + + public Criteria andFsLessThan(String value) { + addCriterion("fs <", value, "fs"); + return (Criteria) this; + } + + public Criteria andFsLessThanOrEqualTo(String value) { + addCriterion("fs <=", value, "fs"); + return (Criteria) this; + } + + public Criteria andFsLike(String value) { + addCriterion("fs like", value, "fs"); + return (Criteria) this; + } + + public Criteria andFsNotLike(String value) { + addCriterion("fs not like", value, "fs"); + return (Criteria) this; + } + + public Criteria andFsIn(List values) { + addCriterion("fs in", values, "fs"); + return (Criteria) this; + } + + public Criteria andFsNotIn(List values) { + addCriterion("fs not in", values, "fs"); + return (Criteria) this; + } + + public Criteria andFsBetween(String value1, String value2) { + addCriterion("fs between", value1, value2, "fs"); + return (Criteria) this; + } + + public Criteria andFsNotBetween(String value1, String value2) { + addCriterion("fs not between", value1, value2, "fs"); + return (Criteria) this; + } + + public Criteria andRootPwdIsNull() { + addCriterion("root_pwd is null"); + return (Criteria) this; + } + + public Criteria andRootPwdIsNotNull() { + addCriterion("root_pwd is not null"); + return (Criteria) this; + } + + public Criteria andRootPwdEqualTo(String value) { + addCriterion("root_pwd =", value, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdNotEqualTo(String value) { + addCriterion("root_pwd <>", value, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdGreaterThan(String value) { + addCriterion("root_pwd >", value, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdGreaterThanOrEqualTo(String value) { + addCriterion("root_pwd >=", value, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdLessThan(String value) { + addCriterion("root_pwd <", value, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdLessThanOrEqualTo(String value) { + addCriterion("root_pwd <=", value, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdLike(String value) { + addCriterion("root_pwd like", value, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdNotLike(String value) { + addCriterion("root_pwd not like", value, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdIn(List values) { + addCriterion("root_pwd in", values, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdNotIn(List values) { + addCriterion("root_pwd not in", values, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdBetween(String value1, String value2) { + addCriterion("root_pwd between", value1, value2, "rootPwd"); + return (Criteria) this; + } + + public Criteria andRootPwdNotBetween(String value1, String value2) { + addCriterion("root_pwd not between", value1, value2, "rootPwd"); + return (Criteria) this; + } + + public Criteria andIsInitIsNull() { + addCriterion("is_init is null"); + return (Criteria) this; + } + + public Criteria andIsInitIsNotNull() { + addCriterion("is_init is not null"); + return (Criteria) this; + } + + public Criteria andIsInitEqualTo(String value) { + addCriterion("is_init =", value, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitNotEqualTo(String value) { + addCriterion("is_init <>", value, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitGreaterThan(String value) { + addCriterion("is_init >", value, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitGreaterThanOrEqualTo(String value) { + addCriterion("is_init >=", value, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitLessThan(String value) { + addCriterion("is_init <", value, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitLessThanOrEqualTo(String value) { + addCriterion("is_init <=", value, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitLike(String value) { + addCriterion("is_init like", value, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitNotLike(String value) { + addCriterion("is_init not like", value, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitIn(List values) { + addCriterion("is_init in", values, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitNotIn(List values) { + addCriterion("is_init not in", values, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitBetween(String value1, String value2) { + addCriterion("is_init between", value1, value2, "isInit"); + return (Criteria) this; + } + + public Criteria andIsInitNotBetween(String value1, String value2) { + addCriterion("is_init not between", value1, value2, "isInit"); + return (Criteria) this; + } + + public Criteria andCreateTimeIsNull() { + addCriterion("create_time is null"); + return (Criteria) this; + } + + public Criteria andCreateTimeIsNotNull() { + addCriterion("create_time is not null"); + return (Criteria) this; + } + + public Criteria andCreateTimeEqualTo(Date value) { + addCriterion("create_time =", value, "createTime"); + return (Criteria) this; + } + + public Criteria andCreateTimeNotEqualTo(Date value) { + addCriterion("create_time <>", value, "createTime"); + return (Criteria) this; + } + + public Criteria andCreateTimeGreaterThan(Date value) { + addCriterion("create_time >", value, "createTime"); + return (Criteria) this; + } + + public Criteria andCreateTimeGreaterThanOrEqualTo(Date value) { + addCriterion("create_time >=", value, "createTime"); + return (Criteria) this; + } + + public Criteria andCreateTimeLessThan(Date value) { + addCriterion("create_time <", value, "createTime"); + return (Criteria) this; + } + + public Criteria andCreateTimeLessThanOrEqualTo(Date value) { + addCriterion("create_time <=", value, "createTime"); + return (Criteria) this; + } + + public Criteria andCreateTimeIn(List values) { + addCriterion("create_time in", values, "createTime"); + return (Criteria) this; + } + + public Criteria andCreateTimeNotIn(List values) { + addCriterion("create_time not in", values, "createTime"); + return (Criteria) this; + } + + public Criteria andCreateTimeBetween(Date value1, Date value2) { + addCriterion("create_time between", value1, value2, "createTime"); + return (Criteria) this; + } + + public Criteria andCreateTimeNotBetween(Date value1, Date value2) { + addCriterion("create_time not between", value1, value2, "createTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeIsNull() { + addCriterion("update_time is null"); + return (Criteria) this; + } + + public Criteria andUpdateTimeIsNotNull() { + addCriterion("update_time is not null"); + return (Criteria) this; + } + + public Criteria andUpdateTimeEqualTo(Date value) { + addCriterion("update_time =", value, "updateTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeNotEqualTo(Date value) { + addCriterion("update_time <>", value, "updateTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeGreaterThan(Date value) { + addCriterion("update_time >", value, "updateTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeGreaterThanOrEqualTo(Date value) { + addCriterion("update_time >=", value, "updateTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeLessThan(Date value) { + addCriterion("update_time <", value, "updateTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeLessThanOrEqualTo(Date value) { + addCriterion("update_time <=", value, "updateTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeIn(List values) { + addCriterion("update_time in", values, "updateTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeNotIn(List values) { + addCriterion("update_time not in", values, "updateTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeBetween(Date value1, Date value2) { + addCriterion("update_time between", value1, value2, "updateTime"); + return (Criteria) this; + } + + public Criteria andUpdateTimeNotBetween(Date value1, Date value2) { + addCriterion("update_time not between", value1, value2, "updateTime"); + return (Criteria) this; + } + } + + /** + * This class was generated by MyBatis Generator. This class corresponds to the database table devops_doris + * @mbg.generated + */ + public static class Criterion { + private String condition; + private Object value; + private Object secondValue; + private boolean noValue; + private boolean singleValue; + private boolean betweenValue; + private boolean listValue; + private String typeHandler; + + public String getCondition() { + return condition; + } + + public Object getValue() { + return value; + } + + public Object getSecondValue() { + return secondValue; + } + + public boolean isNoValue() { + return noValue; + } + + public boolean isSingleValue() { + return singleValue; + } + + public boolean isBetweenValue() { + return betweenValue; + } + + public boolean isListValue() { + return listValue; + } + + public String getTypeHandler() { + return typeHandler; + } + + protected Criterion(String condition) { + super(); + this.condition = condition; + this.typeHandler = null; + this.noValue = true; + } + + protected Criterion(String condition, Object value, String typeHandler) { + super(); + this.condition = condition; + this.value = value; + this.typeHandler = typeHandler; + if (value instanceof List) { + this.listValue = true; + } else { + this.singleValue = true; + } + } + + protected Criterion(String condition, Object value) { + this(condition, value, null); + } + + protected Criterion(String condition, Object value, Object secondValue, String typeHandler) { + super(); + this.condition = condition; + this.value = value; + this.secondValue = secondValue; + this.typeHandler = typeHandler; + this.betweenValue = true; + } + + protected Criterion(String condition, Object value, Object secondValue) { + this(condition, value, secondValue, null); + } + } + + /** * This class was generated by MyBatis Generator. * This class corresponds to the database table devops_doris * @@ -877,96 +928,4 @@ public class DevopsDorisExample { super(); } } - - /** - * This class was generated by MyBatis Generator. - * This class corresponds to the database table devops_doris - * - * @mbg.generated - */ - public static class Criterion { - private String condition; - - private Object value; - - private Object secondValue; - - private boolean noValue; - - private boolean singleValue; - - private boolean betweenValue; - - private boolean listValue; - - private String typeHandler; - - public String getCondition() { - return condition; - } - - public Object getValue() { - return value; - } - - public Object getSecondValue() { - return secondValue; - } - - public boolean isNoValue() { - return noValue; - } - - public boolean isSingleValue() { - return singleValue; - } - - public boolean isBetweenValue() { - return betweenValue; - } - - public boolean isListValue() { - return listValue; - } - - public String getTypeHandler() { - return typeHandler; - } - - protected Criterion(String condition) { - super(); - this.condition = condition; - this.typeHandler = null; - this.noValue = true; - } - - protected Criterion(String condition, Object value, String typeHandler) { - super(); - this.condition = condition; - this.value = value; - this.typeHandler = typeHandler; - if (value instanceof List) { - this.listValue = true; - } else { - this.singleValue = true; - } - } - - protected Criterion(String condition, Object value) { - this(condition, value, null); - } - - protected Criterion(String condition, Object value, Object secondValue, String typeHandler) { - super(); - this.condition = condition; - this.value = value; - this.secondValue = secondValue; - this.typeHandler = typeHandler; - this.betweenValue = true; - } - - protected Criterion(String condition, Object value, Object secondValue) { - this(condition, value, secondValue, null); - } - } } \ No newline at end of file diff --git a/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlink.java b/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlink.java index 68c627f..e537aa6 100644 --- a/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlink.java +++ b/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlink.java @@ -23,26 +23,56 @@ public class DevopsFlink { * Database Column Remarks: 客户名 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.name * @mbg.generated */ - @TamsCol(value = "租户名", save = 1, query = 1, showWidth = 100) + @TamsCol(value = "租户名", save = 1, query = 1, showWidth = 100, orderby = 1) private String name; + /** + * Database Column Remarks: 集群 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.cluster + * @mbg.generated + */ + @TamsCol(value = "集群名", save = 1, query = 1, showWidth = 100, orderby = 2) + private String cluster; /** * Database Column Remarks: ip1地址 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.ip * @mbg.generated */ - @TamsCol(value = "IP地址", save = 1, query = 1, showWidth = 150) + @TamsCol(value = "IP地址", save = 1, query = 1, showWidth = 150, orderby = 3) private String ip; + /** + * Database Column Remarks: 主机名，系统生成 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.hostname + * @mbg.generated + */ + @TamsCol(value = "主机名", save = -1, query = -1, showWidth = 150) + private String hostname; + /** + * Database Column Remarks: root用户名 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.root_user + * @mbg.generated + */ + @TamsCol(value = "root用户", save = 1, query = -1, orderby = 5) + private String rootUser; /** * Database Column Remarks: root密码 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.root_pwd * @mbg.generated */ - @TamsCol(value = "root密码", save = 1, query = -1) + @TamsCol(value = "root密码", save = 1, query = -1, orderby = 6) private String rootPwd; + /** + * Database Column Remarks: 是否需要做免密 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.need_free + * @mbg.generated + */ + @TamsCol(value = "需要免密", save = 1, query = 0, enumClass = YesOrNo.class, showWidth = 100, orderby = 4) + private String needFree; /** * Database Column Remarks: 是否初始化，yes:已初始化 no:未初始化 创建duckula用户，创建环境变量创建目录 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.is_init * @mbg.generated */ - @TamsCol(value = "初始化", save = 1, query = 0, enumClass = YesOrNo.class, showWidth = 100) + @TamsCol(value = "初始化", save = -1, query = 0, enumClass = YesOrNo.class, showWidth = 100, orderby = 7) private String isInit; + /** + * Database Column Remarks: 是否免密 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.is_free + * @mbg.generated + */ + @TamsCol(value = "免密", save = -1, query = 0, enumClass = YesOrNo.class, showWidth = 100, orderby = 8) + private String isFree; /** * Database Column Remarks: 创建时间 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.create_time * @mbg.generated @@ -58,13 +88,18 @@ public class DevopsFlink { * This method was generated by MyBatis Generator. This method corresponds to the database table devops_flink * @mbg.generated */ - public DevopsFlink(Long id, String name, String ip, String rootPwd, String isInit, Date createTime, - Date updateTime) { + public DevopsFlink(Long id, String name, String cluster, String ip, String hostname, String rootUser, + String rootPwd, String needFree, String isInit, String isFree, Date createTime, Date updateTime) { this.id = id; this.name = name; + this.cluster = cluster; this.ip = ip; + this.hostname = hostname; + this.rootUser = rootUser; this.rootPwd = rootPwd; + this.needFree = needFree; this.isInit = isInit; + this.isFree = isFree; this.createTime = createTime; this.updateTime = updateTime; } @@ -113,6 +148,24 @@ public class DevopsFlink { this.name = name; } + /** + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.cluster + * @return the value of devops_flink.cluster + * @mbg.generated + */ + public String getCluster() { + return cluster; + } + + /** + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.cluster + * @param cluster the value for devops_flink.cluster + * @mbg.generated + */ + public void setCluster(String cluster) { + this.cluster = cluster; + } + /** * This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.ip * @return the value of devops_flink.ip @@ -131,6 +184,42 @@ public class DevopsFlink { this.ip = ip; } + /** + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.hostname + * @return the value of devops_flink.hostname + * @mbg.generated + */ + public String getHostname() { + return hostname; + } + + /** + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.hostname + * @param hostname the value for devops_flink.hostname + * @mbg.generated + */ + public void setHostname(String hostname) { + this.hostname = hostname; + } + + /** + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.root_user + * @return the value of devops_flink.root_user + * @mbg.generated + */ + public String getRootUser() { + return rootUser; + } + + /** + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.root_user + * @param rootUser the value for devops_flink.root_user + * @mbg.generated + */ + public void setRootUser(String rootUser) { + this.rootUser = rootUser; + } + /** * This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.root_pwd * @return the value of devops_flink.root_pwd @@ -149,6 +238,24 @@ public class DevopsFlink { this.rootPwd = rootPwd; } + /** + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.need_free + * @return the value of devops_flink.need_free + * @mbg.generated + */ + public String getNeedFree() { + return needFree; + } + + /** + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.need_free + * @param needFree the value for devops_flink.need_free + * @mbg.generated + */ + public void setNeedFree(String needFree) { + this.needFree = needFree; + } + /** * This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.is_init * @return the value of devops_flink.is_init @@ -167,6 +274,24 @@ public class DevopsFlink { this.isInit = isInit; } + /** + * This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.is_free + * @return the value of devops_flink.is_free + * @mbg.generated + */ + public String getIsFree() { + return isFree; + } + + /** + * This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.is_free + * @param isFree the value for devops_flink.is_free + * @mbg.generated + */ + public void setIsFree(String isFree) { + this.isFree = isFree; + } + /** * This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.create_time * @return the value of devops_flink.create_time diff --git a/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlinkExample.java b/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlinkExample.java index dd6e5ad..dd316f2 100644 --- a/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlinkExample.java +++ b/src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlinkExample.java @@ -293,6 +293,76 @@ public class DevopsFlinkExample { return (Criteria) this; } + public Criteria andClusterIsNull() { + addCriterion("cluster is null"); + return (Criteria) this; + } + + public Criteria andClusterIsNotNull() { + addCriterion("cluster is not null"); + return (Criteria) this; + } + + public Criteria andClusterEqualTo(String value) { + addCriterion("cluster =", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterNotEqualTo(String value) { + addCriterion("cluster <>", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterGreaterThan(String value) { + addCriterion("cluster >", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterGreaterThanOrEqualTo(String value) { + addCriterion("cluster >=", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterLessThan(String value) { + addCriterion("cluster <", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterLessThanOrEqualTo(String value) { + addCriterion("cluster <=", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterLike(String value) { + addCriterion("cluster like", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterNotLike(String value) { + addCriterion("cluster not like", value, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterIn(List values) { + addCriterion("cluster in", values, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterNotIn(List values) { + addCriterion("cluster not in", values, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterBetween(String value1, String value2) { + addCriterion("cluster between", value1, value2, "cluster"); + return (Criteria) this; + } + + public Criteria andClusterNotBetween(String value1, String value2) { + addCriterion("cluster not between", value1, value2, "cluster"); + return (Criteria) this; + } + public Criteria andIpIsNull() { addCriterion("ip is null"); return (Criteria) this; @@ -363,6 +433,146 @@ public class DevopsFlinkExample { return (Criteria) this; } + public Criteria andHostnameIsNull() { + addCriterion("hostname is null"); + return (Criteria) this; + } + + public Criteria andHostnameIsNotNull() { + addCriterion("hostname is not null"); + return (Criteria) this; + } + + public Criteria andHostnameEqualTo(String value) { + addCriterion("hostname =", value, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameNotEqualTo(String value) { + addCriterion("hostname <>", value, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameGreaterThan(String value) { + addCriterion("hostname >", value, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameGreaterThanOrEqualTo(String value) { + addCriterion("hostname >=", value, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameLessThan(String value) { + addCriterion("hostname <", value, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameLessThanOrEqualTo(String value) { + addCriterion("hostname <=", value, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameLike(String value) { + addCriterion("hostname like", value, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameNotLike(String value) { + addCriterion("hostname not like", value, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameIn(List values) { + addCriterion("hostname in", values, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameNotIn(List values) { + addCriterion("hostname not in", values, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameBetween(String value1, String value2) { + addCriterion("hostname between", value1, value2, "hostname"); + return (Criteria) this; + } + + public Criteria andHostnameNotBetween(String value1, String value2) { + addCriterion("hostname not between", value1, value2, "hostname"); + return (Criteria) this; + } + + public Criteria andRootUserIsNull() { + addCriterion("root_user is null"); + return (Criteria) this; + } + + public Criteria andRootUserIsNotNull() { + addCriterion("root_user is not null"); + return (Criteria) this; + } + + public Criteria andRootUserEqualTo(String value) { + addCriterion("root_user =", value, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserNotEqualTo(String value) { + addCriterion("root_user <>", value, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserGreaterThan(String value) { + addCriterion("root_user >", value, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserGreaterThanOrEqualTo(String value) { + addCriterion("root_user >=", value, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserLessThan(String value) { + addCriterion("root_user <", value, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserLessThanOrEqualTo(String value) { + addCriterion("root_user <=", value, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserLike(String value) { + addCriterion("root_user like", value, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserNotLike(String value) { + addCriterion("root_user not like", value, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserIn(List values) { + addCriterion("root_user in", values, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserNotIn(List values) { + addCriterion("root_user not in", values, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserBetween(String value1, String value2) { + addCriterion("root_user between", value1, value2, "rootUser"); + return (Criteria) this; + } + + public Criteria andRootUserNotBetween(String value1, String value2) { + addCriterion("root_user not between", value1, value2, "rootUser"); + return (Criteria) this; + } + public Criteria andRootPwdIsNull() { addCriterion("root_pwd is null"); return (Criteria) this; @@ -433,6 +643,76 @@ public class DevopsFlinkExample { return (Criteria) this; } + public Criteria andNeedFreeIsNull() { + addCriterion("need_free is null"); + return (Criteria) this; + } + + public Criteria andNeedFreeIsNotNull() { + addCriterion("need_free is not null"); + return (Criteria) this; + } + + public Criteria andNeedFreeEqualTo(String value) { + addCriterion("need_free =", value, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeNotEqualTo(String value) { + addCriterion("need_free <>", value, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeGreaterThan(String value) { + addCriterion("need_free >", value, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeGreaterThanOrEqualTo(String value) { + addCriterion("need_free >=", value, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeLessThan(String value) { + addCriterion("need_free <", value, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeLessThanOrEqualTo(String value) { + addCriterion("need_free <=", value, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeLike(String value) { + addCriterion("need_free like", value, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeNotLike(String value) { + addCriterion("need_free not like", value, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeIn(List values) { + addCriterion("need_free in", values, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeNotIn(List values) { + addCriterion("need_free not in", values, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeBetween(String value1, String value2) { + addCriterion("need_free between", value1, value2, "needFree"); + return (Criteria) this; + } + + public Criteria andNeedFreeNotBetween(String value1, String value2) { + addCriterion("need_free not between", value1, value2, "needFree"); + return (Criteria) this; + } + public Criteria andIsInitIsNull() { addCriterion("is_init is null"); return (Criteria) this; @@ -503,6 +783,76 @@ public class DevopsFlinkExample { return (Criteria) this; } + public Criteria andIsFreeIsNull() { + addCriterion("is_free is null"); + return (Criteria) this; + } + + public Criteria andIsFreeIsNotNull() { + addCriterion("is_free is not null"); + return (Criteria) this; + } + + public Criteria andIsFreeEqualTo(String value) { + addCriterion("is_free =", value, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeNotEqualTo(String value) { + addCriterion("is_free <>", value, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeGreaterThan(String value) { + addCriterion("is_free >", value, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeGreaterThanOrEqualTo(String value) { + addCriterion("is_free >=", value, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeLessThan(String value) { + addCriterion("is_free <", value, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeLessThanOrEqualTo(String value) { + addCriterion("is_free <=", value, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeLike(String value) { + addCriterion("is_free like", value, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeNotLike(String value) { + addCriterion("is_free not like", value, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeIn(List values) { + addCriterion("is_free in", values, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeNotIn(List values) { + addCriterion("is_free not in", values, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeBetween(String value1, String value2) { + addCriterion("is_free between", value1, value2, "isFree"); + return (Criteria) this; + } + + public Criteria andIsFreeNotBetween(String value1, String value2) { + addCriterion("is_free not between", value1, value2, "isFree"); + return (Criteria) this; + } + public Criteria andCreateTimeIsNull() { addCriterion("create_time is null"); return (Criteria) this; diff --git a/src/main/java/net/wicp/tams/app/duckula/controller/config/constant/DevOpsType.java b/src/main/java/net/wicp/tams/app/duckula/controller/config/constant/DevOpsType.java index 8faa403..46161e7 100644 --- a/src/main/java/net/wicp/tams/app/duckula/controller/config/constant/DevOpsType.java +++ b/src/main/java/net/wicp/tams/app/duckula/controller/config/constant/DevOpsType.java @@ -10,16 +10,44 @@ import net.wicp.tams.common.constant.dic.intf.IEnumCombobox; */ public enum DevOpsType implements IEnumCombobox { - flink("flink流计算", "oss://lc-bigdata/doris/check_system.sh", "oss://lc-bigdata/doris/%s/check_system.sh", "v12"), + flink("flink流计算", "oss://lc-bigdata/flink", "oss://lc-bigdata/flink/init/frontcheck.sh", + "oss://lc-bigdata/doris/%s/check_system.sh", "v12", "oss://lc-bigdata/flink/init.tar", + new String[] { "oss://lc-bigdata/flink/init/frontcheck.sh" }), - doris("大数据存储", "oss://lc-bigdata/doris/check_system.sh", "", ""), + doris("大数据存储", "oss://lc-bigdata/doris", "oss://lc-bigdata/doris/check_system.sh", "", "", + "oss://lc-bigdata/doris/check_system.sh", new String[] {}), - dmep("dmep数据平台", "", "", ""); + dmep("dmep数据平台", "oss://lc-bigdata/dmep", "", "", "", "oss://lc-bigdata/doris/check_system.sh", new String[] {}); private final String desc; private final String checkurl; + private final String baseurl;// 根路径，要跟据它来截取相对路径 private final String installurlFormat; private final String lastversion; + private final String[] otherparams;// 其它文件 ，如flink需要在check后要做免密 + private final String checkDownFile;//OSS要下载的文件 + + public String getCheckDownFile() { + return checkDownFile; + } + + public String getRelaPath(String url) { + return url.replace(this.baseurl, ""); + } + + public String getRelaPathCheck() { + return getRelaPath(this.checkurl); + } + + public String getRelaPathCheckDir() { + String fileName = this.checkurl.substring(this.checkurl.lastIndexOf("/") + 1); + String replace = getRelaPathCheck().replace(fileName, ""); + return replace; + } + + public String[] getOtherparams() { + return otherparams; + } public String getCheckurl() { return checkurl; @@ -33,11 +61,15 @@ public enum DevOpsType implements IEnumCombobox { return String.format(this.installurlFormat, lastversion); } - private DevOpsType(String desc, String checkurl, String installurlFormat, String lastversion) { + private DevOpsType(String desc, String baseurl, String checkurl, String installurlFormat, String lastversion, + String checkDownFile, String[] otherparams) { this.desc = desc; + this.baseurl = baseurl; this.checkurl = checkurl; this.installurlFormat = installurlFormat; this.lastversion = lastversion; + this.checkDownFile = checkDownFile; + this.otherparams = otherparams; } public String getDesc() { diff --git a/src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsDorisMapper.java b/src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsDorisMapper.java index 2955970..759ca33 100644 --- a/src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsDorisMapper.java +++ b/src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsDorisMapper.java @@ -15,125 +15,84 @@ import net.wicp.tams.app.duckula.controller.bean.models.DevopsDoris; import net.wicp.tams.app.duckula.controller.bean.models.DevopsDorisExample; public interface DevopsDorisMapper extends BaseMapper { - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - long countByExample(DevopsDorisExample example); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - int deleteByExample(DevopsDorisExample example); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - @Delete({ - "delete from devops_doris", - "where id = #{id,jdbcType=BIGINT}" - }) - int deleteByPrimaryKey(Long id); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - @Insert({ - "insert into devops_doris (id, name, ", - "ip, cluster, roles, ", - "fs, root_pwd, is_init, ", - "create_time, update_time)", - "values (#{id,jdbcType=BIGINT}, #{name,jdbcType=VARCHAR}, ", - "#{ip,jdbcType=VARCHAR}, #{cluster,jdbcType=VARCHAR}, #{roles,jdbcType=VARCHAR}, ", - "#{fs,jdbcType=VARCHAR}, #{rootPwd,jdbcType=VARCHAR}, #{isInit,jdbcType=VARCHAR}, ", - "#{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP})" - }) - int insert(DevopsDoris record); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - int insertSelective(DevopsDoris record); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - List selectByExample(DevopsDorisExample example); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - @Select({ - "select", - "id, name, ip, cluster, roles, fs, root_pwd, is_init, create_time, update_time", - "from devops_doris", - "where id = #{id,jdbcType=BIGINT}" - }) - @ResultMap("net.wicp.tams.app.duckula.controller.dao.DevopsDorisMapper.BaseResultMap") - DevopsDoris selectByPrimaryKey(Long id); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - int updateByExampleSelective(@Param("record") DevopsDoris record, @Param("example") DevopsDorisExample example); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - int updateByExample(@Param("record") DevopsDoris record, @Param("example") DevopsDorisExample example); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - int updateByPrimaryKeySelective(DevopsDoris record); - - /** - * This method was generated by MyBatis Generator. - * This method corresponds to the database table devops_doris - * - * @mbg.generated - */ - @Update({ - "update devops_doris", - "set name = #{name,jdbcType=VARCHAR},", - "ip = #{ip,jdbcType=VARCHAR},", - "cluster = #{cluster,jdbcType=VARCHAR},", - "roles = #{roles,jdbcType=VARCHAR},", - "fs = #{fs,jdbcType=VARCHAR},", - "root_pwd = #{rootPwd,jdbcType=VARCHAR},", - "is_init = #{isInit,jdbcType=VARCHAR},", - "create_time = #{createTime,jdbcType=TIMESTAMP},", - "update_time = #{updateTime,jdbcType=TIMESTAMP}", - "where id = #{id,jdbcType=BIGINT}" - }) - int updateByPrimaryKey(DevopsDoris record); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + long countByExample(DevopsDorisExample example); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + int deleteByExample(DevopsDorisExample example); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + @Delete({ "delete from devops_doris", "where id = #{id,jdbcType=BIGINT}" }) + int deleteByPrimaryKey(Long id); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + @Insert({ "insert into devops_doris (id, name, ", "ip, cluster, roles, ", "fs, root_pwd, is_init, ", + "create_time, update_time)", "values (#{id,jdbcType=BIGINT}, #{name,jdbcType=VARCHAR}, ", + "#{ip,jdbcType=VARCHAR}, #{cluster,jdbcType=VARCHAR}, #{roles,jdbcType=VARCHAR}, ", + "#{fs,jdbcType=VARCHAR}, #{rootPwd,jdbcType=VARCHAR}, #{isInit,jdbcType=VARCHAR}, ", + "#{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP})" }) + int insert(DevopsDoris record); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + int insertSelective(DevopsDoris record); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + List selectByExample(DevopsDorisExample example); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + @Select({ "select", "id, name, ip, cluster, roles, fs, root_pwd, is_init, create_time, update_time", + "from devops_doris", "where id = #{id,jdbcType=BIGINT}" }) + @ResultMap("net.wicp.tams.app.duckula.controller.dao.DevopsDorisMapper.BaseResultMap") + DevopsDoris selectByPrimaryKey(Long id); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + int updateByExampleSelective(@Param("record") DevopsDoris record, @Param("example") DevopsDorisExample example); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + int updateByExample(@Param("record") DevopsDoris record, @Param("example") DevopsDorisExample example); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + int updateByPrimaryKeySelective(DevopsDoris record); + + /** + * This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris + * @mbg.generated + */ + @Update({ "update devops_doris", "set name = #{name,jdbcType=VARCHAR},", "ip = #{ip,jdbcType=VARCHAR},", + "cluster = #{cluster,jdbcType=VARCHAR},", "roles = #{roles,jdbcType=VARCHAR},", + "fs = #{fs,jdbcType=VARCHAR},", "root_pwd = #{rootPwd,jdbcType=VARCHAR},", + "is_init = #{isInit,jdbcType=VARCHAR},", "create_time = #{createTime,jdbcType=TIMESTAMP},", + "update_time = #{updateTime,jdbcType=TIMESTAMP}", "where id = #{id,jdbcType=BIGINT}" }) + int updateByPrimaryKey(DevopsDoris record); } \ No newline at end of file diff --git a/src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsFlinkMapper.java b/src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsFlinkMapper.java index 247c7e1..987582c 100644 --- a/src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsFlinkMapper.java +++ b/src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsFlinkMapper.java @@ -39,10 +39,13 @@ public interface DevopsFlinkMapper extends BaseMapper{ * This method was generated by MyBatis Generator. This method corresponds to the database table devops_flink * @mbg.generated */ - @Insert({ "insert into devops_flink (id, name, ", "ip, root_pwd, is_init, ", "create_time, update_time)", + @Insert({ "insert into devops_flink (id, name, ", "cluster, ip, hostname, ", "root_user, root_pwd, ", + "need_free, is_init, ", "is_free, create_time, ", "update_time)", "values (#{id,jdbcType=BIGINT}, #{name,jdbcType=VARCHAR}, ", - "#{ip,jdbcType=VARCHAR}, #{rootPwd,jdbcType=VARCHAR}, #{isInit,jdbcType=VARCHAR}, ", - "#{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP})" }) + "#{cluster,jdbcType=VARCHAR}, #{ip,jdbcType=VARCHAR}, #{hostname,jdbcType=VARCHAR}, ", + "#{rootUser,jdbcType=VARCHAR}, #{rootPwd,jdbcType=VARCHAR}, ", + "#{needFree,jdbcType=VARCHAR}, #{isInit,jdbcType=VARCHAR}, ", + "#{isFree,jdbcType=VARCHAR}, #{createTime,jdbcType=TIMESTAMP}, ", "#{updateTime,jdbcType=TIMESTAMP})" }) int insert(DevopsFlink record); /** @@ -61,8 +64,8 @@ public interface DevopsFlinkMapper extends BaseMapper{ * This method was generated by MyBatis Generator. This method corresponds to the database table devops_flink * @mbg.generated */ - @Select({ "select", "id, name, ip, root_pwd, is_init, create_time, update_time", "from devops_flink", - "where id = #{id,jdbcType=BIGINT}" }) + @Select({ "select", "id, name, cluster, ip, hostname, root_user, root_pwd, need_free, is_init, is_free, ", + "create_time, update_time", "from devops_flink", "where id = #{id,jdbcType=BIGINT}" }) @ResultMap("net.wicp.tams.app.duckula.controller.dao.DevopsFlinkMapper.BaseResultMap") DevopsFlink selectByPrimaryKey(Long id); @@ -88,9 +91,11 @@ public interface DevopsFlinkMapper extends BaseMapper{ * This method was generated by MyBatis Generator. This method corresponds to the database table devops_flink * @mbg.generated */ - @Update({ "update devops_flink", "set name = #{name,jdbcType=VARCHAR},", "ip = #{ip,jdbcType=VARCHAR},", - "root_pwd = #{rootPwd,jdbcType=VARCHAR},", "is_init = #{isInit,jdbcType=VARCHAR},", - "create_time = #{createTime,jdbcType=TIMESTAMP},", "update_time = #{updateTime,jdbcType=TIMESTAMP}", - "where id = #{id,jdbcType=BIGINT}" }) + @Update({ "update devops_flink", "set name = #{name,jdbcType=VARCHAR},", "cluster = #{cluster,jdbcType=VARCHAR},", + "ip = #{ip,jdbcType=VARCHAR},", "hostname = #{hostname,jdbcType=VARCHAR},", + "root_user = #{rootUser,jdbcType=VARCHAR},", "root_pwd = #{rootPwd,jdbcType=VARCHAR},", + "need_free = #{needFree,jdbcType=VARCHAR},", "is_init = #{isInit,jdbcType=VARCHAR},", + "is_free = #{isFree,jdbcType=VARCHAR},", "create_time = #{createTime,jdbcType=TIMESTAMP},", + "update_time = #{updateTime,jdbcType=TIMESTAMP}", "where id = #{id,jdbcType=BIGINT}" }) int updateByPrimaryKey(DevopsFlink record); } \ No newline at end of file diff --git a/src/main/java/net/wicp/tams/duckula/ops/pages/devops/FlinkConfig.java b/src/main/java/net/wicp/tams/duckula/ops/pages/devops/FlinkConfig.java index 9c0c8d1..75ef34f 100644 --- a/src/main/java/net/wicp/tams/duckula/ops/pages/devops/FlinkConfig.java +++ b/src/main/java/net/wicp/tams/duckula/ops/pages/devops/FlinkConfig.java @@ -1,5 +1,8 @@ package net.wicp.tams.duckula.ops.pages.devops; +import java.util.List; + +import org.apache.commons.collections.CollectionUtils; import org.apache.tapestry5.ioc.annotations.Inject; import org.apache.tapestry5.util.TextStreamResponse; @@ -8,11 +11,15 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import lombok.extern.slf4j.Slf4j; import net.wicp.tams.app.duckula.controller.bean.models.DevopsFlink; +import net.wicp.tams.app.duckula.controller.bean.models.DevopsFlinkExample; +import net.wicp.tams.app.duckula.controller.bean.models.DevopsFlinkExample.Criteria; import net.wicp.tams.app.duckula.controller.config.constant.DevOpsType; import net.wicp.tams.app.duckula.controller.dao.DevopsFlinkMapper; import net.wicp.tams.common.Result; +import net.wicp.tams.common.apiext.IOUtil; import net.wicp.tams.common.apiext.StringUtil; import net.wicp.tams.common.constant.PathType; +import net.wicp.tams.common.constant.dic.YesOrNo; import net.wicp.tams.common.os.SSHAssit; import net.wicp.tams.common.os.pool.SSHConnection; import net.wicp.tams.component.tools.TapestryAssist; @@ -27,6 +34,16 @@ public class FlinkConfig extends ParentPageBean { @Override public void doSave(DevopsFlink t, boolean isInsert) { if (isInsert) { + t.setIsInit(YesOrNo.no.name()); + t.setIsFree(YesOrNo.no.name()); + List list = queryHostByCluster(t.getCluster()); + int lastindex = 0; + if (CollectionUtils.isNotEmpty(list)) { + String hostname = list.get(list.size() - 1).getHostname(); + String last = hostname.substring(hostname.length() - 1, hostname.length()); + lastindex = Integer.parseInt(last); + } + t.setHostname(String.format("prod-bigdata-flink%02d", ++lastindex));// 设置主机名 devopsFlinkMapper.insert(t); } else { devopsFlinkMapper.updateByPrimaryKeySelective(t); @@ -53,6 +70,16 @@ public class FlinkConfig extends ParentPageBean { } } + // 不排序是以id顺序 + private List queryHostByCluster(String cluster) { + DevopsFlinkExample example = new DevopsFlinkExample(); + Criteria criteria = example.createCriteria(); + criteria.andClusterEqualTo(cluster); + List list = devopsFlinkMapper.selectByExample(example); + + return list; + } + /*** * 测试用后端调用 * @@ -60,17 +87,69 @@ public class FlinkConfig extends ParentPageBean { */ public TextStreamResponse onCheckHost() { final DevopsFlink devopsFlink = TapestryAssist.getBeanFromPage(DevopsFlink.class, requestGlobals); + // 查询此集群下面的主机配置 + List list = queryHostByCluster(devopsFlink.getCluster()); + StringBuffer checkparam = new StringBuffer(); + StringBuffer freeparam = new StringBuffer(); + for (int i = 0; i < list.size(); i++) { + DevopsFlink flink = list.get(i); + checkparam.append(String.format(" %s %s", flink.getIp(), flink.getHostname())); + freeparam.append(String.format(" %s %s %s", flink.getRootUser(), flink.getHostname(), flink.getRootPwd())); + } // 1、OSS下载 - String localPath = PathType.getPath(DevOpsType.flink.getCheckurl()); + String localPath = PathType.getPath(DevOpsType.flink.getCheckDownFile()); // 1、登陆 - SSHConnection conn = SSHAssit.getConn(devopsFlink.getIp(), "root", devopsFlink.getRootPwd()); - String fileName = localPath.substring(localPath.lastIndexOf("/") + 1); - conn.scp(localPath, fileName, "~", "0744"); - // 执行 - Result result = conn.executeCommand(String.format("sh ~/%s", fileName)); - log.info(result.getMessage()); - conn.close(); - return TapestryAssist.getTextStreamResponse(Result.getError("检查结果：" + result.getMessage())); + SSHConnection conn = SSHAssit.getConn(devopsFlink.getIp(), devopsFlink.getRootUser(), devopsFlink.getRootPwd()); + // String fileName = localPath.substring(localPath.lastIndexOf("/") + 1); + String remoteDir = IOUtil.mergeFolderAndFilePath("~/", DevOpsType.flink.getRelaPathCheckDir()); + conn.executeCommand("mkdir -p " + remoteDir); + // conn.scpToDir(localPath,remoteDir , "0744"); + conn.scpDir(localPath, remoteDir, "0744", new String[] {}, new String[] {}); + // conn.scp(localPath, fileName, "~" + DevOpsType.flink.getRelaPathCheck(), + // "0744"); + // check + Result result = conn.executeCommand(String.format("sh %s %s", + IOUtil.mergeFolderAndFilePath("~/", DevOpsType.flink.getRelaPathCheck()), checkparam.toString())); + if (!result.isSuc()) {// 不成功 + log.info(result.getMessage()); + conn.close(); + return TapestryAssist.getTextStreamResponse(Result.getError(result.getMessage())); + } + devopsFlink.setIsInit(YesOrNo.yes.name()); + devopsFlinkMapper.updateByPrimaryKeySelective(devopsFlink);// 保存check结果 + if (YesOrNo.yes.name().equals(devopsFlink.getNeedFree())) { + boolean doFree = true;// 默认需要做 + for (DevopsFlink ele : list) { + if (YesOrNo.no.name().equals(ele.getIsInit())) { + doFree = false; + break; + } + } + if (doFree) { + // 三台机都做免密 + for (DevopsFlink devopsFlink2 : list) { + SSHConnection freeconn = SSHAssit.getConn(devopsFlink.getIp(), devopsFlink2.getRootUser(), + devopsFlink2.getRootPwd()); + try { + // free + Result freeRs = freeconn.executeCommand(String.format("sh %s %s", + IOUtil.mergeFolderAndFilePath("~/", + DevOpsType.flink.getRelaPath(DevOpsType.flink.getOtherparams()[0])), + freeparam.toString())); + if (freeRs.isSuc()) { + // 保存 + devopsFlink2.setIsFree(YesOrNo.yes.name()); + devopsFlinkMapper.updateByPrimaryKeySelective(devopsFlink2);// 保存免密结果 + + } + } finally { + SSHAssit.close(freeconn); + } + } + + } + } + return TapestryAssist.getTextStreamResponse(Result.getSuc()); } } diff --git a/src/main/resources/mybatis/primary/sqlmap/DevopsFlinkMapper.xml b/src/main/resources/mybatis/primary/sqlmap/DevopsFlinkMapper.xml index adfcdab..f04cd57 100644 --- a/src/main/resources/mybatis/primary/sqlmap/DevopsFlinkMapper.xml +++ b/src/main/resources/mybatis/primary/sqlmap/DevopsFlinkMapper.xml @@ -9,9 +9,14 @@ + + + + + @@ -87,7 +92,8 @@ WARNING - @mbg.generated This element is automatically generated by MyBatis Generator, do not modify. --> - id, name, ip, root_pwd, is_init, create_time, update_time + id, name, cluster, ip, hostname, root_user, root_pwd, need_free, is_init, is_free, + create_time, update_time