diff options
| author | A. Jesse Jiryu Davis <jesse@mongodb.com> | 2018-12-06 23:15:36 -0500 |
|---|---|---|
| committer | A. Jesse Jiryu Davis <jesse@mongodb.com> | 2018-12-20 08:36:44 -0600 |
| commit | bf58b1ab2abfb2a3ab7a86c154f9f5954ed6f98c (patch) | |
| tree | 558b52d1c2db71bb630ed38f9391db58cde986f4 /jstests/change_streams/apply_ops.js | |
| parent | 759846ffced5ef84734bd917a99061edf44dd786 (diff) | |
| download | mongo-bf58b1ab2abfb2a3ab7a86c154f9f5954ed6f98c.tar.gz | |
SERVER-36902 Update jsTests for new shell transaction API
Diffstat (limited to 'jstests/change_streams/apply_ops.js')
| -rw-r--r-- | jstests/change_streams/apply_ops.js | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/jstests/change_streams/apply_ops.js b/jstests/change_streams/apply_ops.js index ee116d3495d..5212f16e14b 100644 --- a/jstests/change_streams/apply_ops.js +++ b/jstests/change_streams/apply_ops.js @@ -72,7 +72,7 @@ ns: {db: db.getName(), coll: coll.getName()}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }, { documentKey: {_id: 2}, @@ -80,7 +80,7 @@ ns: {db: db.getName(), coll: coll.getName()}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }, { documentKey: {_id: 1}, @@ -88,14 +88,14 @@ operationType: "update", updateDescription: {removedFields: [], updatedFields: {a: 1}}, lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }, { documentKey: {_id: kDeletedDocumentId}, ns: {db: db.getName(), coll: coll.getName()}, operationType: "delete", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }, { operationType: "drop", @@ -123,7 +123,7 @@ ns: {db: db.getName(), coll: otherCollName}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }); // Verify that a whole-db stream returns the expected sequence of changes, including the insert @@ -141,7 +141,7 @@ ns: {db: otherDbName, coll: otherDbCollName}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }); // Verify that a whole-cluster stream returns the expected sequence of changes, including the |