社群 學習 工具庫 休閒
搜尋
繁体中文
首頁 > 資料庫 > mysql教程 > 如何寫一個屬於自己的資料庫封裝(2)

如何寫一個屬於自己的資料庫封裝(2)

PHPz
發布： 2017-04-04 14:23:05
原創
1350 人瀏覽過


Connector.php

  • 負責與資料庫通信，增刪改讀（CRUD）

首先， 建立一個Connector類， 且設定屬性

<?php
class Connector {
    // 数据库地址前缀，常见的有mysql，slqlsrv，odbc等等等
    private $driver = &#39;mysql&#39;;
    // 数据库地址
    private $host = &#39;localhost&#39;;
    // 数据库默认名称, 设置为静态是因为有切换数据库的需求
    private static $db = &#39;sakila&#39;;
    // 数据库用户名
    private $username = &#39;root&#39;;
    // 数据库密码
    private $password = &#39;&#39;;
    // 当前数据库连接
    protected $connection;
    // 数据库连接箱，切换已存在的数据库连接不需要重新通信，从这里取即可
    protected static $container = [];

    // PDO默认属性配置，具体请自行查看文档
    protected $options = [
        PDO::ATTR_CASE => PDO::CASE_NATURAL,
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_ORACLE_NULLS => PDO::NULL_NATURAL,
        PDO::ATTR_STRINGIFY_FETCHES => false,
    ];
}
登入後複製

以上程式碼配合註解應該可以理解了所以不多解釋了，直接進入函數

  • buildConnectString - 就是產生DSN連接串，非常直白

      protected function buildConnectString() {
      return "$this->driver:host=$this->host;dbname=".self::$db;
  }
      // "mysql:host=localhost;dbname=sakila;"
    登入後複製

  • connect - 連接資料庫

      public function connect() {
      try {
          // 连接数据库，生成pdo实例， 将之赋予$connection，并存入$container之中
          self::$container[self::$db] = $this->connection = new PDO($this->buildConnectString(), $this->username, $this->password, $this->options);
          // 返回数据库连接
          return $this->connection;
      } catch (Exception $e) {
          // 若是失败, 返回原因
          // 还记得dd()吗?这个辅助函数还会一直用上
          dd($e->getMessage());
      }
  }
    登入後複製

  • setDatabase - 切換資料庫

      public function setDatabase($db) {
      self::$db = $db;
      return $this;
  }
    登入後複製

  • _construct - 產生實例後第一步要幹嘛

      function construct() {
      // 如果从未连接过该数据库, 那就新建连接
      if(empty(self::$container[self::$db])) $this->connect();
      // 反之, 从$container中提取, 无需再次通信
      $this->connection = self::$container[self::$db];
  }
    登入後複製

接下來兩個函數式配合著用的,單看可能會懵逼, 配合範例單步調試

$a = new Connector();

$bindValues = [
    'PENELOPE',
    'GUINESS'
];

dd($a->read('select * from actor where first_name = ? and last_name = ?', $bindValues));
登入後複製

傳回值

array (size=1)
  0 => 
    object(stdClass)[4]
      public 'actor_id' => string '1' (length=1)
      public 'first_name' => string 'PENELOPE' (length=8)
      public 'last_name' => string 'GUINESS' (length=7)
      public 'last_update' => string '2006-02-15 04:34:33' (length=19)
