mongo import and export

mongo-export

#!/bin/node

"use strict";
var fs = require('fs'),
    exec = require('child_process').exec;

var db = process.argv[2],
    out_dir = process.argv[3],
    host = process.argv[4] || 'localhost';

if(!out_dir) {
    out_dir = './';
}
else {
    if(!fs.statSync(out_dir).isDirectory()) {
        fs.mkdirSync(out_dir);
    }
}

exec('mongo ' + db + ' --host ' + host + ' --quiet --eval "print(db.getCollectionNames())"', function(err, stdout, stderr) {
    if(err) {
        console.log(stdout);
        console.error(stderr);
        throw new Error(err);
    }
    stdout.split(',').forEach(exportCollection);
});

function exportCollection(collection) {
    console.log('Exporting: '+collection);
    exec('mongoexport --host ' + host + ' -d ' + db + ' -c "' + collection + '" --jsonArray', function(err, stdout) {
        if(err) {
            throw new Error(err);
        }
        var data = JSON.parse(stdout);
        console.log(collection+': '+data.length+' records');
        fs.writeFile(out_dir+'/'+db+'_'+collection+'.json', JSON.stringify(data, null, "    "), function(err) {
            if(err) {
                throw new Error(err);
            }
        });
    });
}

mongo-import

#!/bin/node

"use strict";
var fs = require('fs'),
    path = require('path'),
    exec = require('child_process').exec;

var db = process.argv[2],
    src_dir = process.argv[3],
    host = process.argv[4] || 'localhost';


fs.readdir(src_dir, function(err, files) {
    if(err) {
        throw new Error(err);
    }
    files = files.filter(function(file) { return path.extname(file) === '.json';});
    files.forEach(importCollection);
});

function importCollection(file) {
    var collection = file.substring(file.indexOf('_')+1, file.lastIndexOf('.'));
    console.log('Import: '+collection);
    exec('mongoimport --host ' + host + ' -d ' + db + ' -c "' + collection + '" --jsonArray < "'+src_dir+'/'+file+'"', function(err, stdout, stderr) {
        console.log(stdout);
        if(err) {
            console.error(stderr);
            throw new Error(err);
        }
    });
}