Browse Source

Execute update of the rule nodes on each upgrade of the system

pull/8753/head
Andrii Shvaika 3 years ago
parent
commit
64a3c6402d
  1. 1
      application/src/main/java/org/thingsboard/server/install/ThingsboardInstallService.java
  2. 1
      application/src/main/java/org/thingsboard/server/service/install/update/DataUpdateService.java
  3. 8
      application/src/main/java/org/thingsboard/server/service/install/update/DefaultDataUpdateService.java

1
application/src/main/java/org/thingsboard/server/install/ThingsboardInstallService.java

@ -268,6 +268,7 @@ public class ThingsboardInstallService {
entityDatabaseSchemaService.createOrUpdateViewsAndFunctions(); entityDatabaseSchemaService.createOrUpdateViewsAndFunctions();
entityDatabaseSchemaService.createOrUpdateDeviceInfoView(persistToTelemetry); entityDatabaseSchemaService.createOrUpdateDeviceInfoView(persistToTelemetry);
log.info("Updating system data..."); log.info("Updating system data...");
dataUpdateService.upgradeRuleNodes();
systemDataLoaderService.updateSystemWidgets(); systemDataLoaderService.updateSystemWidgets();
installScripts.loadSystemLwm2mResources(); installScripts.loadSystemLwm2mResources();
} }

1
application/src/main/java/org/thingsboard/server/service/install/update/DataUpdateService.java

@ -19,4 +19,5 @@ public interface DataUpdateService {
void updateData(String fromVersion) throws Exception; void updateData(String fromVersion) throws Exception;
void upgradeRuleNodes();
} }

8
application/src/main/java/org/thingsboard/server/service/install/update/DefaultDataUpdateService.java

@ -209,16 +209,16 @@ public class DefaultDataUpdateService implements DataUpdateService {
log.info("Skipping edge events migration"); log.info("Skipping edge events migration");
} }
break; break;
case "3.5.0": case "3.5.1":
log.info("Updating data from version 3.5.0 to 3.5.1 ..."); log.info("Updating data from version 3.5.1 to 3.5.2 ...");
upgradeRuleNodes();
break; break;
default: default:
throw new RuntimeException("Unable to update data, unsupported fromVersion: " + fromVersion); throw new RuntimeException("Unable to update data, unsupported fromVersion: " + fromVersion);
} }
} }
private void upgradeRuleNodes() { @Override
public void upgradeRuleNodes() {
try { try {
log.info("Lookup rule nodes to upgrade ..."); log.info("Lookup rule nodes to upgrade ...");
var nodeClassToVersionMap = getNodeClassToVersionMap(); var nodeClassToVersionMap = getNodeClassToVersionMap();

Loading…
Cancel
Save