登入後複製

  • read - 讀取資料

      public function read($sql, $bindings) {
      // 将sql语句放入预处理函数
      // $sql = select * from actor where first_name = ? and last_name = ?
      $statement = $this->connection->prepare($sql);
      // 将附带参数带入pdo实例
      // $bindings = ['PENELOPE', 'GUINESS']
      $this->bindValues($statement, $bindings);
      // 执行
      $statement->execute();
      // 返回所有合法数据, 以Object对象为数据类型
      return $statement->fetchAll(PDO::FETCH_OBJ);
  }
    登入後複製

  • bindValues - 將附帶參數帶入pdo實例

          // 从例子中可以看出, 我用在预处理的变量为?, 这是因为pdo的局限性, 有兴趣可以在评论区讨论这个问题
  public function bindValues($statement, $bindings) {
      // $bindings = ['PENELOPE', 'GUINESS']
      // 依次循环每一个参数
      foreach ($bindings as $key => $value) {
          // $key = 0/1
          // $value = 'PENELOPE'/'GUINESS'
          $statement->bindValue(
              // 如果是字符串类型, 那就直接使用, 反之是数字, 将其+1
              // 这里是数值, 因此返回1/2
              is_string($key) ? $key : $key + 1,
              // 直接放入值
              // 'PENELOPE'/'GUINESS'
              $value,
              // 这里直白不多说
              // PDO::PARAM_STR/PDO::PARAM_STR
              is_int($value) ? PDO::PARAM_INT : PDO::PARAM_STR
          );
      }
  }
    登入後複製

    所以懂了嗎 _( :3”∠)

  • update - 改寫資料

      // 与read不同的地方在于, read返回数据, update返回boolean(true/false)
  public function update($sql, $bindings) {
      $statement = $this->connection->prepare($sql);
      $this->bindValues($statement, $bindings);
      return $statement->execute();
  }
    登入後複製

  • delete# - 刪除資料

    // 与update一样, 分开是因为方便日后维护制定
  public function delete($sql, $bindings) {
      $statement = $this->connection->prepare($sql);
      $this->bindValues($statement, $bindings);
      return $statement->execute();
  }
    登入後複製

  • create - 增加資料

    // 返回最新的自增ID, 如果有
  public function create($sql, $bindings) {
      $statement = $this->connection->prepare($sql);
      $this->bindValues($statement, $bindings);
      $statement->execute();
      return $this->lastInsertId();
  }
    登入後複製

  • lastInsertId - 傳回新增id, 如果有

      // pdo自带,只是稍微封装
  public function lastInsertId() {
      $id = $this->connection->lastInsertId();
      return empty($id) ? null : $id;
  }
    登入後複製

過於進階複雜的SQL語句可能無法封裝, 因此準備了可直接用RAW query通訊資料庫的兩個函數

  • exec - 適用於增刪改

      public function exec($sql) {
      return $this->connection->exec($sql);
  }
    登入後複製

  • query - 適用於讀取

      public function query($sql) {
      $q = $this->connection->query($sql);
      return $q->fetchAll(PDO::FETCH_OBJ);
  }
    登入後複製

將資料庫事務相關的函數封裝起來, 直白所以沒有註釋

        public function beginTransaction() {
        $this->connection->beginTransaction();
        return $this;
    }

    public function rollBack() {
        $this->connection->rollBack();
        return $this;
    }

    public function commit() {
        $this->connection->commit();
        return $this;
    }

    public function inTransaction() {
        return $this->connection->inTransaction();
    }
登入後複製

完整程式碼

<?php
class Connector {
    // 数据库地址前缀，常见的有mysql，slqlsrv，odbc等等等
    private $driver = &#39;mysql&#39;;
    // 数据库地址
    private $host = &#39;localhost&#39;;
    // 数据库默认名称, 设置为静态是因为有切换数据库的需求
    private static $db = &#39;sakila&#39;;
    // 数据库用户名
    private $username = &#39;root&#39;;
    // 数据库密码
    private $password = &#39;&#39;;
    // 当前数据库连接
    protected $connection;
    // 数据库连接箱，切换已存在的数据库连接不需要重新通信，从这里取即可
    protected static $container = [];

    // PDO默认属性配置，具体请自行查看文档
    protected $options = [
        PDO::ATTR_CASE => PDO::CASE_NATURAL,
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_ORACLE_NULLS => PDO::NULL_NATURAL,
        PDO::ATTR_STRINGIFY_FETCHES => false,
    ];

    function construct() {
        // 如果从未连接过该数据库, 那就新建连接
        if(empty(self::$container[self::$db])) $this->connect();
        // 反之, 从$container中提取, 无需再次通信
        $this->connection = self::$container[self::$db];
    }

    // 生成DSN连接串
    protected function buildConnectString() {
        return "$this->driver:host=$this->host;dbname=".self::$db;
    }

    // 连接数据库
    public function connect() {
        try {
            // 连接数据库，生成pdo实例， 将之赋予$connection，并存入$container之中
            self::$container[self::$db] = $this->connection = new PDO($this->buildConnectString(), $this->username, $this->password, $this->options);

            // 返回数据库连接
            return $this->connection;
        } catch (Exception $e) {
            // 若是失败, 返回原因
            dd($e->getMessage());
        }
    }

    // 切换数据库
    public function setDatabase($db) {
        self::$db = $db;
        return $this;
    }

    // 读取数据
    public function read($sql, $bindings) {
        // 将sql语句放入预处理函数
        $statement = $this->connection->prepare($sql);
        // 将附带参数带入pdo实例
        $this->bindValues($statement, $bindings);
        // 执行
        $statement->execute();
        // 返回所有合法数据, 以Object对象为数据类型
        return $statement->fetchAll(PDO::FETCH_OBJ);
    }

