Commit bbff3cb

authored

Disable mongoc_client reuse between connections (#3197)

1 parent c23cadd commit bbff3cbCopy full SHA for bbff3cb

File tree

+32

-0

lines changed

+32

-0

lines changed

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -217,6 +217,10 @@ protected function createConnection(string $dsn, array $config, array $options):`
`217`	`217`	`$options['password'] = $config['password'];`
`218`	`218`	`}`
`219`	`219`
	`220`	`+ if (isset($config['name'])) {`
	`221`	`+ $driverOptions += ['connectionName' => $config['name']];`
	`222`	`+ }`
	`223`	`+`
`220`	`224`	`return new Client($dsn, $options, $driverOptions);`
`221`	`225`	`}`
`222`	`226`

Lines changed: 28 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -277,6 +277,34 @@ public function testQueryLog()`
`277`	`277`	`}`
`278`	`278`	`}`
`279`	`279`
	`280`	`+ public function testQueryLogWithMultipleClients()`
	`281`	`+ {`
	`282`	`+ $connection = DB::connection('mongodb');`
	`283`	`+ $this->assertInstanceOf(Connection::class, $connection);`
	`284`	`+`
	`285`	`+ // Create a second connection with the same config as the first`
	`286`	`+ // Make sure to change the name as it's used as a connection identifier`
	`287`	`+ $config = $connection->getConfig();`
	`288`	`+ $config['name'] = 'mongodb2';`
	`289`	`+ $secondConnection = new Connection($config);`
	`290`	`+`
	`291`	`+ $connection->enableQueryLog();`
	`292`	`+ $secondConnection->enableQueryLog();`
	`293`	`+`
	`294`	`+ $this->assertCount(0, $connection->getQueryLog());`
	`295`	`+ $this->assertCount(0, $secondConnection->getQueryLog());`
	`296`	`+`
	`297`	`+ $connection->table('items')->get();`
	`298`	`+`
	`299`	`+ $this->assertCount(1, $connection->getQueryLog());`
	`300`	`+ $this->assertCount(0, $secondConnection->getQueryLog());`
	`301`	`+`
	`302`	`+ $secondConnection->table('items')->get();`
	`303`	`+`
	`304`	`+ $this->assertCount(1, $connection->getQueryLog());`
	`305`	`+ $this->assertCount(1, $secondConnection->getQueryLog());`
	`306`	`+ }`
	`307`	`+`
`280`	`308`	`public function testDisableQueryLog()`
`281`	`309`	`{`
`282`	`310`	`// Disabled by default`

Comments

(0)