mirror of
https://github.com/NNTmux/newznab-tmux.git
synced 2026-08-29 01:08:56 +00:00
Remove nntmux/data folder
This commit is contained in:
DariusIII
@@ -1,4 +1,5 @@
|
||||
2017-08-01 DariusIII
|
||||
* Chg: Remove nntmux/data folder
|
||||
* Chg: Update pnotify to latest version
|
||||
2017-07-31 DariusIII
|
||||
* Chg: Rename www folder into public, adjust constants.php acordingly
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@@ -1,197 +0,0 @@
|
||||
<?php
|
||||
/**
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program (see LICENSE.txt in the base directory. If
|
||||
* not, see:
|
||||
*
|
||||
* @link <http://www.gnu.org/licenses/>.
|
||||
* @author niel
|
||||
*/
|
||||
namespace nntmux\data;
|
||||
|
||||
/**
|
||||
* This is the base class for a data abstraction layer.
|
||||
*/
|
||||
abstract class Source
|
||||
{
|
||||
/**
|
||||
* Stores the status of this object's connection. Updated when `connect()` or `disconnect()` are
|
||||
* called, or if an error occurs that closes the object's connection.
|
||||
*
|
||||
* @var boolean
|
||||
*/
|
||||
protected $_isConnected = false;
|
||||
|
||||
/**
|
||||
* Constructor. Sets defaults and returns object.
|
||||
*
|
||||
* Options defined:
|
||||
* - 'autoConnect' `boolean` If true, a connection is made on initialization. Defaults to true.
|
||||
*
|
||||
* @param array $config
|
||||
*
|
||||
* @return Source object
|
||||
*/
|
||||
public function __construct(array $config = [])
|
||||
{
|
||||
$defaults = ['autoConnect' => true];
|
||||
$this->_config = $config + $defaults;
|
||||
$this->_init();
|
||||
}
|
||||
|
||||
/**
|
||||
* Ensures the connection is closed, before the object is destroyed.
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function __destruct()
|
||||
{
|
||||
if ($this->isConnected()) {
|
||||
$this->disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
protected function _init()
|
||||
{
|
||||
if ($this->_config['autoConnect']) {
|
||||
$this->connect();
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks the connection status of this data source. If the `'autoConnect'` option is set to
|
||||
* true and the source connection is not currently active, a connection attempt will be made
|
||||
* before returning the result of the connection status.
|
||||
*
|
||||
* @param array $options
|
||||
*
|
||||
* @return bool
|
||||
*/
|
||||
public function isConnected(array $options = [])
|
||||
{
|
||||
$defaults = ['autoConnect' => false];
|
||||
$options += $defaults;
|
||||
|
||||
if (!$this->_isConnected && $options['autoConnect']) {
|
||||
try {
|
||||
$this->connect();
|
||||
} catch (\NetworkException $e) {
|
||||
$this->_isConnected = false;
|
||||
}
|
||||
}
|
||||
return $this->_isConnected;
|
||||
}
|
||||
|
||||
/**
|
||||
* Quotes data-source-native identifiers, where applicable.
|
||||
*
|
||||
* @param string $name Identifier name.
|
||||
*
|
||||
* @return string Returns `$name`, quoted if applicable.
|
||||
*/
|
||||
public function name($name)
|
||||
{
|
||||
return $name;
|
||||
}
|
||||
|
||||
/**
|
||||
* Abstract. Must be defined by child classes.
|
||||
*/
|
||||
abstract public function connect();
|
||||
|
||||
/**
|
||||
* Abstract. Must be defined by child classes.
|
||||
*/
|
||||
abstract public function disconnect();
|
||||
|
||||
/**
|
||||
* Returns a list of objects (sources) that models can bind to, i.e. a list of tables in the
|
||||
* case of a database, or REST collections, in the case of a web service.
|
||||
*
|
||||
* @param string $class The fully-name-spaced class name of the object making the request.
|
||||
*
|
||||
* @return array Returns an array of objects to which models can connect.
|
||||
*/
|
||||
abstract public function sources($class = null);
|
||||
|
||||
/**
|
||||
* Gets the column schema for a given entity (such as a database table).
|
||||
*
|
||||
* @param mixed $entity Specifies the table name for which the schema should be returned, or
|
||||
* the class name of the model object requesting the schema, in which case the model
|
||||
* class will be queried for the correct table name.
|
||||
* @param array $schema
|
||||
* @param array $meta The meta-information for the model class, which this method may use in
|
||||
* introspecting the schema.
|
||||
*
|
||||
* @return array Returns a `Schema` object describing the given model's schema, where the
|
||||
* array keys are the available fields, and the values are arrays describing each
|
||||
* field, containing the following keys:
|
||||
* - `'type'`: The field type name
|
||||
*/
|
||||
abstract public function describe($entity, $schema = [], array $meta = []);
|
||||
|
||||
/**
|
||||
* Create a record. This is the abstract method that is implemented by specific data sources.
|
||||
* This method should take a query object and use it to create a record in the data source.
|
||||
*
|
||||
* @param mixed $query An object which defines the update operation(s) that should be performed
|
||||
* against the data store. This can be a `Query`, a `RecordSet`, a `Record`, or a
|
||||
* subclass of one of the three. Alternatively, `$query` can be an adapter-specific
|
||||
* query string.
|
||||
* @param array $options The options from Model include,
|
||||
* - `validate` _boolean_ default: true
|
||||
* - `events` _string_ default: create
|
||||
* - `whitelist` _array_ default: null
|
||||
* - `callbacks` _boolean_ default: true
|
||||
* - `locked` _boolean_ default: true
|
||||
*
|
||||
* @return boolean Returns true if the operation was a success, otherwise false.
|
||||
*/
|
||||
abstract public function create($query, array $options = []);
|
||||
|
||||
/**
|
||||
* Abstract. Must be defined by child classes.
|
||||
*
|
||||
* @param mixed $query
|
||||
* @param array $options
|
||||
*
|
||||
* @return boolean Returns true if the operation was a success, otherwise false.
|
||||
*/
|
||||
abstract public function delete($query, array $options = []);
|
||||
|
||||
/**
|
||||
* Abstract. Must be defined by child classes.
|
||||
*
|
||||
* @param mixed $query
|
||||
* @param array $options
|
||||
*
|
||||
* @return boolean Returns true if the operation was a success, otherwise false.
|
||||
*/
|
||||
abstract public function read($query, array $options = []);
|
||||
|
||||
/**
|
||||
* Updates a set of records in a concrete data store.
|
||||
*
|
||||
* @param mixed $query An object which defines the update operation(s) that should be performed
|
||||
* against the data store. This can be a `Query`, a `RecordSet`, a `Record`, or a
|
||||
* subclass of one of the three. Alternatively, `$query` can be an adapter-specific
|
||||
* query string.
|
||||
* @param array $options Options to execute, which are defined by the concrete implementation.
|
||||
*
|
||||
* @return boolean Returns true if the update operation was a success, otherwise false.
|
||||
*/
|
||||
abstract public function update($query, array $options = []);
|
||||
}
|
||||
|
||||
?>
|
||||
@@ -1,28 +0,0 @@
|
||||
<?php
|
||||
/**
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program (see LICENSE.txt in the base directory. If
|
||||
* not, see:
|
||||
*
|
||||
* @link <http://www.gnu.org/licenses/>.
|
||||
* @author niel
|
||||
* @copyright 2014 nZEDb
|
||||
*/
|
||||
namespace nntmux\data\model;
|
||||
|
||||
use nntmux\data\Model;
|
||||
|
||||
class Anidb extends Model
|
||||
{
|
||||
|
||||
}
|
||||
File diff suppressed because it is too large
Load Diff
@@ -1,222 +0,0 @@
|
||||
<?php
|
||||
/**
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program (see LICENSE.txt in the base directory. If
|
||||
* not, see:
|
||||
*
|
||||
* @link <http://www.gnu.org/licenses/>.
|
||||
* @author niel
|
||||
*/
|
||||
namespace nntmux\data\model\source;
|
||||
|
||||
use nntmux\Object;
|
||||
|
||||
abstract class Result extends Object implements \Iterator
|
||||
{
|
||||
/**
|
||||
* Autoconfig.
|
||||
*/
|
||||
protected $_autoConfig = ['resource'];
|
||||
|
||||
/**
|
||||
* Contains the current element of the result set.
|
||||
*/
|
||||
protected $_current = false;
|
||||
|
||||
/**
|
||||
* Contains the cached result set.
|
||||
*/
|
||||
protected $_cache = null;
|
||||
|
||||
/**
|
||||
* If the result resource has been initialized
|
||||
*/
|
||||
protected $_init = false;
|
||||
|
||||
/**
|
||||
* The current position of the iterator.
|
||||
*/
|
||||
protected $_iterator = 0;
|
||||
|
||||
/**
|
||||
* If the result resource has been initialized
|
||||
*/
|
||||
protected $_key = null;
|
||||
|
||||
/**
|
||||
* The bound resource.
|
||||
*/
|
||||
protected $_resource = null;
|
||||
|
||||
/**
|
||||
* Setted to `true` when the collection has begun iterating.
|
||||
*
|
||||
* @var integer
|
||||
*/
|
||||
protected $_started = false;
|
||||
|
||||
/**
|
||||
* Indicates whether the current position is valid or not.
|
||||
*
|
||||
* @var boolean
|
||||
* @see lithium\data\source\Result::valid()
|
||||
*/
|
||||
protected $_valid = false;
|
||||
|
||||
|
||||
/**
|
||||
* Close the resource.
|
||||
*/
|
||||
public function close()
|
||||
{
|
||||
unset($this->_resource);
|
||||
$this->_resource = null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Contains the current result.
|
||||
*
|
||||
* @return array|null The current result (or `null` if there is none).
|
||||
*/
|
||||
public function current()
|
||||
{
|
||||
if (!$this->_init) {
|
||||
$this->_fetch();
|
||||
}
|
||||
$this->_started = true;
|
||||
return $this->_current;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the current key position on the result.
|
||||
*
|
||||
* @return integer The current iterator position.
|
||||
*/
|
||||
public function key()
|
||||
{
|
||||
if (!$this->_init) {
|
||||
$this->_fetch();
|
||||
}
|
||||
$this->_started = true;
|
||||
return $this->_key;
|
||||
}
|
||||
|
||||
/**
|
||||
* Fetches the next element from the resource.
|
||||
*
|
||||
* @return array|false The next result (or `false` if there is none).
|
||||
*/
|
||||
public function next()
|
||||
{
|
||||
if ($this->_started === false) {
|
||||
return $this->current();
|
||||
}
|
||||
$this->_valid = $this->_fetch();
|
||||
if (!$this->_valid) {
|
||||
$this->_key = null;
|
||||
$this->_current = false;
|
||||
}
|
||||
return $this->current();
|
||||
}
|
||||
|
||||
/**
|
||||
* Fetches the previous element from the cache.
|
||||
*
|
||||
* @return mixed The previous result (or `false` if there is none).
|
||||
*/
|
||||
public function prev()
|
||||
{
|
||||
if (!$this->_cache) {
|
||||
return null;
|
||||
}
|
||||
if (isset($this->_cache[--$this->_iterator - 1])) {
|
||||
$this->_key = $this->_iterator - 1;
|
||||
return $this->_current = $this->_cache[$this->_iterator - 1];
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the used resource.
|
||||
*/
|
||||
public function resource()
|
||||
{
|
||||
return $this->_resource;
|
||||
}
|
||||
|
||||
/**
|
||||
* Rewinds the result set to the first position.
|
||||
*/
|
||||
public function rewind()
|
||||
{
|
||||
$this->_iterator = 0;
|
||||
$this->_started = false;
|
||||
$this->_key = null;
|
||||
$this->_current = false;
|
||||
$this->_init = false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks if current position is valid.
|
||||
*
|
||||
* @return boolean `true` if valid, `false` otherwise.
|
||||
*/
|
||||
public function valid()
|
||||
{
|
||||
if (!$this->_init) {
|
||||
$this->_valid = $this->_fetch();
|
||||
}
|
||||
return $this->_valid;
|
||||
}
|
||||
|
||||
/**
|
||||
* Fetches the current element from the resource.
|
||||
*
|
||||
* @return boolean Return `true` on success or `false` otherwise.
|
||||
*/
|
||||
protected function _fetch()
|
||||
{
|
||||
$this->_init = true;
|
||||
if ($this->_fetchFromCache() || $this->_fetchFromResource()) {
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
abstract protected function _fetchFromResource();
|
||||
|
||||
/**
|
||||
* Returns the result from the primed cache.
|
||||
*
|
||||
* @return boolean Return `true` on success or `false` if it has not been cached yet.
|
||||
*/
|
||||
protected function _fetchFromCache()
|
||||
{
|
||||
if ($this->_iterator < count($this->_cache)) {
|
||||
$this->_key = $this->_iterator;
|
||||
$this->_current = $this->_cache[$this->_iterator++];
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* The destructor.
|
||||
*/
|
||||
public function __destruct()
|
||||
{
|
||||
$this->close();
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
@@ -1,491 +0,0 @@
|
||||
<?php
|
||||
/**
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program (see LICENSE.txt in the base directory. If
|
||||
* not, see:
|
||||
*
|
||||
* @link <http://www.gnu.org/licenses/>.
|
||||
* @author niel
|
||||
*/
|
||||
namespace nntmux\data\model\source\database;
|
||||
|
||||
use \PDO;
|
||||
use \PDOException;
|
||||
|
||||
use nntmux\data\model\source\Database;
|
||||
|
||||
/**
|
||||
* Extends the `Database` class to implement the necessary SQL-formatting and resultset-fetching
|
||||
* features for working with MySQL databases.
|
||||
*
|
||||
* For more information on configuring the database connection, see the `__construct()` method.
|
||||
*
|
||||
* @see lithium\data\source\database\adapter\MySql::__construct()
|
||||
*/
|
||||
class MySql extends Database
|
||||
{
|
||||
|
||||
/**
|
||||
* MySQL column type definitions.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
protected $_columns = [
|
||||
'id' => ['use' => 'int', 'length' => 11, 'increment' => true],
|
||||
'string' => ['use' => 'varchar', 'length' => 255],
|
||||
'text' => ['use' => 'text'],
|
||||
'integer' => ['use' => 'int', 'length' => 11, 'formatter' => 'intval'],
|
||||
'float' => ['use' => 'float', 'formatter' => 'floatval'],
|
||||
'datetime' => ['use' => 'datetime', 'format' => 'Y-m-d H:i:s'],
|
||||
'timestamp' => ['use' => 'timestamp', 'format' => 'Y-m-d H:i:s'],
|
||||
'time' => ['use' => 'time', 'format' => 'H:i:s', 'formatter' => 'date'],
|
||||
'date' => ['use' => 'date', 'format' => 'Y-m-d', 'formatter' => 'date'],
|
||||
'binary' => ['use' => 'blob'],
|
||||
'boolean' => ['use' => 'tinyint', 'length' => 1]
|
||||
];
|
||||
/**
|
||||
* Meta atrribute syntax
|
||||
* By default `'escape'` is false and 'join' is `' '`
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
protected $_metas = [
|
||||
'column' => [
|
||||
'charset' => ['keyword' => 'CHARACTER SET'],
|
||||
'collate' => ['keyword' => 'COLLATE'],
|
||||
'comment' => ['keyword' => 'COMMENT', 'escape' => true]
|
||||
],
|
||||
'table' => [
|
||||
'charset' => ['keyword' => 'DEFAULT CHARSET'],
|
||||
'collate' => ['keyword' => 'COLLATE'],
|
||||
'engine' => ['keyword' => 'ENGINE'],
|
||||
'tablespace' => ['keyword' => 'TABLESPACE']
|
||||
]
|
||||
];
|
||||
/**
|
||||
* Column contraints
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
protected $_constraints = [
|
||||
'primary' => ['template' => 'PRIMARY KEY ({:column})'],
|
||||
'foreign_key' => [
|
||||
'template' => 'FOREIGN KEY ({:column}) REFERENCES {:to} ({:toColumn}) {:on}'
|
||||
],
|
||||
'index' => ['template' => 'INDEX ({:column})'],
|
||||
'unique' => [
|
||||
'template' => 'UNIQUE {:index} ({:column})',
|
||||
'key' => 'KEY',
|
||||
'index' => 'INDEX'
|
||||
],
|
||||
'check' => ['template' => 'CHECK ({:expr})']
|
||||
];
|
||||
/**
|
||||
* Pair of opening and closing quote characters used for quoting identifiers in queries.
|
||||
*
|
||||
* @var array
|
||||
*/
|
||||
protected $_quotes = ['`', '`'];
|
||||
|
||||
/**
|
||||
* MySQL-specific value denoting whether or not table aliases should be used in DELETE and
|
||||
* UPDATE queries.
|
||||
*
|
||||
* @var boolean
|
||||
*/
|
||||
protected $_useAlias = true;
|
||||
|
||||
/**
|
||||
* Constructs the MySQL adapter and sets the default port to 3306.
|
||||
*
|
||||
* @see lithium\data\source\Database::__construct()
|
||||
* @see lithium\data\Source::__construct()
|
||||
* @see lithium\data\Connections::add()
|
||||
*
|
||||
* @param array $config Configuration options for this class. For additional configuration,
|
||||
* see `lithium\data\source\Database` and `lithium\data\Source`. Available options
|
||||
* defined by this class:
|
||||
* - `'database'`: The name of the database to connect to. Defaults to 'lithium'.
|
||||
* - `'host'`: The IP or machine name where MySQL is running, followed by a colon,
|
||||
* followed by a port number or socket. Defaults to `'localhost:3306'`.
|
||||
* - `'persistent'`: If a persistent connection (if available) should be made.
|
||||
* Defaults to true.
|
||||
* Typically, these parameters are set in `Connections::add()`, when adding the
|
||||
* adapter to the list of active connections.
|
||||
*/
|
||||
public function __construct(array $config = [])
|
||||
{
|
||||
$defaults = ['host' => 'localhost:3306', 'encoding' => null];
|
||||
parent::__construct($config + $defaults);
|
||||
}
|
||||
|
||||
/**
|
||||
* Check for required PHP extension, or supported database feature.
|
||||
*
|
||||
* @param string $feature Test for support for a specific feature, i.e. `"transactions"` or
|
||||
* `"arrays"`.
|
||||
*
|
||||
* @return boolean|null Returns `true` if the particular feature (or if MySQL) support is enabled,
|
||||
* otherwise `false`.
|
||||
*/
|
||||
public static function enabled($feature = null)
|
||||
{
|
||||
if (!$feature) {
|
||||
return extension_loaded('pdo_mysql');
|
||||
}
|
||||
$features = [
|
||||
'arrays' => false,
|
||||
'transactions' => false,
|
||||
'booleans' => true,
|
||||
'schema' => true,
|
||||
'relationships' => true,
|
||||
'sources' => true
|
||||
];
|
||||
return isset($features[$feature]) ? $features[$feature] : null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Connects to the database using the options provided to the class constructor.
|
||||
*
|
||||
* @return boolean Returns `true` if a database connection could be established, otherwise
|
||||
* `false`.
|
||||
*/
|
||||
public function connect()
|
||||
{
|
||||
if (!$this->_config['dsn']) {
|
||||
$host = $this->_config['host'];
|
||||
list($host, $port) = explode(':', $host) + [1 => "3306"];
|
||||
$dsn = "mysql:host=%s;port=%s;dbname=%s";
|
||||
$this->_config['dsn'] = sprintf($dsn, $host, $port, $this->_config['database']);
|
||||
}
|
||||
|
||||
if (!parent::connect()) {
|
||||
return false;
|
||||
}
|
||||
|
||||
$info = $this->connection->getAttribute(PDO::ATTR_SERVER_VERSION);
|
||||
$this->_useAlias = (boolean)version_compare($info, "4.1", ">=");
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the list of tables in the currently-connected database.
|
||||
*
|
||||
* @param string $model The fully-name-spaced class name of the model object making the request.
|
||||
*
|
||||
* @return array Returns an array of sources to which models can connect.
|
||||
* @filter This method can be filtered.
|
||||
*/
|
||||
public function sources($model = null)
|
||||
{
|
||||
$_config = $this->_config;
|
||||
$params = compact('model');
|
||||
|
||||
return $this->_filter(__METHOD__,
|
||||
$params,
|
||||
function($self) use ($_config) {
|
||||
$name = $self->name($_config['database']);
|
||||
|
||||
if (!$result = $self->invokeMethod('_execute',
|
||||
["SHOW TABLES FROM {$name};"])
|
||||
) {
|
||||
return null;
|
||||
}
|
||||
$sources = [];
|
||||
|
||||
while ($data = $result->next()) {
|
||||
$sources[] = array_shift($data);
|
||||
}
|
||||
return $sources;
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets the column schema for a given MySQL table.
|
||||
*
|
||||
* @param mixed $entity Specifies the table name for which the schema should be returned, or
|
||||
* the class name of the model object requesting the schema, in which case the model
|
||||
* class will be queried for the correct table name.
|
||||
* @param array $fields Any schema data pre-defined by the model.
|
||||
* @param array $meta
|
||||
*
|
||||
* @return array Returns an associative array describing the given table's schema, where the
|
||||
* array keys are the available fields, and the values are arrays describing each
|
||||
* field, containing the following keys:
|
||||
* - `'type'`: The field type name
|
||||
* @filter This method can be filtered.
|
||||
*/
|
||||
public function describe($entity, $fields = [], array $meta = [])
|
||||
{
|
||||
$params = compact('entity', 'meta', 'fields');
|
||||
return $this->_filter(__METHOD__,
|
||||
$params,
|
||||
function($self, $params) {
|
||||
extract($params);
|
||||
|
||||
if ($fields) {
|
||||
return $self->invokeMethod('_instance', ['schema', compact('fields')]);
|
||||
}
|
||||
$name = $self->invokeMethod('_entityName',
|
||||
[$entity, ['quoted' => true]]);
|
||||
$columns = $self->read("DESCRIBE {$name}",
|
||||
[
|
||||
'return' => 'array', 'schema' => [
|
||||
'field', 'type', 'null', 'key', 'default', 'extra'
|
||||
]
|
||||
]);
|
||||
$fields = [];
|
||||
|
||||
foreach ($columns as $column) {
|
||||
$schema = $self->invokeMethod('_column', [$column['type']]);
|
||||
$default = $column['default'];
|
||||
|
||||
if ($default === 'CURRENT_TIMESTAMP') {
|
||||
$default = null;
|
||||
} elseif ($schema['type'] === 'boolean') {
|
||||
$default = !!$default;
|
||||
}
|
||||
$fields[$column['field']] = $schema + [
|
||||
'null' => ($column['null'] === 'YES' ? true : false),
|
||||
'default' => $default
|
||||
];
|
||||
}
|
||||
return $self->invokeMethod('_instance', ['schema', compact('fields')]);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets or sets the encoding for the connection.
|
||||
*
|
||||
* @param $encoding
|
||||
*
|
||||
* @return mixed If setting the encoding; returns true on success, else false.
|
||||
* When getting, returns the encoding.
|
||||
*/
|
||||
public function encoding($encoding = null)
|
||||
{
|
||||
$encodingMap = ['UTF-8' => 'utf8'];
|
||||
|
||||
if (empty($encoding)) {
|
||||
$query = $this->connection->query("SHOW VARIABLES LIKE 'character_set_client'");
|
||||
$encoding = $query->fetchColumn(1);
|
||||
return ($key = array_search($encoding, $encodingMap)) ? $key : $encoding;
|
||||
}
|
||||
$encoding = isset($encodingMap[$encoding]) ? $encodingMap[$encoding] : $encoding;
|
||||
|
||||
try {
|
||||
$this->connection->exec("SET NAMES '{$encoding}'");
|
||||
return true;
|
||||
} catch (PDOException $e) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Converts a given value into the proper type based on a given schema definition.
|
||||
*
|
||||
* @see lithium\data\source\Database::schema()
|
||||
*
|
||||
* @param mixed $value The value to be converted. Arrays will be recursively converted.
|
||||
* @param array $schema Formatted array from `lithium\data\source\Database::schema()`
|
||||
*
|
||||
* @return mixed Value with converted type.
|
||||
*/
|
||||
public function value($value, array $schema = [])
|
||||
{
|
||||
if (($result = parent::value($value, $schema)) !== null) {
|
||||
return $result;
|
||||
}
|
||||
return $this->connection->quote((string)$value);
|
||||
}
|
||||
|
||||
/**
|
||||
* Retrieves database error message and error code.
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function error()
|
||||
{
|
||||
if ($error = $this->connection->errorInfo()) {
|
||||
return [$error[1], $error[2]];
|
||||
}
|
||||
}
|
||||
|
||||
public function alias($alias, $context)
|
||||
{
|
||||
if ($context->type() === 'update' || $context->type() === 'delete') {
|
||||
return;
|
||||
}
|
||||
return parent::alias($alias, $context);
|
||||
}
|
||||
|
||||
/**
|
||||
* @todo Eventually, this will need to rewrite aliases for DELETE and UPDATE queries, same with
|
||||
* order().
|
||||
*
|
||||
* @param string $conditions
|
||||
* @param string $context
|
||||
* @param array $options
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function conditions($conditions, $context, array $options = [])
|
||||
{
|
||||
return parent::conditions($conditions, $context, $options);
|
||||
}
|
||||
|
||||
/**
|
||||
* Execute a given query.
|
||||
*
|
||||
* @see lithium\data\source\Database::renderCommand()
|
||||
*
|
||||
* @param string $sql The sql string to execute
|
||||
* @param array $options Available options:
|
||||
* - 'buffered': If set to `false` uses mysql_unbuffered_query which
|
||||
* sends the SQL query query to MySQL without automatically fetching and buffering the
|
||||
* result rows as `mysql_query()` does (for less memory usage).
|
||||
*
|
||||
* @return resource Returns the result resource handle if the query is successful.
|
||||
* @filter
|
||||
*/
|
||||
protected function _execute($sql, array $options = [])
|
||||
{
|
||||
$defaults = ['buffered' => true];
|
||||
$options += $defaults;
|
||||
$this->connection->exec("USE `{$this->_config['database']}`");
|
||||
|
||||
$conn = $this->connection;
|
||||
|
||||
$params = compact('sql', 'options');
|
||||
|
||||
return $this->_filter(__METHOD__,
|
||||
$params,
|
||||
function($self, $params) use ($conn) {
|
||||
$sql = $params['sql'];
|
||||
$options = $params['options'];
|
||||
$conn->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, $options['buffered']);
|
||||
|
||||
try {
|
||||
$resource = $conn->query($sql);
|
||||
} catch (PDOException $e) {
|
||||
$self->invokeMethod('_error', [$sql]);
|
||||
};
|
||||
return $self->invokeMethod('_instance', ['result', compact('resource')]);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets the last auto-generated ID from the query that inserted a new record.
|
||||
*
|
||||
* @param object $query The `Query` object associated with the query which generated
|
||||
*
|
||||
* @return mixed Returns the last inserted ID key for an auto-increment column or a column
|
||||
* bound to a sequence.
|
||||
*/
|
||||
protected function _insertId($query)
|
||||
{
|
||||
$resource = $this->_execute('SELECT LAST_INSERT_ID() AS insertID');
|
||||
list($id) = $resource->next();
|
||||
return ($id && $id !== '0') ? $id : null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Converts database-layer column types to basic types.
|
||||
*
|
||||
* @param string $real Real database-layer column type (i.e. `"varchar(255)"`)
|
||||
*
|
||||
* @return array Column type (i.e. "string") plus 'length' when appropriate.
|
||||
*/
|
||||
protected function _column($real)
|
||||
{
|
||||
if (is_array($real)) {
|
||||
return $real['type'] . (isset($real['length']) ? "({$real['length']})" : '');
|
||||
}
|
||||
|
||||
if (!preg_match('/(?P<type>\w+)(?:\((?P<length>[\d,]+)\))?/', $real, $column)) {
|
||||
return $real;
|
||||
}
|
||||
$column = array_intersect_key($column, ['type' => null, 'length' => null]);
|
||||
|
||||
if (isset($column['length']) && $column['length']) {
|
||||
$length = explode(',', $column['length']) + [null, null];
|
||||
$column['length'] = $length[0] ? intval($length[0]) : null;
|
||||
$length[1] ? $column['precision'] = intval($length[1]) : null;
|
||||
}
|
||||
|
||||
switch (true) {
|
||||
case in_array($column['type'], ['date', 'time', 'datetime', 'timestamp']):
|
||||
return $column;
|
||||
case ($column['type'] === 'tinyint' && $column['length'] == '1'):
|
||||
case ($column['type'] === 'boolean'):
|
||||
return ['type' => 'boolean'];
|
||||
break;
|
||||
case (strpos($column['type'], 'int') !== false):
|
||||
$column['type'] = 'integer';
|
||||
break;
|
||||
case (strpos($column['type'], 'char') !== false || $column['type'] === 'tinytext'):
|
||||
$column['type'] = 'string';
|
||||
break;
|
||||
case (strpos($column['type'], 'text') !== false):
|
||||
$column['type'] = 'text';
|
||||
break;
|
||||
case (strpos($column['type'], 'blob') !== false || $column['type'] === 'binary'):
|
||||
$column['type'] = 'binary';
|
||||
break;
|
||||
case preg_match('/float|double|decimal/', $column['type']):
|
||||
$column['type'] = 'float';
|
||||
break;
|
||||
default:
|
||||
$column['type'] = 'text';
|
||||
break;
|
||||
}
|
||||
return $column;
|
||||
}
|
||||
|
||||
/**
|
||||
* Helper for `DatabaseSchema::_column()`
|
||||
*
|
||||
* @param array $field A field array
|
||||
*
|
||||
* @return string The SQL column string
|
||||
*/
|
||||
protected function _buildColumn($field)
|
||||
{
|
||||
extract($field);
|
||||
if ($type === 'float' && $precision) {
|
||||
$use = 'decimal';
|
||||
}
|
||||
|
||||
$out = $this->name($name) . ' ' . $use;
|
||||
|
||||
$allowPrecision = preg_match('/^(decimal|float|double|real|numeric)$/', $use);
|
||||
$precision = ($precision && $allowPrecision) ? ",{$precision}" : '';
|
||||
|
||||
if ($length && ($allowPrecision || preg_match('/(char|binary|int|year)/', $use))) {
|
||||
$out .= "({$length}{$precision})";
|
||||
}
|
||||
|
||||
$out .= $this->_buildMetas('column', $field, ['charset', 'collate']);
|
||||
|
||||
if (isset($increment) && $increment) {
|
||||
$out .= ' NOT NULL AUTO_INCREMENT';
|
||||
} else {
|
||||
$out .= is_bool($null) ? ($null ? ' NULL' : ' NOT NULL') : '';
|
||||
$out .= $default ? ' DEFAULT ' . $this->value($default, $field) : '';
|
||||
}
|
||||
|
||||
return $out . $this->_buildMetas('column', $field, ['comment']);
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
@@ -1,71 +0,0 @@
|
||||
<?php
|
||||
/**
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program (see LICENSE.txt in the base directory. If
|
||||
* not, see:
|
||||
*
|
||||
* @link <http://www.gnu.org/licenses/>.
|
||||
* @author niel
|
||||
*/
|
||||
namespace nntmux\data\model\source\database\adapter\pdo;
|
||||
|
||||
use \PDO;
|
||||
use \PDOStatement;
|
||||
use \PDOException;
|
||||
|
||||
/**
|
||||
* This class is a wrapper around the MySQL result returned and can be used to iterate over it.
|
||||
*
|
||||
* It also provides a simple caching mechanism which stores the result after the first load.
|
||||
* You are then free to iterate over the result back and forth through the provided methods
|
||||
* and don't have to think about hitting the database too often.
|
||||
*
|
||||
* On initialization, it needs a `PDOStatement` to operate on. You are then free to use all
|
||||
* methods provided by the `Iterator` interface.
|
||||
*
|
||||
* @link http://php.net/manual/de/class.pdostatement.php The PDOStatement class.
|
||||
* @link http://php.net/manual/de/class.iterator.php The Iterator interface.
|
||||
*/
|
||||
class Result extends \nntmux\data\source\Result
|
||||
{
|
||||
public $named = false;
|
||||
|
||||
/**
|
||||
* Fetches the result from the resource and caches it.
|
||||
*
|
||||
* @return boolean Return `true` on success or `false` if it is not valid.
|
||||
*/
|
||||
protected function _fetchFromResource()
|
||||
{
|
||||
if ($this->_resource instanceof PDOStatement) {
|
||||
try {
|
||||
$mode = $this->named ? PDO::FETCH_NAMED : PDO::FETCH_NUM;
|
||||
if ($result = $this->_resource->fetch($mode)) {
|
||||
$this->_key = $this->_iterator;
|
||||
$this->_current = $this->_cache[$this->_iterator++] = $result;
|
||||
return true;
|
||||
}
|
||||
} catch (PDOException $e) {
|
||||
}
|
||||
}
|
||||
$this->_resource = null;
|
||||
return false;
|
||||
}
|
||||
|
||||
public function __destruct()
|
||||
{
|
||||
$this->close();
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
Reference in New Issue
Block a user