rdbms.vm.js 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266
  1. // Licensed to Cloudera, Inc. under one
  2. // or more contributor license agreements. See the NOTICE file
  3. // distributed with this work for additional information
  4. // regarding copyright ownership. Cloudera, Inc. licenses this file
  5. // to you under the Apache License, Version 2.0 (the
  6. // "License"); you may not use this file except in compliance
  7. // with the License. You may obtain a copy of the License at
  8. //
  9. // http://www.apache.org/licenses/LICENSE-2.0
  10. //
  11. // Unless required by applicable law or agreed to in writing, software
  12. // distributed under the License is distributed on an "AS IS" BASIS,
  13. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14. // See the License for the specific language governing permissions and
  15. // limitations under the License.
  16. function RdbmsViewModel() {
  17. var self = this;
  18. self.servers = ko.observableArray();
  19. self.selectedServer = ko.observable(0);
  20. self.databases = ko.observableArray();
  21. self.selectedDatabase = ko.observable(0);
  22. self.query = ko.mapping.fromJS({
  23. 'id': -1,
  24. 'query': '',
  25. 'name': null,
  26. 'description': null,
  27. 'errors': []
  28. });
  29. self.rows = ko.observableArray();
  30. self.columns = ko.observableArray();
  31. self.filter = ko.observable("");
  32. self.isLoading = ko.observable(false);
  33. self.isReady = ko.observable(false);
  34. self.server = ko.computed({
  35. 'read': function() {
  36. if (self.servers().length > 0) {
  37. return self.servers()[self.selectedServer()];
  38. } else{
  39. return null;
  40. }
  41. },
  42. 'write': function(value) {
  43. var filtered = $.each(self.servers(), function(index, server) {
  44. if (server.name() == value) {
  45. self.selectedServer(index);
  46. }
  47. });
  48. }
  49. });
  50. self.database = ko.computed({
  51. 'read': function() {
  52. if (self.databases()) {
  53. return self.databases()[self.selectedDatabase()];
  54. } else{
  55. return "";
  56. }
  57. },
  58. 'write': function(value) {
  59. self.selectedDatabase(self.databases.indexOf(value));
  60. }
  61. });
  62. self.getFirstDatabase = function() {
  63. if (self.databases()) {
  64. return self.databases()[0];
  65. } else {
  66. return null;
  67. }
  68. };
  69. self.getServerNiceName = function(value) {
  70. return self.servers[value];
  71. };
  72. self.updateResults = function(results) {
  73. var rows = [];
  74. self.columns(results.columns);
  75. $.each(results.rows, function(i, result_row) {
  76. var row = [];
  77. $.each(self.columns(), function(j, column) {
  78. row.push(result_row[column]);
  79. });
  80. rows.push(row);
  81. });
  82. self.rows(rows);
  83. };
  84. self.updateServers = function(servers) {
  85. var newServers = [];
  86. $.each(servers, function(name, nice_name) {
  87. newServers.push({
  88. 'name': ko.observable(name),
  89. 'nice_name': ko.observable(nice_name)
  90. });
  91. });
  92. self.servers(newServers);
  93. var last = $.totalStorage('hueRdbmsLastServer') || ((newServers[0].length > 0) ? newServers[0].name() : null);
  94. if (last) {
  95. self.server(last);
  96. }
  97. };
  98. self.updateDatabases = function(databases) {
  99. self.databases(databases);
  100. var key = 'hueRdbmsLastDatabase-' + self.server().name();
  101. var last = $.totalStorage(key) || ((databases.length > 0) ? databases[0] : null);
  102. if (last) {
  103. self.database(last);
  104. }
  105. };
  106. self.updateQuery = function(design) {
  107. self.query.query(design.query);
  108. self.query.id(design.id);
  109. self.query.name(design.name);
  110. self.query.description(design.desc);
  111. self.database(design.database);
  112. self.server(design.server);
  113. };
  114. self.chooseServer = function(value, e) {
  115. $.each(self.servers(), function(index, server) {
  116. if (server.name() == value.name()) {
  117. self.selectedServer(index);
  118. }
  119. });
  120. $.totalStorage('hueRdbmsLastServer', self.server().name());
  121. self.fetchDatabases();
  122. };
  123. self.chooseDatabase = function(value, e) {
  124. var key = 'hueRdbmsLastDatabase-' + self.server().name();
  125. self.selectedDatabase(self.databases.indexOf(value));
  126. $.totalStorage(key, value);
  127. };
  128. self.explainQuery = function() {
  129. var data = ko.mapping.toJS(self.query);
  130. data.database = self.database();
  131. data.server = self.server().name();
  132. var request = {
  133. url: '/rdbms/api/explain/',
  134. dataType: 'json',
  135. type: 'POST',
  136. success: function(data) {
  137. self.query.errors.removeAll();
  138. if (data.status === 0) {
  139. $(document).trigger('explain.query', data);
  140. self.updateResults(data.results);
  141. self.query.id(data.design);
  142. $(document).trigger('explained.query', data);
  143. } else {
  144. self.query.errors.push(data.message);
  145. }
  146. },
  147. error: $.noop,
  148. data: data
  149. };
  150. $.ajax(request);
  151. };
  152. self.fetchQuery = function(id) {
  153. var _id = id || self.query.id();
  154. if (_id && _id != -1) {
  155. var request = {
  156. url: '/rdbms/api/query/' + _id + '/get',
  157. dataType: 'json',
  158. type: 'GET',
  159. success: function(data) {
  160. self.updateQuery(data.design);
  161. },
  162. error: $.noop
  163. };
  164. $.ajax(request);
  165. }
  166. };
  167. self.saveQuery = function() {
  168. var self = this;
  169. if (self.query.query() && self.query.name()) {
  170. var data = ko.mapping.toJS(self.query);
  171. data['desc'] = data['description'];
  172. data['server'] = self.server().name();
  173. data['database'] = self.database();
  174. var url = '/rdbms/api/query/';
  175. if (self.query.id() && self.query.id() != -1) {
  176. url += self.query.id() + '/';
  177. }
  178. var request = {
  179. url: url,
  180. dataType: 'json',
  181. type: 'POST',
  182. success: function(data) {
  183. $(document).trigger('saved.query', data);
  184. },
  185. error: function() {
  186. $(document).trigger('error.query');
  187. },
  188. data: data
  189. };
  190. $.ajax(request);
  191. }
  192. };
  193. self.executeQuery = function() {
  194. var data = ko.mapping.toJS(self.query);
  195. data.database = self.database();
  196. data.server = self.server().name();
  197. var request = {
  198. url: '/rdbms/api/execute/',
  199. dataType: 'json',
  200. type: 'POST',
  201. success: function(data) {
  202. self.query.errors.removeAll();
  203. if (data.status === 0) {
  204. $(document).trigger('execute.query', data);
  205. self.updateResults(data.results);
  206. self.query.id(data.design);
  207. $(document).trigger('executed.query', data);
  208. } else {
  209. self.query.errors.push(data.message);
  210. }
  211. },
  212. error: $.noop,
  213. data: data
  214. };
  215. $.ajax(request);
  216. };
  217. self.fetchServers = function() {
  218. var request = {
  219. url: '/rdbms/api/servers/',
  220. dataType: 'json',
  221. type: 'GET',
  222. success: function(data) {
  223. self.updateServers(data.servers);
  224. self.fetchDatabases();
  225. },
  226. error: $.noop
  227. };
  228. $.ajax(request);
  229. };
  230. self.fetchDatabases = function() {
  231. if (self.server()) {
  232. var request = {
  233. url: '/rdbms/api/servers/' + self.server().name() + '/databases/',
  234. dataType: 'json',
  235. type: 'GET',
  236. success: function(data) {
  237. self.updateDatabases(data.databases);
  238. },
  239. error: $.noop
  240. };
  241. $.ajax(request);
  242. }
  243. };
  244. }