Node.js 蚕食计划（七）—— MongoDB + GraphQL + Vue 初体验「建议收藏」

const mongoose = require(‘mongoose‘); const Schema = mongoose.Schema; // 影片信息
const MovieSchema = new Schema({ name: String, // 影片名称
  years: Number,        // 上映年代
  director: String,     // 导演
  category: [String],   // 影片类型
  comments: [           // 影评
 { author: String, createdAt: { type: Date, default: Date.now(), }, updatedAt: { type: Date, default: Date.now() } } ], }); module.exports = mongoose.model(‘Movie‘, MovieSchema);

代码100分

代码100分mongoose.model(‘ModelName‘, SchemaObj)

Model.create(data, callback)

代码100分// 返回所有符合查询条件 conditions 的数据
Model.find(conditions, callback); // 返回找到的第一个文档
Model.findOne(conditions, callback); // 只针对主键 _id 查询
Model.findById(‘_id‘, callback);

// 批量修改符合条件 conditions 的数据
Model.updateMany(conditions, update, options, callback) // 修改指定 id 的数据
Model.findByIdAndUpdate(id, update, options , callback) // 修改第一个符合查询条件的数据
Model.updateOne(conditions, update, options , callback) // 替换第一个符合查询条件的数据
Model.replaceOne(conditions, update, options , callback)

// 删除符合条件的所有数据
Model.remove(conditions, callback); // 删除指定 id 的数据
Model.findByIdAndRemove(id, options, callback);

const Movie = require(‘../mongodb/models/movie‘); // 新建电影
const createMovie = (req) => { return Movie.create(req); } // 更新电影信息
const updateMovie = (req) => { return Movie.findByIdAndUpdate(req._id, req, { new: true, }); } // 保存电影
const saveMovie = async (ctx, next) => { const req = ctx.request.body; // 校验必填
  if (!req.name) { return { message: ‘影片名称不能为空‘ } } const data = req._id ? await updateMovie(req) : await createMovie(req); return { data }; }; module.exports = { saveMovie, };

/* /mongodb/index.js */

const mongoose = require("mongoose"); const { dbUrl } = require("../config"); // const dbUrl = ‘mongodb://127.0.0.1:27017/Movie‘; // 数据库地址

const connect = () => { // mongoose.set(‘debug‘, true)
 mongoose.connect(dbUrl); mongoose.connection.on("disconnected", () => { mongoose.connect(dbUrl); }); mongoose.connection.on("error", (err) => { console.error(‘Connect Failed: ‘, err); }); mongoose.connection.on("open", async () => { console.log(‘?? Connecting MongoDB Successfully ??‘); }); };

/* /router/api/movie.js */

const router = require(‘koa-router‘)(); const { apiPrefix } = require(‘../../config‘); // const apiPrefix = ‘/api‘;
const movieController = require(‘../../controllers/movie‘); router.prefix(apiPrefix); router.post(‘/movie/save‘, movieController.saveMovie); router.get(‘/movie/list‘, movieController.getMovie); router.delete(‘/movie/delete/:id‘, movieController.deleteMovie); module.exports = router;

// app.js
const Koa = require(‘koa‘); const bodyParser = require(‘koa-bodyparser‘); const api = require(‘./router/api‘); // 连接数据库
require(‘./mongodb‘); const app = new Koa(); app.use(bodyParser()); // 注册 API
for (const key in api) { const router = api[key]; app.use(router.routes()).use(router.allowedMethods()); } app.listen({port: 3200});

npm install graphql koa-graphql --save

schema {
  query: Query
  mutation: Mutation
}

const Schema = buildSchema(` type Query { getList: [Movie] getDetail: [Movie] } type Mutation { add(post: input): [Movie], } `)

/* /graphql/schema.js - 使用 buildSchema 创建的 GraphQL Schema */

const { buildSchema } = require(‘graphql‘); const Schema = buildSchema(` type Query { getAllMovie: [Movie] } type Movie { _id: String, name: String, years: String, director: String, } `) // 暂时不用 Mutation
 module.exports = Schema;

/* /controllers/movie.js */

const graphqlHTTP = require(‘koa-graphql‘); const MovieSchema = require(‘../graphql/schema‘); const Movie = require(‘../mongodb/models/movie‘); // GraphQL 类型处理函数
const root = { getAllMovie: async () => { return Movie.find({}); } } // 查询所有电影
const getMovie = graphqlHTTP({ schema: MovieSchema, rootValue: root, graphiql: true }); module.exports = { getMovie, };

/* /router/api/movie.js */

const router = require(‘koa-router‘)(); const movieController = require(‘../../controllers/movie‘); router.all(‘/movie/list‘, movieController.getMovie); module.exports = router;

request.post(‘/api/movie/list‘, { query: `{ getAllMovie { _id, name, } }` });

const { GraphQLSchema, GraphQLObjectType } = require(‘graphql‘); const schema = new GraphQLSchema({ query: new GraphQLObjectType(), mutation: new GraphQLObjectType(), });

/* /graphql/schema.js - 构建类型 */

const { GraphQLSchema, GraphQLObjectType } = require(‘graphql‘); const getAllMovie = require(‘./query/movie.js‘); const RootQuery = new GraphQLObjectType({ name: ‘RootQueryType‘, fields: { getAllMovie, } }); module.exports = new GraphQLSchema({ query: RootQuery, // mutation: RootMutation,
});

/* /graphql/types/movies.js - 定义 Movie 类型 */
const graphql = require(‘graphql‘); const { GraphQLObjectType, GraphQLList, GraphQLString, GraphQLInt, } = graphql; const MovieType = new GraphQLObjectType({ name: ‘Movie‘, fields: () => ({ _id: { type: GraphQLString }, // String
 name: { type: GraphQLString }, years: { type: GraphQLInt }, // Int
 poster: { type: GraphQLString }, director: { type: GraphQLString }, category: { type: new GraphQLList(GraphQLString) }, // [String]
 }) }); module.exports = MovieType;

/* /graphql/query/movies.js - 定义 getAllMovie 字段 */

const { GraphQLList } =  require(‘graphql‘); const movieGraphQLType = require(‘../types/movie.js‘); const Movie = require(‘../../mongodb/models/movie.js‘); module.exports = { type: new GraphQLList(movieGraphQLType), args: {}, resolve() { return Movie.find({}) } }

/* /controllers/movie.js */

const graphqlHTTP = require(‘koa-graphql‘); const MovieSchema = require(‘../graphql/schema‘);// 查询所有电影
const getMovie = graphqlHTTP({ schema: MovieSchema, graphiql: true }); module.exports = { getMovie, };

Syntax Error: Unexpected single quote character (‘), did you mean to use a double quote (")?