-
Notifications
You must be signed in to change notification settings - Fork 0
/
functions.js
80 lines (68 loc) · 2.31 KB
/
functions.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
server.get('/users', function (req, res, next) {
connect();
var query = "SELECT guid from " + table;
connection.query(query, function(err, rows, fields) {
if (err) {
console.log("Error querying database: " + err);
res.send(500);
}
res.send(200, rows);
});
})
server.get('/' + field + '/:guid', function (req, res, next) {
connect();
var query = "SELECT " + field + " from " + table + " where guid like \"" + req.params.guid + "\"";
connection.query(query, function(err, rows, fields) {
if (err) {
console.log("Error querying database: " + err);
res.send(500);
}
console.log('Query for: ', req.params.guid , ', returned: ', rows[0][field]);
// sending the first hit (but there should theoretically only be one)
res.send(200, rows[0][field]);
});
})
server.post('/user', function (req, res, next) {
connect();
console.log(req.params);
if (req.params.guid === undefined) {
return next(new restify.InvalidArgumentError('GUID must be supplied'))
}
var query = "INSERT into " + table + " (guid, " + field + ") VALUES('" + req.params.guid + "', " + req.params[field] + ")";
connection.query(query, function(err, rows, fields) {
if (err) {
console.log("Error querying database: " + err);
res.send(500);
}
console.log('Created row for: ', req.params.guid);
res.send(201);
});
})
server.put('/user/:guid', function (req, res, next) {
connect();
console.log(req.params);
if (req.params[field] === undefined) {
return next(new restify.InvalidArgumentError(field + ' must be supplied'))
}
var query = "UPDATE " + table + " set " + field + "=" + req.params[field] + " where guid like \"" + req.params.guid + "\"";
connection.query(query, function(err, rows, fields) {
if (err) {
console.log("Error querying database: " + err);
res.send(500);
}
console.log('Updated row for: ', req.params.guid);
res.send(200);
});
})
server.del('/user/:guid', function (req, res, next) {
connect();
var query = "DELETE from " + table + " where guid like \"" + req.params.guid + "\"";
connection.query(query, function(err, rows, fields) {
if (err) {
console.log("Error querying database: " + err);
res.send(500);
}
console.log('Deleted row for: ', req.params.guid);
res.send(200);
});
})