这是我与rethinkdb的第一次互动,看起来不错,但是我遇到了一些问题...
这个想法很简单:创建一个数据库(如果尚未创建)。
代码很简单,或者说是代码的概念:
module.exports = function(r, config) {
var connection = null;
r.connect(config.rdb, function(err, conn) {
if (err) throw err
connection = conn;
});
r.dbList()
.contains('semestres')
.do(function(dbExists) {
return r.branch(
dbExists,
{ created: 0 },
r.dbCreate('semestres')
);
})
.run(connection, function(err) {
if (err) throw err;
});
};
因此,这只会创建一个连接并将该连接分配给变量,然后检查数据库“ semestres”是否存在,如果存在,则不执行任何操作,否则,请创建它。
但不是,运行服务器时出现此错误:
Unhandled rejection RqlDriverError: First argument to `run` must be an open connection.
at new RqlDriverError (/home/nano/Dev/semestres/node_modules/rethinkdb/errors.js:14:13)
at FunCall.TermBase.run (/home/nano/Dev/semestres/node_modules/rethinkdb/ast.js:129:29)
at module.exports (/home/nano/Dev/semestres/config/database.js:20:6)
at Object.<anonymous> (/home/nano/Dev/semestres/server.js:10:29)
at Module._compile (module.js:428:26)
at Object.Module._extensions..js (module.js:446:10)
at Module.load (module.js:353:32)
at Function.Module._load (module.js:308:12)
at Function.Module.runMain (module.js:469:10)
at startup (node.js:124:18)
at node.js:882:3
那么,如何在rethinkdb中进行此类操作?
因为这是JavaScript,并且代码是异步的,所以您的dbList
查询无权访问connection
变量。您需要将dbList
代码放入connect回调中。
module.exports = function(r, config) {
var connection = null;
r.connect(config.rdb, function(err, conn) {
if (err) throw err
connection = conn;
r.dbList()
.contains('semestres')
.do(function(dbExists) {
return r.branch(
dbExists,
{ created: 0 },
r.dbCreate('semestres')
);
})
.run(connection, function(err) {
if (err) throw err;
});
};
});
这与RethinkDB本身无关,但与范围界定在JavaScript中的工作方式有关。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句