mirror of
https://github.com/doctrine/KeyValueStore.git
synced 2026-03-24 16:52:17 +01:00
Compare commits
5 Commits
missing-ra
...
force-cs
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6faf449755 | ||
|
|
5ecca2e0e2 | ||
|
|
22af505cac | ||
|
|
16c1bc3d3d | ||
|
|
5e6144a852 |
31
.travis.yml
31
.travis.yml
@@ -1,30 +1,35 @@
|
||||
language: php
|
||||
|
||||
services:
|
||||
- cassandra
|
||||
- couchdb
|
||||
- mongodb
|
||||
- redis-server
|
||||
|
||||
matrix:
|
||||
include:
|
||||
-
|
||||
dist: precise
|
||||
php: 5.5
|
||||
cache:
|
||||
directories:
|
||||
- $HOME/.composer/cache
|
||||
|
||||
php:
|
||||
- 5.5
|
||||
- 5.6
|
||||
- 7.0
|
||||
- 7.1
|
||||
- 7.2
|
||||
- 7.3
|
||||
- hhvm
|
||||
|
||||
before_install:
|
||||
- if [[ ${TRAVIS_PHP_VERSION:0:1} != "7" ]]; then sh ./tests/travis.sh; fi
|
||||
- if [[ $TRAVIS_PHP_VERSION != "hhvm" && $TRAVIS_PHP_VERSION != "7.0" ]]; then sh ./tests/travis.sh; fi
|
||||
- composer self-update
|
||||
|
||||
install:
|
||||
- composer --prefer-source install
|
||||
- composer require satooshi/php-coveralls:~0.6@stable --no-update
|
||||
- composer install --prefer-dist --no-interaction --no-progress
|
||||
|
||||
before_script:
|
||||
- vendor/bin/php-cs-fixer -v fix --diff --dry-run
|
||||
|
||||
script:
|
||||
- vendor/bin/phpunit --verbose
|
||||
- vendor/bin/phpunit --verbose --coverage-text --coverage-clover=coverage.clover
|
||||
|
||||
after_script:
|
||||
- if [[ $TRAVIS_PHP_VERSION != "5.6" && $TRAVIS_PULL_REQUEST == "false" ]]; then php vendor/bin/ocular code-coverage:upload --format=php-clover coverage.clover; fi
|
||||
|
||||
notifications:
|
||||
email: false
|
||||
|
||||
@@ -6,10 +6,11 @@
|
||||
},
|
||||
"require-dev": {
|
||||
"datastax/php-driver": "^1.0",
|
||||
"doctrine/couchdb": "^2.0@alpha",
|
||||
"doctrine/couchdb": "^1.0.0-beta4",
|
||||
"phpunit/phpunit": "^4.8|^5.0",
|
||||
"aws/aws-sdk-php": "^3.8",
|
||||
"riak/riak-client": "dev-master"
|
||||
"riak/riak-client": "dev-master",
|
||||
"friendsofphp/php-cs-fixer": "^1.11"
|
||||
},
|
||||
"suggest": {
|
||||
"aws/aws-sdk-php": "to use the DynamoDB storage",
|
||||
|
||||
@@ -202,7 +202,7 @@ class RangeQuery
|
||||
/**
|
||||
* Execute query and return a result iterator.
|
||||
*
|
||||
* @return array
|
||||
* @return ResultIterator
|
||||
*/
|
||||
public function execute()
|
||||
{
|
||||
|
||||
@@ -29,14 +29,14 @@ namespace Doctrine\KeyValueStore\Query;
|
||||
interface RangeQueryStorage
|
||||
{
|
||||
/**
|
||||
* Execute the range query and return an array
|
||||
* Execute the range query and return a ResultIterator
|
||||
*
|
||||
* @param RangeQuery $query
|
||||
* @param string $storageName
|
||||
* @param array $key
|
||||
* @param Closure $hydrateRow
|
||||
*
|
||||
* @return array
|
||||
* @return ResultIterator
|
||||
*/
|
||||
public function executeRangeQuery(RangeQuery $query, $storageName, $key, \Closure $hydrateRow = null);
|
||||
}
|
||||
|
||||
@@ -20,7 +20,6 @@
|
||||
|
||||
namespace Doctrine\KeyValueStore\Storage;
|
||||
|
||||
use Doctrine\DBAL\Connection;
|
||||
use Doctrine\KeyValueStore\NotFoundException;
|
||||
|
||||
/**
|
||||
@@ -79,7 +78,7 @@ class ArrayStorage implements Storage
|
||||
*/
|
||||
public function update($storageName, $key, array $data)
|
||||
{
|
||||
if (!isset($this->data[$storageName])) {
|
||||
if (! isset($this->data[$storageName])) {
|
||||
$this->data[$storageName] = [];
|
||||
}
|
||||
|
||||
@@ -93,11 +92,11 @@ class ArrayStorage implements Storage
|
||||
*/
|
||||
public function delete($storageName, $key)
|
||||
{
|
||||
if (!isset($this->data[$storageName])) {
|
||||
if (! isset($this->data[$storageName])) {
|
||||
return;
|
||||
}
|
||||
|
||||
if (!isset($this->data[$storageName][serialize($key)])) {
|
||||
if (! isset($this->data[$storageName][serialize($key)])) {
|
||||
return;
|
||||
}
|
||||
|
||||
@@ -113,11 +112,11 @@ class ArrayStorage implements Storage
|
||||
*/
|
||||
public function find($storageName, $key)
|
||||
{
|
||||
if (!isset($this->data[$storageName])) {
|
||||
if (! isset($this->data[$storageName])) {
|
||||
throw new NotFoundException();
|
||||
}
|
||||
|
||||
if (!isset($this->data[$storageName][serialize($key)])) {
|
||||
if (! isset($this->data[$storageName][serialize($key)])) {
|
||||
throw new NotFoundException();
|
||||
}
|
||||
|
||||
|
||||
@@ -23,8 +23,6 @@ namespace Doctrine\KeyValueStore\Storage;
|
||||
use Cassandra\ExecutionOptions;
|
||||
use Cassandra\Session;
|
||||
use Doctrine\KeyValueStore\NotFoundException;
|
||||
use Doctrine\KeyValueStore\Query\RangeQuery;
|
||||
use Doctrine\KeyValueStore\Query\RangeQueryStorage;
|
||||
|
||||
/**
|
||||
* Cassandra Storage Engine for KeyValueStore.
|
||||
@@ -33,7 +31,7 @@ use Doctrine\KeyValueStore\Query\RangeQueryStorage;
|
||||
*
|
||||
* @uses https://github.com/datastax/php-driver
|
||||
*/
|
||||
class CassandraStorage implements Storage, RangeQueryStorage
|
||||
class CassandraStorage implements Storage
|
||||
{
|
||||
/**
|
||||
* @var \Cassandra\Session
|
||||
@@ -178,13 +176,6 @@ class CassandraStorage implements Storage, RangeQueryStorage
|
||||
return $data;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
public function executeRangeQuery(RangeQuery $query, $storageName, $key, \Closure $hydrateRow = null)
|
||||
{
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
|
||||
@@ -21,9 +21,6 @@
|
||||
namespace Doctrine\KeyValueStore\Storage;
|
||||
|
||||
use Doctrine\CouchDB\CouchDBClient;
|
||||
use Doctrine\CouchDB\Mango\MangoQuery;
|
||||
use Doctrine\KeyValueStore\Query\RangeQuery;
|
||||
use Doctrine\KeyValueStore\Query\RangeQueryStorage;
|
||||
|
||||
/**
|
||||
* Key-Value-Storage using a Doctrine CouchDB Client library as backend.
|
||||
@@ -33,7 +30,7 @@ use Doctrine\KeyValueStore\Query\RangeQueryStorage;
|
||||
*
|
||||
* @author Emanuele Minotto <minottoemanuele@gmail.com>
|
||||
*/
|
||||
final class CouchDbStorage implements Storage, RangeQueryStorage
|
||||
final class CouchDbStorage implements Storage
|
||||
{
|
||||
/**
|
||||
* @var CouchDBClient
|
||||
@@ -119,7 +116,7 @@ final class CouchDbStorage implements Storage, RangeQueryStorage
|
||||
/**
|
||||
* @param string $storageName
|
||||
* @param array|string $key
|
||||
*
|
||||
*
|
||||
* @return string
|
||||
*/
|
||||
private function flattenKey($storageName, $key)
|
||||
@@ -140,72 +137,4 @@ final class CouchDbStorage implements Storage, RangeQueryStorage
|
||||
|
||||
return $finalKey;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
public function executeRangeQuery(RangeQuery $query, $storageName, $key, \Closure $hydrateRow = null)
|
||||
{
|
||||
$mangoQuery = new MangoQuery();
|
||||
$partitionKey = $query->getPartitionKey();
|
||||
|
||||
$conditions = [];
|
||||
foreach ($query->getConditions() as $condition) {
|
||||
switch ($condition[0]) {
|
||||
case RangeQuery::CONDITION_LE:
|
||||
$conditions[] = [
|
||||
$partitionKey => [
|
||||
'$lte' => $condition[1],
|
||||
],
|
||||
];
|
||||
break;
|
||||
|
||||
case RangeQuery::CONDITION_GE:
|
||||
$conditions[] = [
|
||||
$partitionKey => [
|
||||
'$gte' => $condition[1],
|
||||
],
|
||||
];
|
||||
break;
|
||||
|
||||
case RangeQuery::CONDITION_NEQ:
|
||||
$conditions[] = [
|
||||
$partitionKey => [
|
||||
'$ne' => $condition[1],
|
||||
],
|
||||
];
|
||||
break;
|
||||
|
||||
case RangeQuery::CONDITION_STARTSWITH:
|
||||
$conditions[] = [
|
||||
$partitionKey => [
|
||||
'$regex' => '^'.$condition[1],
|
||||
],
|
||||
];
|
||||
break;
|
||||
|
||||
default:
|
||||
$conditions[] = [
|
||||
$partitionKey => [
|
||||
'$'.$condition[0] => $condition[1],
|
||||
],
|
||||
];
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
$mangoQuery
|
||||
->select(['_id', $key])
|
||||
->where(['$and' => $conditions])
|
||||
->limit($query->getLimit());
|
||||
|
||||
$results = [];
|
||||
$mangoResults = $this->client->find($query);
|
||||
|
||||
foreach ($mangoResults as $mangoResult) {
|
||||
$results[] = $hydrateRow($mangoResult);
|
||||
}
|
||||
|
||||
return $results;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -183,7 +183,7 @@ class WindowsAzureTableStorage implements Storage, RangeQueryStorage
|
||||
$tableNode->appendChild($dom->createTextNode($tableName));
|
||||
$xml = $dom->saveXML();
|
||||
|
||||
$url = $this->baseUrl . '/Tables';
|
||||
$url = $this->baseUrl . '/Tables';
|
||||
$response = $this->request('POST', $url, $xml, $headers);
|
||||
|
||||
if ($response->getStatusCode() != 201) {
|
||||
|
||||
@@ -33,10 +33,7 @@ class MongoDbStorageTest extends \PHPUnit_Framework_TestCase
|
||||
{
|
||||
protected function setUp()
|
||||
{
|
||||
$this->mongo = $this
|
||||
->getMockBuilder('\Mongo')
|
||||
->disableOriginalConstructor()
|
||||
->getMock();
|
||||
$this->mongo = $this->getMock('\Mongo');
|
||||
|
||||
$this->mongodb = $this->getMockBuilder('\MongoDB')->disableOriginalConstructor()->getMock();
|
||||
|
||||
|
||||
@@ -39,10 +39,6 @@ class RiakStorageTest extends \PHPUnit_Framework_TestCase
|
||||
|
||||
protected function setup()
|
||||
{
|
||||
if (PHP_MAJOR_VERSION >= 7) {
|
||||
$this->markTestSkipped('Riak extension is not available for PHP versions >= 7');
|
||||
}
|
||||
|
||||
$this->riak = $this->getMockBuilder('Riak\\Client')
|
||||
->disableOriginalConstructor()
|
||||
->getMock();
|
||||
|
||||
@@ -20,9 +20,7 @@
|
||||
|
||||
namespace Doctrine\Tests\KeyValueStore\Storage;
|
||||
|
||||
use Doctrine\KeyValueStore\Http\Client;
|
||||
use Doctrine\KeyValueStore\Http\Response;
|
||||
use Doctrine\KeyValueStore\Storage\WindowsAzureTable\AuthorizationSchema;
|
||||
use Doctrine\KeyValueStore\Storage\WindowsAzureTableStorage;
|
||||
|
||||
class WindowsAzureTableStorageTest extends AbstractStorageTestCase
|
||||
@@ -31,14 +29,8 @@ class WindowsAzureTableStorageTest extends AbstractStorageTestCase
|
||||
|
||||
protected function createStorage()
|
||||
{
|
||||
$this->client = $this
|
||||
->getMockBuilder(Client::class)
|
||||
->disableOriginalConstructor()
|
||||
->getMock();
|
||||
$auth = $this
|
||||
->getMockBuilder(AuthorizationSchema::class)
|
||||
->disableOriginalConstructor()
|
||||
->getMock();
|
||||
$this->client = $this->getMock('Doctrine\KeyValueStore\Http\Client');
|
||||
$auth = $this->getMock('Doctrine\KeyValueStore\Storage\WindowsAzureTable\AuthorizationSchema');
|
||||
$auth->expects($this->any())->method('signRequest')->will($this->returnValue('Authorization: SharedKeyLite testaccount1:uay+rilMVayH/SVI8X+a3fL8k/NxCnIePdyZSkqvydM='));
|
||||
|
||||
$storage = new WindowsAzureTableStorage(
|
||||
|
||||
Reference in New Issue
Block a user