将csv值作为数组发送到mongo db (指南针)

基础概念

CSV（Comma-Separated Values）是一种常见的数据交换格式，每一行代表一条记录，每个字段由逗号分隔。MongoDB是一个基于分布式文件存储的开源数据库系统，使用的数据结构是BSON（Binary JSON），类似于JSON但支持更多数据类型。

类型

CSV文件可以是单行或多行，包含或不包含标题行。
MongoDB中的集合（collection）类似于关系数据库中的表（table），但更加灵活。

应用场景

数据迁移：从CSV文件导入数据到MongoDB。
数据分析：将CSV数据转换为MongoDB文档进行复杂查询和分析。

如何将CSV值作为数组发送到MongoDB

假设你有一个CSV文件data.csv，内容如下：

name,age,city
Alice,30,New York
Bob,25,Los Angeles
Charlie,35,Chicago

你可以使用Node.js和MongoDB驱动程序来实现这一过程。以下是一个示例代码：

const fs = require('fs');
const csv = require('csv-parser');
const MongoClient = require('mongodb').MongoClient;

// MongoDB连接字符串
const url = 'mongodb://localhost:27017';
const dbName = 'mydatabase';
const collectionName = 'users';

// 读取CSV文件并转换为数组
const dataArray = [];
fs.createReadStream('data.csv')
  .pipe(csv())
  .on('data', (data) => dataArray.push(data))
  .on('end', () => {
    console.log('CSV file successfully processed');

    // 连接到MongoDB
    MongoClient.connect(url, { useNewUrlParser: true, useUnifiedTopology: true }, (err, client) => {
      if (err) {
        return console.error('Unable to connect to the server', err);
      }
      console.log('Connected successfully to server');

      const db = client.db(dbName);
      const collection = db.collection(collectionName);

      // 将数据插入MongoDB
      collection.insertMany(dataArray, (err, result) => {
        if (err) {
          return console.error('Unable to insert documents', err);
        }
        console.log('Documents inserted');
        client.close();
      });
    });
  });