fanbinit/rhymix
1
0
Fork 0
mirror of https://github.com/Lastorder-DC/rhymix.git synced 2026-05-04 17:44:38 +09:00
Code Issues Projects Releases Packages Wiki Activity

Add explicit connect() and disconnect() methods to DB class

Browse source
This commit is contained in:
Kijin Sung 2023-06-19 15:00:39 +09:00
parent 8b8ae5f64c
commit 66e1b93b78
1 changed files with 32 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

38
common/framework/DB.php
View file

@ -101,32 +101,58 @@ class DB
return; return;
} }
// Cache the debug comment setting.
$this->_debug_queries = in_array('queries', Config::get('debug.display_content') ?: []);
$this->_debug_comment = !!config('debug.query_comment');
$this->_debug_full_stack = !!Config::get('debug.query_full_stack');
// Connect to the DB. // Connect to the DB.
$this->connect($config);
}
/**
* Connect to the database.
*
* @param array $config
* @return void
*/
public function connect(array $config): void
{
// Assemble the DSN and default options.
$dsn = 'mysql:host=' . $config['host']; $dsn = 'mysql:host=' . $config['host'];
$dsn .= (isset($config['port']) && $config['port'] != 3306) ? (';port=' . $config['port']) : ''; $dsn .= (isset($config['port']) && $config['port'] != 3306) ? (';port=' . $config['port']) : '';
$dsn .= ';dbname=' . $config['database']; $dsn .= ';dbname=' . $config['database'];
$dsn .= ';charset=' . $this->_charset; $dsn .= ';charset=' . $this->_charset;
class_exists('\Rhymix\Framework\Helpers\DBStmtHelper');
$options = array( $options = array(
\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION, \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION,
\PDO::ATTR_EMULATE_PREPARES => false, \PDO::ATTR_EMULATE_PREPARES => false,
\PDO::ATTR_STATEMENT_CLASS => array('\Rhymix\Framework\Helpers\DBStmtHelper'), \PDO::ATTR_STATEMENT_CLASS => array('\Rhymix\Framework\Helpers\DBStmtHelper'),
\PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => false, \PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => false,
); );
// Preload the statement helper class.
class_exists('\Rhymix\Framework\Helpers\DBStmtHelper');
try try
{ {
$this->_handle = new Helpers\DBHelper($dsn, $config['user'], $config['pass'], $options); $this->_handle = new Helpers\DBHelper($dsn, $config['user'], $config['pass'], $options);
$this->_handle->setType($type); $this->_handle->setType($this->_type);
} }
catch (\PDOException $e) catch (\PDOException $e)
{ {
throw new Exceptions\DBError($e->getMessage()); throw new Exceptions\DBError($e->getMessage());
} }
}
// Cache the debug comment setting. /**
$this->_debug_queries = in_array('queries', Config::get('debug.display_content') ?: []); * Disconnect from the database.
$this->_debug_comment = !!config('debug.query_comment'); *
$this->_debug_full_stack = !!Config::get('debug.query_full_stack'); * @return void
*/
public function disconnect(): void
{
$this->_handle = null;
unset(self::$_instances[$this->_type]);
} }
/** /**