如何在 Atlas Search 中使用自动完成功能

AtlasGoClusters在Atlas中，Go项目的 页面。

1. 如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含所需项目的组织。

2. 如果尚未显示，请从导航栏的Projects菜单中选择所需的项目。

3. 如果尚未出现，请单击侧边栏中的 Clusters（集群）。

   会显示集群页面。

转到集群的 Atlas Search 页面。

您可以从侧边栏、 Data Explorer 或集群详细信息页面转到 Atlas Search 页面。

转到 Search Tester（搜索测试器）。

单击要查询的索引右侧的 Query 按钮。

查看和编辑查询语法。

单击Edit Query查看 JSON格式的默认查询语法示例。

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

将以下查询复制并粘贴到 Query Editor 中，然后点击 Query Editor 中的 Search 按钮。

[
  {
    $search: {
      index: "autocomplete-tutorial",
      autocomplete: {
        query: "ger",
        path: "title"
      }
    }
  }
]

SCORE: 6.085907459259033  _id:  "573a1390f29313caabcd50e5"
  plot: "The cartoonist, Winsor McCay, brings the Dinosaurus back to life in th…"
  genre: Array
  runtime: 12
SCORE: 6.085907459259033  _id:  "573a1393f29313caabcddae1"
  plot: "Edmund, a young boy who lives in war-devastated Germany after the Seco…"
  genres: Array
  runtime: 78
SCORE: 6.085907459259033  _id:  "573a1397f29313caabce6b75"
  plot: "Germany in Autumn does not have a plot per se; it mixes documentary fo…"
  genres: Array
  runtime: 123
SCORE: 6.085907459259033  _id:  "573a1397f29313caabce77b5"
  plot: "Germany 1939. Hans and Lene marry the day before the war breaks out, a…"
  genres: Array
  runtime: 123
SCORE: 6.085907459259033  _id:  "573a13d4f29313caabd99fa2"
  plot: "A documentary on the German artist that includes glimpses at his studi…"
  genres: Array
  runtime: 97
SCORE: 6.046686172485352  _id:  "573a1399f29313caabcedb50"
  plot: "The story of the Apache chief and his armed resistance to the US Gover…"
  genres: Array
  runtime: 115
SCORE: 5.8947296142578125  _id:  "573a13a5f29313caabd15dae"
  num_mflix_comments: 1
  genres: Array
  runtime: 83
SCORE: 5.826231956481934  _id:  "573a139bf29313caabcf36bd"
  plot: "Geri sets up a chess game to play his greatest opponent - himself."
  genres: Array
  runtime: 4
SCORE: 5.772464752197266  _id:  "573a13d2f29313caabd922de"
  plot: "The true story of an Argentine family who lived with Josef Mengele wit…"
  genres: Array
  runtime: 93
SCORE: 5.772464752197266  _id:  "573a13b4f29313caabd41bb7"
  plot: "In 1928, Dr. Max Gerson, a German-Jewish researcher, stumbled upon a t…"
  genres: Array
  countries: Array

展开查询结果。

Search Tester 可能不会显示其所返回文档的所有字段。要查看所有字段，包括在查询路径中指定的字段，请展开结果中的文档。

AtlasGoClusters在Atlas中，Go项目的 页面。

1. 如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含所需项目的组织。

2. 如果尚未显示，请从导航栏的Projects菜单中选择所需的项目。

3. 如果尚未出现，请单击侧边栏中的 Clusters（集群）。

   会显示集群页面。

转到集群的 Atlas Search 页面。

您可以从侧边栏、 Data Explorer 或集群详细信息页面转到 Atlas Search 页面。

转到 Search Tester（搜索测试器）。

单击要查询的索引右侧的 Query 按钮。

查看和编辑查询语法。

单击 Edit Query 以查看 JSON 格式的默认查询语法示例。

使用 compound 和 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

将以下查询复制并粘贴到 Query Editor 中，然后点击 Query Editor 中的 Search 按钮。

[
  {
    $search: {
      index: "autocomplete-tutorial",
      compound: {
        should: [{
          autocomplete: {
            query: "pri",
            path: "title"
          }
        },
        {
          autocomplete: {
            query: "pri",
            path: "plot"
          }
        }],
        minimumShouldMatch: 1
      }
    }
  }
]

SCORE: 7.52535343170166  _id:  "573a13e7f29313caabdc80cd"
  plot: "Prison Terminal: The Last Days of Private Jack Hall is a moving cinema…"
  genre: Array
  runtime: 40
SCORE: 7.235145568847656  _id:  "573a13adf29313caabd2b504"
  plot: "Now settled in Genovia, Princess Mia faces a new revelation: she is be…"
  genres: Array
  runtime: 113
SCORE: 7.202958106994629  _id:  "573a13b5f29313caabd43816"
  plot: "A young fugitive prince and princess must stop a villain who unknowing…"
  genres: Array
  runtime: 116
SCORE: 7.201740264892578  _id:  "573a139af29313caabcf0d54"
  plot: "The first wedding anniversary of Princess Odette and Prince Derek is d…"
  genres: Array
  runtime: 71
SCORE: 7.174992561340332  _id:  "573a1399f29313caabceeead"
  plot: "Jane Austen's classic novel about the prejudice that occurred between …"
  genres: Array
  runtime: 327
SCORE: 7.173888206481934  _id:  "573a13c1f29313caabd63a21"
  plot: "A princess whose country has been invaded goes into hiding in Louisian…"
  genres: Array
  countries: Array
SCORE: 7.163987159729004  _id:  "573a13eef29313caabdd51a6"
  plot: "Follows the people racing to bring the hot new 3D printing technology …"
  genres: Array
  runtime: 100
SCORE: 7.155245780944824  _id:  "573a13a5f29313caabd14adf"
  plot: "When her father is captured by The Sheriff of Nottingham and Prince Jo…"
  genres: Array
  runtime: 88
SCORE: 7.146618843078613  _id:  "573a139af29313caabcf0efc"
  plot: "An Egyptian prince learns of his identity as a Hebrew and, later his d…"
  genres: Array
  runtime: 99
SCORE: 7.132328987121582  _id:  "573a139af29313caabcf003b"
  plot: "Two Russian soldiers, one battle-seasoned and the other barely into hi…"
  genres: Array
  runtime: 99

展开查询结果。

Search Tester 可能不会显示其所返回文档的所有字段。要查看所有字段，包括在查询路径中指定的字段，请展开结果中的文档。

通过 mongosh 连接到您的集群。

在终端窗口中打开mongosh并连接到集群。 有关连接的详细说明，请参阅通过mongosh连接。

使用 sample_mflix 数据库。

在 mongosh 提示符下运行以下命令：

use sample_mflix

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

以下查询会搜索 title 字段中包含字符 ger 的电影。该查询包含 $limit 阶段，用于将输出限制为 20 个结果，以及 $project 阶段，用于排除除 title 之外的所有字段。

