thingsboard-aplcache
Changes
application/src/main/java/org/thingsboard/server/service/install/CassandraAbstractDatabaseSchemaService.java 4(+2 -2)
application/src/main/java/org/thingsboard/server/service/install/CassandraDatabaseSchemaService.java 43(+0 -43)
application/src/main/java/org/thingsboard/server/service/install/CassandraEntityDatabaseSchemaService.java 5(+4 -1)
application/src/main/java/org/thingsboard/server/service/install/CassandraTsDatabaseSchemaService.java 5(+4 -1)
application/src/main/java/org/thingsboard/server/service/install/EntityDatabaseSchemaService.java 4(+4 -0)
application/src/main/java/org/thingsboard/server/service/install/HybridDatabaseSchemaService.java 44(+0 -44)
application/src/main/java/org/thingsboard/server/service/install/SqlAbstractDatabaseSchemaService.java 4(+2 -2)
application/src/main/java/org/thingsboard/server/service/install/SqlDatabaseSchemaService.java 44(+0 -44)
application/src/main/java/org/thingsboard/server/service/install/SqlEntityDatabaseSchemaService.java 5(+4 -1)
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 {
+}