PDOでのMysql接続関連

Question

前提・実現したいこと

以下のclass Sql 別々のファイルで2箇所でインスタンス化しfunction ProductDataSelect と WpIdCheck をそれぞれ使用しているのですが、WpIdCheckの方が途中で処理が止まってしまいます。
調べたところWpIdCheck の方は $dbh が null となっているため、正しくDBとアクセスできていないようです。
どのようにしたらそれぞれの WpIdCheck でもMysqlに接続させることができますでしょうか。

class Sql
{
    private function DBconnect() {
        // DB 接続処理
        try {
            $dsn = "mysql:dbname=".DBNAME.";host=".HOST.";";
            $dbh = new PDO($dsn, USERNAME, PASSWORD);
            $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);

        } catch (Exception $e) {
            echo "DB アクセス失敗";
            echo $e ;
        }
        return $dbh;
    }

    public function ProductDataSelect($shop_name) {
        $dbh    = $this->DBconnect();
        $sql    = "SELECT * FROM research_data WHERE shop = :shop";
        $stmt   = $dbh->prepare($sql);
        $params = [':shop' => $shop_name];

        $stmt->execute($params);
        $research_url = $stmt->fetchAll(PDO::FETCH_ASSOC);

        return $research_url;
     }

     public function WpIdCheck () {
        try {
            $dbh = $this->DBconnect();
            $sql = "SELECT * FROM research_data WHERE shop = :shop";
error_log(var_export('ここのエラーログは正しく表示されている', true));
　　　　　　　// ここで処理が止まっている、エラーろぐも発生していない.
            $stmt = $dbh->prepare($sql);
error_log(var_export('ここの文字列はエラーログに出力されない。。。', true));

            $param = [':shop' => 'xxxxxxxx'];
            $stmt->execute($param);
            $result = $stmt->fetchAll(PDO::FETCH_ASSOC);
        } catch (PDOException $e) {
            print $e->getMessage();
            print "WpIdCheck エラーテスト用";
            die();
        }
    }
}

他ファイルでの呼び出し例
A file

$sql_obj      = new Sql();
$test         = $sql_obj->WpIdCheck();

B file

$db_obj = new Sql();
$url_list = $db_obj->ProductDataSelect($shop_name);

発生している問題・エラーメッセージ

なし
エラーは発生しておらず catch の方にも処理は流れてきませんでした。

試したこと

function DBconnect を当初 __construct で処理していましたが、WpIdCheck でアクセスできなくてから共通ではダメなのかと考え各function で一番初めに以下処理を追加しました。
結局解決できませんでしたが。。。

$dbh    = $this->DBconnect();

非常に単純な内容の可能性もあり申し訳ありませんが、各所にエラーログを仕込んでも解決に至りませんでした。

補足情報（FW/ツールのバージョンなど）

ローカル MAMP環境
php7.1.23
MySQL 5.6.38

Comments

[m.ts10806]

PHPのバージョンは7.xとマイナーバージョンまで正しく記載してください。
ただ、そもそもSqlクラス　閉じ}が足りてないのでシンタックスエラーでそもそも動かないような。

[m.ts10806]

あと大量に全角空白があるのでこのコード、正しく動かないですよ。

[NOBUTUNA]

返答ありがとうございます。
全角は確認しましたが実ソースコード上では一つもありませんでした。
クラスの閉じ } 追加いたします。こちらも実コード上では付いておりました

[m.ts10806]

現在のコードが正しく提示されないことには本来必要のないやり取りが発生しますので、そこは工夫していただければと。
コードブロック内は原則、現在のコードのみで補足コメントは外だしされたほうが良いですね。

Answer 1

本件、解決に至りましたので内容を記載いたします。
Sqlクラスをインスタンス化し使用している　A file　なのですが、このファイルは他ファイルから以下のような形式で呼び出されておりました。

exec("php A_file.php");

上記のような呼ばれ方をしている処理を他file同様　require_once関数でA_fileを読み込み、クラスをインスタンス化して使用することで$dbhの中がnullではなく実行できるようになりました。

Comments

[m.ts10806]

それはまあ、exec()はコマンド実行するだけですからね・・
さすがに今回の質問内容だけでは分からないので、ファイルが複数あって読み込ませているのでしたらそこまで書くようにしてください。
何もないとincludeなりrequireで読み込ませている前提と考えますので。

Answer 2

本件、解決に至りましたので内容を記載いたします。
Sqlクラスをインスタンス化し使用している　A file　なのですが、このファイルは他ファイルから以下のような形式で呼び出されておりました。

exec("php A_file.php");

上記のような呼ばれ方をしている処理を他file同様　require_once関数でA_fileを読み込み、クラスをインスタンス化して使用することで$dbhの中がnullではなく実行できるようになりました。

Answer 3

直接の回答ではないですけど

function DBconnect を当初 __construct で処理していましたが、WpIdCheck でアクセスできなくてから共通ではダメなのかと考え

いえ、コンストラクタで接続した結果をプロパティに持てば良いです。

クラス

class Sql
{
    private $dbh = null;
    private $dbname = "ｘｘｘ";
    private $host = "ｘｘｘ";
    private $user = "ｘｘｘ";
    private $pass = "ｘｘｘ";

    function __construct(){
        // DB 接続処理
        try {
            $dsn = "mysql:dbname=".$this->dbname.";host=".$this->host.";";
            $this->dbh = new PDO($dsn, $this->user, $this->pass);
            $this->dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);

        } catch (PDOException $e) {
            echo "DB アクセス失敗";
            var_dump($e);
            die();
        }
    }

    public function getTest() {
        try {
            $sql = "SELECT * FROM test WHERE name like :name";
            $stmt = $this->dbh->prepare($sql);
            $param = [':name' => '%test%'];
            $stmt->execute($param);
            return $stmt->fetchAll(PDO::FETCH_ASSOC);
        } catch (PDOException $e) {
            echo "getTest失敗";
            var_dump($e);
            die();
        }
    }
}

利用する側

$dbsql = new Sql();
var_dump($dbsql->getTest());

newしたときに実行されるコンストラクタでnullだった$dbhに接続情報が入るので、生成されたインスタンスを使えば$dbhは有効です。