Created
April 30, 2015 14:26
-
-
Save nathanwdavis/fc45bee99f22de9a93be to your computer and use it in GitHub Desktop.
Put this in your .robomongorc.js to get a toCSV() function you can stick on the end of a query to output CSV
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
//// toCSV | |
var toCSV = function(data, options){ | |
var headers = []; | |
var records = []; | |
var line; | |
var response = ''; | |
var i, l = data.length, rl=0, j, k; | |
var reReplaceTextDelim; | |
var processRecord = function(src, rec, prefix){ | |
var key, val, idx; | |
prefix = prefix || ''; | |
rec = rec || new Array(headers.length); | |
for(key in src){ | |
val = src[key]; | |
key = prefix+key; | |
switch(typeof(val)){ | |
case('object'): | |
if(val instanceof Array){ | |
processRecord(val, rec, key+options.headerDelim); | |
break; | |
}else if(val instanceof ObjectId){ | |
if(!options.includeObjectIdWrapper){ | |
val = ''+val; | |
} | |
}else if(!(val instanceof Date)){ | |
processRecord(val, rec, key+options.headerDelim); | |
break; | |
} | |
default: | |
if((idx = headers.indexOf(key))===-1){ | |
idx = headers.length; | |
headers.push(key); | |
} | |
rec[idx] = val.toString(); | |
} | |
} | |
return rec; | |
}; | |
options = options || {}; | |
options.delim = options.delim || ','; | |
options.textDelim = (options.textDelim !== undefined) ? options.textDelim : '"'; | |
options.eoln = options.eoln || '\r\n'; | |
options.headerDelim = options.headerDelim || '_'; | |
options.escapeTextDelim = options.escapeTextDelim || ('\\'+options.textDelim); | |
reReplaceTextDelim = new RegExp(options.textDelim, 'gi'); | |
if(options.includeHeaders === void(0)){ | |
options.includeHeaders = true; | |
} | |
for(i=0; i<l; i++){ | |
line = processRecord(data[i]); | |
if(rl < line.length){ | |
rl = line.length; | |
} | |
records.push(line); | |
} | |
if(options.includeHeaders){ | |
response = options.textDelim + headers.join(options.textDelim + options.delim + options.textDelim) + options.textDelim + options.eoln; | |
} | |
for(i=0; i<l; i++){ | |
line = records[i]; | |
if(line.length<rl){ | |
line = line.concat(new Array(rl-line.length)); | |
} | |
k = line.length; | |
for(j=0; j<k; j++){ | |
if(line[j] !== void(0)){ | |
response += options.textDelim + line[j] + options.textDelim; | |
} | |
if(j<k-1){ | |
response += options.delim; | |
} | |
} | |
response += options.eoln; | |
} | |
return response; | |
}; | |
DBQuery.prototype.toCSV = function(options){ | |
var cursor = this; | |
var data = []; | |
while(cursor.hasNext()){ | |
data.push(cursor.next()); | |
} | |
print(toCSV(data, options)); | |
}; | |
Array.prototype.toCSV = function(options) { | |
print(toCSV(this, options)); | |
}; |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment