Commit 770253a32ce950225d8da9836814cc71eb2a3de6

Authored by viktorbasanets
1 parent 1e1beaae

Was fixed the type of startTs & endTs fields of EntityViewEntity class and queri…

…es of schemas db tables
@@ -29,8 +29,8 @@ CREATE TABLE IF NOT EXISTS thingsboard.entity_views ( @@ -29,8 +29,8 @@ CREATE TABLE IF NOT EXISTS thingsboard.entity_views (
29 customer_id timeuuid, 29 customer_id timeuuid,
30 name text, 30 name text,
31 keys text, 31 keys text,
32 - ts_begin bigint,  
33 - ts_end bigint, 32 + start_ts bigint,
  33 + end_ts bigint,
34 search_text text, 34 search_text text,
35 additional_info text, 35 additional_info text,
36 PRIMARY KEY (id, entity_id, tenant_id, customer_id) 36 PRIMARY KEY (id, entity_id, tenant_id, customer_id)
@@ -43,8 +43,8 @@ CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_na @@ -43,8 +43,8 @@ CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_na
43 AND tenant_id IS NOT NULL 43 AND tenant_id IS NOT NULL
44 AND customer_id IS NOT NULL 44 AND customer_id IS NOT NULL
45 AND keys IS NOT NULL 45 AND keys IS NOT NULL
46 - AND ts_begin IS NOT NULL  
47 - AND ts_end IS NOT NULL 46 + AND start_ts IS NOT NULL
  47 + AND end_ts IS NOT NULL
48 AND name IS NOT NULL 48 AND name IS NOT NULL
49 AND id IS NOT NULL 49 AND id IS NOT NULL
50 PRIMARY KEY (tenant_id, name, id, entity_id, customer_id) 50 PRIMARY KEY (tenant_id, name, id, entity_id, customer_id)
@@ -57,8 +57,8 @@ CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_en @@ -57,8 +57,8 @@ CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_en
57 AND tenant_id IS NOT NULL 57 AND tenant_id IS NOT NULL
58 AND customer_id IS NOT NULL 58 AND customer_id IS NOT NULL
59 AND keys IS NOT NULL 59 AND keys IS NOT NULL
60 - AND ts_begin IS NOT NULL  
61 - AND ts_end IS NOT NULL 60 + AND start_ts IS NOT NULL
  61 + AND end_ts IS NOT NULL
62 AND name IS NOT NULL 62 AND name IS NOT NULL
63 AND id IS NOT NULL 63 AND id IS NOT NULL
64 PRIMARY KEY (tenant_id, entity_id, id, customer_id, name) 64 PRIMARY KEY (tenant_id, entity_id, id, customer_id, name)
@@ -71,8 +71,8 @@ CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_cu @@ -71,8 +71,8 @@ CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_cu
71 AND tenant_id IS NOT NULL 71 AND tenant_id IS NOT NULL
72 AND customer_id IS NOT NULL 72 AND customer_id IS NOT NULL
73 AND keys IS NOT NULL 73 AND keys IS NOT NULL
74 - AND ts_begin IS NOT NULL  
75 - AND ts_end IS NOT NULL 74 + AND start_ts IS NOT NULL
  75 + AND end_ts IS NOT NULL
76 AND name IS NOT NULL 76 AND name IS NOT NULL
77 AND id IS NOT NULL 77 AND id IS NOT NULL
78 PRIMARY KEY (tenant_id, customer_id, id, entity_id, name) 78 PRIMARY KEY (tenant_id, customer_id, id, entity_id, name)
@@ -85,8 +85,8 @@ CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_cu @@ -85,8 +85,8 @@ CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_cu
85 AND tenant_id IS NOT NULL 85 AND tenant_id IS NOT NULL
86 AND customer_id IS NOT NULL 86 AND customer_id IS NOT NULL
87 AND keys IS NOT NULL 87 AND keys IS NOT NULL
88 - AND ts_begin IS NOT NULL  
89 - AND ts_end IS NOT NULL 88 + AND start_ts IS NOT NULL
  89 + AND end_ts IS NOT NULL
90 AND name IS NOT NULL 90 AND name IS NOT NULL
91 AND id IS NOT NULL 91 AND id IS NOT NULL
92 PRIMARY KEY (tenant_id, customer_id, entity_id, id, name) 92 PRIMARY KEY (tenant_id, customer_id, entity_id, id, name)
@@ -24,8 +24,8 @@ CREATE TABLE IF NOT EXISTS entity_views ( @@ -24,8 +24,8 @@ CREATE TABLE IF NOT EXISTS entity_views (
24 customer_id varchar(31), 24 customer_id varchar(31),
25 name varchar(255), 25 name varchar(255),
26 keys varchar(255), 26 keys varchar(255),
27 - ts_begin varchar(255),  
28 - ts_end varchar(255), 27 + start_ts bigint,
  28 + end_ts bigint,
29 search_text varchar(255), 29 search_text varchar(255),
30 additional_info varchar 30 additional_info varchar
31 ); 31 );
@@ -156,8 +156,8 @@ public class ModelConstants { @@ -156,8 +156,8 @@ public class ModelConstants {
156 public static final String ENTITY_VIEW_TYPE_PROPERTY = DEVICE_TYPE_PROPERTY; 156 public static final String ENTITY_VIEW_TYPE_PROPERTY = DEVICE_TYPE_PROPERTY;
157 public static final String ENTITY_VIEW_TENANT_AND_NAME_VIEW_NAME = "entity_view_by_tenant_and_name"; 157 public static final String ENTITY_VIEW_TENANT_AND_NAME_VIEW_NAME = "entity_view_by_tenant_and_name";
158 public static final String ENTITY_VIEW_KEYS_PROPERTY = "keys"; 158 public static final String ENTITY_VIEW_KEYS_PROPERTY = "keys";
159 - public static final String ENTITY_VIEW_TS_BEGIN_PROPERTY = "ts_begin";  
160 - public static final String ENTITY_VIEW_TS_END_PROPERTY = "ts_end"; 159 + public static final String ENTITY_VIEW_START_TS_PROPERTY = "start_ts";
  160 + public static final String ENTITY_VIEW_END_TS_PROPERTY = "end_ts";
161 public static final String ENTITY_VIEW_ADDITIONAL_INFO_PROPERTY = ADDITIONAL_INFO_PROPERTY; 161 public static final String ENTITY_VIEW_ADDITIONAL_INFO_PROPERTY = ADDITIONAL_INFO_PROPERTY;
162 public static final String ENTITY_VIEW_BY_TENANT_AND_SEARCH_TEXT_COLUMN_FAMILY_NAME = "entity_view_by_tenant_and_search_text"; 162 public static final String ENTITY_VIEW_BY_TENANT_AND_SEARCH_TEXT_COLUMN_FAMILY_NAME = "entity_view_by_tenant_and_search_text";
163 163
@@ -75,11 +75,11 @@ public class EntityViewEntity implements SearchTextEntity<EntityView> { @@ -75,11 +75,11 @@ public class EntityViewEntity implements SearchTextEntity<EntityView> {
75 @Column(name = ModelConstants.ENTITY_VIEW_KEYS_PROPERTY) 75 @Column(name = ModelConstants.ENTITY_VIEW_KEYS_PROPERTY)
76 private String keys; 76 private String keys;
77 77
78 - @Column(name = ModelConstants.ENTITY_VIEW_TS_BEGIN_PROPERTY)  
79 - private String tsBegin; 78 + @Column(name = ModelConstants.ENTITY_VIEW_START_TS_PROPERTY)
  79 + private long startTs;
80 80
81 - @Column(name = ModelConstants.ENTITY_VIEW_TS_END_PROPERTY)  
82 - private String tsEnd; 81 + @Column(name = ModelConstants.ENTITY_VIEW_END_TS_PROPERTY)
  82 + private long endTs;
83 83
84 @Column(name = ModelConstants.SEARCH_TEXT_PROPERTY) 84 @Column(name = ModelConstants.SEARCH_TEXT_PROPERTY)
85 private String searchText; 85 private String searchText;
@@ -114,8 +114,8 @@ public class EntityViewEntity implements SearchTextEntity<EntityView> { @@ -114,8 +114,8 @@ public class EntityViewEntity implements SearchTextEntity<EntityView> {
114 } catch (IOException e) { 114 } catch (IOException e) {
115 e.printStackTrace(); 115 e.printStackTrace();
116 } 116 }
117 - this.tsBegin = entityView.getStartTs() != 0L ? String.valueOf(entityView.getStartTs()) : "0";  
118 - this.tsEnd = entityView.getEndTs() != 0L ? String.valueOf(entityView.getEndTs()) : "0"; 117 + this.startTs = entityView.getStartTs() != 0L ? entityView.getStartTs() : 0L;
  118 + this.endTs = entityView.getEndTs() != 0L ? entityView.getEndTs() : 0L;
119 this.searchText = entityView.getSearchText(); 119 this.searchText = entityView.getSearchText();
120 this.additionalInfo = entityView.getAdditionalInfo(); 120 this.additionalInfo = entityView.getAdditionalInfo();
121 } 121 }
@@ -144,8 +144,8 @@ public class EntityViewEntity implements SearchTextEntity<EntityView> { @@ -144,8 +144,8 @@ public class EntityViewEntity implements SearchTextEntity<EntityView> {
144 } catch (IOException e) { 144 } catch (IOException e) {
145 e.printStackTrace(); 145 e.printStackTrace();
146 } 146 }
147 - entityView.setStartTs(Long.parseLong(tsBegin));  
148 - entityView.setEndTs(Long.parseLong(tsEnd)); 147 + entityView.setStartTs(startTs);
  148 + entityView.setEndTs(endTs);
149 entityView.setAdditionalInfo(additionalInfo); 149 entityView.setAdditionalInfo(additionalInfo);
150 return entityView; 150 return entityView;
151 } 151 }
@@ -66,11 +66,11 @@ public class EntityViewEntity extends BaseSqlEntity<EntityView> implements Searc @@ -66,11 +66,11 @@ public class EntityViewEntity extends BaseSqlEntity<EntityView> implements Searc
66 @Column(name = ModelConstants.ENTITY_VIEW_KEYS_PROPERTY) 66 @Column(name = ModelConstants.ENTITY_VIEW_KEYS_PROPERTY)
67 private String keys; 67 private String keys;
68 68
69 - @Column(name = ModelConstants.ENTITY_VIEW_TS_BEGIN_PROPERTY)  
70 - private String tsBegin; 69 + @Column(name = ModelConstants.ENTITY_VIEW_START_TS_PROPERTY)
  70 + private long startTs;
71 71
72 - @Column(name = ModelConstants.ENTITY_VIEW_TS_END_PROPERTY)  
73 - private String tsEnd; 72 + @Column(name = ModelConstants.ENTITY_VIEW_END_TS_PROPERTY)
  73 + private long endTs;
74 74
75 @Column(name = ModelConstants.SEARCH_TEXT_PROPERTY) 75 @Column(name = ModelConstants.SEARCH_TEXT_PROPERTY)
76 private String searchText; 76 private String searchText;
@@ -105,8 +105,8 @@ public class EntityViewEntity extends BaseSqlEntity<EntityView> implements Searc @@ -105,8 +105,8 @@ public class EntityViewEntity extends BaseSqlEntity<EntityView> implements Searc
105 } catch (IOException e) { 105 } catch (IOException e) {
106 e.printStackTrace(); 106 e.printStackTrace();
107 } 107 }
108 - this.tsBegin = entityView.getStartTs() != 0L ? String.valueOf(entityView.getStartTs()) : "0";  
109 - this.tsEnd = entityView.getEndTs() != 0L ? String.valueOf(entityView.getEndTs()) : "0"; 108 + this.startTs = entityView.getStartTs() != 0L ? entityView.getStartTs() : 0L;
  109 + this.endTs = entityView.getEndTs() != 0L ? entityView.getEndTs() : 0L;
