Ember数据操作 #

import Controller from '@ember/controller';
import { inject as service } from '@ember/service';
import { action } from '@ember/object';

export default class PostsNewController extends Controller {
  @service store;

  @action
  createPost() {
    const post = this.store.createRecord('post', {
      title: 'New Post',
      body: 'Content...',
    });
  }
}

@action
async savePost() {
  const post = this.store.createRecord('post', {
    title: 'New Post',
    body: 'Content...',
  });

  try {
    await post.save();
    console.log('保存成功');
  } catch (error) {
    console.error('保存失败:', error);
  }
}

@action
async createComment(post) {
  const comment = this.store.createRecord('comment', {
    body: 'Great post!',
    post: post,
  });

  await comment.save();
}

// app/routes/posts.js
import Route from '@ember/routing/route';
import { inject as service } from '@ember/service';

export default class PostsRoute extends Route {
  @service store;

  model() {
    return this.store.findAll('post');
  }
}

// app/routes/posts/show.js
import Route from '@ember/routing/route';
import { inject as service } from '@ember/service';

export default class PostsShowRoute extends Route {
  @service store;

  model(params) {
    return this.store.findRecord('post', params.post_id);
  }
}

model() {
  return this.store.query('post', {
    category: 'tech',
    status: 'published',
    page: 1,
    limit: 10,
  });
}

model() {
  return this.store.queryRecord('post', {
    slug: 'hello-world',
  });
}

// 获取所有已加载记录
const posts = this.store.peekAll('post');

// 获取单个已加载记录
const post = this.store.peekRecord('post', 1);

@action
async updatePost(post) {
  post.title = 'Updated Title';
  await post.save();
}

@action
async updatePost(post, attrs) {
  post.setProperties(attrs);
  await post.save();
}

@action
async changeAuthor(post, newAuthor) {
  post.author = newAuthor;
  await post.save();
}

@action
async updateTitle(post, newTitle) {
  post.title = newTitle;
  await post.save({ adapterOptions: { partial: true } });
}

@action
async deletePost(post) {
  await post.destroyRecord();
}

@action
markForDeletion(post) {
  post.deleteRecord();
  // 需要调用 save() 才会持久化
}

@action
removeFromCache(post) {
  post.unloadRecord();
}

// 新记录
post.isNew; // true/false

// 已保存
post.isSaved; // true/false

// 有未保存更改
post.hasDirtyAttributes; // true/false

// 正在保存
post.isSaving; // true/false

// 已删除
post.isDeleted; // true/false

// 正在删除
post.isDeleting; // true/false

// 有效
post.isValid; // true/false

// 有错误
post.hasErrors; // true/false

const changes = post.changedAttributes();
// { title: ['Old Title', 'New Title'] }

@action
cancelChanges(post) {
  post.rollbackAttributes();
}

@action
async createMultiple() {
  const posts = [
    { title: 'Post 1', body: '...' },
    { title: 'Post 2', body: '...' },
    { title: 'Post 3', body: '...' },
  ];

  const records = posts.map((data) => this.store.createRecord('post', data));

  await Promise.all(records.map((post) => post.save()));
}

@action
async publishAll(posts) {
  posts.forEach((post) => {
    post.isPublished = true;
  });

  await Promise.all(posts.map((post) => post.save()));
}

@action
async deleteAll(posts) {
  await Promise.all(posts.map((post) => post.destroyRecord()));
}

@action
async savePost(post) {
  try {
    await post.save();
  } catch (error) {
    console.error('保存失败:', error);
    // 检查错误
    if (post.errors.length > 0) {
      post.errors.forEach((error) => {
        console.log(`${error.attribute}: ${error.message}`);
      });
    }
  }
}

@action
async saveWithValidation(post) {
  try {
    await post.save();
  } catch (error) {
    if (error.errors) {
      error.errors.forEach((err) => {
        console.log(`字段 ${err.source.pointer} ${err.detail}`);
      });
    }
  }
}

@action
async saveWithRetry(post, retries = 3) {
  for (let i = 0; i < retries; i++) {
    try {
      await post.save();
      return;
    } catch (error) {
      if (i === retries - 1) throw error;
      await new Promise((resolve) => setTimeout(resolve, 1000));
    }
  }
}

@action
async addComment(post) {
  const comment = this.store.createRecord('comment', {
    body: 'New comment',
    post: post,
  });

  await comment.save();
}

@action
async removeComment(comment) {
  comment.post = null;
  await comment.save();
}

@action
async addTag(post, tag) {
  post.tags.pushObject(tag);
  await post.save();
}

@action
async removeTag(post, tag) {
  post.tags.removeObject(tag);
  await post.save();
}

model(params) {
  return this.store.findRecord('post', params.post_id, {
    reload: true,
  });
}

model(params) {
  return this.store.findRecord('post', params.post_id, {
    backgroundReload: true,
  });
}

model(params) {
  return this.store.findRecord('post', params.post_id, {
    include: 'author,comments',
  });
}

// 好的做法
export default class PostsRoute extends Route {
  model() {
    return this.store.findAll('post');
  }
}

// 避免 - 在组件中加载数据

// 好的做法
async savePost(post) {
  await post.save();
  this.router.transitionTo('posts.show', post.id);
}

// 避免 - Promise链
savePost(post) {
  post.save().then(() => {
    this.router.transitionTo('posts.show', post.id);
  });
}

{{#if @post.isSaving}}
  <span>保存中...</span>
{{else}}
  <button {{on "click" (fn this.save @post)}}>保存</button>
{{/if}}