如何对日期和数值字段运行 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
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
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
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
}