/
index.js
92 lines (80 loc) · 1.46 KB
/
index.js
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
var adapters
, path = require('path')
, _aliases
, _paths;
_aliases = {
postgres: 'postgres'
, pg: 'postgres'
, postgresql: 'postgres'
, mysql: 'mysql'
, sqlite: 'sqlite'
, riak: 'riak'
, mongo: 'mongo'
, memory: 'memory'
, filesystem: 'filesystem'
, level: 'level'
};
_adapters = {
postgres: {
path: 'sql/postgres'
, lib: 'pg'
, type: 'sql'
}
, mysql: {
path: 'sql/mysql'
, lib: 'mysql'
, type: 'sql'
}
, sqlite: {
path: 'sql/sqlite'
, lib: 'sqlite3'
, type: 'sql'
}
, riak: {
path: 'riak/index'
, lib: null
, type: 'nosql'
}
, mongo: {
path: 'mongo/index'
, lib: 'mongodb'
, type: 'nosql'
}
, memory: {
path: 'memory/index'
, lib: null
, type: 'nosql'
}
, filesystem: {
path: 'filesystem/index'
, lib: null
, type: 'nosql'
}
, level: {
path: 'level/index'
, lib: 'level'
, type: 'nosql'
}
};
for (var p in _adapters) {
_adapters[p].name = p;
}
adapters = new (function () {
this.getAdapterInfo = function (adapter) {
var canonical = _aliases[adapter]
, adapter = _adapters[canonical];
return adapter || null;
};
this.create = function (name, config) {
var info = this.getAdapterInfo(name)
, ctorPath
, ctor;
if (!info) {
throw new Error('"' + name + '" is not a valid adapter.');
}
ctorPath = path.join(__dirname, info.path)
ctor = require(ctorPath).Adapter;
return new ctor(config || {});
};
})();
module.exports = adapters;