PHP Classes

File: vendor/mongodb/mongodb/tests/SpecTests/change-streams/change-streams.yml

Recommend this page to a friend!
  Classes of LAGGOUNE Walid   MongoDB Queue PHP Query Execute   vendor/mongodb/mongodb/tests/SpecTests/change-streams/change-streams.yml   Download  
File: vendor/mongodb/mongodb/tests/SpecTests/change-streams/change-streams.yml
Role: Auxiliary data
Content type: text/plain
Description: Auxiliary data
Class: MongoDB Queue PHP Query Execute
Query and execute multiple queries using MongoDB
Author: By
Last change:
Date: 4 years ago
Size: 13,586 bytes
 

Contents

Class file image Download
collection_name: &collection_name "test" database_name: &database_name "change-stream-tests" collection2_name: &collection2_name "test2" database2_name: &database2_name "change-stream-tests-2" tests: - description: "$changeStream must be the first stage in a change stream pipeline sent to the server" minServerVersion: "3.6.0" target: collection topology: - replicaset changeStreamPipeline: [] changeStreamOptions: {} operations: - database: *database_name collection: *collection_name name: insertOne arguments: document: x: 1 expectations: - command_started_event: command: aggregate: *collection_name cursor: {} pipeline: - $changeStream: fullDocument: default command_name: aggregate database_name: *database_name result: success: - _id: "42" documentKey: "42" operationType: insert ns: db: *database_name coll: *collection_name fullDocument: x: $numberInt: "1" - description: The server returns change stream responses in the specified server response format minServerVersion: "3.6.0" target: collection topology: - replicaset changeStreamPipeline: [] changeStreamOptions: {} operations: - database: *database_name collection: *collection_name name: insertOne arguments: document: x: 1 expectations: [] result: success: - _id: "42" documentKey: "42" operationType: insert ns: db: *database_name coll: *collection_name fullDocument: x: $numberInt: "1" - description: Executing a watch helper on a Collection results in notifications for changes to the specified collection minServerVersion: "3.6.0" target: collection topology: - replicaset changeStreamPipeline: [] changeStreamOptions: {} operations: - database: *database_name collection: *collection2_name name: insertOne arguments: document: x: 1 - database: *database2_name collection: *collection_name name: insertOne arguments: document: y: 2 - database: *database_name collection: *collection_name name: insertOne arguments: document: z: 3 expectations: - command_started_event: command: aggregate: *collection_name cursor: {} pipeline: - $changeStream: fullDocument: default command_name: aggregate database_name: *database_name result: success: - operationType: insert ns: db: *database_name coll: *collection_name fullDocument: z: $numberInt: "3" - description: Change Stream should allow valid aggregate pipeline stages minServerVersion: "3.6.0" target: collection topology: - replicaset changeStreamPipeline: - $match: "fullDocument.z": 3 changeStreamOptions: {} operations: - database: *database_name collection: *collection_name name: insertOne arguments: document: y: 2 - database: *database_name collection: *collection_name name: insertOne arguments: document: z: 3 expectations: - command_started_event: command: aggregate: *collection_name cursor: {} pipeline: - $changeStream: fullDocument: default - $match: "fullDocument.z": $numberInt: "3" command_name: aggregate database_name: *database_name result: success: - operationType: insert ns: db: *database_name coll: *collection_name fullDocument: z: $numberInt: "3" - description: Executing a watch helper on a Database results in notifications for changes to all collections in the specified database. minServerVersion: "3.8.0" target: database topology: - replicaset changeStreamPipeline: [] changeStreamOptions: {} operations: - database: *database_name collection: *collection2_name name: insertOne arguments: document: x: 1 - database: *database2_name collection: *collection_name name: insertOne arguments: document: y: 2 - database: *database_name collection: *collection_name name: insertOne arguments: document: z: 3 expectations: - command_started_event: command: aggregate: $numberInt: "1" cursor: {} pipeline: - $changeStream: fullDocument: default command_name: aggregate database_name: *database_name result: success: - operationType: insert ns: db: *database_name coll: *collection2_name fullDocument: x: $numberInt: "1" - operationType: insert ns: db: *database_name coll: *collection_name fullDocument: z: $numberInt: "3" - description: Executing a watch helper on a MongoClient results in notifications for changes to all collections in all databases in the cluster. minServerVersion: "3.8.0" target: client topology: - replicaset changeStreamPipeline: [] changeStreamOptions: {} operations: - database: *database_name collection: *collection2_name name: insertOne arguments: document: x: 1 - database: *database2_name collection: *collection_name name: insertOne arguments: document: y: 2 - database: *database_name collection: *collection_name name: insertOne arguments: document: z: 3 expectations: - command_started_event: command: aggregate: $numberInt: "1" cursor: {} pipeline: - $changeStream: fullDocument: default allChangesForCluster: true command_name: aggregate database_name: admin result: success: - operationType: insert ns: db: *database_name coll: *collection2_name fullDocument: x: $numberInt: "1" - operationType: insert ns: db: *database2_name coll: *collection_name fullDocument: y: $numberInt: "2" - operationType: insert ns: db: *database_name coll: *collection_name fullDocument: z: $numberInt: "3" - description: Test insert, update, replace, and delete event types minServerVersion: "3.6.0" target: collection topology: - replicaset changeStreamPipeline: [] changeStreamOptions: {} operations: - database: *database_name collection: *collection_name name: insertOne arguments: document: x: 1 - database: *database_name collection: *collection_name name: updateOne arguments: filter: x: 1 update: $set: x: 2 - database: *database_name collection: *collection_name name: replaceOne arguments: filter: x: 2 replacement: x: 3 - database: *database_name collection: *collection_name name: deleteOne arguments: filter: x: 3 expectations: - command_started_event: command: aggregate: *collection_name cursor: {} pipeline: - $changeStream: fullDocument: default command_name: aggregate database_name: *database_name result: success: - operationType: insert ns: db: *database_name coll: *collection_name fullDocument: x: $numberInt: "1" - operationType: update ns: db: *database_name coll: *collection_name updateDescription: updatedFields: x: $numberInt: "2" - operationType: replace ns: db: *database_name coll: *collection_name fullDocument: x: $numberInt: "3" - operationType: delete ns: db: *database_name coll: *collection_name - description: Test rename and invalidate event types minServerVersion: "4.0.1" target: collection topology: - replicaset changeStreamPipeline: [] changeStreamOptions: {} operations: - database: *database_name collection: *collection_name name: rename arguments: to: *collection2_name expectations: - command_started_event: command: aggregate: *collection_name cursor: {} pipeline: - $changeStream: fullDocument: default command_name: aggregate database_name: *database_name result: success: - operationType: rename ns: db: *database_name coll: *collection_name to: db: *database_name coll: *collection2_name - operationType: invalidate - description: Test drop and invalidate event types minServerVersion: "4.0.1" target: collection topology: - replicaset changeStreamPipeline: [] changeStreamOptions: {} operations: - database: *database_name collection: *collection_name name: drop expectations: - command_started_event: command: aggregate: *collection_name cursor: {} pipeline: - $changeStream: fullDocument: default command_name: aggregate database_name: *database_name result: success: - operationType: drop ns: db: *database_name coll: *collection_name - operationType: invalidate # Test that resume logic works correctly even after consecutive retryable failures of a getMore command, # with no intervening events. This is ensured by setting the batch size of the change stream to 1, - description: Test consecutive resume minServerVersion: "4.1.7" target: collection topology: - replicaset changeStreamPipeline: [] changeStreamOptions: { batchSize: 1} failPoint: configureFailPoint: failCommand mode: {times: 2} data: failCommands: ["getMore"] closeConnection: true operations: - database: *database_name collection: *collection_name name: insertOne arguments: document: x: 1 - database: *database_name collection: *collection_name name: insertOne arguments: document: x: 2 - database: *database_name collection: *collection_name name: insertOne arguments: document: x: 3 expectations: - command_started_event: command: aggregate: *collection_name cursor: {batchSize: 1} pipeline: - $changeStream: fullDocument: default command_name: aggregate database_name: *database_name result: success: - operationType: insert ns: db: *database_name coll: *collection_name fullDocument: x: $numberInt: "1" - operationType: insert ns: db: *database_name coll: *collection_name fullDocument: x: $numberInt: "2" - operationType: insert ns: db: *database_name coll: *collection_name fullDocument: x: $numberInt: "3"