123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109 |
- <?php
- namespace Predis\Pipeline;
- use \PHPUnit_Framework_TestCase as StandardTestCase;
- use SplQueue;
- use Predis\ResponseError;
- use Predis\Profile\ServerProfile;
- class StandardExecutorTest extends StandardTestCase
- {
-
- public function testExecutorWithSingleConnection()
- {
- $executor = new StandardExecutor();
- $pipeline = $this->getCommandsQueue();
- $connection = $this->getMock('Predis\Connection\SingleConnectionInterface');
- $connection->expects($this->exactly(3))
- ->method('writeCommand');
- $connection->expects($this->exactly(3))
- ->method('readResponse')
- ->will($this->returnValue('PONG'));
- $replies = $executor->execute($connection, $pipeline);
- $this->assertTrue($pipeline->isEmpty());
- $this->assertSame(array('PONG', 'PONG', 'PONG'), $replies);
- }
-
- public function testExecutorWithReplicationConnection()
- {
- $executor = new StandardExecutor();
- $pipeline = $this->getCommandsQueue();
- $connection = $this->getMock('Predis\Connection\ReplicationConnectionInterface');
- $connection->expects($this->once())
- ->method('switchTo')
- ->with('master');
- $connection->expects($this->exactly(3))
- ->method('writeCommand');
- $connection->expects($this->exactly(3))
- ->method('readResponse')
- ->will($this->returnValue('PONG'));
- $replies = $executor->execute($connection, $pipeline);
- $this->assertTrue($pipeline->isEmpty());
- $this->assertSame(array('PONG', 'PONG', 'PONG'), $replies);
- }
-
- public function testExecutorCanThrowExceptions()
- {
- $executor = new StandardExecutor(true);
- $pipeline = $this->getCommandsQueue();
- $error = new ResponseError('ERR Test error');
- $connection = $this->getMock('Predis\Connection\SingleConnectionInterface');
- $connection->expects($this->once())
- ->method('readResponse')
- ->will($this->returnValue($error));
- $executor->execute($connection, $pipeline);
- }
-
-
-
-
- protected function getCommandsQueue()
- {
- $profile = ServerProfile::getDevelopment();
- $pipeline = new SplQueue();
- $pipeline->enqueue($profile->createCommand('ping'));
- $pipeline->enqueue($profile->createCommand('ping'));
- $pipeline->enqueue($profile->createCommand('ping'));
- return $pipeline;
- }
- }
|