rdbms.vm.js 7.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274
  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.resultsEmpty = ko.observable(false);
  32. self.server = ko.computed({
  33. 'read': function() {
  34. if (self.servers().length > 0) {
  35. return self.servers()[self.selectedServer()];
  36. } else{
  37. return null;
  38. }
  39. },
  40. 'write': function(value) {
  41. var filtered = $.each(self.servers(), function(index, server) {
  42. if (server.name() == value) {
  43. self.selectedServer(index);
  44. }
  45. });
  46. }
  47. });
  48. self.database = ko.computed({
  49. 'read': function() {
  50. if (self.databases()) {
  51. return self.databases()[self.selectedDatabase()];
  52. } else{
  53. return "";
  54. }
  55. },
  56. 'write': function(value) {
  57. self.selectedDatabase(self.databases.indexOf(value));
  58. }
  59. });
  60. self.getFirstDatabase = function() {
  61. if (self.databases()) {
  62. return self.databases()[0];
  63. } else {
  64. return null;
  65. }
  66. };
  67. self.getServerNiceName = function(value) {
  68. return self.servers[value];
  69. };
  70. self.updateResults = function(results) {
  71. var rows = [];
  72. self.columns.removeAll(); // Needed for datatables to refresh properly.
  73. self.columns(results.columns);
  74. $.each(results.rows, function(i, result_row) {
  75. var row = [];
  76. $.each(self.columns(), function(j, column) {
  77. row.push(result_row[column]);
  78. });
  79. rows.push(row);
  80. });
  81. self.rows(rows);
  82. };
  83. self.updateServers = function(servers) {
  84. var newServers = [];
  85. $.each(servers, function(name, nice_name) {
  86. newServers.push({
  87. 'name': ko.observable(name),
  88. 'nice_name': ko.observable(nice_name)
  89. });
  90. });
  91. self.servers(newServers);
  92. var last = $.totalStorage('hueRdbmsLastServer') || ((newServers[0].length > 0) ? newServers[0].name() : null);
  93. if (last) {
  94. self.server(last);
  95. }
  96. };
  97. self.updateDatabases = function(databases) {
  98. self.databases(databases);
  99. var key = 'hueRdbmsLastDatabase-' + self.server().name();
  100. var last = $.totalStorage(key) || ((databases.length > 0) ? databases[0] : null);
  101. if (last) {
  102. self.database(last);
  103. }
  104. };
  105. self.updateQuery = function(design) {
  106. self.query.query(design.query);
  107. self.query.id(design.id);
  108. self.query.name(design.name);
  109. self.query.description(design.desc);
  110. self.database(design.database);
  111. self.server(design.server);
  112. };
  113. self.chooseServer = function(value, e) {
  114. $.each(self.servers(), function(index, server) {
  115. if (server.name() == value.name()) {
  116. self.selectedServer(index);
  117. }
  118. });
  119. $.totalStorage('hueRdbmsLastServer', self.server().name());
  120. self.fetchDatabases();
  121. };
  122. self.chooseDatabase = function(value, e) {
  123. var key = 'hueRdbmsLastDatabase-' + self.server().name();
  124. self.selectedDatabase(self.databases.indexOf(value));
  125. $.totalStorage(key, value);
  126. };
  127. var error_fn = function(jqXHR, status, errorThrown) {
  128. try {
  129. $(document).trigger('server.error', $.parseJSON(jqXHR.responseText));
  130. } catch(e) {
  131. $(document).trigger('server.unmanageable_error', jqXHR.responseText);
  132. }
  133. };
  134. self.explainQuery = function() {
  135. var data = ko.mapping.toJS(self.query);
  136. data.database = self.database();
  137. data.server = self.server().name();
  138. var request = {
  139. url: '/rdbms/api/explain/',
  140. dataType: 'json',
  141. type: 'POST',
  142. success: function(data) {
  143. self.query.errors.removeAll();
  144. if (data.status === 0) {
  145. $(document).trigger('explain.query', data);
  146. self.updateResults(data.results);
  147. self.query.id(data.design);
  148. self.resultsEmpty(data.results.rows.length === 0);
  149. $(document).trigger('explained.query', data);
  150. } else {
  151. self.query.errors.push(data.message);
  152. }
  153. },
  154. error: error_fn,
  155. data: data
  156. };
  157. $.ajax(request);
  158. };
  159. self.fetchQuery = function(id) {
  160. var _id = id || self.query.id();
  161. if (_id && _id != -1) {
  162. var request = {
  163. url: '/rdbms/api/query/' + _id + '/get',
  164. dataType: 'json',
  165. type: 'GET',
  166. success: function(data) {
  167. self.updateQuery(data.design);
  168. },
  169. error: error_fn
  170. };
  171. $.ajax(request);
  172. }
  173. };
  174. self.saveQuery = function() {
  175. var self = this;
  176. if (self.query.query() && self.query.name()) {
  177. var data = ko.mapping.toJS(self.query);
  178. data['desc'] = data['description'];
  179. data['server'] = self.server().name();
  180. data['database'] = self.database();
  181. var url = '/rdbms/api/query/';
  182. if (self.query.id() && self.query.id() != -1) {
  183. url += self.query.id() + '/';
  184. }
  185. var request = {
  186. url: url,
  187. dataType: 'json',
  188. type: 'POST',
  189. success: function(data) {
  190. $(document).trigger('saved.query', data);
  191. },
  192. error: function() {
  193. $(document).trigger('error.query');
  194. },
  195. data: data
  196. };
  197. $.ajax(request);
  198. }
  199. };
  200. self.executeQuery = function() {
  201. var data = ko.mapping.toJS(self.query);
  202. data.database = self.database();
  203. data.server = self.server().name();
  204. var request = {
  205. url: '/rdbms/api/execute/',
  206. dataType: 'json',
  207. type: 'POST',
  208. success: function(data) {
  209. self.query.errors.removeAll();
  210. if (data.status === 0) {
  211. $(document).trigger('execute.query', data);
  212. self.updateResults(data.results);
  213. self.query.id(data.design);
  214. self.resultsEmpty(data.results.rows.length === 0);
  215. $(document).trigger('executed.query', data);
  216. } else {
  217. self.query.errors.push(data.message);
  218. }
  219. },
  220. error: error_fn,
  221. data: data
  222. };
  223. $.ajax(request);
  224. };
  225. self.fetchServers = function() {
  226. var request = {
  227. url: '/rdbms/api/servers/',
  228. dataType: 'json',
  229. type: 'GET',
  230. success: function(data) {
  231. self.updateServers(data.servers);
  232. self.fetchDatabases();
  233. },
  234. error: error_fn
  235. };
  236. $.ajax(request);
  237. };
  238. self.fetchDatabases = function() {
  239. if (self.server()) {
  240. var request = {
  241. url: '/rdbms/api/servers/' + self.server().name() + '/databases/',
  242. dataType: 'json',
  243. type: 'GET',
  244. success: function(data) {
  245. self.updateDatabases(data.databases);
  246. },
  247. error: error_fn
  248. };
  249. $.ajax(request);
  250. }
  251. };
  252. }