1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
// mongo.js
// NOTE 'Mongo' may be defined here or in MongoJS.cpp. Add code to init, not to this constructor.
if ( typeof Mongo == "undefined" ){
Mongo = function( host ){
this.init( host );
}
}
if ( ! Mongo.prototype ){
throw "Mongo.prototype not defined";
}
if ( ! Mongo.prototype.find )
Mongo.prototype.find = function( ns , query , fields , limit , skip , batchSize , options ){ throw "find not implemented"; }
if ( ! Mongo.prototype.insert )
Mongo.prototype.insert = function( ns , obj ){ throw "insert not implemented"; }
if ( ! Mongo.prototype.remove )
Mongo.prototype.remove = function( ns , pattern ){ throw "remove not implemented;" }
if ( ! Mongo.prototype.update )
Mongo.prototype.update = function( ns , query , obj , upsert ){ throw "update not implemented;" }
if ( typeof mongoInject == "function" ){
mongoInject( Mongo.prototype );
}
Mongo.prototype.setSlaveOk = function( value ) {
if( value == undefined ) value = true
this.slaveOk = value
}
Mongo.prototype.getDB = function( name ){
return new DB( this , name );
}
Mongo.prototype.getDBs = function(){
var res = this.getDB( "admin" ).runCommand( { "listDatabases" : 1 } );
if ( ! res.ok )
throw "listDatabases failed:" + tojson( res );
return res;
}
Mongo.prototype.adminCommand = function( cmd ){
return this.getDB( "admin" ).runCommand( cmd );
}
Mongo.prototype.setLogLevel = function( logLevel ){
return this.adminCommand({ setParameter : 1, logLevel : logLevel })
}
Mongo.prototype.getDBNames = function(){
return this.getDBs().databases.map(
function(z){
return z.name;
}
);
}
Mongo.prototype.getCollection = function(ns){
var idx = ns.indexOf( "." );
if ( idx < 0 )
throw "need . in ns";
var db = ns.substring( 0 , idx );
var c = ns.substring( idx + 1 );
return this.getDB( db ).getCollection( c );
}
Mongo.prototype.toString = function(){
return "connection to " + this.host;
}
Mongo.prototype.tojson = Mongo.prototype.toString;
connect = function( url , user , pass ){
chatty( "connecting to: " + url )
if ( user && ! pass )
throw "you specified a user and not a password. either you need a password, or you're using the old connect api";
var idx = url.lastIndexOf( "/" );
var db;
if ( idx < 0 )
db = new Mongo().getDB( url );
else
db = new Mongo( url.substring( 0 , idx ) ).getDB( url.substring( idx + 1 ) );
if ( user && pass ){
if ( ! db.auth( user , pass ) ){
throw "couldn't login";
}
}
return db;
}
|
