Browse Source

Get rid of configuration field

pull/3693/head
Volodymyr Babak 6 years ago
parent
commit
b52d2aae17
  1. 1
      application/src/main/data/upgrade/2.6.0/schema_update.cql
  2. 1
      application/src/main/data/upgrade/2.6.0/schema_update.sql
  3. 2
      application/src/main/java/org/thingsboard/server/service/edge/rpc/EdgeGrpcSession.java
  4. 2
      common/data/src/main/java/org/thingsboard/server/common/data/edge/Edge.java
  5. 2
      common/edge-api/src/main/proto/edge.proto
  6. 1
      dao/src/main/java/org/thingsboard/server/dao/model/ModelConstants.java
  7. 6
      dao/src/main/java/org/thingsboard/server/dao/model/nosql/EdgeEntity.java
  8. 6
      dao/src/main/java/org/thingsboard/server/dao/model/sql/EdgeEntity.java
  9. 1
      dao/src/main/resources/cassandra/schema-entities.cql
  10. 1
      dao/src/main/resources/sql/schema-entities-hsql.sql
  11. 1
      dao/src/main/resources/sql/schema-entities.sql

1
application/src/main/data/upgrade/2.6.0/schema_update.cql

@ -59,7 +59,6 @@ CREATE TABLE IF NOT EXISTS thingsboard.edge (
secret text,
edge_license_key text,
cloud_endpoint text,
configuration text,
additional_info text,
PRIMARY KEY (id, tenant_id, customer_id, type)
);

1
application/src/main/data/upgrade/2.6.0/schema_update.sql

