|
|
|
<?php
|
|
|
|
|
|
|
|
/**
|
|
|
|
* MINZ - Copyright 2011 Marien Fressinaud
|
|
|
|
* Sous licence AGPL3 <http://www.gnu.org/licenses/>
|
|
|
|
*/
|
|
|
|
|
|
|
|
/**
|
|
|
|
* The Model_sql class represents the model for interacting with databases.
|
|
|
|
*/
|
|
|
|
class Minz_ModelPdo {
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Shares the connection to the database between all instances.
|
|
|
|
*/
|
|
|
|
public static $usesSharedPdo = true;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @var Minz_Pdo|null
|
|
|
|
*/
|
|
|
|
private static $sharedPdo;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @var string|null
|
|
|
|
*/
|
|
|
|
private static $sharedCurrentUser;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @var Minz_Pdo|null
|
|
|
|
*/
|
|
|
|
protected $pdo;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @var string|null
|
|
|
|
*/
|
|
|
|
protected $current_user;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @return void
|
|
|
|
* @throws Minz_ConfigurationNamespaceException
|
|
|
|
* @throws Minz_PDOConnectionException
|
|
|
|
* @throws PDOException
|
|
|
|
*/
|
|
|
|
private function dbConnect() {
|
|
|
|
$db = Minz_Configuration::get('system')->db;
|
|
|
|
$driver_options = isset($db['pdo_options']) && is_array($db['pdo_options']) ? $db['pdo_options'] : [];
|
|
|
|
$driver_options[PDO::ATTR_ERRMODE] = PDO::ERRMODE_SILENT;
|
|
|
|
$dbServer = parse_url('db://' . $db['host']);
|
|
|
|
$dsn = '';
|
|
|
|
$dsnParams = empty($db['connection_uri_params']) ? '' : (';' . $db['connection_uri_params']);
|
|
|
|
|
|
|
|
switch ($db['type']) {
|
|
|
|
case 'mysql':
|
|
|
|
$dsn = 'mysql:host=' . (empty($dbServer['host']) ? $db['host'] : $dbServer['host']) . ';charset=utf8mb4';
|
|
|
|
if (!empty($db['base'])) {
|
|
|
|
$dsn .= ';dbname=' . $db['base'];
|
|
|
|
}
|
|
|
|
if (!empty($dbServer['port'])) {
|
|
|
|
$dsn .= ';port=' . $dbServer['port'];
|
|
|
|
}
|
|
|
|
$driver_options[PDO::MYSQL_ATTR_INIT_COMMAND] = 'SET NAMES utf8mb4';
|
|
|
|
$this->pdo = new Minz_PdoMysql($dsn . $dsnParams, $db['user'], $db['password'], $driver_options);
|
|
|
|
$this->pdo->setPrefix($db['prefix'] . $this->current_user . '_');
|
|
|
|
break;
|
|
|
|
case 'sqlite':
|
|
|
|
$dsn = 'sqlite:' . join_path(DATA_PATH, 'users', $this->current_user, 'db.sqlite');
|
|
|
|
$this->pdo = new Minz_PdoSqlite($dsn . $dsnParams, $db['user'], $db['password'], $driver_options);
|
|
|
|
$this->pdo->setPrefix('');
|
|
|
|
break;
|
|
|
|
case 'pgsql':
|
|
|
|
$dsn = 'pgsql:host=' . (empty($dbServer['host']) ? $db['host'] : $dbServer['host']);
|
|
|
|
if (!empty($db['base'])) {
|
|
|
|
$dsn .= ';dbname=' . $db['base'];
|
|
|
|
}
|
|
|
|
if (!empty($dbServer['port'])) {
|
|
|
|
$dsn .= ';port=' . $dbServer['port'];
|
|
|
|
}
|
|
|
|
$this->pdo = new Minz_PdoPgsql($dsn . $dsnParams, $db['user'], $db['password'], $driver_options);
|
|
|
|
$this->pdo->setPrefix($db['prefix'] . $this->current_user . '_');
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
throw new Minz_PDOConnectionException(
|
|
|
|
'Invalid database type!',
|
|
|
|
$db['user'], Minz_Exception::ERROR
|
|
|
|
);
|
|
|
|
}
|
|
|
|
self::$sharedPdo = $this->pdo;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Create the connection to the database using the variables
|
|
|
|
* HOST, BASE, USER and PASS variables defined in the configuration file
|
|
|
|
* @param string|null $currentUser
|
|
|
|
* @param Minz_Pdo|null $currentPdo
|
|
|
|
* @throws Minz_ConfigurationNamespaceException
|
|
|
|
* @throws Minz_PDOConnectionException
|
|
|
|
*/
|
|
|
|
public function __construct($currentUser = null, $currentPdo = null) {
|
|
|
|
if ($currentUser === null) {
|
|
|
|
$currentUser = Minz_Session::param('currentUser');
|
|
|
|
}
|
|
|
|
if ($currentPdo !== null) {
|
|
|
|
$this->pdo = $currentPdo;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
if ($currentUser == '') {
|
|
|
|
throw new Minz_PDOConnectionException('Current user must not be empty!', '', Minz_Exception::ERROR);
|
|
|
|
}
|
|
|
|
if (self::$usesSharedPdo && self::$sharedPdo !== null && $currentUser === self::$sharedCurrentUser) {
|
|
|
|
$this->pdo = self::$sharedPdo;
|
|
|
|
$this->current_user = self::$sharedCurrentUser;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
$this->current_user = $currentUser;
|
|
|
|
self::$sharedCurrentUser = $currentUser;
|
|
|
|
|
|
|
|
$ex = null;
|
|
|
|
//Attempt a few times to connect to database
|
|
|
|
for ($attempt = 1; $attempt <= 5; $attempt++) {
|
|
|
|
try {
|
|
|
|
$this->dbConnect();
|
|
|
|
return;
|
|
|
|
} catch (PDOException $e) {
|
|
|
|
$ex = $e;
|
|
|
|
if (empty($e->errorInfo[0]) || $e->errorInfo[0] !== '08006') {
|
|
|
|
//We are only interested in: SQLSTATE connection exception / connection failure
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
} catch (Exception $e) {
|
|
|
|
$ex = $e;
|
|
|
|
}
|
|
|
|
sleep(2);
|
|
|
|
}
|
|
|
|
|
|
|
|
$db = Minz_Configuration::get('system')->db;
|
|
|
|
|
|
|
|
throw new Minz_PDOConnectionException(
|
|
|
|
$ex->getMessage(),
|
|
|
|
$db['user'], Minz_Exception::ERROR
|
|
|
|
);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @return void
|
|
|
|
*/
|
|
|
|
public function beginTransaction() {
|
|
|
|
$this->pdo->beginTransaction();
|
|
|
|
}
|
|
|
|
|
|
|
|
public function inTransaction(): bool {
|
|
|
|
return $this->pdo->inTransaction();
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @return void
|
|
|
|
*/
|
|
|
|
public function commit() {
|
|
|
|
$this->pdo->commit();
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @return void
|
|
|
|
*/
|
|
|
|
public function rollBack() {
|
|
|
|
$this->pdo->rollBack();
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @return void
|
|
|
|
*/
|
|
|
|
public static function clean() {
|
|
|
|
self::$sharedPdo = null;
|
|
|
|
self::$sharedCurrentUser = '';
|
|
|
|
}
|
|
|
|
}
|