title: 数据操作

本篇文档介绍如何进行数据操作,分为写入,更新和删除数据。

数据操作包含以下七种方法:

方法 说明
set() 向指定 节点 写入数据。若此节点已存在数据,会覆盖原有数据。
setPriority() 设置节点优先级。
setWithPriority() 向指定节点写入数据并且设置该节点优先级。
push() 向指定节点添加 子节点。子节点的 key 自动生成并保证唯一。
remove() 删除指定节点。
update() 更新指定子节点。
transaction() 并发操作时保证数据一致性。

写入数据

set() 方法用于向指定节点写入数据。此方法会先清空指定节点,再写入数据。

set() 方法可设置回调方法来获取操作的结果。

例如,向 Jobs 节点下写入 full_namegender

  1. // 初始化
  2. var config = {
  3. authDomain: "<appId>.wilddog.com",
  4. syncURL: "https://<appId>.wilddogio.com"
  5. };
  6. wilddog.initializeApp(config);
  7. var ref = wilddog.sync().ref("/web/saving-data/wildblog/users");
  8. // child() 用来定位到某个节点。
  9. ref.child("Jobs").set({
  10. "full_name": "Steve Jobs",
  11. "gender": "male"
  12. });

设置回调方法:

  1. ref.child("Jobs").set({
  2. "full_name": "Steve Jobs",
  3. "gender": "male"
  4. }, function(error) {
  5. if (error == null){
  6. // 数据同步到野狗云端成功完成
  7. }
  8. });

设置节点优先级

setPriority(priority) 方法用于设置节点的优先级。

Wilddog Sync 支持为每个节点设置优先级(priority),用于实现节点按 优先级排序。优先级是节点的隐藏属性,默认为 null。

例如,设置user节点的优先级为100:

  1. wilddog.sync().ref('user').setPriority(100)
  2. .then(function(){
  3. console.info('set priority success.')
  4. })
  5. .catch(function(err){
  6. console.info('set priority failed', err.code, err);
  7. });

更多使用,请参考 setPriority()

写入数据并设置节点优先级

setWithPriority(value, priority)方法用于向指定节点写入数据并且设置该节点优先级。

例如,写入 jack 的姓名并且设置优先级为100:

  1. wilddog.sync().ref('full_name').setWithPriority('jack',100)
  2. .then(function(){
  3. console.info('set data success.')
  4. })
  5. .catch(function(err){
  6. console.info('set data failed', err.code, err);
  7. });

更多使用,请参考 setWithPriority()

追加子节点

push() 方法用于向指定节点添加子节点。新增子节点的 key 由 Wilddog Sync 自动生成并保证唯一。 新增子节点的 key 基于时间戳和随机算法生成,并可以按照添加时间进行排序。

例如,追加子节点到 messages 节点:

  1. var postsRef = ref.child("messages");
  2. postsRef.push({
  3. "full_name" : "Steve Jobs",
  4. "message" : "Think difference"
  5. });
  6. postsRef.push({
  7. "full_name" : "Bill Gates",
  8. "message" : "Hello World"
  9. });

产生的数据如下:

  1. {
  2. "messages": {
  3. "-JRHTHaIs-jNPLXO": {
  4. "full_name" : "Steve Jobs",
  5. "message" : "Think difference"
  6. },
  7. "-JRHTHaKuITFIhnj": {
  8. "full_name" : "Bill Gates",
  9. "message" : "Hello World"
  10. }
  11. }
  12. }

更新数据

update() 方法用于更新指定子节点。

update() 方法支持多路径更新。可以只调用一次方法更新多个路径的数据。

例如,更新 Jobs 的个人信息:

  1. //原数据如下
  2. {
  3. "Jobs": {
  4. "full_name" : "Steve Jobs",
  5. "gender" : "male"
  6. }
  7. }
  1. // 只更新 Jobs 的 full_name
  2. var hopperRef = ref.child("Jobs");
  3. hopperRef.update({
  4. "full_name": "Tim Cook"
  5. });

例如,同时更新 b 节点下的 d 和 x 节点下的 z:

  1. //原数据如下
  2. {
  3. "a": {
  4. "b": {
  5. "c": "cc",
  6. "d": "dd"
  7. },
  8. "x": {
  9. "y": "yy",
  10. "z": "zz"
  11. }
  12. }
  13. }

正确示例:

  1. ref.update({
  2. "b/d": "updateD",
  3. "x/z": "updateZ"
  4. });

错误示例:

  1. // 错误的多路径更新写法,会覆盖原有数据
  2. ref.update({
  3. "b": {
  4. "d": "updateD"
  5. },
  6. "x": {
  7. "z": "updateZ"
  8. }
  9. });

删除数据

remove() 方法用于删除指定节点。

例如,删除写入的数据:

  1. ref.set({
  2. "full_name" : "Steve Jobs",
  3. "gender" : "male"
  4. });
  5. //删除上面写入的数据
  6. ref.remove();

提示:

设置节点的 value 为 null 等同于 remove() 方法。

事务处理

transaction() 方法用于并发操作时保证数据一致性。

例如,在实现多人点赞功能时,多人同时写入评分会产生覆盖,导致最终结果不准确。使用 transaction()方法可以避免这种情况:

  1. var config = {
  2. authDomain: "docs-examples.wilddog.com",
  3. syncURL: "https://docs-examples.wilddogio.com"
  4. };
  5. wilddog.initializeApp(config);
  6. var upvotesRef = wilddog.sync().ref("/saving-data/wildblog/posts/-JRHTHaIs-jNPLXOQivY/upvotes");
  7. upvotesRef.transaction(function (currentValue) {
  8. return (currentValue || 0) + 1; // 判断计数器是否为空或者是自增加
  9. });

注意:

回调方法的返回值可能为空,需要进行相应的处理。

更多使用,请参考 transaction()