Insert CSV File In Mysql Table Using Nodejs

 

 

const fs = require("fs");
const mysql = require("mysql");
const fastcsv = require("fast-csv");

let pkStream = fs.createReadStream("abc.csv");
let pkCsvData = [];
let pkCsvStream = fastcsv
  .parse()
  .on("data", function (data) {
    pkCsvData.push(data);
  })
  .on("end", function () {
    pkCsvData.shift();

    const pkConnection = mysql.createConnection({
      host: "localhost",
      user: "root",
      password: "root@123",
      database: "abc",
    });

    pkConnection.connect((error) => {
      if (error) {
        console.error(error);
      } else {
        let pkQuery = "INSERT INTO users (name, address) VALUES ?";
        pkConnection.query(pkQuery, [pkCsvData], (error, response) => {
          console.log(error || response);
        });
      }
    });
  });

pkStream.pipe(pkCsvStream);