如何对日期和数值字段运行 Atlas Search 字符串查询

1
  [
2
    {
3
      lastScrapedDate: '2019-03-06',
4
      propertyName: 'LAHAINA, MAUI! RESORT/CONDO BEACHFRONT!! SLEEPS 4!',
5
      propertyType: 'Condominium',
6
      accommodatesNumber: '4'
7
    },
8
    {
9
      lastScrapedDate: '2019-03-06',
10
      propertyName: 'Makaha Valley Paradise with OceanView',
11
      propertyType: 'Condominium',
12
      accommodatesNumber: '4'
13
    },
14
    {
15
      lastScrapedDate: '2019-03-06',
16
      propertyName: 'March 2019 availability! Oceanview on Sugar Beach!',
17
      propertyType: 'Condominium',
18
      accommodatesNumber: '4'
19
    },
20
    {
21
      lastScrapedDate: '2019-03-06',
22
      propertyName: 'Tropical Jungle Oasis',
23
      propertyType: 'Condominium',
24
      accommodatesNumber: '4'
25
    },
26
    {
27
      lastScrapedDate: '2019-02-11',
28
      propertyName: 'Hospede-se com acesso fácil.',
29
      propertyType: 'Condominium',
30
      accommodatesNumber: '4'
31
    }
32
  ]
33
  

1
  [
2
    {
3
      lastScrapedDate: '2019-02-11',
4
      propertyName: '2017 , férias no Rio',
5
      propertyType: 'House',
6
      accommodatesNumber: '2',
7
      maximumNumberOfNights: '30'
8
    },
9
    {
10
      lastScrapedDate: '2019-03-07',
11
      propertyName: 'Newly renovated home',
12
      propertyType: 'House',
13
      accommodatesNumber: '2',
14
      maximumNumberOfNights: '30'
15
    },
16
    {
17
      lastScrapedDate: '2019-02-18',
18
      propertyName: 'Vintage House For Rent',
19
      propertyType: 'House',
20
      accommodatesNumber: '2',
21
      maximumNumberOfNights: '30'
22
    },
23
    {
24
      lastScrapedDate: '2019-02-18',
25
      propertyName: '4floor house in Taksim,Taksimde 4katli müstakil ev',
26
      propertyType: 'House',
27
      accommodatesNumber: '2',
28
      maximumNumberOfNights: '30'
29
    },
30
    {
31
      lastScrapedDate: '2019-02-16',
32
      propertyName: '22 Oporto Guesthouse Cordoaria',
33
      propertyType: 'House',
34
      accommodatesNumber: '2',
35
      maximumNumberOfNights: '30'
36
    }
37
    

1
    [
2
      {
3
        lastScrapedDate: '2019-02-11',
4
        propertyName: 'Horto flat with small garden',
5
        propertyType: 'Apartment',
6
        accommodatesNumber: '4',
7
        maximumNumberOfNights: '1125'
8
      },
9
      {
10
        lastScrapedDate: '2019-03-06',
11
        propertyName: 'Private Room in Bushwick',
12
        propertyType: 'Apartment',
13
        accommodatesNumber: '1',
14
        maximumNumberOfNights: '1125'
15
      },
16
      {
17
        lastScrapedDate: '2019-02-11',
18
        propertyName: 'Apt Linda Vista Lagoa - Rio',
19
        propertyType: 'Apartment',
20
        accommodatesNumber: '2',
21
        maximumNumberOfNights: '1125'
22
      },
23
      {
24
        lastScrapedDate: '2019-02-18',
25
        propertyName: 'Charming Flat in Downtown Moda',
26
        propertyType: 'House',
27
        accommodatesNumber: '6',
28
        maximumNumberOfNights: '1125'
29
      },
30
      {
31
        lastScrapedDate: '2019-02-11',
32
        propertyName: "Catete's Colonial Big Hause Room B",
33
        propertyType: 'House',
34
        accommodatesNumber: '8',
35
        maximumNumberOfNights: '1125'
36
      }
37
    ]

1
[
2
    {
3
      lastScrapedDate: '2019-03-06',
4
      propertyName: 'Ocean View Waikiki Marina w/prkg',
5
      propertyType: 'Condominium',
6
      accommodatesNumber: '2',
7
      maximumNumberOfNights: '365'
8
    },
9
    {
10
      lastScrapedDate: '2019-03-07',
11
      propertyName: 'New York City - Upper West Side Apt',
12
      propertyType: 'Apartment',
13
      accommodatesNumber: '2',
14
      maximumNumberOfNights: '360'
15
    },
16
    {
17
      lastScrapedDate: '2019-03-07',
18
      propertyName: 'Sydney Hyde Park City Apartment (checkin from 6am)',
19
      propertyType: 'Apartment',
20
      accommodatesNumber: '2',
21
      maximumNumberOfNights: '30'
22
    },
23
    {
24
      lastScrapedDate: '2019-03-07',
25
      propertyName: 'Private Room (2)  in Guest House at Coogee Beach',
26
      propertyType: 'House',
27
      accommodatesNumber: '2',
28
      maximumNumberOfNights: '365'
29
    },
30
    {
31
      lastScrapedDate: '2019-03-06',
32
      propertyName: '~Ao Lele~ Flying Cloud',
33
      propertyType: 'Treehouse',
34
      accommodatesNumber: '2',
35
      maximumNumberOfNights: '30'
36
    }
37
]

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 DateNumberToStringQuery
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 airbnbDatabase = mongoClient.GetDatabase("sample_airbnb");
20
        var matViewCollection = airbnbDatabase.GetCollection<matViewDocument>("airbnb_mat_view");
21
22
        // define and run pipeline
23
        var results = matViewCollection.Aggregate()
24
            .Search(Builders<matViewDocument>.Search.QueryString(
25
                airbnb => airbnb.propertyType, 
26
                "(Apartment OR Condominium) AND accommodatesNumber: 4 AND lastScrapedDate: 2019"
27
                ),
28
                indexName: "date-number-fields-tutorial")
29
            .Limit(5)
30
            .Project<matViewDocument>(Builders<matViewDocument>.Projection
31
                .Exclude(airbnb => airbnb.Id))
32
            .ToList();
33
34
        // print results
35
        foreach (var airbnb in results) 
36
        {
37
            Console.WriteLine(airbnb.ToJson());
38
        }
39
    }
