diff options
| author | Daniel Gottlieb <daniel.gottlieb@mongodb.com> | 2018-12-20 10:32:11 -0500 |
|---|---|---|
| committer | Daniel Gottlieb <daniel.gottlieb@mongodb.com> | 2018-12-20 10:32:11 -0500 |
| commit | d0ff20fa00e17a30f2518d556147b178bbefab28 (patch) | |
| tree | 546d39ee4612b98a7a365031c4673d0ed764a763 /jstests/change_streams | |
| parent | bf58b1ab2abfb2a3ab7a86c154f9f5954ed6f98c (diff) | |
| download | mongo-d0ff20fa00e17a30f2518d556147b178bbefab28.tar.gz | |
Revert "SERVER-36902 Update jsTests for new shell transaction API"
This reverts commit bf58b1ab2abfb2a3ab7a86c154f9f5954ed6f98c.
Diffstat (limited to 'jstests/change_streams')
| -rw-r--r-- | jstests/change_streams/apply_ops.js | 12 | ||||
| -rw-r--r-- | jstests/change_streams/apply_ops_resumability.js | 10 |
2 files changed, 11 insertions, 11 deletions
diff --git a/jstests/change_streams/apply_ops.js b/jstests/change_streams/apply_ops.js index 5212f16e14b..ee116d3495d 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: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }, { documentKey: {_id: 2}, @@ -80,7 +80,7 @@ ns: {db: db.getName(), coll: coll.getName()}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }, { documentKey: {_id: 1}, @@ -88,14 +88,14 @@ operationType: "update", updateDescription: {removedFields: [], updatedFields: {a: 1}}, lsid: session.getSessionId(), - txnNumber: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }, { documentKey: {_id: kDeletedDocumentId}, ns: {db: db.getName(), coll: coll.getName()}, operationType: "delete", lsid: session.getSessionId(), - txnNumber: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }, { operationType: "drop", @@ -123,7 +123,7 @@ ns: {db: db.getName(), coll: otherCollName}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }); // 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: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }); // Verify that a whole-cluster stream returns the expected sequence of changes, including the diff --git a/jstests/change_streams/apply_ops_resumability.js b/jstests/change_streams/apply_ops_resumability.js index 619bd7152d6..a8d25d775d4 100644 --- a/jstests/change_streams/apply_ops_resumability.js +++ b/jstests/change_streams/apply_ops_resumability.js @@ -62,7 +62,7 @@ ns: {db: db.getName(), coll: coll.getName()}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }, { documentKey: {_id: 2}, @@ -70,7 +70,7 @@ ns: {db: db.getName(), coll: coll.getName()}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }, { documentKey: {_id: 1}, @@ -78,7 +78,7 @@ operationType: "update", updateDescription: {removedFields: [], updatedFields: {a: 1}}, lsid: session.getSessionId(), - txnNumber: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }, { documentKey: {_id: 3}, @@ -149,7 +149,7 @@ ns: {db: db.getName(), coll: otherCollName}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }); // Verify that a whole-db stream can be resumed from the middle of the transaction, and that it @@ -169,7 +169,7 @@ ns: {db: otherDbName, coll: otherDbCollName}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: session.getTxnNumber_forTesting(), + txnNumber: NumberLong(session._txnNumber), }); // Verify that a whole-cluster stream can be resumed from the middle of the transaction, and |