Rumah >pembangunan bahagian belakang >Golang >pertanyaan golang mongodb
Dalam beberapa tahun kebelakangan ini, Golang semakin digunakan, terutamanya dalam senario data besar Semakin ramai pembangun telah mula menggunakan Golang untuk melaksanakan aplikasi mereka. Sebagai pangkalan data berprestasi tinggi, berorientasikan dokumen, MongoDB juga disukai dan digunakan oleh lebih ramai orang. Artikel ini akan memperkenalkan cara menggunakan MongoDB untuk pertanyaan di Golang.
Pertama, kita perlu memperkenalkan pakej pemacu MongoDB ke dalam Golang, seperti yang ditunjukkan di bawah:
import "go.mongodb.org/mongo-driver/mongo" import "go.mongodb.org/mongo-driver/mongo/options"
Seterusnya, kita perlu mewujudkan sambungan MongoDB. Berikut ialah kod sampel:
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 }
Di mana, uri
ialah rentetan sambungan ke pangkalan data MongoDB. Kami mewujudkan sambungan MongoDB dalam fungsi ConnectMongo
dan mengembalikan contoh mongo.Client
.
Kemudian anda boleh melakukan operasi pertanyaan. Berikut ialah contoh pertanyaan mudah Dalam contoh ini, kami menanyakan koleksi test
dalam pangkalan data untuk mencari semua pengguna yang jantinanya lelaki: 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 }Dalam kod di atas, kami mula-mula mendapat Dapatkan
koleksi dalam pangkalan data, dan kemudian gunakan struktur jenis test
untuk mentakrifkan keadaan pertanyaan, iaitu, jantina adalah lelaki. Seterusnya, kami mencipta konteks menggunakan fungsi users
dan membatalkannya untuk mengehadkan masa operasi pertanyaan dan membenarkan pengeluaran sumber tepat pada masanya. bson.M
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
Kemudian kami menggunakan fungsi
ialah konteks yang dibuat di atas, collection.Find(ctx, filter)
ialah syarat pertanyaan dan kursor ctx
dikembalikan. filter
cursor
Akhir sekali, kami menukar kursor ini kepada tatasusunan
, di mana cursor.All(ctx, &results)
bermaksud menghantar alamat keputusan kepada fungsi ini untuk operasi. bson.M
&results
Selain operasi pertanyaan di atas, terdapat beberapa kaedah pertanyaan lain, seperti:
1 Padanan tepat
bson.D
Berikut ialah contoh kod:
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 }
Dalam kod di atas, kami menggunakan
untuk memadankan sepenuhnya keadaan pertanyaan, di mana dan bson.D
masing-masing mewakili MongoDB Key- pasangan nilai. {“cond1”, value1}
{“cond2”, value2}
2. Padanan biasa
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 }
Dalam kod di atas, kami menggunakan
untuk mewakili ungkapan biasa, dengan ialah rentetan ungkapan biasa. $regex
“pattern”
Akhir sekali, selepas menggunakan MongoDB, kami perlu menutup sambungan pangkalan data untuk mengeluarkan sumber berkaitan. Berikut ialah contoh kod:
func CloseMongo(client *mongo.Client) error { ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) defer cancel() return client.Disconnect(ctx) }
Dengan kod di atas, kami boleh menggunakan MongoDB dengan mudah untuk operasi pertanyaan di Golang. Sama ada padanan tepat atau padanan biasa, kami boleh mencapainya dengan mudah melalui pakej pemacu MongoDB. Pada masa yang sama, selepas digunakan, sambungan pangkalan data mesti ditutup dengan segera untuk melepaskan sumber.
Atas ialah kandungan terperinci pertanyaan golang mongodb. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!