## 創建core/Database.php ``` <?php namespace core; use core\database\connection\MysqlConnection; class Database { protected $connections = []; // all connection // 獲取默認鏈接 protected function getDefaultConnection() { return \App::getContainer()->get('config')->get('database.default'); } // 設置默認鏈接 public function setDefaultConnection($name) { \App::getContainer()->get('config')->set('database.default', $name); } // 根據配置信息的name來創建鏈接 public function connection($name = null) { if (isset($this->connections[$name])) // 如果存在就直接返回 return $this->connections[$name]; if ($name == null) // 選擇默認鏈接 $name = $this->getDefaultConnection(); $config = \App::getContainer()->get('config')->get('database.connections.' . $name); // 獲取鏈接的配置 $connectionClass = null; // 鏈接處理的類 switch ($config['driver']) { case 'mysql': $connectionClass = MysqlConnection::class; break; // 如果有其他類型的數據庫 那就繼續完善 } $dsn = sprintf('%s:host=%s;dbname=%s', $config['driver'], $config['host'], $config['dbname']); try { $pdo = new \PDO($dsn, $config['username'], $config['password'], $config['options']); } catch (\PDOException $e) { die($e->getMessage()); } return $this->connections[$name] = new $connectionClass($pdo, $config); } // 代理模式 public function __call($method, $parameters) { return $this->connection()->$method(...$parameters); } } ``` ## 創建core/database/connection/Connection.php ``` <?php namespace core\database\connection; // 鏈接的基礎類 class Connection { protected $pdo; protected $tablePrefix; protected $config; public function __construct($pdo, $config) { $this->pdo = $pdo; $this->tablePrefix = $config['prefix']; $this->config = $config; } } ``` ## 創建core/database/connection/MysqlConnection.php ``` <?php namespace core\database\connection; // 繼承基礎類 class MysqlConnection extends Connection { protected static $connection; public function getConnection() { return self::$connection; } // 執行sql public function select($sql, $bindings = [], $useReadPdo = true) { $statement = $this->pdo; $sth = $statement->prepare($sql); try { $sth->execute( $bindings); return $sth->fetchAll(); } catch (\PDOException $exception){ echo ($exception->getMessage()); } } } ``` ## 綁定db  ## 運行   ### 關于數據庫配置 config/database.php ``` <?php return [ 'default' => 'mysql_one', 'connections' => [ 'mysql_one' => [ 'driver' => 'mysql', 'host' => '134.175.80.215', // 這是我的一個遠程服務器 沒用的 但是也別亂搞 'username' => 'php_frame', 'dbname' => 'php_frame', 'password' => '12345678', 'prefix' => '', 'options' => [ ] ], ] ]; ```