編集履歴

質問編集履歴

PHPコードを追記

2017/11/11 07:57

投稿

okame

スコア54

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -66,6 +66,368 @@
+###追記：PHPのソースコード
+まずは以下の登録した管理者の情報を編集する完了画面のコードです。
+26行目の``` $managerRepository->execute('UPDATE'); ``` で更新処理を実行します。
+```php
+<?php
+require_once $_SERVER['DOCUMENT_ROOT'] . '/vendor/autoload.php';
+use AppBundle\Entity\ManagerRepository;
+$loader = new Twig_Loader_Filesystem($_SERVER['DOCUMENT_ROOT'] . '/app/resources/views/');
+$twig   = new Twig_Environment($loader);
+// このページに直接アクセスしてきた場合はエラー画面遷移
+if (count($_POST) == 0) {
+    echo $twig->render('admin/error.html.twig', [
+        'error' => '操作に誤りがありました。初めからやり直してください。',
+    ]);
+    exit();
+}
+$managerRepository = new ManagerRepository();
+$managerRepository->setAllProperties('UPDATE');
+$managerRepository->execute('UPDATE');
+echo $twig->render('admin/staff/editComplete.html.twig', [
+    'username' => $managerRepository->getUsername(),
+]);
+?>
+```
+上記26行目のメソッドのコードは以下です。
+下の方のコード```$dbObject->run('UPDATE', $sql, $values); ``` に続きます。
+$sqlに格納しているクエリは直接DBツール上で実行しましたが、正常に実行できます。
+```php
+<?php
+namespace AppBundle\Entity;
+use AppBundle\Common\DatabaseAccessObject;
+class ManagerRepository extends Manager
+{
+    ...
+    public function execute($type)
+    {
+        $dbObject = new DatabaseAccessObject();
+        $sql = '';
+        $values = [];
+        switch ($type) {
+        ...
+            case 'UPDATE':
+                $sql = 'UPDATE manager SET
+                          user_name = ?,
+                          password = ?,
+                          password_updated_at = ?,
+                          last_name = ?,
+                          first_name = ?,
+                          remarks = ?,
+                          updated_at = ?,
+                          updated_manager_id = 0 WHERE id = ?';
+                $values = [
+                    $this->getUsername(),
+                    $this->getPassword(),
+                    $this->getPasswordUpdatedAt(),
+                    $this->getLastName(),
+                    $this->getFirstName(),
+                    $this->getRemarks(),
+                    $this->getUpdatedAt(),
+                    $this->getId(),
+                ];
+                $dbObject->run('UPDATE', $sql, $values);
+                break;
+                ...
+        }
+    }
+```
+上記```$dbObject->run('UPDATE', $sql, $values); ``` のコードは以下です。
+```php
+<?php
+namespace AppBundle\Common;
+use AppBundle\Common\Config;
+/**
+ * データベースへの接続情報をセット
+ */
+Config::set('dsn', 'mysql:host=localhost;dbname=***;charset=utf8');
+Config::set('user', '***');
+Config::set('password', 'ad***');
+/**
+ * Class DatabaseAccessObject データベースへの接続、リクエストを管理
+ */
+class DatabaseAccessObject
+{
+    /**
+     * @var \PDO $dbh データベースハンドラ
+     */
+    private $dbh;
+    /**
+     * データベースへ接続する
+     *
+     * @throws \PDOException
+     */
+    public function __construct()
+    {
+        // データベース情報
+        $dsn        = Config::get('dsn');
+        $user       = Config::get('user');
+        $password   = Config::get('password');
+        // DB接続とエラー発生時のエラーモード設定
+        $this->dbh = new \PDO($dsn, $user, $password);
+        $this->dbh->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
+    }
+    /**
+     * セットしたクエリを実行する
+     *
+     * @paramsh array $params
+     * @return array $stmt
+     * @throws \PDOException
+     */
+    public function run($type, $query, $params = [])
+    {
+        $this->dbh->beginTransaction();
+        try {
+            $stmt = $this->dbh->prepare($query);
+            if (count($params)) {
+                $stmt->execute($params);
+            } else {
+                $stmt->execute();
+            }
+        } catch (\Exception $e) {
+            // トランザクションが失敗した際のロールバック処理
+            $this->dbh->rollBack();
+            throw $e;
+        }
+        $this->dbh->commit();
+        if ($type == 'SELECT') {
+            return $stmt->fetchAll();
+        } elseif ($type == 'SELECT_BY_ONE') {
+            return $stmt->fetch();
+        }
+    }
+    /**
+     * 接続を閉じる
+     */
+    public function __destruct()
+    {
+        $this->dbh = null;
+    }
+}
+```
+最終的にPDOStatement::execute()メソッドでクエリを投げているわけですが、
+これの返り値は「true」となり、エラーは発生していません。
 ###以上です