1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279
|
===============
Database Access
===============
.. sectionauthor:: Bernhard Posselt <dev@bernhard-posselt.com>
The basic way to run a database query is to inject the **Db** service.
.. code-block:: php
<?php
namespace OCA\MyApp\AppInfo;
use \OCP\AppFramework\App;
use \OCA\MyApp\Db\AuthorDAO;
class Application extends App {
public function __construct(array $urlParams=array()){
parent::__construct('myapp', $urlParams);
$container = $this->getContainer();
/**
* Database Layer
*/
$container->registerService('AuthorDAO', function($c) {
return new AuthorDAO($c->query('ServerContainer')->getDb());
});
}
}
Inside your database layer class you can now start running queries like:
.. code-block:: php
<?php
// db/authordao.php
namespace OCA\MyApp\Db;
use \OCP\IDb;
class AuthorDAO {
private $db;
public function __construct(IDb $db) {
$this->db = $db;
}
public function find($id) {
$sql = 'SELECT * FROM `*PREFIX*myapp_authors` ' .
'WHERE `id` = ?';
$query = $db->prepareQuery($sql);
$query->bindParam(1, $id, \PDO::PARAM_INT);
$result = $query->execute();
while($row = $result->fetchRow()) {
return $row;
}
}
}
Mappers
=======
The aforementioned example is the most basic way write a simple database query but the more queries amass, the more code has to be written and the harder it will become to maintain it.
To generalize and simplify the problem, split code into resources and create an **Entity** and a **Mapper** class for it. The mapper class provides a way to run Sql queries and maps the result onto the related entities.
To create a mapper, inherit from the mapper baseclass and call the parent constructor with the following parameters:
* Database connection
* Table name
* **Optional**: Entity class name, defaults to \\OCA\\MyApp\\Db\\Author in the example below
.. code-block:: php
<?php
// db/authormapper.php
namespace OCA\MyApp\Db;
use \OCP\IDb;
use \OCP\AppFramework\Db\Mapper;
class AuthorMapper extends Mapper {
public function __construct(IDb $db) {
parent::__construct($db, 'myapp_authors');
}
/**
* @throws \OCP\AppFramework\Db\DoesNotExistException if not found
* @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException if more than one result
*/
public function find($id) {
$sql = 'SELECT * FROM `*PREFIX*myapp_authors` ' .
'WHERE `id` = ?';
return $this->findEntity($sql, array($id));
}
public function findAll($limit=null, $offset=null) {
$sql = 'SELECT * FROM `*PREFIX*myapp_authors`';
return $this->findEntities($sql, $limit, $offset);
}
public function authorNameCount($name) {
$sql = 'SELECT COUNT(*) AS `count` FROM `*PREFIX*myapp_authors` ' .
'WHERE `name` = ?';
$query = $this->db->prepareQuery($sql);
$query->bindParam(1, $name, \PDO::PARAM_STR);
$result = $query->execute();
while($row = $result->fetchRow()) {
return $row['count'];
}
}
}
Every mapper also implements default methods for deleting and updating an entity based on its id::
$authorMapper->delete($entity);
or::
$authorMapper->update($entity);
Mappers should be registered in the constructor to reuse them inside the application:
.. code-block:: php
<?php
namespace OCA\MyApp\AppInfo;
use \OCP\AppFramework\App;
use \OCA\MyApp\Db\AuthorMapper;
class Application extends App {
public function __construct(array $urlParams=array()){
parent::__construct('myapp', $urlParams);
$container = $this->getContainer();
/**
* Database Layer
*/
$container->registerService('AuthorMapper', function($c) {
return new AuthorMapper($c->query('ServerContainer')->getDb());
});
}
}
Entities
========
Entities are data objects that carry all the table's information for one row. Every Entity has an **id** field by default that is set to the integer type. Table rows are mapped from lower case and underscore separated names to pascal case attributes:
* **Table column name**: phone_number
* **Property name**: phoneNumber
.. code-block:: php
<?php
// db/author.php
namespace OCA\MyApp\Db;
use \OCP\AppFramework\Db\Entity;
class Author extends Entity {
protected $stars;
protected $name;
protected $phoneNumber;
public function __construct() {
// add types in constructor
$this->addType('stars', 'integer');
}
}
Types
-----
The following properties should be annotated by types, to not only assure that the types are converted correctly for storing them in the database (e.g. PHP casts false to the empty string which fails on postgres) but also for casting them when they are retrieving from the database.
The following types can be added for a field:
* integer
* float
* boolean
Accessing attributes
--------------------
Since all attributes should be protected, getters and setters are automatically generated for you:
.. code-block:: php
<?php
// db/author.php
namespace OCA\MyApp\Db;
use \OCP\AppFramework\Db\Entity;
class Author extends Entity {
protected $stars;
protected $name;
protected $phoneNumber;
}
$author = new Author();
$author->setId(3);
$author->getPhoneNumber() // null
Custom attribute to database column mapping
-------------------------------------------
By default each attribute will be mapped to a database column by a certain convention, e.g. **phoneNumber**
will be mapped to the column **phone_number** and vice versa. Sometimes it is needed though to map attributes to
different columns because of backwards compability. To define a custom
mapping, simply override the **columnToProperty** and **propertyToColumn** methods of the entity in question:
.. code-block:: php
<?php
// db/author.php
namespace OCA\MyApp\Db;
use \OCP\AppFramework\Db\Entity;
class Author extends Entity {
protected $stars;
protected $name;
protected $phoneNumber;
// map attribute phoneNumber to the database column phonenumber
public function columnToProperty($column) {
if ($column === 'phonenumber') {
return 'phoneNumber';
} else {
return parent::columnToProperty($column);
}
}
public function propertyToColumn($property) {
if ($column === 'phoneNumber') {
return 'phonenumber';
} else {
return parent::propertyToColumn($property);
}
}
}
Slugs
-----
Slugs are used to identify resources in the URL by a string rather than integer id. Since the URL allows only certain values, the entity baseclass provides a slugify method for it:
.. code-block:: php
<?php
$author = new Author();
$author->setName('Some*thing');
$author->slugify('name'); // Some-thing
|