requête golang mongodb

Ces dernières années, Golang a été de plus en plus utilisé, notamment dans les scénarios Big Data. De plus en plus de développeurs ont commencé à utiliser Golang pour implémenter leurs applications. En tant que base de données hautes performances orientée document, MongoDB est également appréciée et utilisée par de plus en plus de personnes. Cet article explique comment utiliser MongoDB pour les requêtes dans Golang.

Tout d'abord, nous devons introduire le package de pilotes MongoDB dans Golang, comme indiqué ci-dessous :

import "go.mongodb.org/mongo-driver/mongo"
import "go.mongodb.org/mongo-driver/mongo/options"

Ensuite, nous devons établir une connexion MongoDB. Voici l'exemple de code :

func ConnectMongo(uri string) (*mongo.Client, error) {
    client, err := mongo.NewClient(options.Client().ApplyURI(uri))
    if err != nil {
        return nil, err
    }
    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()
    err = client.Connect(ctx)
    if err != nil {
        return nil, err
    }
    return client, nil
}

Où, uri est la chaîne de connexion de la base de données MongoDB. Nous établissons une connexion MongoDB dans la fonction ConnectMongo et renvoyons une instance de mongo.Client. uri 是 MongoDB 数据库的连接字符串。我们在 ConnectMongo 函数中建立了一个 MongoDB 的连接，并返回一个 mongo.Client 的实例。

接着就可以进行查询操作了。以下是一个简单的查询示例，在这个示例中，我们查询 test 数据库中的 users 集合，找出所有性别为男性的用户：

func FindMaleUsers(client *mongo.Client) ([]bson.M, error) {
    collection := client.Database("test").Collection("users")

    filter := bson.M{"sex": "male"}

    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()

    cursor, err := collection.Find(ctx, filter)
    if err != nil {
        return nil, err
    }

    var results []bson.M
    if err = cursor.All(ctx, &results); err != nil {
        return nil, err
    }
    return results, nil
}

在上述代码中，我们首先获取了 test 数据库中的 users 集合，然后使用 bson.M 类型的结构体定义了查询条件，即性别为男性。接着，我们使用 ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) 函数创建了一个上下文，并将其取消函数挂起，以限制查询操作的时间并允许及时释放资源。

然后我们使用 collection.Find(ctx, filter) 函数对数据库进行查询操作，其中 ctx 是上面创建的上下文，filter 是查询条件，并返回了一个游标 cursor。

最后，我们将这个游标通过 cursor.All(ctx, &results) 函数转换为一个 bson.M 数组，其中 &results 表示将结果的地址传递给此函数进行操作。

除了上述查询操作外，还有一些其他的查询方式，比如：

1. 完全匹配

在 MongoDB 中，我们可以使用 bson.D 来表示完整匹配条件。

以下是一个示例代码：

func FindByCondition(client *mongo.Client) ([]bson.M, error) {
    collection := client.Database("test").Collection("users")

    filter := bson.D{
        {"cond1", value1},
        {"cond2", value2},
        ...
    }

    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()

    cursor, err := collection.Find(ctx, filter)
    if err != nil {
        return nil, err
    }

    var results []bson.M
    if err = cursor.All(ctx, &results); err != nil {
        return nil, err
    }
    return results, nil
}

在上述代码中，我们使用 bson.D 对查询条件进行了完全匹配，其中 {“cond1”, value1} 与 {“cond2”, value2} 分别表示 MongoDB 中的键值对。

2. 正则匹配

在 MongoDB 中，我们可以使用正则表达式进行查询操作。以下是一个示例代码：

func FindByRegex(client *mongo.Client) ([]bson.M, error) {
    collection := client.Database("test").Collection("users")

    filter := bson.M{
        "field": bson.M{"$regex": "pattern"},
    }

    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()

    cursor, err := collection.Find(ctx, filter)
    if err != nil {
        return nil, err
    }

    var results []bson.M
    if err = cursor.All(ctx, &results); err != nil {
        return nil, err
    }
    return results, nil
}

在上述代码中，我们使用 $regex 来表示正则表达式，其中 “pattern”

Ensuite, vous pouvez effectuer l'opération de requête. Ce qui suit est un exemple de requête simple. Dans cet exemple, nous interrogeons la collection users dans la base de données test pour trouver tous les utilisateurs dont le sexe est masculin :

func CloseMongo(client *mongo.Client) error {
    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()
    return client.Disconnect(ctx)
}

Dans ce qui précède. Dans le code, nous obtenons d'abord la collection users dans la base de données test, puis utilisons une structure de type bson.M pour définir les conditions de requête. , c'est-à-dire que le sexe est masculin. Ensuite, nous utilisons la fonction ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) pour créer un contexte et suspendre sa fonction d'annulation afin de limiter le temps des opérations de requête et permettre les ressources doivent être libérées en temps opportun.

Ensuite, nous utilisons la fonction collection.Find(ctx, filter) pour interroger la base de données, où ctx est le contexte créé ci-dessus, et filter est la condition de la requête et renvoie un curseur cursor. 🎜🎜Enfin, nous convertissons ce curseur en un tableau bson.M via la fonction cursor.All(ctx, &results), où &results représente Passez l'adresse du résultat à cette fonction pour opérer. 🎜🎜En plus des opérations de requête ci-dessus, il existe d'autres méthodes de requête, telles que : 🎜

1 Correspondance exacte

🎜Dans MongoDB, nous pouvons utiliser bson.D pour. représentent les critères de correspondance complets. 🎜🎜Ce qui suit est un exemple de code : 🎜rrreee🎜Dans le code ci-dessus, nous utilisons bson.D pour correspondre pleinement aux conditions de la requête, où {"cond1", value1} et {"cond2", value2} représentent respectivement des paires clé-valeur dans MongoDB. 🎜

2. Correspondance régulière

🎜Dans MongoDB, nous pouvons utiliser des expressions régulières pour les opérations de requête. Voici un exemple de code : 🎜rrreee🎜Dans le code ci-dessus, nous utilisons $regex pour représenter l'expression régulière, où "pattern" est la chaîne de l'expression régulière. 🎜🎜Enfin, après avoir utilisé MongoDB, nous devons fermer la connexion à la base de données pour libérer les ressources associées. Voici l'exemple de code : 🎜rrreee🎜Avec le code ci-dessus, nous pouvons facilement utiliser MongoDB pour les opérations de requête dans Golang. Qu'il s'agisse d'une correspondance exacte ou d'une correspondance régulière, nous pouvons facilement y parvenir grâce au package de pilotes MongoDB. Dans le même temps, après utilisation, la connexion à la base de données doit être fermée rapidement pour libérer les ressources. 🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!