Gitiles
Code Review Sign In
gerrit.nordix.org / onap / ccsdk / distribution / dad42728c966c57212bf506f10bd9812497f8ce8 / . / dgbuilder / red / sla.js
blob: 1729ecbb1a497e4c9265df9a7af2f1c0208de17c [file] [log] [blame]
Chinthakayala, Sheshashailavas (sc2914)d1569972017-08-28 05:25:46 -0900[diff] [blame]1exports.listSLA = function(settings,req,res) {
2try{
3 var mysql = require('mysql');
4
5 //console.dir(settings);
6
7 var connection = mysql.createConnection(
8 {
9 host : settings.dbHost,
10 port : settings.dbPort,
11 user : settings.dbUser,
12 password : settings.dbPassword,
13 database : settings.dbName
14 });
15
16 var rows=[];
17
18 var sqlQuery = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC";
19 //console.log("sqlQuery:" + sqlQuery);
20 connection.query(sqlQuery, function(err, rows) {
21 if(!err) {
22 if ( rows.length > 0 )
23 {
24 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
25 }else{
26 res.send({'rows': [],'dbHost':settings.dbHost});
27 }
28 } else {
29 console.log("error:" + err);
30 res.send({error: "Connection to DB failed.",'dbHost':settings.dbHost});
31 }
32 //console.dir(rows);
33 connection.end();
34 }); //end query
35}catch(error){
36 console.log(error);
37 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
38}
39}
40
41exports.listCurrentDGs = function(settings,req,res) {
42 var _module = req.query.module;
43 var rpc = req.query.rpc;
44 console.log("_module:" + _module);
45 console.log("rpc:" + rpc);
46try{
47 var mysql = require('mysql');
48
49 //console.dir(settings);
50
51 var connection = mysql.createConnection(
52 {
53 host : settings.dbHost,
54 port : settings.dbPort,
55 user : settings.dbUser,
56 password : settings.dbPassword,
57 database : settings.dbName
58 });
59
60 var rows=[];
61
62 var sqlQuery = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC where module ='" + _module + "' and rpc ='" + rpc + "'";
63 console.log("sqlQuery:" + sqlQuery);
64 connection.query(sqlQuery, function(err, rows) {
65 if(!err) {
66 if ( rows.length > 0 )
67 {
68 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
69 }else{
70 res.send({'rows': [],'dbHost':settings.dbHost});
71 }
72 } else {
73 console.log("error:" + err);
74 res.send({error: "Connection to DB failed.",'dbHost':settings.dbHost});
75 }
76 //console.dir(rows);
77 connection.end();
78 }); //end query
79}catch(error){
80 console.log(error);
81 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
82}
83}
84
85exports.activateDG = function(settings,req,res){
86 var _module = req.query.module;
87 var rpc = req.query.rpc;
88 var version = req.query.version;
89 var mode = req.query.mode;
90 var displayOnlyCurrent = req.query.displayOnlyCurrent;
91
92try{
93 var mysql = require('mysql');
94
95 var connection = mysql.createConnection(
96 {
97 host : settings.dbHost,
98 port : settings.dbPort,
99 user : settings.dbUser,
100 password : settings.dbPassword,
101 database : settings.dbName
102 });
103
104 var rows=[];
105
106 var updateStmt = "UPDATE SVC_LOGIC SET active=\'Y\' WHERE module=\'"
107 + _module + "' AND rpc=\'"
108 + rpc + "' AND version=\'"
109 + version + "' AND mode=\'"
110 + mode + "'";
111
112 connection.query(updateStmt, function(err, result) {
113 var nextUpdateStmt = "UPDATE SVC_LOGIC SET active=\'N\' WHERE module=\'"
114 + _module + "' AND rpc=\'"
115 + rpc + "' AND version !=\'"
116 + version + "'";
117 connection.query(nextUpdateStmt, function(err, result) {
118 var query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC";
119 if(displayOnlyCurrent == 'true'){
120 query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC WHERE module=\'"
121 + _module + "' and rpc=\'" + rpc + "'";
122 }
123 connection.query(query, function(err, rows) {
124 if(!err) {
125 if ( rows.length > 0 )
126 {
127 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
128 }else{
129 res.send({'rows': [],'dbHost':settings.dbHost});
130 }
131 } else {
132 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
133 }
134 connection.end();
135 }); //end query
136 }); //end query
137 }); //end query
138}catch(error){
139 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
140}
141}
142
143
144exports.deActivateDG = function(settings,req,res){
145
146 var _module = req.query.module;
147 var rpc = req.query.rpc;
148 var version = req.query.version;
149 var mode = req.query.mode;
150 var displayOnlyCurrent = req.query.displayOnlyCurrent;
151
152try{
153 var mysql = require('mysql');
154
155 var connection = mysql.createConnection(
156 {
157 host : settings.dbHost,
158 port : settings.dbPort,
159 user : settings.dbUser,
160 password : settings.dbPassword,
161 database : settings.dbName
162 });
163
164 var rows=[];
165
166 var updateStmt = "UPDATE SVC_LOGIC SET active=\'N\' WHERE module=\'"
167 + _module + "' AND rpc=\'"
168 + rpc + "' AND version=\'"
169 + version + "' AND mode=\'"
170 + mode + "'";
171
172 connection.query(updateStmt, function(err, result) {
173 var query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC";
174 if(displayOnlyCurrent == 'true'){
175 query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC WHERE module=\'"
176 + _module + "' and rpc=\'" + rpc + "'";
177 }
178 connection.query(query, function(err, rows) {
179 if(!err) {
180 if ( rows.length > 0 )
181 {
182 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
183 }else{
184 res.send({'rows': [],'dbHost':settings.dbHost});
185 }
186 } else {
187 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
188 }
189 connection.end();
190 }); //end query
191 }); //end query
192}catch(error){
193 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
194}
195}
196
197exports.deleteDG = function(settings,req,res){
198
199 var _module = req.query.module;
200 var rpc = req.query.rpc;
201 var version = req.query.version;
202 var mode = req.query.mode;
203 var displayOnlyCurrent = req.query.displayOnlyCurrent;
204
205try{
206 var mysql = require('mysql');
207
208 var connection = mysql.createConnection(
209 {
210 host : settings.dbHost,
211 port : settings.dbPort,
212 user : settings.dbUser,
213 password : settings.dbPassword,
214 database : settings.dbName
215 });
216
217 var rows=[];
218
219 var deleteStmt = "DELETE FROM SVC_LOGIC WHERE module=\'"
220 + _module + "' AND rpc=\'"
221 + rpc + "' AND version=\'"
222 + version + "' AND mode=\'"
223 + mode + "'";
224 console.log(deleteStmt);
225
226 connection.query(deleteStmt, function(err, result) {
227 var query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC";
228 if(displayOnlyCurrent == 'true'){
229 query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC WHERE module=\'"
230 + _module + "' and rpc=\'" + rpc + "'";
231 }
232 connection.query(query, function(err, rows) {
233 if(!err) {
234 if ( rows.length > 0 )
235 {
236 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
237 }else{
238 res.send({'rows': [],'dbHost':settings.dbHost});
239 }
240 } else {
241 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
242 }
243 connection.end();
244 }); //end query
245 }); //end query
246}catch(error){
247 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
248}
249}