thingsboard-aplcache

Details

diff --git a/application/src/main/java/org/thingsboard/server/install/ThingsboardInstallService.java b/application/src/main/java/org/thingsboard/server/install/ThingsboardInstallService.java
index f863d0b..2a55abf 100644
--- a/application/src/main/java/org/thingsboard/server/install/ThingsboardInstallService.java
+++ b/application/src/main/java/org/thingsboard/server/install/ThingsboardInstallService.java
@@ -24,9 +24,10 @@ import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Service;
 import org.thingsboard.server.service.component.ComponentDiscoveryService;
 import org.thingsboard.server.service.install.DataUpdateService;
-import org.thingsboard.server.service.install.DatabaseSchemaService;
 import org.thingsboard.server.service.install.DatabaseUpgradeService;
+import org.thingsboard.server.service.install.EntityDatabaseSchemaService;
 import org.thingsboard.server.service.install.SystemDataLoaderService;
+import org.thingsboard.server.service.install.TsDatabaseSchemaService;
 
 @Service
 @Profile("install")
@@ -43,7 +44,10 @@ public class ThingsboardInstallService {
     private Boolean loadDemo;
 
     @Autowired
-    private DatabaseSchemaService databaseSchemaService;
+    private EntityDatabaseSchemaService entityDatabaseSchemaService;
+
+    @Autowired
+    private TsDatabaseSchemaService tsDatabaseSchemaService;
 
     @Autowired
     private DatabaseUpgradeService databaseUpgradeService;
@@ -114,9 +118,13 @@ public class ThingsboardInstallService {
 
                 log.info("Starting ThingsBoard Installation...");
 
-                log.info("Installing DataBase schema...");
+                log.info("Installing DataBase schema for entities...");
+
+                entityDatabaseSchemaService.createDatabaseSchema();
+
+                log.info("Installing DataBase schema for timeseries...");
 
-                databaseSchemaService.createDatabaseSchema();
+                tsDatabaseSchemaService.createDatabaseSchema();
 
                 log.info("Loading system data...");
 
diff --git a/application/src/main/java/org/thingsboard/server/service/install/CassandraAbstractDatabaseSchemaService.java b/application/src/main/java/org/thingsboard/server/service/install/CassandraAbstractDatabaseSchemaService.java
index d8d4744..10559ba 100644
--- a/application/src/main/java/org/thingsboard/server/service/install/CassandraAbstractDatabaseSchemaService.java
+++ b/application/src/main/java/org/thingsboard/server/service/install/CassandraAbstractDatabaseSchemaService.java
@@ -25,7 +25,7 @@ import java.nio.file.Paths;
 import java.util.List;
 
 @Slf4j
-public abstract class CassandraAbstractDatabaseSchemaService /*implements DatabaseSchemaService*/ {
+public abstract class CassandraAbstractDatabaseSchemaService implements DatabaseSchemaService {
 
     private static final String CASSANDRA_DIR = "cassandra";
 
@@ -41,7 +41,7 @@ public abstract class CassandraAbstractDatabaseSchemaService /*implements Databa
         this.schemaCql = schemaCql;
     }
 
-    //@Override
+    @Override
     public void createDatabaseSchema() throws Exception {
         log.info("Installing Cassandra DataBase schema part: " + schemaCql);
         Path schemaFile = Paths.get(installScripts.getDataDir(), CASSANDRA_DIR, schemaCql);
diff --git a/application/src/main/java/org/thingsboard/server/service/install/CassandraEntityDatabaseSchemaService.java b/application/src/main/java/org/thingsboard/server/service/install/CassandraEntityDatabaseSchemaService.java
index 9e4afb1..7937ef2 100644
--- a/application/src/main/java/org/thingsboard/server/service/install/CassandraEntityDatabaseSchemaService.java
+++ b/application/src/main/java/org/thingsboard/server/service/install/CassandraEntityDatabaseSchemaService.java
@@ -16,9 +16,12 @@
 package org.thingsboard.server.service.install;
 
 import org.springframework.stereotype.Service;
+import org.thingsboard.server.dao.util.NoSqlDao;
 
 @Service
-public class CassandraEntityDatabaseSchemaService extends CassandraAbstractDatabaseSchemaService {
+@NoSqlDao
+public class CassandraEntityDatabaseSchemaService extends CassandraAbstractDatabaseSchemaService
+        implements EntityDatabaseSchemaService {
     public CassandraEntityDatabaseSchemaService() {
         super("schema-entities.cql");
     }
diff --git a/application/src/main/java/org/thingsboard/server/service/install/CassandraTsDatabaseSchemaService.java b/application/src/main/java/org/thingsboard/server/service/install/CassandraTsDatabaseSchemaService.java
index addc180..ba18b57 100644
--- a/application/src/main/java/org/thingsboard/server/service/install/CassandraTsDatabaseSchemaService.java
+++ b/application/src/main/java/org/thingsboard/server/service/install/CassandraTsDatabaseSchemaService.java
@@ -16,9 +16,12 @@
 package org.thingsboard.server.service.install;
 
 import org.springframework.stereotype.Service;
+import org.thingsboard.server.dao.util.NoSqlTsDao;
 
 @Service
-public class CassandraTsDatabaseSchemaService extends CassandraAbstractDatabaseSchemaService {
+@NoSqlTsDao
+public class CassandraTsDatabaseSchemaService extends CassandraAbstractDatabaseSchemaService
+        implements TsDatabaseSchemaService {
     public CassandraTsDatabaseSchemaService() {
         super("schema-ts.cql");
     }
diff --git a/application/src/main/java/org/thingsboard/server/service/install/EntityDatabaseSchemaService.java b/application/src/main/java/org/thingsboard/server/service/install/EntityDatabaseSchemaService.java
new file mode 100644
index 0000000..1d0ddc3
--- /dev/null
+++ b/application/src/main/java/org/thingsboard/server/service/install/EntityDatabaseSchemaService.java
@@ -0,0 +1,4 @@
+package org.thingsboard.server.service.install;
+
+public interface EntityDatabaseSchemaService extends DatabaseSchemaService {
+}
diff --git a/application/src/main/java/org/thingsboard/server/service/install/SqlAbstractDatabaseSchemaService.java b/application/src/main/java/org/thingsboard/server/service/install/SqlAbstractDatabaseSchemaService.java
index f468a6e..4a39b8f 100644
--- a/application/src/main/java/org/thingsboard/server/service/install/SqlAbstractDatabaseSchemaService.java
+++ b/application/src/main/java/org/thingsboard/server/service/install/SqlAbstractDatabaseSchemaService.java
@@ -27,7 +27,7 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 
 @Slf4j
-public abstract class SqlAbstractDatabaseSchemaService /*implements DatabaseSchemaService*/ {
+public abstract class SqlAbstractDatabaseSchemaService implements DatabaseSchemaService {
 
     private static final String SQL_DIR = "sql";
 
@@ -49,7 +49,7 @@ public abstract class SqlAbstractDatabaseSchemaService /*implements DatabaseSche
         this.schemaSql = schemaSql;
     }
 
-    //@Override
+    @Override
     public void createDatabaseSchema() throws Exception {
 
         log.info("Installing SQL DataBase schema part: " + schemaSql);
diff --git a/application/src/main/java/org/thingsboard/server/service/install/SqlEntityDatabaseSchemaService.java b/application/src/main/java/org/thingsboard/server/service/install/SqlEntityDatabaseSchemaService.java
index 0826099..16453c6 100644
--- a/application/src/main/java/org/thingsboard/server/service/install/SqlEntityDatabaseSchemaService.java
+++ b/application/src/main/java/org/thingsboard/server/service/install/SqlEntityDatabaseSchemaService.java
@@ -16,9 +16,12 @@
 package org.thingsboard.server.service.install;
 
 import org.springframework.stereotype.Service;
+import org.thingsboard.server.dao.util.SqlDao;
 
 @Service
-public class SqlEntityDatabaseSchemaService extends SqlAbstractDatabaseSchemaService {
+@SqlDao
+public class SqlEntityDatabaseSchemaService extends SqlAbstractDatabaseSchemaService
+        implements EntityDatabaseSchemaService {
     public SqlEntityDatabaseSchemaService() {
         super("schema-entities.sql");
     }
diff --git a/application/src/main/java/org/thingsboard/server/service/install/SqlTsDatabaseSchemaService.java b/application/src/main/java/org/thingsboard/server/service/install/SqlTsDatabaseSchemaService.java
index 6c8f8b5..82daf90 100644
--- a/application/src/main/java/org/thingsboard/server/service/install/SqlTsDatabaseSchemaService.java
+++ b/application/src/main/java/org/thingsboard/server/service/install/SqlTsDatabaseSchemaService.java
@@ -16,9 +16,12 @@
 package org.thingsboard.server.service.install;
 
 import org.springframework.stereotype.Service;
+import org.thingsboard.server.dao.util.SqlTsDao;
 
 @Service
-public class SqlTsDatabaseSchemaService extends SqlAbstractDatabaseSchemaService {
+@SqlTsDao
+public class SqlTsDatabaseSchemaService extends SqlAbstractDatabaseSchemaService
+        implements TsDatabaseSchemaService {
     public SqlTsDatabaseSchemaService() {
         super("schema-ts.sql");
     }
diff --git a/application/src/main/java/org/thingsboard/server/service/install/TsDatabaseSchemaService.java b/application/src/main/java/org/thingsboard/server/service/install/TsDatabaseSchemaService.java
new file mode 100644
index 0000000..d95166f
--- /dev/null
+++ b/application/src/main/java/org/thingsboard/server/service/install/TsDatabaseSchemaService.java
@@ -0,0 +1,4 @@
+package org.thingsboard.server.service.install;
+
+public interface TsDatabaseSchemaService extends DatabaseSchemaService {
+}