    // 将附带参数带入pdo实例
    public function bindValues($statement, $bindings) {
        // 依次循环每一个参数
        foreach ($bindings as $key => $value) {
            $statement->bindValue(
                // 如果是字符串类型, 那就直接使用, 反之是数字, 将其+1
                is_string($key) ? $key : $key + 1,
                // 直接放入值
                $value,
                // 这里直白不多说
                is_int($value) ? PDO::PARAM_INT : PDO::PARAM_STR
            );
        }
    }

    // 改写数据
    public function update($sql, $bindings) {
        // 与read不同的地方在于, read返回数据, update返回boolean(true/false)
        $statement = $this->connection->prepare($sql);
        $this->bindValues($statement, $bindings);
        return $statement->execute();
    }

    // 删除数据
    public function delete($sql, $bindings) {
        $statement = $this->connection->prepare($sql);
        $this->bindValues($statement, $bindings);
        return $statement->execute();
    }

    // 增加数据
    public function create($sql, $bindings) {
        $statement = $this->connection->prepare($sql);
        $this->bindValues($statement, $bindings);
        $statement->execute();
        return $this->lastInsertId();
    }

    // 返回新增id, 如果有
    public function lastInsertId() {
        $id = $this->connection->lastInsertId();
        return empty($id) ? null : $id;
    }

    // 适用于增删改
    public function exec($sql) {
        return $this->connection->exec($sql);
    }

    // 适用于读
    public function query($sql) {
        $q = $this->connection->query($sql);
        return $q->fetchAll(PDO::FETCH_OBJ);
    }

    public function beginTransaction() {
        $this->connection->beginTransaction();
        return $this;
    }

    public function rollBack() {
        $this->connection->rollBack();
        return $this;
    }

    public function commit() {
        $this->connection->commit();
        return $this;
    }

    public function inTransaction() {
        return $this->connection->inTransaction();
    }
}
登入後複製

本期疑問

1.) 因為php本身的特性, 預設運行完所有程式碼類別會自行析構,pdo自動斷聯, 所以我沒有disconnect(),讓pdo斷開連接, 不知這樣是不是一種bad practice?
2.) 增加和改寫數據的兩個函數並不支持多組數據一次性加入,只能單次增該, 原因是我之前寫了嫌太繁瑣所以刪了, 有心的童鞋可以提供方案


以上是如何寫一個屬於自己的資料庫封裝(2)的詳細內容。更多資訊請關注PHP中文網其他相關文章！

相關標籤：
資料庫封裝
來源：php.cn
上一篇：如何寫一個屬於自己的資料庫封裝(1) 下一篇：如何寫一個屬於自己的資料庫封裝(3)
本網站聲明
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
作者最新文章
最新問題
匹配單字的正規表示式 我有一個腳本，我試圖將新的職位名稱與資料庫中的現有職位名稱進行配對。 SELECTa.titleASJobTitle,j.DescriptionASMatchedJobTitle,...
來自於 2024-04-06 21:24:04
0
1
606
使用MySQL SQL查詢計算另一張表中欄位的總和 我有一個這樣的模式：具有屬性“user_id”和“username”的用戶表以及具有屬性“customer_id”（user_id的FK）和“finalPrice”的訂單表資料庫架...
來自於 2024-04-06 19:39:29
0
1
441
Laravel 8 - 如何將 /{editable_text} 路由重新導向到 /{user} 路由 我一直在嘗試建立重定向路由來引導我存取用戶個人資料。重定向路由應該是來自使用者資料庫的字串/文本，並且應該重定向到相同的使用者個人資料頁面。例如，假設我的user1有一個名為“ed...
來自於 2024-04-06 17:26:11
0
1
410
實體倉庫擴展了JpaRepository<Entity, Id>和JpaSpecificationExecutor<Entity>，EntitySpec擴展了Specification<Entity> 這是我的端點http://localhost:8080/country/all回复所有國家都可以當我想過濾它們時返回未找到國家為空並返回異常thrownewRecordNotFou...
來自於 2024-04-06 17:11:03
0
1
421
部分值條件下的記錄查詢 - SQL技巧分享 我有一個名為zipcode的表，其中有一個名為code的欄位。 Code列包含郵遞區號的前綴，例如395453302120312我想寫一個SQL查詢，檢查提供的zipcode是否與...
來自於 2024-04-06 16:01:26
0
1
395
相關專題
更多>
熱門推薦
熱門教學
更多>
相關教學
熱門推薦
最新課程
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板