app
assets
public
vendor
alexgarrett
composer
danielstjules
doctrine
hassankhan
illuminate
container
contracts
database
Capsule
Connectors
ConnectionFactory.php
Connector.php
ConnectorInterface.php
MySqlConnector.php
PostgresConnector.php
SQLiteConnector.php
SqlServerConnector.php
Console
Eloquent
Migrations
Query
Schema
Connection.php
ConnectionInterface.php
ConnectionResolver.php
ConnectionResolverInterface.php
DatabaseManager.php
DatabaseServiceProvider.php
Grammar.php
MigrationServiceProvider.php
MySqlConnection.php
PostgresConnection.php
QueryException.php
README.md
SQLiteConnection.php
SeedServiceProvider.php
Seeder.php
SqlServerConnection.php
composer.json
support
nesbot
slim
symfony
twig
autoload.php
.gitignore
README.md
composer.json
composer.lock
composer.phar
mode.php
113 lines
3.1 KiB
PHP
Executable File
113 lines
3.1 KiB
PHP
Executable File
<?php namespace Illuminate\Database\Connectors;
|
|
|
|
class MySqlConnector extends Connector implements ConnectorInterface {
|
|
|
|
/**
|
|
* Establish a database connection.
|
|
*
|
|
* @param array $config
|
|
* @return \PDO
|
|
*/
|
|
public function connect(array $config)
|
|
{
|
|
$dsn = $this->getDsn($config);
|
|
|
|
$options = $this->getOptions($config);
|
|
|
|
// We need to grab the PDO options that should be used while making the brand
|
|
// new connection instance. The PDO options control various aspects of the
|
|
// connection's behavior, and some might be specified by the developers.
|
|
$connection = $this->createConnection($dsn, $config, $options);
|
|
|
|
if (isset($config['unix_socket']))
|
|
{
|
|
$connection->exec("use `{$config['database']}`;");
|
|
}
|
|
|
|
$collation = $config['collation'];
|
|
|
|
// Next we will set the "names" and "collation" on the clients connections so
|
|
// a correct character set will be used by this client. The collation also
|
|
// is set on the server but needs to be set here on this client objects.
|
|
$charset = $config['charset'];
|
|
|
|
$names = "set names '$charset'".
|
|
( ! is_null($collation) ? " collate '$collation'" : '');
|
|
|
|
$connection->prepare($names)->execute();
|
|
|
|
// Next, we will check to see if a timezone has been specified in this config
|
|
// and if it has we will issue a statement to modify the timezone with the
|
|
// database. Setting this DB timezone is an optional configuration item.
|
|
if (isset($config['timezone']))
|
|
{
|
|
$connection->prepare(
|
|
'set time_zone="'.$config['timezone'].'"'
|
|
)->execute();
|
|
}
|
|
|
|
// If the "strict" option has been configured for the connection we'll enable
|
|
// strict mode on all of these tables. This enforces some extra rules when
|
|
// using the MySQL database system and is a quicker way to enforce them.
|
|
if (isset($config['strict']) && $config['strict'])
|
|
{
|
|
$connection->prepare("set session sql_mode='STRICT_ALL_TABLES'")->execute();
|
|
}
|
|
|
|
return $connection;
|
|
}
|
|
|
|
/**
|
|
* Create a DSN string from a configuration.
|
|
*
|
|
* Chooses socket or host/port based on the 'unix_socket' config value.
|
|
*
|
|
* @param array $config
|
|
* @return string
|
|
*/
|
|
protected function getDsn(array $config)
|
|
{
|
|
return $this->configHasSocket($config) ? $this->getSocketDsn($config) : $this->getHostDsn($config);
|
|
}
|
|
|
|
/**
|
|
* Determine if the given configuration array has a UNIX socket value.
|
|
*
|
|
* @param array $config
|
|
* @return bool
|
|
*/
|
|
protected function configHasSocket(array $config)
|
|
{
|
|
return isset($config['unix_socket']) && ! empty($config['unix_socket']);
|
|
}
|
|
|
|
/**
|
|
* Get the DSN string for a socket configuration.
|
|
*
|
|
* @param array $config
|
|
* @return string
|
|
*/
|
|
protected function getSocketDsn(array $config)
|
|
{
|
|
extract($config);
|
|
|
|
return "mysql:unix_socket={$config['unix_socket']};dbname={$database}";
|
|
}
|
|
|
|
/**
|
|
* Get the DSN string for a host / port configuration.
|
|
*
|
|
* @param array $config
|
|
* @return string
|
|
*/
|
|
protected function getHostDsn(array $config)
|
|
{
|
|
extract($config);
|
|
|
|
return isset($config['port'])
|
|
? "mysql:host={$host};port={$port};dbname={$database}"
|
|
: "mysql:host={$host};dbname={$database}";
|
|
}
|
|
|
|
}
|