[PHP 7] SQL Repository implementation
SQL Repository library aims to reduce the time spent writing repositories.
Motivation for this library was the boredom of writing SQL or using query builders to do the same thing over and over again in multiple projects.
SQL Repository allows you to fetch, paginate and operate with data easily without adding overhead and following good practices.
SqlRepositoryHydrator
trait to enable it.Use Composer to install the package:
$ composer require nilportugues/sql-repository
Show me the code
See the /example directory. Examples for both Custom ID
and AutoIncremental ID
are provided.
Explanation
Mapping
interface providedIdentity
interface provided. Adds 2 methods, id()
and __toString
.SqlRepository
class provided. Inject your PDO connection and the Mapping class to the SqlRepository
You’re good to go.
–
Mapping must implement the Mapping
interface.
Mapping classes are used to read data from entities and save them in the storage of choice. This is done by mapping the Entities fields and specifying which fields and how are actually stored in the data storage.
For complex objects, let’s say an Entity that has a Value Object, it is possible to still do one single mapping on the Entity and access the Value Object properties to get them stored.
Mappings are also used to hydrate data into it’s entities again if the hydrator trait is used.
Remember, an Entity must implement the Identity
interface to work with SqlRepository. This Entity can be any class of yours.
use NilPortugues\Foundation\Domain\Model\Repository\Contracts\Identity;
class User implements Identity
{
protected $userId;
protected $username;
protected $alias;
protected $email;
protected $registeredOn;
/**
* User constructor.
*
* @param $userId
* @param $username
* @param $alias
* @param $email
* @param \DateTime $registeredOn
*/
public function __construct($userId, $username, $alias, $email, \DateTime $registeredOn)
{
$this->userId = $userId;
$this->username = $username;
$this->alias = $alias;
$this->email = $email;
$this->registeredOn = $registeredOn;
}
// ... your getters/setters
public function id()
{
return $this->userId;
}
public function __toString()
{
return (string) $this->id();
}
}
All methods from Mapping interface are mandatory.
use NilPortugues\Foundation\Domain\Model\Repository\Contracts\Mapping;
class UserMapping implements Mapping
{
/**
* Name of the identity field in storage.
*/
public function identity() : string
{
return 'user_id';
}
/**
* Returns the table name.
*/
public function name() : string
{
return 'users';
}
/**
* Keys are object properties without property defined in identity().
* Values its SQL column equivalents.
*/
public function map() : array
{
return [
// Flat objects or objects with one value don't
// require dot notation.
'userId' => 'user_id',
'username' => 'username',
'alias' => 'public_username',
'email' => 'email',
// Notice how we are accessing date value inside
// the \DateTime object! We use dot notation to
// access deep values.
// For instance, registeredOn.timezone will be
// ignored because we are not mapping
'registeredOn.date' => 'created_at',
];
}
/**
* @param array $data
* @return User
*/
public function fromArray(array $data)
{
return new User(
$data['user_id'],
$data['username'],
$data['public_username'],
$data['email'],
new \DateTime($data['created_at'])
);
}
/**
* The automatic generated strategy used will be the data-store's if set to true.
*/
public function autoGenerateId() : bool
{
return true;
}
}
Finally, it’s usage is straight-forward:
use NilPortugues\Foundation\Infrastructure\Model\Repository\Sql\SqlRepository;
use NilPortugues\Foundation\Infrastructure\Model\Repository\Sql\SqlRepositoryHydrator;
class UserRepository extends SqlRepository
{
use SqlRepositoryHydrator;
}
$pdo = new PDO('mysql:host=localhost;dbname=test', 'user', 'password');
$mapping = new UserMapping();
$repository = new UserRepository($pdo, $mapping);
The repository class implements all the methods required to interact and filter your data.
SqlRepository can handle all CRUD operations by default by extending the SqlRepository
class.
If you’re not into CRUD, you can also have read-only, write-only and pagination-only repositories:
SqlReadRepository
class.SqlWriteRepository
class.SqlPageRepository
class.All the methods listed under SqlWriteRepository, SqlReadRepository and SqlPageRepository.
public function add($value)
public function addAll(array $values)
public function remove(Identity $id)
public function removeAll(Filter $filter = null)
public function transactional(callable $transaction)
public function count(Filter $filter = null)
public function exists(Identity $id)
public function getDriver()
public function find(Identity $id, Fields $fields = null)
public function findBy(Filter $filter = null, Sort $sort = null, Fields $fields = null)
public function findByDistinct(Fields $distinctFields, Filter $filter = null, Sort $sort = null, Fields $fields = null)
public function count(Filter $filter = null)
public function exists(Identity $id)
public function getDriver()
public function findAll(Pageable $pageable = null)
public function count(Filter $filter = null)
public function exists(Identity $id)
public function getDriver()
All data can be extracted by fields name, using filters, applying ordering and pages, capable of applying fields, filters and ordering criteria.
Selecting by field will make hydratation fail. Currently partial object hydratation is not supported.
Class: NilPortugues\Foundation\Domain\Model\Repository\Fields
Methods:
public function __construct(array $fields = [])
public function add($field)
public function get()
Class: NilPortugues\Foundation\Domain\Model\Repository\Filter
Methods:
public function filters()
public function must()
public function mustNot()
public function should()
public function clear()
For must(), mustNot() and should(), the methods available are:
public function notStartsWith($filterName, $value)
public function notEndsWith($filterName, $value)
public function notEmpty($filterName)
public function empty($filterName)
public function startsWith($filterName, $value)
public function endsWith($filterName, $value)
public function equal($filterName, $value)
public function notEqual($filterName, $value)
public function includeGroup($filterName, array $value)
public function notIncludeGroup($filterName, array $value)
public function range($filterName, $firstValue, $secondValue)
public function notRange($filterName, $firstValue, $secondValue)
public function notContain($filterName, $value)
public function contain($filterName, $value)
public function beGreaterThanOrEqual($filterName, $value)
public function beGreaterThan($filterName, $value)
public function beLessThanOrEqual($filterName, $value)
public function beLessThan($filterName, $value)
public function clear()
public function get()
public function hasEmpty($filterName)
Pagination is handled by two objects, Pageable
that has the requirements to paginate, and Page
that it’s actually the page with the page data, such as page number, total number, and the data.
Class: NilPortugues\Foundation\Domain\Model\Repository\Pageable
Methods:
public function __construct($pageNumber, $pageSize, Sort $sort = null, Filter $filter = null, Fieldse $fields = null)
public function offset()
public function pageNumber()
public function sortings()
public function next()
public function pageSize()
public function previousOrFirst()
public function hasPrevious()
public function first()
public function filters()
public function fields()
Class: NilPortugues\Foundation\Domain\Model\Repository\Page
Methods:
public function __construct(array $elements, $totalElements, $pageNumber, $totalPages, Sort $sort = null, Filter $filter = null, Fields $fields = null)
public function content()
public function hasPrevious()
public function isFirst()
public function isLast()
public function hasNext()
public function pageSize()
public function pageNumber()
public function totalPages()
public function nextPageable()
public function sortings()
public function filters()
public function fields()
public function previousPageable()
public function totalElements()
public function map(callable $converter)
Class: NilPortugues\Foundation\Domain\Model\Repository\Sort
Methods:
public function __construct(array $properties = [], Order $order = null)
public function andSort(SortInterface $sort)
public function orders()
public function equals(SortInterface $sort)
public function orderFor($propertyName)
public function setOrderFor($propertyName, Order $order)
public function property($propertyName)
Sometimes you want to sort by multiple fields, this is where Order comes in play.
Class: NilPortugues\Foundation\Domain\Model\Repository\Order
Methods:
public function __construct($direction)
public function isDescending()
public function isAscending()
public function __toString()
public function equals($object)
public function direction()
–
To run the PHPUnit tests at the command line, go to the tests directory and issue phpunit.
This library attempts to comply with PSR-1, PSR-2, PSR-4.
If you notice compliance oversights, please send a patch via Pull Request.
Contributions to the package are always welcome!
Get in touch with me using one of the following means:
The code base is licensed under the MIT license.