// Copyright (C) MongoDB, Inc. 2017-present. // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 package driverlegacy import ( "context" "go.mongodb.org/mongo-driver/mongo/options" "go.mongodb.org/mongo-driver/x/bsonx" "go.mongodb.org/mongo-driver/mongo/writeconcern" "go.mongodb.org/mongo-driver/x/mongo/driver/description" "go.mongodb.org/mongo-driver/x/mongo/driver/session" "go.mongodb.org/mongo-driver/x/mongo/driver/topology" "go.mongodb.org/mongo-driver/x/mongo/driver/uuid" "go.mongodb.org/mongo-driver/x/network/command" "go.mongodb.org/mongo-driver/x/network/result" ) // Delete handles the full cycle dispatch and execution of a delete command against the provided // topology. func Delete( ctx context.Context, cmd command.Delete, topo *topology.Topology, selector description.ServerSelector, clientID uuid.UUID, pool *session.Pool, retryWrite bool, opts ...*options.DeleteOptions, ) (result.Delete, error) { if cmd.Session != nil && cmd.Session.PinnedServer != nil { selector = cmd.Session.PinnedServer } ss, err := topo.SelectServerLegacy(ctx, selector) if err != nil { return result.Delete{}, err } // If no explicit session and deployment supports sessions, start implicit session. if cmd.Session == nil && topo.SupportsSessions() && writeconcern.AckWrite(cmd.WriteConcern) { cmd.Session, err = session.NewClientSession(pool, clientID, session.Implicit) if err != nil { return result.Delete{}, err } defer cmd.Session.EndSession() } deleteOpts := options.MergeDeleteOptions(opts...) if deleteOpts.Collation != nil { if ss.Description().WireVersion.Max < 5 { return result.Delete{}, ErrCollation } collDoc, err := bsonx.ReadDoc(deleteOpts.Collation.ToDocument()) if err != nil { return result.Delete{}, err } cmd.Opts = append(cmd.Opts, bsonx.Elem{"collation", bsonx.Document(collDoc)}) } // Execute in a single trip if retry writes not supported, or retry not enabled if !retrySupported(topo, ss.Description(), cmd.Session, cmd.WriteConcern) || !retryWrite { if cmd.Session != nil { cmd.Session.RetryWrite = false // explicitly set to false to prevent encoding transaction number } return delete(ctx, &cmd, ss, nil) } cmd.Session.RetryWrite = retryWrite cmd.Session.IncrementTxnNumber() res, originalErr := delete(ctx, &cmd, ss, nil) // Retry if appropriate if cerr, ok := originalErr.(command.Error); (ok && cerr.Retryable()) || (res.WriteConcernError != nil && command.IsWriteConcernErrorRetryable(res.WriteConcernError)) { ss, err := topo.SelectServerLegacy(ctx, selector) // Return original error if server selection fails or new server does not support retryable writes if err != nil || !retrySupported(topo, ss.Description(), cmd.Session, cmd.WriteConcern) { return res, originalErr } return delete(ctx, &cmd, ss, cerr) } return res, originalErr } func delete( ctx context.Context, cmd *command.Delete, ss *topology.SelectedServer, oldErr error, ) (result.Delete, error) { desc := ss.Description() conn, err := ss.ConnectionLegacy(ctx) if err != nil { if oldErr != nil { return result.Delete{}, oldErr } return result.Delete{}, err } if !writeconcern.AckWrite(cmd.WriteConcern) { go func() { defer func() { _ = recover() }() defer conn.Close() _, _ = cmd.RoundTrip(ctx, desc, conn) }() return result.Delete{}, command.ErrUnacknowledgedWrite } defer conn.Close() res, err := cmd.RoundTrip(ctx, desc, conn) ss.ProcessWriteConcernError(res.WriteConcernError) return res, err }