commit
c28b803927
|
@ -49,6 +49,9 @@ exports.initialize = function initializeSchema(schema, callback) {
|
|||
s.database = s.database || 'test';
|
||||
|
||||
}
|
||||
|
||||
s.safe = s.safe || false;
|
||||
|
||||
schema.adapter = new MongoDB(s, schema, callback);
|
||||
};
|
||||
|
||||
|
@ -69,7 +72,7 @@ function MongoDB(s, schema, callback) {
|
|||
server = new mongodb.Server(s.host, s.port, {});
|
||||
}
|
||||
|
||||
new mongodb.Db(s.database, server, {}).open(function (err, client) {
|
||||
new mongodb.Db(s.database, server, { safe: s.safe }).open(function (err, client) {
|
||||
if (err) throw err;
|
||||
if (s.username && s.password) {
|
||||
t = this;
|
||||
|
|
Loading…
Reference in New Issue