Urus niaga MongoDB, kaedah API panggil balik

Kandungan soalan

Selepas membaca banyak dokumen/artikel tentang transaksi MongoDB, saya masih memerlukan penjelasan lanjut.

Di sini tertulis:

MongoDB provides two APIs to use transactions. The first is the core API which has similar syntax to relational databases. The second, the callback API, is the recommended approach to using transactions in MongoDB.

Tetapi ia terus memperkenalkan kaedah teras API tanpa menyentuh kaedah yang disyorkan sama sekali.

Dokumentasi rasmi di sini menyatakan,

This example highlights the key components of the transactions API. In particular, it uses the callback API. The callback API:

starts a transaction
executes the specified operations
commits the result (or aborts on error)

Walau bagaimanapun, apabila ia melibatkan langkah "melakukan tindakan yang ditentukan" yang sangat penting, contoh itu tidak menunjukkan sebarang kod yang berkaitan. Iaitu, saya "masih memerlukan contoh dunia nyata" seperti yang ditanya dalam Transaksi MongoDB Dalam NodeJS.

PS. Sekiranya contoh berubah atau hilang, berikut ialah versi Golang:

// WithTransactionExample is an example of using the Session.WithTransaction function.
func WithTransactionExample(ctx context.Context) error {
    // For a replica set, include the replica set name and a seedlist of the members in the URI string; e.g.
    // uri := "mongodb://mongodb0.example.com:27017,mongodb1.example.com:27017/?replicaSet=myRepl"
    // For a sharded cluster, connect to the mongos instances; e.g.
    // uri := "mongodb://mongos0.example.com:27017,mongos1.example.com:27017/"
    uri := mtest.ClusterURI()
    clientOpts := options.Client().ApplyURI(uri)
    client, err := mongo.Connect(ctx, clientOpts)
    if err != nil {
        return err
    }
    defer func() { _ = client.Disconnect(ctx) }()
    // Prereq: Create collections.
    wcMajority := writeconcern.Majority()
    wcMajority.WTimeout = 1 * time.Second
    wcMajorityCollectionOpts := options.Collection().SetWriteConcern(wcMajority)
    fooColl := client.Database("mydb1").Collection("foo", wcMajorityCollectionOpts)
    barColl := client.Database("mydb1").Collection("bar", wcMajorityCollectionOpts)
    // Step 1: Define the callback that specifies the sequence of operations to perform inside the transaction.
    callback := func(sessCtx mongo.SessionContext) (interface{}, error) {
        // Important: You must pass sessCtx as the Context parameter to the operations for them to be executed in the
        // transaction.
        if _, err := fooColl.InsertOne(sessCtx, bson.D{{"abc", 1}}); err != nil {
            return nil, err
        }
        if _, err := barColl.InsertOne(sessCtx, bson.D{{"xyz", 999}}); err != nil {
            return nil, err
        }
        return nil, nil
    }
    // Step 2: Start a session and run the callback using WithTransaction.
    session, err := client.StartSession()
    if err != nil {
        return err
    }
    defer session.EndSession(ctx)
    result, err := session.WithTransaction(ctx, callback)
    if err != nil {
        return err
    }
    log.Printf("result: %v\n", result)
    return nil
}

Nampaknya saya dari contoh bahawa langkah "melakukan tindakan yang ditentukan" yang paling penting dilakukan dalam panggilan balik. adakah begitu? Jika ya, dokumentasi rasmi benar-benar perlu menekankan perkara ini.

Jawapan betul

Contoh selesai. Ia mengandungi komen penting berikut:

// Step 2: Start a session and run the callback using WithTransaction.

Jadicallback函数是由Session执行的.WithTransaction() kaedah. Anda akan memanggil kaedah callback 函数传递给它，它将被 Session.WithTransaction().

Pelaksanaan ini memastikan bahawa operasi yang diselesaikan dalam fungsi panggil balik akan dilaksanakan sebagai transaksi (iaitu, sama ada semua operasi digunakan atau tiada operasi digunakan). Jika fungsi panggil balik mengembalikan ralat bukan nil, transaksi akan dibatalkan, jika tidak transaksi akan dilakukan.

Atas ialah kandungan terperinci Urus niaga MongoDB, kaedah API panggil balik. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!