db.movies.aggregate([
  {
    $search: {
      "index": "autocomplete-tutorial",
      "autocomplete": {
        "path": "title",
        "query": "ger"
      }
    }
  },
  {
    $limit: 20
  },
  {
    $project: {
      "_id": 0,
      "title": 1
    }
  }
])

{ title: "Gertie the Dinosaur" },
{ title: "Germany Year Zero" },
{ title: "Germany in Autumn" },
{ title: "Germany Pale Mother" },
{ title: "Gerhard Richter - Painting" },
{ title: "Geronimo: An American Legend" },
{ title: "How to Live in the German Federal Republic" },
{ title: "Geri's Game" },
{ title: "The Gerson Miracle" },
{ title: "The German Doctor" },
{ title: "From Caligari to Hitler: German Cinema in the Age of the Masse"},
{ title: "From Caligari to Hitler: German Cinema in the Age of the Masses"},
{ title: "Gèraldine" },
{ title: "Gervaise" },
{ title: "Gertrud" },
{ title: "Germinal" },
{ title: "Gerry" },
{ title: "Gerontophilia" },
{ title: "Pionery-geroi" },
{ title: "The Good German" }

通过 mongosh 连接到您的集群。

在终端窗口中打开mongosh并连接到集群。 有关连接的详细说明，请参阅通过mongosh连接。

使用 sample_mflix 数据库。

在 mongosh 提示符下运行以下命令：

use sample_mflix

使用 compound 和 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

以下查询搜索在 title 和 plot 字段中包含字符 pri 的电影。该查询包含 $limit 阶段，用于将输出限制为 5 个结果，以及 $project 阶段，用于排除除 title 和 plot 之外的所有字段。

1
db.movies.aggregate([
2
  {
3
    "$search": {
4
      "index": "autocomplete-tutorial",
5
      "compound": {
6
        "should": [{
7
          "autocomplete": {
8
            "query": "pri",
9
            "path": "title"
10
          }
11
        },
12
        {
13
          "autocomplete": {
14
            "query": "pri",
15
            "path": "plot"
16
          }
17
        }],
18
        "minimumShouldMatch": 1
19
      }
20
    }
21
  },
22
  {
23
    "$limit": 5
24
  },
25
  {
26
    "$project": {
27
      "_id": 0,
28
      "title": 1,
29
      "plot": 1
30
    }
31
  }
32
])

{
  plot: 'Prison Terminal: The Last Days of Private Jack Hall is a moving cinema verite documentary that breaks through the walls of one of Americas oldest maximum security prisons to tell the story ...',
  title: 'Prison Terminal: The Last Days of Private Jack Hall'
}
{
  plot: 'Now settled in Genovia, Princess Mia faces a new revelation: she is being primed for an arranged marriage to an English suitor.',
  title: 'The Princess Diaries 2: Royal Engagement'
}
{
  plot: 'A young fugitive prince and princess must stop a villain who unknowingly threatens to destroy the world with a special dagger that enables the magic sand inside to reverse time.',
  title: 'Prince of Persia: The Sands of Time'
}
{
  plot: 'The first wedding anniversary of Princess Odette and Prince Derek is distracted by field fires set by Knuckles. His master Clavius, wants to conquer the world, and he needs to capture a ...',
  title: 'The Swan Princess: Escape from Castle Mountain'
}
{
  plot: "Jane Austen's classic novel about the prejudice that occurred between the 19th century classes and the pride which would keep lovers apart.",
  title: 'Pride and Prejudice'
}

在 MongoDB Compass 中连接到您的集群。

打开 MongoDB Compass 并连接到您的集群。有关连接的详细说明，请参阅通过 Compass 连接。

使用 sample_mflix 数据库中的 movies 集合。

在 Database 屏幕上，依次单击 sample_mflix 数据库和 movies 集合。

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

查询使用了下列管道阶段：

• $search 以便使用 autocomplete 运算符在 title 字段中搜索以 ger 字符开头的词

• $limit 阶段将输出限制为 20 个结果。

• 要排除 title 之外的所有字段的 $project 阶段。

若要在 MongoDB Compass 中运行此查询：

1. 单击 Aggregations 标签页。

2. 单击 Select...，然后从下拉菜单中选择阶段并为该阶段添加查询，以配置以下每个管道阶段。单击 Add Stage 以添加其他阶段。

   在 movies 集合的 Aggregations 标签页中，从下拉菜单中选择阶段并为该阶段添加查询，以配置以下每个管道阶段。单击 Add Stage 添加其他阶段。

   管道阶段	查询
   $search	{ "index": "autocomplete-tutorial", "autocomplete": { "query": "ger", "path": "title" } }
   $limit	20
   $project	{ "_id": 0, "title": 1, }

如果启用了 Auto Preview，MongoDB Compass 将在 $autocomplete 管道阶段旁边显示以下文档：

1
{ title: "Gertie the Dinosaur" },
2
{ title: "Germany Year Zero" },
3
{ title: "Germany in Autumn" },
4
{ title: "Germany Pale Mother" },
5
{ title: "Gerhard Richter - Painting" },
6
{ title: "Geronimo: An American Legend" },
7
{ title: "How to Live in the German Federal Republic" },
8
{ title: "Geri's Game" },
9
{ title: "The Gerson Miracle" },
10
{ title: "The German Doctor" },
11
{ title: "From Caligari to Hitler: German Cinema in the Age of the Masse"},
12
{ title: "From Caligari to Hitler: German Cinema in the Age of the Masses"},
13
{ title: "Gèraldine" },
14
{ title: "Gervaise" },
15
{ title: "Gertrud" },
16
{ title: "Germinal" },
17
{ title: "Gerry" },
18
{ title: "Gerontophilia" },
19
{ title: "Pionery-geroi" },
20
{ title: "The Good German" }

在 MongoDB Compass 中连接到您的集群。

打开 MongoDB Compass 并连接到您的集群。有关连接的详细说明，请参阅通过 Compass 连接。

使用 sample_mflix 数据库中的 movies 集合。

在 Database 屏幕上，依次单击 sample_mflix 数据库和 movies 集合。

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

查询使用了下列管道阶段：

• $search 以使用 autocomplete 操作符在 title 和 plot 字段中搜索以 pri 字符开头的词

• $limit 阶段将输出限制为 5 个结果。

• $project 阶段排除 title 和 plot 以外的所有字段。

若要在 MongoDB Compass 中运行此查询：

1. 单击 Aggregations 标签页。

2. 单击 Select...，然后从下拉菜单中选择阶段并为该阶段添加查询，以配置以下每个管道阶段。单击 Add Stage 以添加其他阶段。

   在 movies 集合的 Aggregations 标签页中，从下拉菜单中选择阶段并为该阶段添加查询，以配置以下每个管道阶段。单击 Add Stage 添加其他阶段。

   管道阶段	查询
   $search	{ "index": "autocomplete-tutorial", "compound": { "should": [{ "autocomplete": { "query": "pri", "path": "title" } }, { "autocomplete": { "query": "pri", "path": "plot" } }], "minimumShouldMatch": 1 } }
   $limit	5
   $project	{ "_id": 0, "title": 1, "plot": 1 }

