|
|
@ -19,11 +19,8 @@ import com.datastax.driver.core.*; |
|
|
import com.datastax.driver.core.querybuilder.QueryBuilder; |
|
|
import com.datastax.driver.core.querybuilder.QueryBuilder; |
|
|
import com.datastax.driver.core.querybuilder.Select; |
|
|
import com.datastax.driver.core.querybuilder.Select; |
|
|
import com.fasterxml.jackson.databind.JsonNode; |
|
|
import com.fasterxml.jackson.databind.JsonNode; |
|
|
import com.google.common.base.Function; |
|
|
|
|
|
import com.google.common.util.concurrent.Futures; |
|
|
|
|
|
import com.google.common.util.concurrent.ListenableFuture; |
|
|
import com.google.common.util.concurrent.ListenableFuture; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; |
|
|
|
|
|
import org.springframework.stereotype.Component; |
|
|
import org.springframework.stereotype.Component; |
|
|
import org.thingsboard.server.common.data.EntityType; |
|
|
import org.thingsboard.server.common.data.EntityType; |
|
|
import org.thingsboard.server.common.data.id.EntityId; |
|
|
import org.thingsboard.server.common.data.id.EntityId; |
|
|
@ -33,10 +30,10 @@ import org.thingsboard.server.common.data.relation.EntityRelation; |
|
|
import org.thingsboard.server.common.data.relation.RelationTypeGroup; |
|
|
import org.thingsboard.server.common.data.relation.RelationTypeGroup; |
|
|
import org.thingsboard.server.dao.CassandraAbstractAsyncDao; |
|
|
import org.thingsboard.server.dao.CassandraAbstractAsyncDao; |
|
|
import org.thingsboard.server.dao.CassandraAbstractSearchTimeDao; |
|
|
import org.thingsboard.server.dao.CassandraAbstractSearchTimeDao; |
|
|
|
|
|
import org.thingsboard.server.dao.annotation.NoSqlDao; |
|
|
import org.thingsboard.server.dao.model.ModelConstants; |
|
|
import org.thingsboard.server.dao.model.ModelConstants; |
|
|
import org.thingsboard.server.dao.model.type.RelationTypeGroupCodec; |
|
|
import org.thingsboard.server.dao.model.type.RelationTypeGroupCodec; |
|
|
|
|
|
|
|
|
import javax.annotation.Nullable; |
|
|
|
|
|
import javax.annotation.PostConstruct; |
|
|
import javax.annotation.PostConstruct; |
|
|
import java.util.ArrayList; |
|
|
import java.util.ArrayList; |
|
|
import java.util.Arrays; |
|
|
import java.util.Arrays; |
|
|
@ -49,7 +46,7 @@ import static com.datastax.driver.core.querybuilder.QueryBuilder.eq; |
|
|
*/ |
|
|
*/ |
|
|
@Component |
|
|
@Component |
|
|
@Slf4j |
|
|
@Slf4j |
|
|
@ConditionalOnProperty(prefix = "cassandra", value = "enabled", havingValue = "true", matchIfMissing = false) |
|
|
@NoSqlDao |
|
|
public class BaseRelationDao extends CassandraAbstractAsyncDao implements RelationDao { |
|
|
public class BaseRelationDao extends CassandraAbstractAsyncDao implements RelationDao { |
|
|
|
|
|
|
|
|
private static final String SELECT_COLUMNS = "SELECT " + |
|
|
private static final String SELECT_COLUMNS = "SELECT " + |
|
|
|