40
}
41
42
[BsonIgnoreExtraElements]
43
public class matViewDocument 
44
{
45
    [BsonIgnoreIfDefault]
46
    public string Id { get; set; }
47
    public string lastScrapedDate { get; set; }
48
    public string propertyName { get; set; }
49
    public string propertyType { get; set; }
50
    public string accommodatesNumber { get; set; }
51
    public string maximumNumberOfNights { get; set; }
52
}

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 DateNumberToStringQuery
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
        var ConventionRegistry.Register("CamelCase", camelCaseConvention, type => true);
16
17
        // connect to your Atlas cluster
18
        var mongoClient = new MongoClient(MongoConnectionString);
19
        var airbnbDatabase = mongoClient.GetDatabase("sample_airbnb");
20
        var matViewCollection = airbnbDatabase.GetCollection<matViewDocument>("airbnb_mat_view");
21
22
        // define and run pipeline
23
        var results = matViewCollection.Aggregate()
24
            .Search(Builders<matViewDocument>.Search.QueryString(
25
                airbnb => airbnb.propertyType, 
26
                "House OR accommodatesNumber: 2 OR lastScrapedDate: 2019 OR maximumNumberOfNights: 30"
27
                ),
28
                indexName: "date-number-fields-tutorial")
29
            .Limit(5)
30
            .Project<matViewDocument>(Builders<matViewDocument>.Projection
31
                .Exclude(airbnb => airbnb.Id))
32
            .ToList();
33
34
        // print results
35
        foreach (var airbnb in results) 
36
        {
37
            Console.WriteLine(airbnb.ToJson());
38
        }
39
    }
40
}
41
42
[BsonIgnoreExtraElements]
43
public class matViewDocument 
44
{
45
    [BsonIgnoreIfDefault]
46
    public string Id { get; set; }
47
    public string lastScrapedDate { get; set; }
48
    public string propertyName { get; set; }
49
    public string propertyType { get; set; }
50
    public string accommodatesNumber { get; set; }
51
    public string maximumNumberOfNights { get; set; }
52
}

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 DateNumberToStringQuery
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 airbnbDatabase = mongoClient.GetDatabase("sample_airbnb");
20
        var matViewCollection = airbnbDatabase.GetCollection<matViewDocument>("airbnb_mat_view");