如果启用了 Auto Preview，MongoDB Compass 将在 $autocomplete 管道阶段旁边显示以下文档：

1
  {
2
    plot: 'Prison Terminal: The Last Days of Private Jack Hall is a moving cinema verite documentary that breaks through the walls of one of Americas oldest maximum security prisons to tell the story ...',
3
    title: 'Prison Terminal: The Last Days of Private Jack Hall'
4
  }
5
  {
6
    plot: 'Now settled in Genovia, Princess Mia faces a new revelation: she is being primed for an arranged marriage to an English suitor.',
7
    title: 'The Princess Diaries 2: Royal Engagement'
8
  }
9
  {
10
    plot: 'A young fugitive prince and princess must stop a villain who unknowingly threatens to destroy the world with a special dagger that enables the magic sand inside to reverse time.',
11
    title: 'Prince of Persia: The Sands of Time'
12
  }
13
  {
14
    plot: 'The first wedding anniversary of Princess Odette and Prince Derek is distracted by field fires set by Knuckles. His master Clavius, wants to conquer the world, and he needs to capture a ...',
15
    title: 'The Swan Princess: Escape from Castle Mountain'
16
  }
17
  {
18
    plot: "Jane Austen's classic novel about the prejudice that occurred between the 19th century classes and the pride which would keep lovers apart.",
19
    title: 'Pride and Prejudice'
20
  }

为查询设置并初始化 .NET/C# 项目。

1. 创建一个名为 basic-autocomplete-example 的新目录，并使用 dotnet new 命令初始化项目。

   mkdir basic-autocomplete-example
   cd basic-autocomplete-example
   dotnet new console

2. 将 .NET/C# 驱动程序作为依赖项添加到项目中。

   dotnet add package MongoDB.Driver

在 Program.cs 文件中创建查询。

1. 将Program.cs文件的内容替换为以下代码。

   此代码示例将执行以下任务：

   • 导入mongodb包和依赖项。

   • 建立与您的 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以便使用 autocomplete 运算符在 title 字段中搜索以 ger 字符开头的词

     • $limit 阶段将输出限制为 20 个结果。

     • 要排除 title 之外的所有字段的 $project 阶段。

   • 遍历游标以打印与查询匹配的文档。

   1
   using MongoDB.Bson;
   2
   using MongoDB.Bson.Serialization.Attributes;
   3
   using MongoDB.Bson.Serialization.Conventions;
   4
   using MongoDB.Driver;
   5
   using MongoDB.Driver.Search;
   6
   7
   public class AutocompleteBasicExample
   8
   {
   9
       private const string MongoConnectionString = "<connection-string>";  
   10
         
   11
       public static void Main(string[] args)
   12
       {
   13
           // allow automapping of the camelCase database fields to our MovieDocument
   14
           var camelCaseConvention = new ConventionPack { new CamelCaseElementNameConvention() };
   15
           ConventionRegistry.Register("CamelCase", camelCaseConvention, type => true);
   16
   17
           // connect to your Atlas cluster
   18
           var mongoClient = new MongoClient(MongoConnectionString);
   19
           var mflixDatabase = mongoClient.GetDatabase("sample_mflix");
   20
           var moviesCollection = mflixDatabase.GetCollection<MovieDocument>("movies");
   21
   22
           // define and run pipeline
   23
           var results = moviesCollection.Aggregate()
   24
               .Search(Builders<MovieDocument>.Search.Autocomplete(movie => movie.Title, "ger"), indexName: "autocomplete-tutorial")
   25
               .Project<MovieDocument>(Builders<MovieDocument>.Projection
   26
                   .Include(movie => movie.Title)
   27
                   .Exclude(movie => movie.Id))
   28
               .Limit(20)
   29
               .ToList();
   30
   31
           // print results
   32
           foreach (var movie in results)
   33
           {
   34
               Console.WriteLine(movie.ToJson());
   35
           }
   36
       }
   37
   }
   38
   39
   [BsonIgnoreExtraElements]
   40
   public class MovieDocument
   41
   {
   42
       [BsonIgnoreIfDefault]
   43
       public ObjectId Id { get; set; }
   44
       public string Title { get; set; }
   45
   }

2. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

编译并运行 Program.cs 文件。

dotnet run basic-autocomplete-example.csproj

{ "title" : "Gertie the Dinosaur" }
{ "title" : "Germany Year Zero" }
{ "title" : "Germany in Autumn" }
{ "title" : "Germany Pale Mother" }
{ "title" : "Gerhard Richter - Painting" }
{ "title" : "Geronimo: An American Legend" }
{ "title" : "How to Live in the German Federal Republic" }
{ "title" : "Geri's Game" }
{ "title" : "The Gerson Miracle" }
{ "title" : "The German Doctor" }
{ "title" : "From Caligari to Hitler: German Cinema in the Age of the Masses" }
{ "title" : "From Caligari to Hitler: German Cinema in the Age of the Masses" }
{ "title" : "Gèraldine" }
{ "title" : "Gervaise" }
{ "title" : "Gertrud" }
{ "title" : "Germinal" }
{ "title" : "Gerry" }
{ "title" : "Gerontophilia" }
{ "title" : "Pionery-geroi" }
{ "title" : "The Good German" }

为查询设置并初始化 .NET/C# 项目。

1. 创建一个名为 advanced-autocomplete-example 的新目录，并使用 dotnet new 命令初始化项目。

   mkdir advanced-autocomplete-example
   cd advanced-autocomplete-example
   dotnet new console

2. 将 .NET/C# 驱动程序作为依赖项添加到项目中。

   dotnet add package MongoDB.Driver

在 Program.cs 文件中创建查询。

