Tag: rethinkdb

rethinkdb&nodejs:将结果保存在var

有可能将rethinkdb的结果查询保存在一个variables中? 喜欢这个?? var test = r.db('chat').table('group_chat').count(r.row('passengers').contains(function(passeggers) { return passeggers('nome').eq('pigi'); })).run() 现在我用这个方法 var test; r.db('chat').table('group_chat').count(r.row('passengers').contains(function(passeggers) { return passeggers('nome').eq('pigi'); })).run().then(function(response){ test = response; })

Rethinkdb点换签不一致

我正在处理变更提要,我有一个变更提要触发的API。 更改供稿中的console.logs仅在调用API并且发生更改供稿时才会打印。 下次换货时没有任何反应。 exports.trackUser = (id) => { return r.table(USERS_TABLE).get(id).changes() .then((feeds) => { console.log(feeds) feeds.each((err, feed) => { if (err) { logger.error(err) } if (feed) { console.log("change feed") } }) }) .error(logger.error); } 这是API。 在这里,一旦API被调用,然后在用户表中有一个更新,我会看到日志。 再次如果有更新,我没有看到日志。 每当USER_TABLE有更新时如何使这个工作成功? 具体到该ID?

RethinkDB抛出错误,而不是在callback中返回它们

Nodejs的情况: r.db('users').get('e@mai.l').without(['password']).run() 如果用户不存在rethinkdb将会抛出一个错误 — 2014-01-22T13:26:04.720Z [20163] [ ctx error ] — RqlRuntimeError: Cannot perform without on a non-object non-sequence `null`. in: r.table('users').get('e@mai.l').without(['password']) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 问题: 为什么Rethink会抛出错误而不是在callback的第一个参数中返回? 为什么它会抛出错误呢? 不能它只是最后返回null,完成请求?

在rethindb中使用节点插入错误

我是rethinkdb的新手。 当我尝试在https://github.com/rethinkdb/rethinkdb-example-nodejs/tree/master/todo-angular-express中的示例代码 function create(req, res, next) { var todo = req.body; todo.createdAt = r.now(); // Set the field `createdAt` to the current time r.table('todos').insert(todo, {returnVals: true}).run(req._rdbConn, function(error, result) { if (error) { handleError(res, error) } else if (result.inserted !== 1) { handleError(res, new Error("Document was not inserted.")) } else { res.send(JSON.stringify(result.new_val)); } next(); }); } […]

使用Nodejs将terminal的输出写入RethinkDB数据库

我目前有一个基本的网站/networking服务器设置通过Node.JS(源可在github )。 我有一个rethinkDB数据库运行,这一切都configuration正确。我的主要问题是搞清楚如何写terminal的输出到RethinkDB。 我想最好的办法是通过Cron作业echo显terminal输出到文件。 主要的问题是如何能够重复加载这个文件到RethinkDB数据库然后显示在网站上?

这个javascript代码在node.js中有什么问题,并且以rethinkdb作为后端?

我的JavaScript代码如下: var r = require('rethinkdb'); var soll1=null; var soll=null; r.connect( {host: 'localhost', port: 28015}, function(err, conn) { r.db("discogs").table("releases").limit(4).run(conn, function(err, cursor) { if (err) throw err; cursor.toArray(function(err, result) { if (err) throw err; soll=result.country; }); }); }); var http = require('http'); http.createServer(function (req, res) {res.write(soll);res.end();}).listen(3001, "127.0.0.1"); console.log('Server running at http://127.0.0.1:3001/'); 我在rethinkdb中的JSON如下。 我想提取“国家”的价值: { "release":{ "genres":{ "genre":"Electronic" […]

CasperJS和蜘蛛时插入数据到数据库中

我在这里find了一个蜘蛛脚本: http : //planzero.org/blog/2013/03/07/spidering_the_web_with_casperjs 基本上我想要做的是使用rethinkDB把所有的链接在一个表被刮。 所以我基本上创build了另一个名为args.js的脚本,它接受一个参数,链接,然后将其存储在数据库中。 args.js // node args.js -link http://somesite.com var r = require('rethinkdb'); var args = process.argv.slice(2); var link = args[1]; var connection = null; var connection = null; r.connect( {host: 'localhost', port: 28015}, function(err, conn) { if (err) throw err; connection = conn; conn.addListener('error', function(e) { processNetworkError(e); }); conn.addListener('close', function() { […]

Rethinkdb节点将提要更改为HTML

我试图显示从rethinkdb数据库到HTML(前端)的任何更改源,但我无法显示任何更改提要。 你能帮我解决这个问题吗? 该文件是app.js var express = require('express'), app = express(), server = require('http').createServer(app), users = {}, db='testing', table = 'todos'; io = require('socket.io').listen(server); var bodyParser = require('body-parser'); server.listen(5000); app.get('/', function(req, res){ res.sendFile(__dirname + '/index.html'); }); var config = require(__dirname + '/config.js'); var r = require('rethinkdbdash')(config.rethinkdb); io.sockets.on('connection', function(socket){ r.db(db).table(table).pluck('title').changes().run(). then(function(feed){ feed.each(function(err, item){ console.log(JSON.stringify(item, null, 2)); io.emit('new […]

Node.JS Rethink-DB检查用户名和电子邮件是否已经存在

当我发现它不检查用户是否存在与电子邮件或用户名的东西是一个问题,我使用基于RethinkDB聊天例子的Node的login/注册系统工作。 当我正在寻求解决这个问题时,我无法找出原因,因为运行一个数据库检查将需要一个函数的callback,这使得它很难实现。 if (typeof req.user !== 'undefined') { res.redirect('/account'); return; } if (!validateEmail(req.param('email'))) { req.flash('error', 'Not a valid email address!') res.redirect('/register'); return; } // Add a check for EMAIL/USERNAME here. if (req.param('password') !== req.param('password2')) { req.flash('error', 'Passwords does not match!') res.redirect('/register'); return; } 我需要帮助,如果一个用户存在一个用户名或邮件是相同的forms,它会发送一个: if (alreadyExists) { req.flash('error', 'That username/email is already in use.') res.redirect('/register'); […]

rethinkdb值的频率

在reThinkDB中为某些值实现“频率”查询的方式是什么? 示例数据: [{ akey : "1", anotherkey : "2" }, { akey : "1", anotherkey : "2" }, { akey : "AAA", anotherkey : "BBB" }, { akey : "CCC", anotherkey : "CCC" }] 应该作为参数输出: { "1" : 2, "AAA" : 1, "CCC" : 1 } 应该anotherkey作为参数: { "2" : 2, "BBB" : 1, "CCC" […]