cuYH863e

1//var mysql      = require('mysql');
2
3
4
5var fs = require('fs');
6var mysql = require('mysql');
7var csv = require('fast-csv');
8
9var stream = fs.createReadStream("test.csv");
10var myData = [];
11var csvStream = csv
12    .parse()
13    .on("data", function (data) {
14        myData.push(data);
15    })
16    .on("end", function () {
17        myData.shift();
18
19        // create a new connection to the database
20
21        var connection = mysql.createConnection({
22            host     : 'censored',
23            user     : 'remote',
24            password : 'remotePass',
25            database : 'remoteDB'
26        });
27        // open the connection
28        connection.connect(function(error)  {
29            if (error) {
30                console.error(error);
31            } else {
32                var createTest = "create table if not exists test(Ingredient varchar(255), ServingSize varchar(255), Calories varchar(255), Protein varchar(255), TotalFat varchar(255), SaturatedFat varchar(255),TransFat varchar(255), Cholesterol varchar(255), Carbohydrate varchar(255), Fiber varchar(255),Sugar varchar(255),Calcium varchar(255), Iron varchar(255),Magnesium varchar(255), Phosphorus varchar(255), Potassium varchar(255), Sodium varchar(255))";
33                connection.query(createTest, function(err, rows){
34                    if(err) {
35                        throw err;
36                    }else{
37                        console.log( rows );
38                    }
39                });
40                var query = 'INSERT INTO test (Ingredient, ServingSize, Calories, Protein, TotalFat, SaturatedFat,TransFat, Cholesterol, Carbohydrate, Fiber,Sugar,Calcium, Iron,Magnesium, Phosphorus, Potassium, Sodium) VALUES ?';
41                connection.query(query, [myData], function(error, response)  {
42                    console.log(error || response);
43                });
44                connection.query('SELECT * FROM test', function (err, result, fields) {
45                    if (err) throw err;
46                    console.log(result);
47                });
48                connection.end(function(err){
49// Do something after the connection is gracefully terminated.
50                });
51            }
52        });
53    });
54
55stream.pipe(csvStream);
56
57
58
59// connection.connect();
60// var createTodos = "create table if not exists todos(name varchar(255), address varchar(255))";
61// connection.query(createTodos, function(err, rows){
62//     if(err) {
63//         throw err;
64//     }else{
65//         console.log( rows );
66//     }
67// });
68// var sql = "INSERT INTO todos (name, address) VALUES ('Company Inc', 'Highway 37')";
69// connection.query(sql);
70// connection.query('SELECT * FROM todos')
71// );
72// connection.connect(
73//     function(err){
74//         if(err) throw err;
75//
76//         connection.query('SELECT * FROM createTodos', function(error)  {
77//             if(error) throw error;
78//
79//             console.log('Data received from Db:\n');
80//             console.log(rows);
81//         }
82//         );
83//     });
84
85// var strQuery = "select * from table1";
86// connection.query( strQuery, function(err, rows){
87//     if(err) {
88//         throw err;
89//     }else{
90//         console.log( rows );
91//     }
92// });
93
94// connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
95//
96//     if (error) throw error;
97//     console.log('The solution is: ', results[0].solution);
98//
99// });