21
22
        // define and run pipeline
23
        var results = matViewCollection.Aggregate()
24
            .Search(Builders<matViewDocument>.Search.Compound()
25
                .Should(Builders<matViewDocument>.Search.Autocomplete(airbnb => airbnb.lastScrapedDate, "2"))
26
                .Should(Builders<matViewDocument>.Search.Autocomplete(airbnb => airbnb.maximumNumberOfNights, "1")),
27
                indexName: "date-number-fields-tutorial")
28
            .Limit(5)
29
            .Project<matViewDocument>(Builders<matViewDocument>.Projection
30
                .Exclude(airbnb => airbnb.Id))
31
            .ToList();
32
33
        // print results
34
        foreach (var airbnb in results) 
35
        {
36
            Console.WriteLine(airbnb.ToJson());
37
        }
38
    }
39
}
40
41
[BsonIgnoreExtraElements]
42
public class matViewDocument 
43
{
44
    [BsonIgnoreIfDefault]
45
    public string Id { get; set; }
46
    public string lastScrapedDate { get; set; }
47
    public string propertyName { get; set; }
48
    public string propertyType { get; set; }
49
    public string accommodatesNumber { get; set; }
50
    public string maximumNumberOfNights { get; set; }
51
}

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 DateNumberToStringQuery
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 airbnbDatabase = mongoClient.GetDatabase("sample_airbnb");
20
        var matViewCollection = airbnbDatabase.GetCollection<matViewDocument>("airbnb_mat_view");
21
22
        // define and run pipeline
23
        var results = matViewCollection.Aggregate()
24
            .Search(Builders<matViewDocument>.Search.Compound()
25
                .Should(Builders<matViewDocument>.Search.Autocomplete(airbnb => airbnb.maximumNumberOfNights, "3"))
26
                .Should(Builders<matViewDocument>.Search.Autocomplete(airbnb => airbnb.accommodatesNumber, "2")),
27
                indexName: "date-number-fields-tutorial")
28
            .Limit(5)
29
            .Project<matViewDocument>(Builders<matViewDocument>.Projection
30
                .Exclude(airbnb => airbnb.Id))
31
            .ToList();
32
33
        // print results
34
        foreach (var airbnb in results) 
35
        {
36
            Console.WriteLine(airbnb.ToJson());
37
        }
38
    }
39
}
40
41
[BsonIgnoreExtraElements]
42
public class matViewDocument 
43
{
44
    [BsonIgnoreIfDefault]
45
    public string Id { get; set; }
46
    public string lastScrapedDate { get; set; }
47
    public string propertyName { get; set; }
48
    public string propertyType { get; set; }
49
    public string accommodatesNumber { get; set; }
50
    public string maximumNumberOfNights { get; set; }
51
}

1
package main
2
3
import (
4
	"context"
5
	"fmt"
6
	"time"
7
8
	"go.mongodb.org/mongo-driver/bson"
9
	"go.mongodb.org/mongo-driver/mongo"
10
	"go.mongodb.org/mongo-driver/mongo/options"
11
)
12
13
func main() {
14
	var err error
15
	// connect to the Atlas cluster
16
	ctx := context.Background()
17
	client, err := mongo.Connect(ctx, options.Client().ApplyURI("<connection-string>"))
18
	if err != nil {
19
		panic(err)
20
	}
21
	defer client.Disconnect(ctx)
22
	// set namespace
23
	collection := client.Database("sample_airbnb").Collection("airbnb_mat_view")
24
	// define pipeline
25
	searchStage := bson.D{{"$search", bson.D{
26
		{"index", "date-number-fields-tutorial"},
27
		{"queryString", bson.D{
28
			{"defaultPath", "propertyType"},
29
			{"query", "propertyType: (Apartment OR Condominium) AND accommodatesNumber: 4 AND lastScrapedDate: 2019"},
30
		}}}}}
31
	limitStage := bson.D{{"$limit", 5}}
32
	projectStage := bson.D{{"$project", bson.D{{"_id", 0}}}}
33
	// specify the amount of time the operation can run on the server
34
	opts := options.Aggregate().SetMaxTime(5 * time.Second)
35
	// run pipeline
36
	cursor, err := collection.Aggregate(ctx, mongo.Pipeline{searchStage, limitStage, projectStage}, opts)
37
	if err != nil {
38
		panic(err)
39
	}
40
	// print results
41
	var results []bson.D
42
	if err = cursor.All(context.TODO(), &results); err != nil {
43
		panic(err)
44
	}
45
	for _, result := range results {
46
		fmt.Println(result)
47
	}
48
}

