weixin_好的 2018-09-24 10:52 采纳率: 100%
浏览 1451
已采纳

nodejs 导入大txt文件 到mongodb

TXT如:
查询表名@#$机构编码|!?|姓名|!?|品种|!?|@#$53|!?|张三|!?|苹果|!?|@#$54|!?|李四|!?|菜篮|!|?@#$......

@#$ |!?| 是原始文件分隔符

查询表名 为mongodb 集合名
机构编码 姓名 品种 字段名 ?var lines = strchunk.split("@#$").trim();?
53 张三 苹果 字段内容 var cols = lines[i].split("@#$").trim();?
参考
第2 行 a b c d
2 21 22 23 24
3 31 32 33 34
问1:如何转换为json {{a:21,b:22,c:23,d:24} , {a:31,b:32,c:33,d:34}}

mongodb数据库 第1 行 a b c d为字段名
第2、3 行为内容

                                                    注意TXT可能有近5000行

问2:如何导入数据库

                                                    求 代码

var fstorm = require('fstorm');
var readLine = require('lei-stream').readLine;
我用过但不成功
注意要处理中文
var iconv = require("iconv-lite");//中文转码

  • 写回答

2条回答 默认 最新

  • devmiao 2018-09-24 11:09
    关注

    var http = require("http"),
        url = require("url"),
        mongo = require('mongodb'),
        path = require("path"),
        ObjectID = require('mongodb').ObjectID,
        Grid = require('gridfs-stream'),
        gridform = require('gridform'),
        fs = require("fs"),
        GridStore = require('mongodb').GridStore;

    function FileServer(db) {
        if (!(this instanceof FileServer)) return new FileServer(db);
        this.db = db;
    }

    FileServer.prototype.start = function start(listenport) {
        var me = this;
        me.db.open(function(err) {
            if (err) {
                console.log(err);

    以下代码采纳后可见

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 delta降尺度计算的一些细节,有偿
  • ¥15 Arduino红外遥控代码有问题
  • ¥15 数值计算离散正交多项式
  • ¥30 数值计算均差系数编程
  • ¥15 redis-full-check比较 两个集群的数据出错
  • ¥15 Matlab编程问题
  • ¥15 训练的多模态特征融合模型准确度很低怎么办
  • ¥15 kylin启动报错log4j类冲突
  • ¥15 超声波模块测距控制点灯,灯的闪烁很不稳定,经过调试发现测的距离偏大
  • ¥15 import arcpy出现importing _arcgisscripting 找不到相关程序