cJsfKdvT

1      var qData = q.query;
2      var insert = "INSERT INTO `records` VALUES ("
3      + new Date().getHours() + ",'" 
4      + qData.UserName + "','" 
5      + qData.UserFavoriteTopic + "');"
6
7      var createTable = "CREATE TABLE IF NOT EXISTS `records` ( \
8        `hour` int(2) NOT NULL default -1, \
9        `username` varchar(255) NOT NULL default '', \
10        `favoriteTopic` varchar(255) NOT NULL default '' \
11        );";
12
13      if (qData.UserName){
14        connection.connect(function(err) {
15            if(err)  console.log("Already Connected ..") 
16            console.log("Connected!");
17
18        connection.query("CREATE DATABASE IF NOT EXISTS my_db;", function (err, result) {
19                if (err) throw err;
20                console.log("DB created")
21            })
22            connection.query("USE my_db;", function (err, result){
23                if (err) throw err;
24                console.log("Using my_db")
25            })
26            connection.query(createTable, function (err, result){
27                if (err) throw err;
28                console.log("Table created!")
29            })
30            connection.query(insert, function (err, result){
31                if (err) {
32                    res.writeHead(404, {'Content-Type': 'text/html'})
33                    return res.end('<h1>An error occurred while trying to save to DB</h1>')
34                }
35                console.log("Saved into DB!")
36                res.writeHead(200, {'Content-Type': 'text/html'})
37                return res.end('<h1>Saved into DB!</h1>')
38            })
39        })
40    }
41    else {
42        
43        return res.end('<h1>An error occurred while trying to save to DB</h1>')
44    }
45}