Fix Cassandra DB upgrade.

Igor Kulikov
1 parent 626063df
Showing 1 changed file with 10 additions and 0 deletions
application/src/main/java/org/thingsboard/server/service/install/CassandraDatabaseUpgradeService.java
--- a/application/src/main/java/org/thingsboard/server/service/install/CassandraDatabaseUpgradeService.java
View file @99dde0c
+++ b/application/src/main/java/org/thingsboard/server/service/install/CassandraDatabaseUpgradeService.java
View file @99dde0c
@@ -203,6 +203,16 @@ public class CassandraDatabaseUpgradeService implements DatabaseUpgradeService {
                 log.info("Schema updated.");
                 break;
+
+            case "2.0.0":
+
+                log.info("Updating schema ...");
+                schemaUpdateFile = Paths.get(installScripts.getDataDir(), "upgrade", "2.1.1", SCHEMA_UPDATE_CQL);
+                loadCql(schemaUpdateFile);
+                log.info("Schema updated.");
+
+                break;
+
             default:
                 throw new RuntimeException("Unable to upgrade Cassandra database, unsupported fromVersion: " + fromVersion);
         }