@ -19,7 +19,6 @@ CREATE TABLE IF NOT EXISTS edge (
additional_info varchar,
customer_id varchar(31),
root_rule_chain_id varchar(31),
configuration varchar(10000000),
type varchar(255),
name varchar(255),
label varchar(255),

2
application/src/main/java/org/thingsboard/server/service/edge/rpc/EdgeGrpcSession.java

@ -969,7 +969,7 @@ public final class EdgeGrpcSession implements Closeable {
.setSecret(edge.getSecret())
.setEdgeLicenseKey(edge.getEdgeLicenseKey())
.setCloudEndpoint(edge.getCloudEndpoint())
.setConfiguration(JacksonUtil.toString(edge.getConfiguration()))
.setAdditionalInfo(JacksonUtil.toString(edge.getAdditionalInfo()))
.setCloudType("CE");
if (edge.getCustomerId() != null) {
builder.setCustomerIdMSB(edge.getCustomerId().getId().getMostSignificantBits())

2
common/data/src/main/java/org/thingsboard/server/common/data/edge/Edge.java

@ -47,7 +47,6 @@ public class Edge extends SearchTextBasedWithAdditionalInfo<EdgeId> implements H
private String secret;
private String edgeLicenseKey;
private String cloudEndpoint;
private transient JsonNode configuration;
public Edge() {
super();
@ -68,7 +67,6 @@ public class Edge extends SearchTextBasedWithAdditionalInfo<EdgeId> implements H
this.secret = edge.getSecret();
this.edgeLicenseKey = edge.getEdgeLicenseKey();
this.cloudEndpoint = edge.getCloudEndpoint();
this.configuration = edge.getConfiguration();
}
@Override

2
common/edge-api/src/main/proto/edge.proto

@ -87,7 +87,7 @@ message EdgeConfiguration {
string secret = 10;
string edgeLicenseKey = 11;
string cloudEndpoint = 12;
string configuration = 13;
string additionalInfo = 13;
string cloudType = 14;
}

1
dao/src/main/java/org/thingsboard/server/dao/model/ModelConstants.java

@ -366,7 +366,6 @@ public class ModelConstants {
public static final String EDGE_NAME_PROPERTY = "name";
public static final String EDGE_LABEL_PROPERTY = "label";
public static final String EDGE_TYPE_PROPERTY = "type";
public static final String EDGE_CONFIGURATION_PROPERTY = "configuration";
public static final String EDGE_ADDITIONAL_INFO_PROPERTY = ADDITIONAL_INFO_PROPERTY;
public static final String EDGE_BY_TENANT_AND_SEARCH_TEXT_COLUMN_FAMILY_NAME = "edge_by_tenant_and_search_text";
public static final String EDGE_BY_TENANT_BY_TYPE_AND_SEARCH_TEXT_COLUMN_FAMILY_NAME = "edge_by_tenant_by_type_and_search_text";

6
dao/src/main/java/org/thingsboard/server/dao/model/nosql/EdgeEntity.java

@ -34,7 +34,6 @@ import java.util.UUID;
import static org.thingsboard.server.dao.model.ModelConstants.EDGE_ADDITIONAL_INFO_PROPERTY;
import static org.thingsboard.server.dao.model.ModelConstants.EDGE_CLOUD_ENDPOINT_KEY_PROPERTY;
import static org.thingsboard.server.dao.model.ModelConstants.EDGE_COLUMN_FAMILY_NAME;
import static org.thingsboard.server.dao.model.ModelConstants.EDGE_CONFIGURATION_PROPERTY;
import static org.thingsboard.server.dao.model.ModelConstants.EDGE_CUSTOMER_ID_PROPERTY;
import static org.thingsboard.server.dao.model.ModelConstants.EDGE_LABEL_PROPERTY;
import static org.thingsboard.server.dao.model.ModelConstants.EDGE_LICENSE_KEY_PROPERTY;
@ -91,9 +90,6 @@ public class EdgeEntity implements SearchTextEntity<Edge> {
@Column(name = EDGE_SECRET_PROPERTY)
private String secret;
@Column(name = EDGE_CONFIGURATION_PROPERTY, codec = JsonCodec.class)
private JsonNode configuration;
@Column(name = EDGE_ADDITIONAL_INFO_PROPERTY, codec = JsonCodec.class)
private JsonNode additionalInfo;
@ -131,7 +127,6 @@ public class EdgeEntity implements SearchTextEntity<Edge> {
this.secret = edge.getSecret();
this.edgeLicenseKey = edge.getEdgeLicenseKey();
this.cloudEndpoint = edge.getCloudEndpoint();
this.configuration = edge.getConfiguration();
this.additionalInfo = edge.getAdditionalInfo();
}
@ -160,7 +155,6 @@ public class EdgeEntity implements SearchTextEntity<Edge> {
edge.setSecret(secret);
edge.setEdgeLicenseKey(edgeLicenseKey);
edge.setCloudEndpoint(cloudEndpoint);
edge.setConfiguration(configuration);
edge.setAdditionalInfo(additionalInfo);
return edge;
}

6
dao/src/main/java/org/thingsboard/server/dao/model/sql/EdgeEntity.java

@ -89,10 +89,6 @@ public class EdgeEntity extends BaseSqlEntity<Edge> implements SearchTextEntity<
@Column(name = EDGE_CLOUD_ENDPOINT_KEY_PROPERTY)
private String cloudEndpoint;
@Type(type = "json")
@Column(name = ModelConstants.EDGE_CONFIGURATION_PROPERTY)
private JsonNode configuration;
@Type(type = "json")
@Column(name = ModelConstants.EDGE_ADDITIONAL_INFO_PROPERTY)
private JsonNode additionalInfo;
@ -121,7 +117,6 @@ public class EdgeEntity extends BaseSqlEntity<Edge> implements SearchTextEntity<
this.secret = edge.getSecret();
this.edgeLicenseKey = edge.getEdgeLicenseKey();
this.cloudEndpoint = edge.getCloudEndpoint();
this.configuration = edge.getConfiguration();
this.additionalInfo = edge.getAdditionalInfo();
}
@ -159,7 +154,6 @@ public class EdgeEntity extends BaseSqlEntity<Edge> implements SearchTextEntity<
edge.setSecret(secret);
edge.setEdgeLicenseKey(edgeLicenseKey);
edge.setCloudEndpoint(cloudEndpoint);
edge.setConfiguration(configuration);
edge.setAdditionalInfo(additionalInfo);
return edge;
}

1
dao/src/main/resources/cassandra/schema-entities.cql

@ -739,7 +739,6 @@ CREATE TABLE IF NOT EXISTS thingsboard.edge (
secret text,
edge_license_key text,
cloud_endpoint text,
configuration text,
additional_info text,
PRIMARY KEY (id, tenant_id, customer_id, type)
);

1
dao/src/main/resources/sql/schema-entities-hsql.sql

@ -259,7 +259,6 @@ CREATE TABLE IF NOT EXISTS edge (
additional_info varchar,
customer_id varchar(31),
root_rule_chain_id varchar(31),
configuration varchar(10000000),
type varchar(255),
name varchar(255),
label varchar(255),

1
dao/src/main/resources/sql/schema-entities.sql

@ -259,7 +259,6 @@ CREATE TABLE IF NOT EXISTS edge (
additional_info varchar,
customer_id varchar(31),
root_rule_chain_id varchar(31),
configuration varchar(10000000),
type varchar(255),
name varchar(255),
label varchar(255),

Loading…
Cancel
Save