110 this.searchText = entityView.getSearchText(); 110 this.searchText = entityView.getSearchText();
111 this.additionalInfo = entityView.getAdditionalInfo(); 111 this.additionalInfo = entityView.getAdditionalInfo();
112 } 112 }
@@ -141,8 +141,8 @@ public class EntityViewEntity extends BaseSqlEntity<EntityView> implements Searc @@ -141,8 +141,8 @@ public class EntityViewEntity extends BaseSqlEntity<EntityView> implements Searc
141 } catch (IOException e) { 141 } catch (IOException e) {
142 e.printStackTrace(); 142 e.printStackTrace();
143 } 143 }
144 - entityView.setStartTs(Long.parseLong(tsBegin));  
145 - entityView.setEndTs(Long.parseLong(tsEnd)); 144 + entityView.setStartTs(startTs);
  145 + entityView.setEndTs(endTs);
146 entityView.setAdditionalInfo(additionalInfo); 146 entityView.setAdditionalInfo(additionalInfo);
147 return entityView; 147 return entityView;
148 } 148 }
@@ -647,8 +647,8 @@ CREATE TABLE IF NOT EXISTS thingsboard.entity_views ( @@ -647,8 +647,8 @@ CREATE TABLE IF NOT EXISTS thingsboard.entity_views (
647 customer_id timeuuid, 647 customer_id timeuuid,
648 name text, 648 name text,
649 keys text, 649 keys text,
650 - ts_begin bigint,  
651 - ts_end bigint, 650 + start_ts bigint,
  651 + end_ts bigint,
652 search_text text, 652 search_text text,
653 additional_info text, 653 additional_info text,
654 PRIMARY KEY (id, tenant_id, customer_id) 654 PRIMARY KEY (id, tenant_id, customer_id)
@@ -657,27 +657,27 @@ CREATE TABLE IF NOT EXISTS thingsboard.entity_views ( @@ -657,27 +657,27 @@ CREATE TABLE IF NOT EXISTS thingsboard.entity_views (
657 CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_name AS 657 CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_name AS
658 SELECT * 658 SELECT *
659 from thingsboard.entity_views 659 from thingsboard.entity_views
660 - WHERE entity_id IS NOT NULL AND tenant_id IS NOT NULL AND customer_id IS NOT NULL AND keys IS NOT NULL AND ts_begin IS NOT NULL AND ts_end IS NOT NULL AND name IS NOT NULL AND id IS NOT NULL 660 + WHERE entity_id IS NOT NULL AND tenant_id IS NOT NULL AND customer_id IS NOT NULL AND keys IS NOT NULL AND start_ts IS NOT NULL AND end_ts IS NOT NULL AND name IS NOT NULL AND id IS NOT NULL
661 PRIMARY KEY (tenant_id, name, id, entity_id, customer_id) 661 PRIMARY KEY (tenant_id, name, id, entity_id, customer_id)
662 WITH CLUSTERING ORDER BY (name ASC, id DESC, entity_id DESC, customer_id DESC); 662 WITH CLUSTERING ORDER BY (name ASC, id DESC, entity_id DESC, customer_id DESC);
663 663
664 CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_entity AS 664 CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_entity AS
665 SELECT * 665 SELECT *
666 from thingsboard.entity_views 666 from thingsboard.entity_views
667 - WHERE entity_id IS NOT NULL AND tenant_id IS NOT NULL AND customer_id IS NOT NULL AND keys IS NOT NULL AND ts_begin IS NOT NULL AND ts_end IS NOT NULL AND name IS NOT NULL AND id IS NOT NULL 667 + WHERE entity_id IS NOT NULL AND tenant_id IS NOT NULL AND customer_id IS NOT NULL AND keys IS NOT NULL AND start_ts IS NOT NULL AND end_ts IS NOT NULL AND name IS NOT NULL AND id IS NOT NULL
668 PRIMARY KEY (tenant_id, entity_id, id, customer_id, name) 668 PRIMARY KEY (tenant_id, entity_id, id, customer_id, name)
669 WITH CLUSTERING ORDER BY (entity_id ASC, customer_id ASC, id DESC, name DESC); 669 WITH CLUSTERING ORDER BY (entity_id ASC, customer_id ASC, id DESC, name DESC);
670 670
671 CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_customer AS 671 CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_customer AS
672 SELECT * 672 SELECT *
673 from thingsboard.entity_views 673 from thingsboard.entity_views
674 - WHERE entity_id IS NOT NULL AND tenant_id IS NOT NULL AND customer_id IS NOT NULL AND keys IS NOT NULL AND ts_begin IS NOT NULL AND ts_end IS NOT NULL AND name IS NOT NULL AND id IS NOT NULL 674 + WHERE entity_id IS NOT NULL AND tenant_id IS NOT NULL AND customer_id IS NOT NULL AND keys IS NOT NULL AND start_ts IS NOT NULL AND end_ts IS NOT NULL AND name IS NOT NULL AND id IS NOT NULL
675 PRIMARY KEY (tenant_id, customer_id, id, entity_id, name) 675 PRIMARY KEY (tenant_id, customer_id, id, entity_id, name)
676 WITH CLUSTERING ORDER BY (customer_id ASC, id DESC, entity_id DESC, name DESC); 676 WITH CLUSTERING ORDER BY (customer_id ASC, id DESC, entity_id DESC, name DESC);
677 677
678 CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_customer_and_entity AS 678 CREATE MATERIALIZED VIEW IF NOT EXISTS thingsboard.entity_views_by_tenant_and_customer_and_entity AS
679 SELECT * 679 SELECT *
680 from thingsboard.entity_views 680 from thingsboard.entity_views
681 - WHERE entity_id IS NOT NULL AND tenant_id IS NOT NULL AND customer_id IS NOT NULL AND keys IS NOT NULL AND ts_begin IS NOT NULL AND ts_end IS NOT NULL AND name IS NOT NULL AND id IS NOT NULL 681 + WHERE entity_id IS NOT NULL AND tenant_id IS NOT NULL AND customer_id IS NOT NULL AND keys IS NOT NULL AND start_ts IS NOT NULL AND end_ts IS NOT NULL AND name IS NOT NULL AND id IS NOT NULL
682 PRIMARY KEY (tenant_id, customer_id, entity_id, id, name) 682 PRIMARY KEY (tenant_id, customer_id, entity_id, id, name)
683 WITH CLUSTERING ORDER BY (customer_id ASC, entity_id DESC, id DESC, name DESC); 683 WITH CLUSTERING ORDER BY (customer_id ASC, entity_id DESC, id DESC, name DESC);
@@ -260,8 +260,8 @@ CREATE TABLE IF NOT EXISTS entity_views ( @@ -260,8 +260,8 @@ CREATE TABLE IF NOT EXISTS entity_views (
260 customer_id varchar(31), 260 customer_id varchar(31),
261 name varchar(255), 261 name varchar(255),
262 keys varchar(255), 262 keys varchar(255),
263 - ts_begin varchar(255),  
264 - ts_end varchar(255), 263 + start_ts bigint,
  264 + end_ts bigint,
265 search_text varchar(255), 265 search_text varchar(255),
266 additional_info varchar 266 additional_info varchar
267 ); 267 );