-
Notifications
You must be signed in to change notification settings - Fork 0
/
insert.js
49 lines (34 loc) · 1.23 KB
/
insert.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
var mssql = require("mssql");
var csv = require("csvtojson");
const config = require('./config');
const dbconfig = {
user: config.db.user,
password: config.db.password,
server: config.db.host,
database: config.db.database,
port: config.db.port,
debug: true,
driver: config.db.driver,
};
mssql.connect(dbconfig, err => {
if (err)
console.log(err);
const trns = new mssql.Transaction();
trns.begin(err => {
// Invoking csv returns a promise
const converter=csv()
.fromFile('./Data.csv')
.then((json)=>{
json.forEach((row)=>{
console.log(row.firstname);
const insertstmt = new mssql.Request(trns);
insertstmt.query("insert into myusers (firstname, lastname) values ('"+ row.firstname+ "', '" + row.lastname + "' ) ", (err, result) => {
trns.commit(err => {
// ... error checks
console.log("Transaction committed.")
})
});
});
});
});
});