Node.jsでMongoDB Atlasを利用する（Node.js その4）

//MongoClientクラスは、MongoDBへの接続を可能にするクラスです
const { MongoClient } = require("mongodb");

const uri ="コピーしたコードを貼り付けて、パスワードを編集します";
//MongoClientを使用して接続する
const client = new MongoClient(uri);

async function run() {
  try {
    // サーバーに接続
    await client.connect();
    // pingコマンドを実行して接続の確認する
    await client.db("admin").command({ ping: 1 });
    console.log("接続成功");
  } finally {
    // 接続を終了
    await client.close();
  }
}
run().catch(console.log);

//データベース名
const databaseName = 'sample';
//コレクション名
const collectionName = 'foods';
const database = client.db(databaseName);
const collection = database.collection(collectionName)

async function run() {
  try {
    await client.connect();
      //ドキュメント
      const doc = { name: "Pudding", healthy: true };
      const result =  await collection.insertOne(doc);
      console.log(result);
  } finally {
    await client.close();
  }
}
run().catch(console.log);

async function run() {
  try {
      await client.connect();
      //ドキュメント
        const docs = [
        { name: "cake", healthy: false },
        { name: "lettuce", healthy: true },
        { name: "donut", healthy: false }
        ];
      const result =  await collection.insertMany(docs, {ordered: true });
      console.log(result);
  } finally {
    await client.close();
  }
}
run().catch(console.log);

async function run() {
  try {
      await client.connect();
      const query = { healthy: false };
      const options = {
      projection: { _id: 0, name: 1 },
      };
    const result = await collection.findOne(query, options);
      console.log(result);
  } finally {
    await client.close();
  }
}
run().catch(console.log);

async function run() {
  try {
      await client.connect();
      const query = { healthy: false };
      const options = {
      projection: { _id: 0, name: 1 },
      };
   const result = await collection.find(query, options);
    if (( result.countDocuments) === 0) {
        console.log("検索結果なし");
        }
    await result.forEach(console.dir);
  } finally {
    await client.close();
  }
}
run().catch(console.log);

// > 5
{rating: { $gt: 5 }}
//1< かつ >5
 $and: [ {{ rating: { $gt: 1 }, rating: { $lt: 5 }}, }]

async function run() {
  try {
      await client.connect();
      const filter = { name: 'cake' };
      const updateDoc = { $set: {healthy: true}};
      const result = await collection.updateOne(filter, updateDoc,  { upsert: true });
      console.log(result);
  } finally {
    await client.close();
  }
}
run().catch(console.log);

//healthy:trueをすべてhealthy:falseに
async function run() {
  try {
      await client.connect();
      const filter = { healthy: true };
      const updateDoc = { $set: {healthy: false}};
      const result = await collection.updateMany(filter, updateDoc);
      console.log(result);
  } finally {
    await client.close();
  }
}
run().catch(console.log);

async function run() {
  try {
    await client.connect();
    const result = await collection.deleteMany({
        healthy: false
    })
    if (( result.countDocuments) === 0) {
        console.log("削除なし");
        }
    console.log(result);
  } finally {
    await client.close();
  }
}
run().catch(console.log);

const mongoose = require('mongoose');
//スキーマの定義
const blogSchema = new mongoose.Schema({
  title: {
    type: String,
    required: true,
  },
  body: {
    type: String,
    required: true
  },
}, { timestamps: true });

//スキーマをモデルにコンパイル
const Blog = mongoose.model('Blog', blogSchema);

module.exports = Blog;

const express = require("express");
const app = express();
const mongoose = require("mongoose");
//モデルを読み込む
const Blog = require("./models.js")
const uri ="mongodb+srv:・・・・・";
//4.x系ではbody-parserのインストールは不要JSONをパースするミドルウェア
app.use(express.json());
//データベースサーバーに接続
mongoose.connect(uri)

app.post("/blog", async (request, response) => {
 //Blogモデルのインスタンスを作成
const blog = new Blog(request.body);
  try {
 //save()でデータベースに保存
    await blog.save();
    response.send(blog);
  } catch (error) {
    response.status(500).send(error);
  }
});

app.get("/blogs", async (request, response) => {
    try {
    // find()は、パラメータが一致するすべてのオブジェクトを返します
    const blogs = await Blog.find({});
    response.send(blogs);
  } catch (error) {
    response.status(500).send(error);
  }
});

app.get("/blog/:id", async (request, response) => {
  const id = request.params.id;
  try {
    const blog = await Blog.findById(id);
    response.send(blog);
  } catch (error) {
    response.status(500).send(error);
  }
});

app.patch("/blog/:id", async (request, response) => {
  const id = request.params.id;
  try {
//findByIdAndUpdate()de、_idで検索したターゲットとそれを置き換えるリクエストデータを取得します
    await Blog.findByIdAndUpdate(id, request.body);
 //save()で変更を保存します
    await Blog.save();
   response.status(200).send();
  } catch (error) {
    response.status(500).send(error);
  }
});

app.delete("/blog/:id", async (request, response) => {
  const id = request.params.id;
    try {
    //_idで検索したターゲットを削除します
    await Blog.findByIdAndDelete(id);
    response.status(200).send();
  } catch (error) {
    response.status(500).send(error);
  }
});