@@ -20,6 +20,7 @@ var adapter = ExportAdapter;
20
20
var cache = require ( './cache' ) ;
21
21
var dbConnections = { } ;
22
22
var databaseURI = 'mongodb://localhost:27017/parse' ;
23
+ var appDatabaseURIs = { } ;
23
24
24
25
function setAdapter ( databaseAdapter ) {
25
26
adapter = databaseAdapter ;
@@ -29,11 +30,17 @@ function setDatabaseURI(uri) {
29
30
databaseURI = uri ;
30
31
}
31
32
33
+ function setAppDatabaseURI ( appId , uri ) {
34
+ appDatabaseURIs [ appId ] = uri ;
35
+ }
36
+
32
37
function getDatabaseConnection ( appId ) {
33
38
if ( dbConnections [ appId ] ) {
34
39
return dbConnections [ appId ] ;
35
40
}
36
- dbConnections [ appId ] = new adapter ( databaseURI , {
41
+
42
+ var dbURI = ( appDatabaseURIs [ appId ] ? appDatabaseURIs [ appId ] : databaseURI ) ;
43
+ dbConnections [ appId ] = new adapter ( dbURI , {
37
44
collectionPrefix : cache . apps [ appId ] [ 'collectionPrefix' ]
38
45
} ) ;
39
46
dbConnections [ appId ] . connect ( ) ;
@@ -44,5 +51,6 @@ module.exports = {
44
51
dbConnections : dbConnections ,
45
52
getDatabaseConnection : getDatabaseConnection ,
46
53
setAdapter : setAdapter ,
47
- setDatabaseURI : setDatabaseURI
54
+ setDatabaseURI : setDatabaseURI ,
55
+ setAppDatabaseURI : setAppDatabaseURI
48
56
} ;
0 commit comments