1. 将Program.cs文件的内容替换为以下代码。

   此代码示例将执行以下任务：

   • 导入mongodb包和依赖项。

   • 建立与您的 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以使用 autocomplete 操作符在 title 和 plot 字段中搜索以 pri 字符开头的词

     • $limit 阶段将输出限制为 5 个结果。

     • $project 阶段排除 title 和 plot 以外的所有字段。

   • 遍历游标以打印与查询匹配的文档。

   1
   using MongoDB.Bson;
   2
   using MongoDB.Bson.Serialization.Attributes;
   3
   using MongoDB.Bson.Serialization.Conventions;
   4
   using MongoDB.Driver;
   5
   using MongoDB.Driver.Search;
   6
   7
   public class AutocompleteAdvancedExample
   8
   {
   9
       private const string MongoConnectionString = "<connection-string>";
   10
       
   11
       public static void Main(string[] args)
   12
       {
   13
           // allow automapping of the camelCase database fields to our MovieDocument
   14
           var camelCaseConvention = new ConventionPack { new CamelCaseElementNameConvention() };
   15
           ConventionRegistry.Register("CamelCase", camelCaseConvention, type => true);
   16
   17
           // connect to your Atlas cluster
   18
           var mongoClient = new MongoClient(MongoConnectionString);
   19
           var mflixDatabase = mongoClient.GetDatabase("sample_mflix");
   20
           var moviesCollection = mflixDatabase.GetCollection<MovieDocument>("movies");
   21
   22
           // define and run pipeline
   23
           var results = moviesCollection.Aggregate()
   24
               .Search(Builders<MovieDocument>.Search.Compound()
   25
                   .Should(Builders<MovieDocument>.Search.Autocomplete(movie => movie.Title, "pri"))
   26
                   .Should(Builders<MovieDocument>.Search.Autocomplete(movie => movie.Plot, "pri"))
   27
                   .MinimumShouldMatch(1),
   28
                   indexName: "autocomplete-tutorial")
   29
               .Project<MovieDocument>(Builders<MovieDocument>.Projection
   30
                   .Include(movie => movie.Plot)
   31
                   .Include(movie => movie.Title)
   32
                   .Exclude(movie => movie.Id))
   33
               .Limit(5)
   34
               .ToList();
   35
   36
           // print results
   37
           foreach (var movie in results)
   38
           {
   39
               Console.WriteLine(movie.ToJson());
   40
           }
   41
       }
   42
   }
   43
   44
   [BsonIgnoreExtraElements]
   45
   public class MovieDocument
   46
   {
   47
       [BsonIgnoreIfDefault]
   48
       public ObjectId Id { get; set; }
   49
       public string Plot { get; set; }
   50
       public string Title { get; set; }
   51
   }

2. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

编译并运行 Program.cs 文件。

dotnet run advanced-autocomplete-example.csproj

{
  "plot" : "Prison Terminal: The Last Days of Private Jack
  Hall is a moving cinema verite documentary that breaks
  through the walls of one of Americas oldest maximum
  security prisons to tell the story ...",
  "title" : "Prison Terminal: The Last Days of Private Jack Hall"
}
{
  "plot" : "Now settled in Genovia, Princess Mia faces a new
  revelation: she is being primed for an arranged marriage to
  an English suitor.",
  "title" : "The Princess Diaries 2: Royal Engagement"
}
{
  "plot" : "A young fugitive prince and princess must stop a
  villain who unknowingly threatens to destroy the world with
  a special dagger that enables the magic sand inside to
  reverse time.",
  "title" : "Prince of Persia: The Sands of Time"
}
{
  "plot" : "The first wedding anniversary of Princess Odette
  and Prince Derek is distracted by field fires set by
  Knuckles. His master Clavius, wants to conquer the world,
  and he needs to capture a ...",
  "title" : "The Swan Princess: Escape from Castle Mountain"
}
{
  "plot" : "Jane Austen's classic novel about the prejudice
  that occurred between the 19th century classes and the
  pride which would keep lovers apart.",
  "title" : "Pride and Prejudice"
}

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 autocomplete-query.go 的文件。

