nodeJS with database

backend/config.js

+
+var Connection = require('tedious').Connection
+var Request = require('tedious').Request
+
+var config = {
+  server: 'DESKTOP-BP4I6KI',
+  database: 'SAMPLE',
+  options: {
+    trustServerCertificate: true
+  },
+  authentication: {
+    type: 'default',
+    options: {
+        userName: 'test', //update me
+        password: 'test'  //update me
+    }
+},
+}
+
+var connection = new Connection(config)
+
+connection.on('connect', function (err) {
+  if (err) {
+    console.log(err)
+  } else {
+    executeStatement()
+  }
+})
+
+function executeStatement () {
+  request = new Request("SELECT * FROM SAMPLE.dbo.pointTable", function (err, rowCount) {
+    if (err) {
+      console.log(err)
+    } else {
+      console.log(rowCount + ' rows')
+    }
+    connection.close()
+  })
+
+  request.on('row', function (columns) {
+    console.log(columns);
+  })
+
+  connection.execSql(request)
+}
\ No newline at end of file

backend/package.json

@@ -11,7 +11,10 @@
     "grpc": "^1.24.3",
     "grpc-web": "^1.0.0",
     "lodash": "4.17.20",
-    "streammagic": "^1.0.0"
+    "mssql": "^6.2.3",
+    "mysql": "^2.18.1",
+    "streammagic": "^1.0.0",
+    "tedious": "^9.2.1"
   },
   "eslintConfig": {
     "root": true,

backend/server.js

@@ -7,6 +7,7 @@ var _ = require('lodash');
 var grpc = require('@grpc/grpc-js');
 var protoLoader = require('@grpc/proto-loader');
 const http = require("http");
+//let connection = mysql.createConnection(config);
 
 var packageDefinition = protoLoader.loadSync(
     PROTO_PATH,
@@ -26,9 +27,22 @@ function sendPoint(call, callback) {
   })
 }
 
+function addToDB(call){
+  return
+  let sql = `INSERT INTO SAMPLE.dbo.pointTable
+           VALUES (2,2)`;
+
+  // execute the insert statment
+  connection.query(sql);
+}
 
 //Route the grpc function to the microservice
 function sendPointStream(call) {
+  
+  if(call.request.modelid){
+    //Non-empty training set
+    addToDB(call);
+  }
   console.log(call.request.modelid)
   console.log(call.request.rows)
   http.get("http://localhost:8090/generatePointStream", res =>{