查找文档

import { MongoClient } from "mongodb";
// Replace the uri string with your MongoDB deployment's connection string.
const uri = "<connection string uri>";
const client = new MongoClient(uri);
async function run() {
  try {
    
    // Get the database and collection on which to run the operation
    const database = client.db("sample_mflix");
    const movies = database.collection("movies");
    // Query for a movie that has the title 'The Room'
    const query = { title: "The Room" };
    const options = {
      // Sort matched documents in descending order by rating
      sort: { "imdb.rating": -1 },
      // Include only the `title` and `imdb` fields in the returned document
      projection: { _id: 0, title: 1, imdb: 1 },
    };
    // Execute query
    const movie = await movies.findOne(query, options);
    // Print the document returned by findOne()
    console.log(movie);
  } finally {
    await client.close();
  }
}
run().catch(console.dir);

import { MongoClient } from "mongodb";
// Replace the uri string with your MongoDB deployment's connection string.
const uri = "<connection string uri>";
const client = new MongoClient(uri);
interface IMDB {
  rating: number;
  votes: number;
  id: number;
}
export interface Movie {
  title: string;
  year: number;
  released: Date;
  plot: string;
  type: "movie" | "series";
  imdb: IMDB;
}
type MovieSummary = Pick<Movie, "title" | "imdb">;
async function run(): Promise<void> {
  try {
    const database = client.db("sample_mflix");
    // Specifying a Schema is always optional, but it enables type hinting on
    // finds and inserts
    const movies = database.collection<Movie>("movies");
    const movie = await movies.findOne<MovieSummary>(
      { title: "The Room" },
      {
        sort: { rating: -1 },
        projection: { _id: 0, title: 1, imdb: 1 },
      }
    );
    console.log(movie);
  } finally {
    await client.close();
  }
}
run().catch(console.dir);

1
import { MongoClient } from "mongodb";
2
3
// Replace the uri string with your MongoDB deployment's connection string.
4
const uri = "<connection string uri>";
5
6
const client = new MongoClient(uri);
7
8
async function run() {
9
  try {
10
    
11
    // Get the database and collection on which to run the operation
12
    const database = client.db("sample_mflix");
13
    const movies = database.collection("movies");
14
15
    // Query for movies that have a runtime less than 15 minutes
16
    const query = { runtime: { $lt: 15 } };
17
    const sortFields = { title: 1 };
18
    const projectFields = { _id: 0, title: 1, imdb: 1 };
19
20
    // Execute query 
21
    const cursor = movies.find(query).sort(sortFields).project(projectFields);
22
23
    // Print a message if no documents were found
24
    if ((await movies.countDocuments(query)) === 0) {
25
      console.log("No documents found!");
26
    }
27
28
    // Print returned documents
29
    for await (const doc of cursor) {
30
      console.dir(doc);
31
    }
32
33
  } finally {
34
    await client.close();
35
  }
36
}
37
run().catch(console.dir);

1
import { MongoClient } from "mongodb";
2
3
// Replace the uri string with your MongoDB deployment's connection string.
4
const uri = "<connection string uri>";
5
6
const client = new MongoClient(uri);
7
8
type Minutes = number;
9
10
interface IMDB {
11
  rating: number;
12
  votes: number;
13
  id: number;
14
}
15
16
interface Movie {
17
  title: string;
18
  imdb: IMDB;
19
  runtime: Minutes;
20
}
21
22
async function run() {
23
  try {
24
    const database = client.db("sample_mflix");
25
    const movies = database.collection<Movie>("movies");
26
27
    const query = { runtime: { $lt: 15 } };
28
    const sortFields = { title: 1 };
29
    const projectFields = { _id: 0, title: 1, imdb: 1 };
30
31
    const cursor = movies.find<Movie>(query).sort(sortFields).project(projectFields);
32
33
    if ((await movies.countDocuments(query)) === 0) {
34
      console.warn("No documents found!");
35
    }
36
37
    for await (const doc of cursor) {
38
      console.dir(doc);
39
    } 
40
  } finally {
41
    await client.close();
42
  }
43
}
44
run().catch(console.dir);