1
package main
2
3
import (
4
	"context"
5
	"fmt"
6
	"time"
7
8
	"go.mongodb.org/mongo-driver/bson"
9
	"go.mongodb.org/mongo-driver/mongo"
10
	"go.mongodb.org/mongo-driver/mongo/options"
11
)
12
13
func main() {
14
	var err error
15
	// connect to the Atlas cluster
16
	ctx := context.Background()
17
	client, err := mongo.Connect(ctx, options.Client().ApplyURI("<connection-string>"))
18
	if err != nil {
19
		panic(err)
20
	}
21
	defer client.Disconnect(ctx)
22
	// set namespace
23
	collection := client.Database("sample_airbnb").Collection("airbnb_mat_view")
24
	// define pipeline
25
	searchStage := bson.D{{"$search", bson.D{
26
		{"index", "date-number-fields-tutorial"},
27
		{"queryString", bson.D{
28
			{"defaultPath", "propertyType"},
29
			{"query", "propertyType: House OR accommodatesNumber: 2 OR lastScrapedDate: 2019 OR maximumNumberOfNights: 30"},
30
		}}}}}
31
	limitStage := bson.D{{"$limit", 5}}
32
	projectStage := bson.D{{"$project", bson.D{{"_id", 0}}}}
33
	// specify the amount of time the operation can run on the server
34
	opts := options.Aggregate().SetMaxTime(5 * time.Second)
35
	// run pipeline
36
	cursor, err := collection.Aggregate(ctx, mongo.Pipeline{searchStage, limitStage, projectStage}, opts)
37
	if err != nil {
38
		panic(err)
39
	}
40
	// print results
41
	var results []bson.D
42
	if err = cursor.All(context.TODO(), &results); err != nil {
43
		panic(err)
44
	}
45
	for _, result := range results {
46
		fmt.Println(result)
47
	}
48
}

1
package main
2
3
import (
4
	"context"
5
	"fmt"
6
	"time"
7
8
	"go.mongodb.org/mongo-driver/bson"
9
	"go.mongodb.org/mongo-driver/mongo"
10
	"go.mongodb.org/mongo-driver/mongo/options"
11
)
12
13
// define structure of movies collection
14
type MovieCollection struct {
15
	title string `bson:"Title,omitempty"`
16
}
17
18
func main() {
19
	var err error
20
	// connect to the Atlas cluster
21
	ctx := context.Background()
22
	client, err := mongo.Connect(ctx, options.Client().ApplyURI("<connection-tring>"))
23
	if err != nil {
24
		panic(err)
25
	}
26
	defer client.Disconnect(ctx)
27
	// set namespace
28
	collection := client.Database("sample_airbnb").Collection("airbnb_mat_view")
29
	// define pipeline
30
	searchStage := bson.D{{"$search", bson.M{
31
		"index": "date-number-fields-tutorial",
32
		"compound": bson.M{
33
			"should": bson.A{
34
				bson.M{
35
					"autocomplete": bson.M{
36
						"path": "lastScrapedDate", "query": "2",
37
					},
38
				},
39
				bson.M{
40
					"autocomplete": bson.M{
41
						"path": "maximumNumberOfNights", "query": "1",
42
					},
43
				},
44
			},
45
		},
46
	}}}
47
	limitStage := bson.D{{"$limit", 5}}
48
	projectStage := bson.D{{"$project", bson.D{{"_id", 0}}}}
49
	// specify the amount of time the operation can run on the server
50
	opts := options.Aggregate().SetMaxTime(5 * time.Second)
51
	// run pipeline
52
	cursor, err := collection.Aggregate(ctx, mongo.Pipeline{searchStage, limitStage, projectStage}, opts)
53
	if err != nil {
54
		panic(err)
55
	}
56
	// print results
57
	var results []bson.D
58
	if err = cursor.All(context.TODO(), &results); err != nil {
59
		panic(err)
60
	}
61
	for _, result := range results {
62
		fmt.Println(result)
63
	}
64
}