2. 将以下代码复制并粘贴到 autocomplete-query.go 文件。

   此代码示例将执行以下任务：

   • 导入mongodb包和依赖项。

   • 建立与您的 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以便使用 autocomplete 运算符在 title 字段中搜索以 ger 字符开头的词

     • $limit 阶段将输出限制为 20 个结果。

     • 要排除 title 之外的所有字段的 $project 阶段。

   • 遍历游标以打印与查询匹配的文档。

   1
   package main
   2
   3
   import (
   4
   	"context"
   5
   	"fmt"
   6
   7
   	"go.mongodb.org/mongo-driver/bson"
   8
   	"go.mongodb.org/mongo-driver/mongo"
   9
   	"go.mongodb.org/mongo-driver/mongo/options"
   10
   )
   11
   12
   func main() {
   13
   	// connect to your Atlas cluster
   14
   	client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI("<connection-string>"))
   15
   	if err != nil {
   16
   		panic(err)
   17
   	}
   18
   	defer client.Disconnect(context.TODO())
   19
   20
   	// set namespace
   21
   	collection := client.Database("sample_mflix").Collection("movies")
   22
   23
   	// define pipeline stages
   24
   	searchStage := bson.D{{"$search", bson.D{{"index", "autocomplete-tutorial"}, {"autocomplete", bson.D{{"query", "ger"}, {"path", "title"}}}}}}
   25
   	limitStage := bson.D{{"$limit", 20}}
   26
   	projectStage := bson.D{{"$project", bson.D{{"title", 1}, {"_id", 0}}}}
   27
   	// run pipeline
   28
   	cursor, err := collection.Aggregate(context.TODO(), mongo.Pipeline{searchStage, limitStage, projectStage})
   29
   	if err != nil {
   30
   		panic(err)
   31
   	}
   32
   33
   	// print results
   34
   	var results []bson.D
   35
   	if err = cursor.All(context.TODO(), &results); err != nil {
   36
   		panic(err)
   37
   	}
   38
   	for _, result := range results {
   39
   		fmt.Println(result)
   40
   	}
   41
   }

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 运行以下命令来查询您的集合：

   go run autocomplete-query.go

   隐藏输出

   [{title Gertie the Dinosaur}]
   [{title Germany Year Zero}]
   [{title Germany in Autumn}]
   [{title Germany Pale Mother}]
   [{title Gerhard Richter - Painting}]
   [{title Geronimo: An American Legend}]
   [{title How to Live in the German Federal Republic}]
   [{title Geri's Game}]
   [{title The Gerson Miracle}]
   [{title The German Doctor}]
   [{title From Caligari to Hitler: German Cinema in the Age of the Masses}]
   [{title From Caligari to Hitler: German Cinema in the Age of the Masses}]
   [{title Gèraldine}]
   [{title Gervaise}]
   [{title Gertrud}]
   [{title Germinal}]
   [{title Gerry}]
   [{title Gerontophilia}]
   [{title Pionery-geroi}]
   [{title The Good German}]

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 autocomplete-query.go 的文件。

2. 将以下代码复制并粘贴到 autocomplete-query.go 文件。

   此代码示例将执行以下任务：

   • 导入mongodb包和依赖项。

   • 建立与您的 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以使用 autocomplete 操作符在 title 和 plot 字段中搜索以 pri 字符开头的词

     • $limit 阶段将输出限制为 5 个结果。

     • $project 阶段排除 title 和 plot 以外的所有字段。

   • 遍历游标以打印与查询匹配的文档。

   1
   package main
   2
   3
   import (
   4
   	"context"
   5
   	"fmt"
   6
   7
   	"go.mongodb.org/mongo-driver/bson"
   8
   	"go.mongodb.org/mongo-driver/mongo"
   9
   	"go.mongodb.org/mongo-driver/mongo/options"
   10
   )
   11
   12
   func main() {
   13
   	// connect to your Atlas cluster
   14
   	client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI("<connection-string>"))
   15
   	if err != nil {
   16
   		panic(err)
   17
   	}
   18
   	defer client.Disconnect(context.TODO())
   19
   20
   	// set namespace
   21
   	collection := client.Database("sample_mflix").Collection("movies")
   22
   23
   	// define pipeline stages
   24
   	searchStage := bson.D{
   25
   		{"$search", bson.D{
   26
   			{"index", "autocomplete-tutorial"},
   27
   			{"compound", bson.D{
   28
   				{"should", bson.A{
   29
   					bson.D{
   30
   						{"autocomplete", bson.D{{"query", "pri"}, {"path", "title"}}},
   31
   					},
   32
   					bson.D{
   33
   						{"autocomplete", bson.D{{"query", "pri"}, {"path", "plot"}}},
   34
   					},
   35
   				}},
   36
   				{"minimumShouldMatch", 1},
   37
   			}},
   38
   		}},
   39
   	}
   40
   	limitStage := bson.D{{"$limit", 5}}
   41
   	projectStage := bson.D{{"$project", bson.D{{"title", 1}, {"plot", 1}, {"_id", 0}}}}
   42
   	// run pipeline
   43
   	cursor, err := collection.Aggregate(context.TODO(), mongo.Pipeline{searchStage, limitStage, projectStage})
   44
   	if err != nil {
   45
   		panic(err)
   46
   	}
   47
   48
   	// print results
   49
   	var results []bson.D
   50
   	if err = cursor.All(context.TODO(), &results); err != nil {
   51
   		panic(err)
   52
   	}
   53
   	for _, result := range results {
   54
   		fmt.Println(result)
   55
   	}
   56
   }

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 运行以下命令来查询您的集合：

   go run autocomplete-query.go

   隐藏输出

   [
    {plot Prison Terminal: The Last Days of Private Jack Hall is a moving cinema verite documentary that breaks through the walls of one of Americas oldest maximum security prisons to tell the story ...}
    {title Prison Terminal: The Last Days of Private Jack Hall}
   ]
   [
    {plot Now settled in Genovia, Princess Mia faces a new revelation: she is being primed for an arranged marriage to an English suitor.}
    {title The Princess Diaries 2: Royal Engagement}
   ]
   [
    {plot A young fugitive prince and princess must stop a villain who unknowingly threatens to destroy the world with a special dagger that enables the magic sand inside to reverse time.}
    {title Prince of Persia: The Sands of Time}
   ]
   [
    {plot The first wedding anniversary of Princess Odette and Prince Derek is distracted by field fires set by Knuckles. His master Clavius, wants to conquer the world, and he needs to capture a ...}
    {title The Swan Princess: Escape from Castle Mountain}
   ]
   [
    {plot Jane Austen's classic novel about the prejudice that occurred between the 19th century classes and the pride which would keep lovers apart.}
    {title Pride and Prejudice}
   ]

确保 CLASSPATH 包含以下库。

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 AutocompleteQuery.java 的文件。

2. 将以下代码复制并粘贴到 AutocompleteQuery.java 文件。

   此代码示例将执行以下任务：

   • 导入mongodb包和依赖项。

   • 建立与您的 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以便使用 autocomplete 运算符在 title 字段中搜索以 ger 字符开头的词

     • $limit 阶段将输出限制为 20 个结果。

     • 要排除 title 之外的所有字段的 $project 阶段。

   • 遍历游标以打印与查询匹配的文档。

   1
   import static com.mongodb.client.model.Aggregates.limit;
   2
   import static com.mongodb.client.model.Aggregates.project;
   3
   import static com.mongodb.client.model.Projections.excludeId;
   4
   import static com.mongodb.client.model.Projections.fields;
   5
   import static com.mongodb.client.model.Projections.include;
   6
   import com.mongodb.client.MongoClient;
   7
   import com.mongodb.client.MongoClients;
   8
   import com.mongodb.client.MongoCollection;
   9
   import com.mongodb.client.MongoDatabase;
   10
   import org.bson.Document;
   11
   import java.util.Arrays;
   12
   13
   public class AutocompleteQuery {
   14
   15
       public static void main(String[] args) {
   16
           // connect to your Atlas cluster
   17
           String uri = "<connection-string>";
   18
           
   19
           try (MongoClient mongoClient = MongoClients.create(uri)) {
   20
               // set namespace
   21
               MongoDatabase database = mongoClient.getDatabase("sample_mflix");
   22
               MongoCollection<Document> collection = database.getCollection("movies");
   23
               
   24
               // define pipeline
   25
               Document agg = new Document("$search", 
   26
                   new Document("index", "autocomplete-tutorial")
   27
                   .append("autocomplete", new Document("query", "ger").append("path", "title")));
   28
               // run pipeline and print results
   29
               collection.aggregate(Arrays.asList(agg,
   30
                   limit(20),
   31
                   project(fields(excludeId(), include("title"))))).forEach(doc -> System.out.println(doc.toJson()));
   32
           }
   33
       }
   34
   }

   注意

   要在 Maven 环境中运行示例代码，请在文件中的 import 语句上方添加以下内容。

   package com.mongodb.drivers;

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 编译并运行 AutocompleteQuery.java 文件。

   javac AutocompleteQuery.java
   java AutocompleteQuery

   隐藏输出

   {"title": "Gertie the Dinosaur"}
   {"title": "Germany Year Zero"}
   {"title": "Germany in Autumn"}
   {"title": "Germany Pale Mother"}
   {"title": "Gerhard Richter - Painting"}
   {"title": "Geronimo: An American Legend"}
   {"title": "How to Live in the German Federal Republic"}
   {"title": "Geri's Game"}
   {"title": "The Gerson Miracle"}
   {"title": "The German Doctor"}
   {"title": "From Caligari to Hitler: German Cinema in the Age of the Masses"}
   {"title": "From Caligari to Hitler: German Cinema in the Age of the Masses"}
   {"title": "Gèraldine"}
   {"title": "Gervaise"}
   {"title": "Gertrud"}
   {"title": "Germinal"}
   {"title": "Gerry"}
   {"title": "Gerontophilia"}
   {"title": "Pionery-geroi"}
   {"title": "The Good German"}

确保 CLASSPATH 包含以下库。

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 AutocompleteQuery.java 的文件。

2. 将以下代码复制并粘贴到 AutocompleteQuery.java 文件。

   此代码示例将执行以下任务：

   • 导入mongodb包和依赖项。

   • 建立与您的 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以使用 autocomplete 操作符在 title 和 plot 字段中搜索以 pri 字符开头的词

     • $limit 阶段将输出限制为 5 个结果。

     • $project 阶段排除 title 和 plot 以外的所有字段。

   • 遍历游标以打印与查询匹配的文档。

   1
   import static com.mongodb.client.model.Aggregates.limit;
   2
   import static com.mongodb.client.model.Aggregates.project;
   3
   import static com.mongodb.client.model.Projections.excludeId;
   4
   import static com.mongodb.client.model.Projections.fields;
   5
   import static com.mongodb.client.model.Projections.include;
   6
   import com.mongodb.client.MongoClient;
   7
   import com.mongodb.client.MongoClients;
   8
   import com.mongodb.client.MongoCollection;
   9
   import com.mongodb.client.MongoDatabase;
   10
   import org.bson.Document;
   11
   import java.util.Arrays;
   12
   13
   public class AutocompleteQuery {
   14
   15
       public static void main(String[] args) {
   16
           // connect to your Atlas cluster
   17
           String uri = "<connection-string>";
   18
           
   19
           try (MongoClient mongoClient = MongoClients.create(uri)) {
   20
               // set namespace
   21
               MongoDatabase database = mongoClient.getDatabase("sample_mflix");
   22
               MongoCollection<Document> collection = database.getCollection("movies");
   23
               
   24
               // define pipeline
   25
               Document agg = new Document("$search", 
   26
                   new Document("index", "autocomplete-tutorial")
   27
                   .append("compound", 
   28
                   new Document("should", Arrays.asList(new Document("autocomplete", 
   29
                                   new Document("query", "pri")
   30
                                           .append("path", "title")), 
   31
                                   new Document("autocomplete", 
   32
                                   new Document("query", "pri")
   33
                                           .append("path", "plot"))))
   34
                               .append("minimumShouldMatch", 1L)));
   35
               // run pipeline and print results
   36
               collection.aggregate(Arrays.asList(agg,
   37
                   limit(5),
   38
                   project(fields(excludeId(), include("title"))))).forEach(doc -> System.out.println(doc.toJson()));
   39
           }
   40
       }
   41
   }

   注意

   要在 Maven 环境中运行示例代码，请在文件中的 import 语句上方添加以下内容。

   package com.mongodb.drivers;

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 编译并运行 AutocompleteQuery.java 文件。

   javac AutocompleteQuery.java
   java AutocompleteQuery

   隐藏输出

   {
     plot: 'Prison Terminal: The Last Days of Private Jack Hall is a moving cinema verite documentary that breaks through the walls of one of Americas oldest maximum security prisons to tell the story ...',
     title: 'Prison Terminal: The Last Days of Private Jack Hall'
   }
   {
     plot: 'Now settled in Genovia, Princess Mia faces a new revelation: she is being primed for an arranged marriage to an English suitor.',
     title: 'The Princess Diaries 2: Royal Engagement'
   }
   {
     plot: 'A young fugitive prince and princess must stop a villain who unknowingly threatens to destroy the world with a special dagger that enables the magic sand inside to reverse time.',
     title: 'Prince of Persia: The Sands of Time'
   }
   {
     plot: 'The first wedding anniversary of Princess Odette and Prince Derek is distracted by field fires set by Knuckles. His master Clavius, wants to conquer the world, and he needs to capture a ...',
     title: 'The Swan Princess: Escape from Castle Mountain'
   }
   {
     plot: "Jane Austen's classic novel about the prejudice that occurred between the 19th century classes and the pride which would keep lovers apart.",
     title: 'Pride and Prejudice'
   }

确保将以下依赖项添加到项目中。

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 AutocompleteQuery.kt 的文件。

2. 将以下代码复制并粘贴到 AutocompleteQuery.kt 文件。

   此代码示例将执行以下任务：

   • 导入mongodb包和依赖项。

   • 建立与您的 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以便使用 autocomplete 运算符在 title 字段中搜索以 ger 字符开头的词

     • $limit 阶段将输出限制为 20 个结果。

     • 要排除 title 之外的所有字段的 $project 阶段。

   • 遍历游标以打印与查询匹配的文档。

   1
   import com.mongodb.client.model.Aggregates.limit
   2
   import com.mongodb.client.model.Aggregates.project
   3
   import com.mongodb.client.model.Projections.*
   4
   import com.mongodb.kotlin.client.coroutine.MongoClient
   5
   import kotlinx.coroutines.runBlocking
   6
   import org.bson.Document
   7
   8
   fun main() {
   9
       // connect to your Atlas cluster
   10
       val uri = "<connection-string>"
   11
       val mongoClient = MongoClient.create(uri)
   12
   13
       // set namespace
   14
       val database = mongoClient.getDatabase("sample_mflix")
   15
       val collection = database.getCollection<Document>("movies")
   16
   17
       runBlocking {
   18
           // define pipeline
   19
           val agg = Document(
   20
               "\$search",
   21
               Document("index", "autocomplete-tutorial")
   22
                   .append("autocomplete", Document("query", "ger").append("path", "title"))
   23
           )
   24
           
   25
           // run pipeline and print results
   26
           val resultsFlow = collection.aggregate<Document>(
   27
               listOf(
   28
                   agg,
   29
                   limit(20),
   30
                   project(fields(excludeId(), include("title")))
   31
               )
   32
           )
   33
           resultsFlow.collect { println(it) }
   34
       }
   35
       mongoClient.close()
   36
   }

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 运行 AutocompleteQuery.kt 文件。

   当你在 IDE 中运行 AutocompleteQuery.kt 程序时，它会打印以下文档：

   Document{{title=Germany in Autumn}}
   Document{{title=Germany Pale Mother}}
   Document{{title=Gertie the Dinosaur}}
   Document{{title=Geronimo: An American Legend}}
   Document{{title=How to Live in the German Federal Republic}}
   Document{{title=Geri's Game}}
   Document{{title=The Gerson Miracle}}
   Document{{title=The German Doctor}}
   Document{{title=From Caligari to Hitler: German Cinema in the Age of the Masses}}
   Document{{title=From Caligari to Hitler: German Cinema in the Age of the Masses}}
   Document{{title=Gervaise}}
   Document{{title=Germinal}}
   Document{{title=Gerry}}
   Document{{title=Gèraldine}}
   Document{{title=Pionery-geroi}}
   Document{{title=Rece do gèry}}
   Document{{title=The Good German}}
   Document{{title=Berlin Is in Germany}}
   Document{{title=Almanya: Welcome to Germany}}
   Document{{title=Hitler: A Film from Germany}}

确保将以下依赖项添加到项目中。

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 AutocompleteQuery.kt 的文件。

2. 将以下代码复制并粘贴到 AutocompleteQuery.kt 文件。

   此代码示例将执行以下任务：

   • 导入mongodb包和依赖项。

   • 建立与您的 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以使用 autocomplete 操作符在 title 和 plot 字段中搜索以 pri 字符开头的词

     • $limit 阶段将输出限制为 5 个结果。

     • $project 阶段排除 title 和 plot 以外的所有字段。

   • 遍历游标以打印与查询匹配的文档。

   1
   import com.mongodb.client.model.Aggregates.limit
   2
   import com.mongodb.client.model.Aggregates.project
   3
   import com.mongodb.client.model.Projections.*
   4
   import com.mongodb.kotlin.client.coroutine.MongoClient
   5
   import kotlinx.coroutines.runBlocking
   6
   import org.bson.Document
   7
   8
   fun main() {
   9
       // connect to your Atlas cluster
   10
       val uri = "<connection-string>"
   11
       val mongoClient = MongoClient.create(uri)
   12
   13
       // set namespace
   14
       val database = mongoClient.getDatabase("sample_mflix")
   15
       val collection = database.getCollection<Document>("movies")
   16
   17
       runBlocking {
   18
           // define pipeline
   19
           val agg = Document(
   20
               "\$search",
   21
               Document("index", "autocomplete-tutorial")
   22
                   .append(
   23
                       "compound",
   24
                       Document(
   25
                           "should", listOf(
   26
                               Document(
   27
                                   "autocomplete",
   28
                                   Document("query", "pri")
   29
                                       .append("path", "title")
   30
                               ),
   31
                               Document(
   32
                                   "autocomplete",
   33
                                   Document("query", "pri")
   34
                                       .append("path", "plot")
   35
                               )
   36
                           )
   37
                       )
   38
                           .append("minimumShouldMatch", 1L)
   39
                   )
   40
           )
   41
   42
           // run pipeline and print results
   43
           val resultsFlow = collection.aggregate<Document>(
   44
               listOf(
   45
                   agg,
   46
                   limit(5),
   47
                   project(fields(excludeId(), include("title", "plot")))
   48
               )
   49
           )
   50
           resultsFlow.collect { println(it) }
   51
       }
   52
       mongoClient.close()
   53
   }

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 运行 AutocompleteQuery.kt 文件。

   当你在 IDE 中运行 AutocompleteQuery.kt 程序时，它会打印以下文档：

   Document{{plot=Prison Terminal: The Last Days of Private Jack Hall is a moving cinema verite documentary that breaks through the walls of one of Americas oldest maximum security prisons to tell the story ..., title=Prison Terminal: The Last Days of Private Jack Hall}}
   Document{{plot=Now settled in Genovia, Princess Mia faces a new revelation: she is being primed for an arranged marriage to an English suitor., title=The Princess Diaries 2: Royal Engagement}}
   Document{{plot=A young fugitive prince and princess must stop a villain who unknowingly threatens to destroy the world with a special dagger that enables the magic sand inside to reverse time., title=Prince of Persia: The Sands of Time}}
   Document{{plot=The first wedding anniversary of Princess Odette and Prince Derek is distracted by field fires set by Knuckles. His master Clavius, wants to conquer the world, and he needs to capture a ..., title=The Swan Princess: Escape from Castle Mountain}}
   Document{{plot=Jane Austen's classic novel about the prejudice that occurred between the 19th century classes and the pride which would keep lovers apart., title=Pride and Prejudice}}

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 autocomplete-query.js 的文件。

2. 将以下代码复制并粘贴到 autocomplete-query.js 文件。

   此代码示例将执行以下任务：

   • 导入 mongodb，即 MongoDB 的 Node.js 驱动程序。

   • 创建一个 MongoClient 类实例，以建立与 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以便使用 autocomplete 运算符在 title 字段中搜索以 ger 字符开头的词

     • $limit 阶段将输出限制为 20 个结果。

     • 要排除 title 之外的所有字段的 $project 阶段。

   • 遍历游标以打印与查询匹配的文档。

   1
   const { MongoClient } = require("mongodb");
   2
   3
   // connect to your Atlas cluster
   4
   const uri =
   5
       "<connection-string>";
   6
   7
   const client = new MongoClient(uri);
   8
   9
   async function run() {
   10
       try {
   11
           await client.connect();
   12
   13
           // set namespace
   14
           const database = client.db("sample_mflix");
   15
           const coll = database.collection("movies");
   16
   17
           // define pipeline
   18
           const agg = [
   19
               {$search: {index: "autocomplete-tutorial", autocomplete: {query: "ger", path: "title"}}},
   20
               {$limit: 20},
   21
               {$project: {_id: 0,title: 1}}
   22
           ];
   23
           // run pipeline
   24
           const result = await coll.aggregate(agg);
   25
   26
           // print results
   27
           await result.forEach((doc) => console.log(doc));
   28
       } finally {
   29
           await client.close();
   30
       }
   31
   }
   32
   run().catch(console.dir);

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 运行以下命令来查询您的集合：

   node autocompelte-query.js

   隐藏输出

   { title: 'Gertie the Dinosaur' }
   { title: 'Germany Year Zero' }
   { title: 'Germany in Autumn' }
   { title: 'Germany Pale Mother' }
   { title: 'Gerhard Richter - Painting' }
   { title: 'Geronimo: An American Legend' }
   { title: 'How to Live in the German Federal Republic' }
   { title: "Geri's Game" }
   { title: 'The Gerson Miracle' }
   { title: 'The German Doctor' }
   { title: 'From Caligari to Hitler: German Cinema in the Age of the Masses' }
   { title: 'From Caligari to Hitler: German Cinema in the Age of the Masses' }
   { title: 'Gèraldine' }
   { title: 'Gervaise' }
   { title: 'Gertrud' }
   { title: 'Germinal' }
   { title: 'Gerry' }
   { title: 'Gerontophilia' }
   { title: 'Pionery-geroi' }
   { title: 'The Good German' }

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 autocomplete-query.js 的文件。

2. 将以下代码复制并粘贴到 autocomplete-query.js 文件。

   此代码示例将执行以下任务：

   • 导入 mongodb，即 MongoDB 的 Node.js 驱动程序。

   • 创建一个 MongoClient 类实例，以建立与 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以使用 autocomplete 操作符在 title 和 plot 字段中搜索以 pri 字符开头的词

     • $limit 阶段将输出限制为 5 个结果。

     • $project 阶段排除 title 和 plot 以外的所有字段。

   • 遍历游标以打印与查询匹配的文档。

   1
   const { MongoClient } = require("mongodb");
   2
   3
   // connect to your Atlas cluster
   4
   const uri =
   5
       "<connection-string>";
   6
   7
   const client = new MongoClient(uri);
   8
   9
   async function run() {
   10
       try {
   11
           await client.connect();
   12
   13
           // set namespace
   14
           const database = client.db("sample_mflix");
   15
           const coll = database.collection("movies");
   16
   17
           // define pipeline
   18
           const agg = [
   19
               {
   20
                   '$search': {
   21
                       'index': 'autocomplete-tutorial',
   22
                       'compound': {
   23
                           'should': [
   24
                               {
   25
                                   'autocomplete': {
   26
                                       'query': 'pri', 
   27
                                       'path': 'title'
   28
                                   }
   29
                               }, 
   30
                               {
   31
                                   'autocomplete': {
   32
                                       'query': 'pri', 
   33
                                       'path': 'plot'
   34
                                   }
   35
                               }
   36
                           ], 
   37
                           'minimumShouldMatch': 1
   38
                       }
   39
                   }
   40
               }, 
   41
               {
   42
                   '$limit': 5
   43
               }, 
   44
               {
   45
                   '$project': {
   46
                       '_id': 0, 
   47
                       'title': 1, 
   48
                       'plot': 1
   49
                   }
   50
               }
   51
           ];
   52
           // run pipelines
   53
           const result = await coll.aggregate(agg);
   54
   55
           // print results
   56
           await result.forEach((doc) => console.log(doc));
   57
       } finally {
   58
           await client.close();
   59
       }
   60
   }
   61
   run().catch(console.dir);

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 运行以下命令来查询您的集合：

   node autocomplete-query.js

   隐藏输出

   {
     plot: 'Prison Terminal: The Last Days of Private Jack Hall is a moving cinema verite documentary that breaks through the walls of one of Americas oldest maximum security prisons to tell the story ...',
     title: 'Prison Terminal: The Last Days of Private Jack Hall'
   }
   {
     plot: 'Now settled in Genovia, Princess Mia faces a new revelation: she is being primed for an arranged marriage to an English suitor.',
     title: 'The Princess Diaries 2: Royal Engagement'
   }
   {
     plot: 'A young fugitive prince and princess must stop a villain who unknowingly threatens to destroy the world with a special dagger that enables the magic sand inside to reverse time.',
     title: 'Prince of Persia: The Sands of Time'
   }
   {
     plot: 'The first wedding anniversary of Princess Odette and Prince Derek is distracted by field fires set by Knuckles. His master Clavius, wants to conquer the world, and he needs to capture a ...',
     title: 'The Swan Princess: Escape from Castle Mountain'
   }
   {
     plot: "Jane Austen's classic novel about the prejudice that occurred between the 19th century classes and the pride which would keep lovers apart.",
     title: 'Pride and Prejudice'
   }

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 autocomplete-query.py 的文件。

2. 将以下代码复制并粘贴到 autocomplete.py 文件。

   以下代码示例：

   • 导入 pymongo，MongoDB 的 Python 驱动程序。

   • 创建一个 MongoClient 类实例，以建立与 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以便使用 autocomplete 运算符在 title 字段中搜索以 ger 字符开头的词

     • $limit 阶段将输出限制为 20 个结果。

     • 要排除 title 之外的所有字段的 $project 阶段。

   • 遍历游标以打印与查询匹配的文档。

   1
   import pymongo
   2
   3
   # connect to your Atlas cluster
   4
   client = pymongo.MongoClient('<connection-string>')
   5
   6
   # define pipeline
   7
   pipeline = [
   8
       {"$search": {"index": "autocomplete-tutorial", "autocomplete": {"query": "ger", "path": "title"}}},
   9
       {"$limit": 20},
   10
       {"$project": {"_id": 0, "title": 1}},
   11
   ]
   12
   # run pipeline
   13
   result = client["sample_mflix"]["movies"].aggregate(pipeline)
   14
   15
   # print results
   16
   for i in result:
   17
       print(i)

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 运行以下命令来查询您的集合：

   python autocomplete-query.py

   隐藏输出

   {'title': 'Gertie the Dinosaur'}
   {'title': 'Germany Year Zero'}
   {'title': 'Germany in Autumn'}
   {'title': 'Germany Pale Mother'}
   {'title': 'Gerhard Richter - Painting'}
   {'title': 'Geronimo: An American Legend'}
   {'title': 'How to Live in the German Federal Republic'}
   {'title': "Geri's Game"}
   {'title': 'The Gerson Miracle'}
   {'title': 'The German Doctor'}
   {'title': 'From Caligari to Hitler: German Cinema in the Age of the Masses'}
   {'title': 'From Caligari to Hitler: German Cinema in the Age of the Masses'}
   {'title': 'G\xe8raldine'}
   {'title': 'Gervaise'}
   {'title': 'Gertrud'}
   {'title': 'Germinal'}
   {'title': 'Gerry'}
   {'title': 'Gerontophilia'}
   {'title': 'Pionery-geroi'}
   {'title': 'The Good German'}

使用 autocomplete 操作符对 movies 集合运行 Atlas Search 查询。

1. 创建一个名为 autocomplete-query.py 的文件。

2. 将以下代码复制并粘贴到 autocomplete.py 文件。

   以下代码示例：

   • 导入 pymongo 、MongoDB 的 Python 驱动程序和 dns 模块，这是使用 DNS 种子列表连接字符串将 pymongo 连接到 Atlas 所必需的。

   • 创建一个 MongoClient 类实例，以建立与 Atlas 集群的连接。

   • 使用以下管道阶段：

     • $search 以使用 autocomplete 操作符在 title 和 plot 字段中搜索以 pri 字符开头的词

     • $limit 阶段将输出限制为 5 个结果。

     • $project 阶段排除 title 和 plot 以外的所有字段。

   • 遍历游标以打印与查询匹配的文档。

   1
   import pymongo
   2
   3
   # connect to your Atlas cluster
   4
   client = pymongo.MongoClient('<connection-string>')
   5
   6
   # define pipeline
   7
   pipeline = [
   8
       {
   9
           '$search': {
   10
               'index': 'autocomplete-tutorial',
   11
               'compound': {
   12
                   'should': [
   13
                       {
   14
                           'autocomplete': {
   15
                               'query': 'pri', 
   16
                               'path': 'title'
   17
                           }
   18
                       }, {
   19
                           'autocomplete': {
   20
                               'query': 'pri', 
   21
                               'path': 'plot'
   22
                           }
   23
                       }
   24
                   ], 
   25
                   'minimumShouldMatch': 1
   26
               }
   27
           }
   28
       }, 
   29
       {
   30
           '$limit': 5
   31
       }, 
   32
       {
   33
           '$project': {
   34
               '_id': 0, 'title': 1, 'plot': 1
   35
           }
   36
       }
   37
   ]
   38
   # run pipeline
   39
   result = client["sample_mflix"]["movies"].aggregate(pipeline)
   40
   41
   # print results
   42
   for i in result:
   43
       print(i)

3. 在运行示例之前，请将 <connection-string> 替换为 Atlas 连接字符串。确保您的连接字符串包含数据库用户的档案。要了解详情，请参阅通过驱动程序连接。

4. 运行以下命令来查询您的集合：

   python autocomplete-query.py

   隐藏输出

   {
     plot: 'Prison Terminal: The Last Days of Private Jack Hall is a moving cinema verite documentary that breaks through the walls of one of Americas oldest maximum security prisons to tell the story ...',
     title: 'Prison Terminal: The Last Days of Private Jack Hall'
   }
   {
     plot: 'Now settled in Genovia, Princess Mia faces a new revelation: she is being primed for an arranged marriage to an English suitor.',
     title: 'The Princess Diaries 2: Royal Engagement'
   }
   {
     plot: 'A young fugitive prince and princess must stop a villain who unknowingly threatens to destroy the world with a special dagger that enables the magic sand inside to reverse time.',
     title: 'Prince of Persia: The Sands of Time'
   }
   {
     plot: 'The first wedding anniversary of Princess Odette and Prince Derek is distracted by field fires set by Knuckles. His master Clavius, wants to conquer the world, and he needs to capture a ...',
     title: 'The Swan Princess: Escape from Castle Mountain'
   }
   {
     plot: "Jane Austen's classic novel about the prejudice that occurred between the 19th century classes and the pride which would keep lovers apart.",
     title: 'Pride and Prejudice'
   }