|
存储数据是web应用最常用的任务之一。在很长的一段时间里，web应用都依赖于关系型数据库。例如PHP和MySQL，但是并不是所有web应用都必须使用关系型数据库。在这篇文章里我们介绍怎么在Node.js应用中使用RethinkDB-开源的JSON数据库。
RethinkDB的官方介绍： “RethinkDB is the first open-source, scalable JSON database built from the ground up for the realtime web. It inverts the traditional database architecture by exposing an exciting new access model – instead of polling for changes, the developer can tell RethinkDB to continuously push updated query results to applications in realtime.”
安装Rethinkdb 为了在Ubuntu上安装rethinkdb，我们需要先添加源： $ source /etc/lsb-release && echo "deb http://download.rethinkdb.com/apt $DISTRIB_CODENAME main" | sudo tee /etc/apt/sources.list.d/rethinkdb.list $ wget -qO- http://download.rethinkdb.com/apt/pubkey.gpg | sudo apt-key add - 更新软件包并安装rethinkdb： sudo apt-get update sudo apt-get install rethinkdb 安装完成之后输入如下命令: rethinkdb 如果没有问题，会看到类似如下输出： Listening for intracluster connections on port 29015 Listening for client driver connections on port 28015 Listening for administrative HTTP connections on port 8080 Listening on addresses: 127.0.0.1, 127.0.1.1, ::1 To fully expose RethinkDB on the network, bind to all addresses by running rethinkdb with the `--bind all` command line option. rethinkdb服务启动并监听28015端口。http://your_server_ip:8080是web管理接口。
安装Node.js Rethinkdbdash客户端 项目地址：https://github.com/neumino/rethinkdbdash 我们使用Rethinkdbash和数据库进行交互，它是Node.js应用和rethinkdbash的桥梁。 安装rethinkdbash： npm install rethinkdbdash
开始使用RethinkDB 下面我们创建一个示例应用demo，它使用一个名叫Rethink_DB的数据库。首先我们创建一个项目目录demo，在目录里创建一个文件app.js： mkdir demo cd demo touch app.js 编辑app.js: var r = require('rethinkdbdash')({ // 导入rethinkdbash客户端模块 port: 28015, // rethinkdb端口 host: 'localhost' // rethinkdb主机 }); 创建Rethink_DB数据库 r.dbCreate('Rethink_DB') .run() .then(function(response){ console.log(response); }) .error(function(err){ console.log('error ', err); }); 执行，如果成功会输出如下信息： $ nodejs app.js Creating a pool connected to localhost:28015 { config_changes: [ { new_val: [Object], old_val: null } ], dbs_created: 1 } 进入RethinkDB web管理接口 http:your_server_ip:8080，我们可以看到已经创建了一个叫Rethink_DB的数据库：
创建表 var r = require('rethinkdbdash')({ port: 28015, host: 'localhost', db: 'Rethink_DB' }); // 创建表，主键为name。如果不指定主键，主键默认为id r.tableCreate('Student', { primaryKey: 'name' }) //r.tableCreate('Student') .run() .then(function(response){ console.log(response); }) .error(function(err){ console.log('error while creating table ', err); })
插入数据 r.table("Student") .insert({ name: "LittleMing", addr: "China" }) .run() .then(function(response){ console.log('Success ',response); }) .error(function(err){ console.log('error occurred ',err); }) ################################ $ nodejs app.js Creating a pool connected to localhost:28015 Success { deleted: 0, errors: 0, inserted: 1, replaced: 0, skipped: 0, unchanged: 0 }
SELECT数据 r.table('Student') .run() .then(function(response){ console.log(response); }) .error(function(err){ console.log(err); }) [ { addr: 'China', name: 'LittleMing' } ]
根据主键查询 r.table('Student') .get('LittleMing') .run() .then(function(response){ console.log(response); }) .error(function(err){ console.log(err); }) { addr: 'China', name: 'LittleMing' }
实时push更新 引用官网描述： “Instead of polling for changes, the developer can tell RethinkDB to continuously push updated query results in realtime.” r.table('Student') .changes() .run() .then(function(cursor){ cursor.each(console.log); }) .error(function(err){ console.log(err); }); 现在我们再往数据中插入输入，输出类似如下： { new_val: { addr: 'hell', name: 'BigMing' }, old_val: null } 上面是一个插入语句的log。old_val是null，new_val有值，这是为了给以存在记录的更新而设的，把旧值放入到old_val中。
相关主题 |