1
package main
2
3
import (
4
	"context"
5
	"fmt"
6
	"time"
7
8
	"go.mongodb.org/mongo-driver/bson"
9
	"go.mongodb.org/mongo-driver/mongo"
10
	"go.mongodb.org/mongo-driver/mongo/options"
11
)
12
13
// define structure of movies collection
14
type MovieCollection struct {
15
	title string `bson:"Title,omitempty"`
16
}
17
18
func main() {
19
	var err error
20
	// connect to the Atlas cluster
21
	ctx := context.Background()
22
	client, err := mongo.Connect(ctx, options.Client().ApplyURI("<connection-string>"))
23
	if err != nil {
24
		panic(err)
25
	}
26
	defer client.Disconnect(ctx)
27
	// set namespace
28
	collection := client.Database("sample_airbnb").Collection("airbnb_mat_view")
29
	// define pipeline
30
	searchStage := bson.D{{"$search", bson.M{
31
		"index": "date-number-fields-tutorial",
32
		"compound": bson.M{
33
			"should": bson.A{
34
				bson.M{
35
					"autocomplete": bson.M{
36
						"path": "maximumNumberOfNights", "query": "3",
37
					},
38
				},
39
				bson.M{
40
					"autocomplete": bson.M{
41
						"path": "accommodatesNumber", "query": "2",
42
					},
43
				},
44
			},
45
		},
46
	}}}
47
	limitStage := bson.D{{"$limit", 5}}
48
	projectStage := bson.D{{"$project", bson.D{{"_id", 0}}}}
49
	// specify the amount of time the operation can run on the server
50
	opts := options.Aggregate().SetMaxTime(5 * time.Second)
51
	// run pipeline
52
	cursor, err := collection.Aggregate(ctx, mongo.Pipeline{searchStage, limitStage, projectStage}, opts)
53
	if err != nil {
54
		panic(err)
55
	}
56
	// print results
57
	var results []bson.D
58
	if err = cursor.All(context.TODO(), &results); err != nil {
59
		panic(err)
60
	}
61
	for _, result := range results {
62
		fmt.Println(result)
63
	}
64
}

1
import java.util.Arrays;
2
import static com.mongodb.client.model.Filters.eq;
3
import static com.mongodb.client.model.Aggregates.limit;
4
import static com.mongodb.client.model.Aggregates.project;
5
import static com.mongodb.client.model.Projections.excludeId;
6
import static com.mongodb.client.model.Projections.fields;
7
import com.mongodb.client.MongoClient;
8
import com.mongodb.client.MongoClients;
9
import com.mongodb.client.MongoCollection;
10
import com.mongodb.client.MongoDatabase;
11
import org.bson.Document;
12
13
public class DateNumberToStringQuery {
14
	public static void main( String[] args ) {
15
		// define query
16
		Document agg = new Document("$search",
17
			new Document ("index", "date-number-fields-tutorial")
18
			.append("queryString",
19
				new Document("defaultPath", "propertyType")
20
                .append("query", "propertyType: (Apartment OR Condominium) AND accommodatesNumber: 4 AND lastScrapedDate: 2019")));
21
		
22
		// specify connection
23
		String uri = "<connection-string>";
24
		
25
        // establish connection and set namespace
26
		try (MongoClient mongoClient = MongoClients.create(uri)) {
27
			MongoDatabase database = mongoClient.getDatabase("sample_airbnb");
28
			MongoCollection<Document> collection = database.getCollection("airbnb_mat_view");
29
			// run query and print results
30
			collection.aggregate(Arrays.asList(agg, 
31
					limit(5), 
32
					project(fields(excludeId()) ))
33
			).forEach(doc -> System.out.println(doc.toJson()));	
34
		}
35
	}
36
}