使用节点pg将csv文件中的多行插入到数据库中

const pg = require('pg');
const fs = require('fs');

// 创建数据库连接
const config = {
  user: 'your_username',
  password: 'your_password',
  host: 'your_host',
  port: 'your_port',
  database: 'your_database'
};

const client = new pg.Client(config);

client.connect((err) => {
  if (err) {
    console.error('数据库连接失败', err);
    return;
  }
  console.log('数据库连接成功');

  // 读取csv文件
  const csvData = fs.readFileSync('path_to_csv_file', 'utf-8');

  // 将csv文件中的每一行插入到数据库中
  const rows = csvData.trim().split('\n');
  rows.forEach((row) => {
    const values = row.split(',');
    const insertQuery = `INSERT INTO table_name (column1, column2, column3) VALUES ($1, $2, $3)`;
    client.query(insertQuery, values, (error, result) => {
      if (error) {
        console.error('插入数据失败', error);
      }
    });
  });

  // 关闭数据库连接
  client.end((error) => {
    if (error) {
      console.error('关闭数据库连接失败', error);
    }
    console.log('数据库连接已关闭');
  });
});