0

собственно написал вот такой код,

var csv = require('csv-stream');
var request = require('request');
var fs = require('fs');
var pg = require('pg');
var conString = "pg://admin:admin@localhost:5432/labels";

// All of these arguments are optional. 
var options = {
    delimiter : ';', // default is , 
    endLine : '\n', // default is \n, 
    escapeChar : '"', // default is an empty string 
    enclosedChar : '"', // default is an empty string 

}
try {


var csvStream = csv.createStream(options);
fs.createReadStream('personss.csv').pipe(csvStream)
.on('error', function (err) {
    console.error(err);
})
.on('data', function (data) {
    // outputs an object containing a set of key/value pair representing a line found in the csv file. 
    console.log(data);

    pg.connect(conString, function (err, client, done) {
            client.query(
                'INSERT into test (firstname, lastname) from', 
        function (err, result) {
                    if (err) {
                        console.log(err);
                    } else {
                        console.log('data inserted');
                    }
                });

    });
});
} catch (e) {
console(e.message);
};

Как написать в client.query чтоб он вставлял в базу данные те строки которые были записанны в переменную data при парсере.

Update

pg.connect(conString, function (err, client, done) {
        var sql = 'INSERT into test (firstname, lastname) VALUES ("' + data.firstname + '","' + data.lastname + '")'
            client.query(sql,
        function (err, result) {
                    if (err) {
                        console.log(err);
                    } else {
                console.log('data inserted' + result.data[0]);
                client.end();
                    }
                });

    });
7
  • 1
    github.com/brianc/… 2 дек 2016 в 10:11
  • я не понимаю как он делает чтоб записывалось то что прошло по стриму в переменную. Начинающий я грубо говоря, маленькими шагами иду вперед
    – t0rick
    2 дек 2016 в 10:15
  • тогда читай первую ссылку, делай forEach по data и внутри вызывай client.query 2 дек 2016 в 10:17
  • 1
    в js цикл записан не правильно, в sql не insert-ятся никакие данные (хотя по первой ссылке явно показано как это делать). почитай хоть какие-то вводные книжки по этим языкам. 2 дек 2016 в 10:43

1 ответ 1

-1
 pg.connect(conString, function (err, client, done) {
    var sql = "INSERT into test (firstname, lastname) VALUES ('" + data.firstname + "','" + data.lastname + "')"
        client.query(sql,
    function (err, result) {
                if (err) {
                    console.log(err);
                } else {
            console.log('data inserted' + result.data[0]);
            client.end();
                }
            });

});

UPDATE 1.0

скажу одно, надо следить за кавычками

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.