1 exports.listSLA = function(settings,req,res) {
3 var mysql = require('mysql');
5 //console.dir(settings);
7 var connection = mysql.createConnection(
9 host : settings.dbHost,
10 port : settings.dbPort,
11 user : settings.dbUser,
12 password : settings.dbPassword,
13 database : settings.dbName
18 var sqlQuery = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC";
19 //console.log("sqlQuery:" + sqlQuery);
20 connection.query(sqlQuery, function(err, rows) {
22 if ( rows.length > 0 )
24 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
26 res.send({'rows': [],'dbHost':settings.dbHost});
29 console.log("error:" + err);
30 res.send({error: "Connection to DB failed.",'dbHost':settings.dbHost});
37 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
41 exports.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);
47 var mysql = require('mysql');
49 //console.dir(settings);
51 var connection = mysql.createConnection(
53 host : settings.dbHost,
54 port : settings.dbPort,
55 user : settings.dbUser,
56 password : settings.dbPassword,
57 database : settings.dbName
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) {
66 if ( rows.length > 0 )
68 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
70 res.send({'rows': [],'dbHost':settings.dbHost});
73 console.log("error:" + err);
74 res.send({error: "Connection to DB failed.",'dbHost':settings.dbHost});
81 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
85 exports.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;
93 var mysql = require('mysql');
95 var connection = mysql.createConnection(
97 host : settings.dbHost,
98 port : settings.dbPort,
99 user : settings.dbUser,
100 password : settings.dbPassword,
101 database : settings.dbName
106 var updateStmt = "UPDATE SVC_LOGIC SET active=\'Y\' WHERE module=\'"
107 + _module + "' AND rpc=\'"
108 + rpc + "' AND version=\'"
109 + version + "' AND mode=\'"
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 !=\'"
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 + "'";
123 connection.query(query, function(err, rows) {
125 if ( rows.length > 0 )
127 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
129 res.send({'rows': [],'dbHost':settings.dbHost});
132 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
139 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
144 exports.deActivateDG = function(settings,req,res){
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;
153 var mysql = require('mysql');
155 var connection = mysql.createConnection(
157 host : settings.dbHost,
158 port : settings.dbPort,
159 user : settings.dbUser,
160 password : settings.dbPassword,
161 database : settings.dbName
166 var updateStmt = "UPDATE SVC_LOGIC SET active=\'N\' WHERE module=\'"
167 + _module + "' AND rpc=\'"
168 + rpc + "' AND version=\'"
169 + version + "' AND mode=\'"
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 + "'";
178 connection.query(query, function(err, rows) {
180 if ( rows.length > 0 )
182 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
184 res.send({'rows': [],'dbHost':settings.dbHost});
187 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
193 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
197 exports.deleteDG = function(settings,req,res){
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;
206 var mysql = require('mysql');
208 var connection = mysql.createConnection(
210 host : settings.dbHost,
211 port : settings.dbPort,
212 user : settings.dbUser,
213 password : settings.dbPassword,
214 database : settings.dbName
219 var deleteStmt = "DELETE FROM SVC_LOGIC WHERE module=\'"
220 + _module + "' AND rpc=\'"
221 + rpc + "' AND version=\'"
222 + version + "' AND mode=\'"
224 console.log(deleteStmt);
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 + "'";
232 connection.query(query, function(err, rows) {
234 if ( rows.length > 0 )
236 res.send({ 'rows': rows,'dbHost':settings.dbHost } );
238 res.send({'rows': [],'dbHost':settings.dbHost});
241 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
247 res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});