influx09-querybuilder-specs.js 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187
  1. define([
  2. 'app/plugins/datasource/influxdb/queryBuilder'
  3. ], function(InfluxQueryBuilder) {
  4. 'use strict';
  5. describe('InfluxQueryBuilder', function() {
  6. describe('series with mesurement only', function() {
  7. it('should generate correct query', function() {
  8. var builder = new InfluxQueryBuilder({
  9. measurement: 'cpu',
  10. groupBy: [{type: 'time', interval: 'auto'}]
  11. });
  12. var query = builder.build();
  13. expect(query).to.be('SELECT mean("value") AS "value" FROM "cpu" WHERE $timeFilter GROUP BY time($interval)');
  14. });
  15. });
  16. describe('series with math expr and as expr', function() {
  17. it('should generate correct query', function() {
  18. var builder = new InfluxQueryBuilder({
  19. measurement: 'cpu',
  20. fields: [{name: 'test', func: 'max', mathExpr: '*2', asExpr: 'new_name'}],
  21. groupBy: [{type: 'time', interval: 'auto'}]
  22. });
  23. var query = builder.build();
  24. expect(query).to.be('SELECT max("test")*2 AS "new_name" FROM "cpu" WHERE $timeFilter GROUP BY time($interval)');
  25. });
  26. });
  27. describe('series with single tag only', function() {
  28. it('should generate correct query', function() {
  29. var builder = new InfluxQueryBuilder({
  30. measurement: 'cpu',
  31. groupBy: [{type: 'time', interval: 'auto'}],
  32. tags: [{key: 'hostname', value: 'server1'}]
  33. });
  34. var query = builder.build();
  35. expect(query).to.be('SELECT mean("value") AS "value" FROM "cpu" WHERE "hostname" = \'server1\' AND $timeFilter'
  36. + ' GROUP BY time($interval)');
  37. });
  38. it('should switch regex operator with tag value is regex', function() {
  39. var builder = new InfluxQueryBuilder({
  40. measurement: 'cpu',
  41. groupBy: [{type: 'time', interval: 'auto'}],
  42. tags: [{key: 'app', value: '/e.*/'}]
  43. });
  44. var query = builder.build();
  45. expect(query).to.be('SELECT mean("value") AS "value" FROM "cpu" WHERE "app" =~ /e.*/ AND $timeFilter GROUP BY time($interval)');
  46. });
  47. });
  48. describe('series with multiple fields', function() {
  49. it('should generate correct query', function() {
  50. var builder = new InfluxQueryBuilder({
  51. measurement: 'cpu',
  52. tags: [],
  53. groupBy: [{type: 'time', interval: 'auto'}],
  54. fields: [{ name: 'tx_in', func: 'sum' }, { name: 'tx_out', func: 'mean' }]
  55. });
  56. var query = builder.build();
  57. expect(query).to.be('SELECT sum("tx_in") AS "tx_in", mean("tx_out") AS "tx_out" ' +
  58. 'FROM "cpu" WHERE $timeFilter GROUP BY time($interval)');
  59. });
  60. });
  61. describe('series with multiple tags only', function() {
  62. it('should generate correct query', function() {
  63. var builder = new InfluxQueryBuilder({
  64. measurement: 'cpu',
  65. groupBy: [{type: 'time', interval: 'auto'}],
  66. tags: [{key: 'hostname', value: 'server1'}, {key: 'app', value: 'email', condition: "AND"}]
  67. });
  68. var query = builder.build();
  69. expect(query).to.be('SELECT mean("value") AS "value" FROM "cpu" WHERE "hostname" = \'server1\' AND "app" = \'email\' AND ' +
  70. '$timeFilter GROUP BY time($interval)');
  71. });
  72. });
  73. describe('series with tags OR condition', function() {
  74. it('should generate correct query', function() {
  75. var builder = new InfluxQueryBuilder({
  76. measurement: 'cpu',
  77. groupBy: [{type: 'time', interval: 'auto'}],
  78. tags: [{key: 'hostname', value: 'server1'}, {key: 'hostname', value: 'server2', condition: "OR"}]
  79. });
  80. var query = builder.build();
  81. expect(query).to.be('SELECT mean("value") AS "value" FROM "cpu" WHERE "hostname" = \'server1\' OR "hostname" = \'server2\' AND ' +
  82. '$timeFilter GROUP BY time($interval)');
  83. });
  84. });
  85. describe('series with groupByTag', function() {
  86. it('should generate correct query', function() {
  87. var builder = new InfluxQueryBuilder({
  88. measurement: 'cpu',
  89. tags: [],
  90. groupBy: [{type: 'time', interval: 'auto'}, {type: 'tag', key: 'host'}],
  91. });
  92. var query = builder.build();
  93. expect(query).to.be('SELECT mean("value") AS "value" FROM "cpu" WHERE $timeFilter ' +
  94. 'GROUP BY time($interval), "host"');
  95. });
  96. });
  97. describe('when building explore queries', function() {
  98. it('should only have measurement condition in tag keys query given query with measurement', function() {
  99. var builder = new InfluxQueryBuilder({ measurement: 'cpu', tags: [] });
  100. var query = builder.buildExploreQuery('TAG_KEYS');
  101. expect(query).to.be('SHOW TAG KEYS FROM "cpu"');
  102. });
  103. it('should handle regex measurement in tag keys query', function() {
  104. var builder = new InfluxQueryBuilder({
  105. measurement: '/.*/',
  106. tags: []
  107. });
  108. var query = builder.buildExploreQuery('TAG_KEYS');
  109. expect(query).to.be('SHOW TAG KEYS FROM /.*/');
  110. });
  111. it('should have no conditions in tags keys query given query with no measurement or tag', function() {
  112. var builder = new InfluxQueryBuilder({ measurement: '', tags: [] });
  113. var query = builder.buildExploreQuery('TAG_KEYS');
  114. expect(query).to.be('SHOW TAG KEYS');
  115. });
  116. it('should have where condition in tag keys query with tags', function() {
  117. var builder = new InfluxQueryBuilder({ measurement: '', tags: [{key: 'host', value: 'se1'}] });
  118. var query = builder.buildExploreQuery('TAG_KEYS');
  119. expect(query).to.be("SHOW TAG KEYS WHERE \"host\" = 'se1'");
  120. });
  121. it('should have no conditions in measurement query for query with no tags', function() {
  122. var builder = new InfluxQueryBuilder({ measurement: '', tags: [] });
  123. var query = builder.buildExploreQuery('MEASUREMENTS');
  124. expect(query).to.be('SHOW MEASUREMENTS');
  125. });
  126. it('should have where condition in measurement query for query with tags', function() {
  127. var builder = new InfluxQueryBuilder({measurement: '', tags: [{key: 'app', value: 'email'}]});
  128. var query = builder.buildExploreQuery('MEASUREMENTS');
  129. expect(query).to.be("SHOW MEASUREMENTS WHERE \"app\" = 'email'");
  130. });
  131. it('should have where tag name IN filter in tag values query for query with one tag', function() {
  132. var builder = new InfluxQueryBuilder({measurement: '', tags: [{key: 'app', value: 'asdsadsad'}]});
  133. var query = builder.buildExploreQuery('TAG_VALUES', 'app');
  134. expect(query).to.be('SHOW TAG VALUES WITH KEY = "app"');
  135. });
  136. it('should have measurement tag condition and tag name IN filter in tag values query', function() {
  137. var builder = new InfluxQueryBuilder({measurement: 'cpu', tags: [{key: 'app', value: 'email'}, {key: 'host', value: 'server1'}]});
  138. var query = builder.buildExploreQuery('TAG_VALUES', 'app');
  139. expect(query).to.be('SHOW TAG VALUES FROM "cpu" WITH KEY = "app" WHERE "host" = \'server1\'');
  140. });
  141. it('should switch to regex operator in tag condition', function() {
  142. var builder = new InfluxQueryBuilder({measurement: 'cpu', tags: [{key: 'host', value: '/server.*/'}]});
  143. var query = builder.buildExploreQuery('TAG_VALUES', 'app');
  144. expect(query).to.be('SHOW TAG VALUES FROM "cpu" WITH KEY = "app" WHERE "host" =~ /server.*/');
  145. });
  146. it('should build show field query', function() {
  147. var builder = new InfluxQueryBuilder({measurement: 'cpu', tags: [{key: 'app', value: 'email'}]});
  148. var query = builder.buildExploreQuery('FIELDS');
  149. expect(query).to.be('SHOW FIELD KEYS FROM "cpu"');
  150. });
  151. });
  152. });
  153. });