ショッピングサイトをつくっていて、クラスを別に分けたいのですが、分け方がわかりません。

Question

データベースに接続するコネクトの部分を別クラスに分けたいのですが、方法につまっています。
分けたクラスには別の名前をつけて、読み込みもしたいです。

分かる方おしえてください。

class PDODatabase{

    private  $dbh     = NULL;
    private  $db_host = "";
    private  $db_user = "";
    private  $db_pass = "";
    private  $db_name = "";
    private  $db_type = "";

    private  $order   = '';
    private  $limit   = '';
    private  $offset  = '';
    private  $groupby = '';

    public function __construct( $db_host, $db_user, $db_pass, $db_name, $db_type )
    {
        $this->dbh     = $this->connectDB( $db_host, $db_user, $db_pass, $db_name, $db_type );
        $this->db_host = $db_host;
        $this->db_user = $db_user;
        $this->db_pass = $db_pass;
        $this->db_name = $db_name;

        //SQL関連
        $this->order   = '';
        $this->limit   = '';
        $this->offset  = '';
        $this->groupby = '';
    }

private function connectDB( $db_host, $db_user, $db_pass, $db_name, $db_type)
{
	try{
		switch( $db_type)
		{
		case'mysql':
			$dsn = 'mysql:host='.$db_host.';dbname='.$db_name;
			$dbh = new PDO($dsn,$db_user,$db_pass);
			$dbh->query('SET NAMES utf8');
			break;

			case'pgsql';
			$dsn = 'pgsql:dbname='.$db_name.'host='.$db_host.'port=5432';
			$dbh = new PDO($dsn,$db_user,$db_pass);
			break;
		}
	}
	catch(PDOException $e)
	{
		var_dump($e->getMessage());
		exit;
	
	}
	return $dbh;
}

---

★★ここから上を別のクラスに分けたい★★

//thisの部分を新しい変数名に変える

    public function setQuery( $query='', $arrVal = array() )
    {
        $stmt = $this->dbh->prepare($query);   //変えた
        $stmt->execute($arrVal);

    }


    public function select( $table, $column ='',$where = '', $arrVal = array())
    {
        $sql = $this->getSql( 'select', $table, $where, $column);

        $stmt = $this->dbh->prepare($sql); //変えた
        $stmt->execute($arrVal);
        
        //データを連想配列に格納
        $data = array();
        while($result = $stmt->fetch(PDO::FETCH_ASSOC))
        {
            array_push($data , $result);
        }


        return $data;
    }

    public function count( $table, $where='', $arrVal=array())
    {
        $sql = $this->getSql('count',$table, $where );
        $stmt = $this->dbh->prepare($sql);    //変えた

        $stmt->execute($arrVal);
        
        $result = $stmt->fetch(PDO::FETCH_ASSOC);

        return intval($result['NUM']);
    }

    public function setOrder( $order ='' )
    {
        if( $strOrder !== '' ) $this->order = ' OREDER BY ' . $strOrder;
    }

    public function setLimitOff( $limit ='', $offset ='' )
    {
        if( $limit !== "" )  $this->limit = " LIMIT " . $limit ;

        if( $offset !== "" )  $this->offset = " OFFSET ". $offset ;

    }

    public function setGroupBy( $groupby )
    {
        if( $groupby !== "" ) $this->groupby = ' GROUP BY ' . $groupby;
    }


    private function getSql( $type,$table,$where='',$column='')
    {

        switch( $type )
        {
        case 'select':
            $columnKey =( $column !=='') ? $column : "*" ; 
            break;

        case 'count':
            $columnKey = 'COUNT(*) AS NUM ';
            break;

        default:
            break;
        }

        $whereSQL = ( $where !== '' )?' WHERE  ' . $where :'';

        $other = $this->groupby . "  " . $this->order ."  " . $this->limit . "  " . $this->offset;

        //sql文の作成
        $sql = " SELECT "
             .      $columnKey 
             . " FROM "
             .      $table
             .      $whereSQL
             .      $other;
        
        return $sql;
    } 


    public function insert($table, $insData=array() )
    {
       
        list( $preSt, $insDataVal, $columns) = $this->getPreparedStatement( 'insert', $insData, $table );
        
        $sql = " INSERT INTO " . $table . " (" 
             .      $columns 
             . ") VALUES (" 
             .      $preSt 
             . ") " ;
        
        $stmt = $this->dbh->prepare( $sql );  //変えた
        $res  = $stmt->execute($insDataVal);
        
        return $res;
    }

    public function update($table ,$insData = array() ,$where, $arrWhereVal=array())
    {
        list( $preSt, $insDataVal) = $this->getPreparedStatement( 'update', $insData, $table );
        
        //sql文の作成
        $sql = " UPDATE "
             .      $table
             . " SET "
             .      $preSt
             . " WHERE "
             .      $where ;
        
        $updateData = array_merge($insDataVal,$arrWhereVal);
        $stmt       = $Data->dbh->prepare( $sql );
        $res        = $stmt->execute($updateData);
        
        return $res ;
    }

    public function getPreparedStatement( $mode, $insData, $table )
    {
       
        if( !empty($insData) )
        {
            
            $insDataKey = array_keys($insData);
            $insDataVal = array_values($insData);
            $preCnt     = count( $insDataKey );
            
            switch( $mode )
            {
            case 'insert':

                $columns  = implode(",",$insDataKey);
                $arrPreSt = array_fill( 0, $preCnt,'?');
                $preSt    = implode(",",$arrPreSt);
                    
                return array($preSt, $insDataVal, $columns);

                break;

            case 'update':
                
                for( $i=0;$i < $preCnt; $i++ )
                {
                    $arrPreSt[$i] = $insDataKey[$i] ." =? ";
                }
                
                $preSt =implode(",",$arrPreSt);

                return array($preSt, $insDataVal);
             
                break;
            }

        }
        else
        {
            return false;
        }
    
    }

    public function getLastId()
    {
        return $this->dbh->lastInsertId(); 
    }

}

Comments

[Z-TALBO]

コードブロックで囲まれたほうが良いですよ。

Answer 1

用途に応じてDBを切り替える必要がある、という事でよろしいでしょうか。
個人的には接続情報等をパラメータとして渡すのは
コードの可読性やメンテナンス性を下げる要因と成りうるので利用しません。
子クラスから取得とか、クラス名にルールを設けて判断とかします。

親クラス
interface IDataObject
{
    public function execute();
}

親クラス
abstract class BaseDatabase implements IDataObject
{
    public function __construct()
    {
        $this->_db = NULL;
    }
    public function execute()
    {
        try
        {
            $this->connect();
            $this->executeImp();
        }
        catch (Exception $e)
        {
            throw $e;
        }
        finally
        {
            $this->disconnect();
        }
    }
    private $_db;
    protected function getResult()
    {
        return $this->_db->query的なメソッド($this->getSql());
    }
    protected function escape($value)
    {
        return $this->_db->escape的なメソッド($value);
    }
    private function connect()
    {
        $this->_db = new DB的なメソッド($this->getDsn());
    }
    private function disconnect()
    {
    }
    abstract protected function getDsn();
    abstract protected function executeImp();
    abstract protected function getSql();
}

このクラスをDB別に作り、子クラスは自分が利用するDBに応じて継承先を変える。
複数DBから持ってくる場合は違う設計にします！

クラス名にルールを設けて親クラスでget_called_class等でクラス名からDBを分ける方法もありかと。
私はよくこちらを利用します。

abstract class AppDatabaseMySql extends BaseDatabase
{
    public function __construct()
    {
        parent::__construct();
    }
    protected function getDsn()
    {
        $dsn = 'dsndesuyo';
        return $dsn;
    }
}

子クラス
MySQLを意識するのはイヤだなぁ
final class HogeHoge extends AppDatabaseMySql
{
    public function __construct(DBレコード格納用のリストクラス $hogeList)
    {
        parent::__construct();
        $this->_hogeList = $hogeList;
    }
    private $_hogeList;
    protected function executeImp()
    {
        while ($result = $this->getResult())
        {
            レコードセットから展開
            $hoge = new Hoge();
            $hoge->loadFromResultSet($result);
            $this->_hogeList->add($hoge);
        }
    }
    protected function getSql()
    {
        $sql = 'SELECT * FROM HOGE';
        return $sql;
    }
}

とすると、機能別に応じた子クラスだけ作ればDB接続を考えなくても良いかな～とか。

Answer 2

クラスを２つに分けた時の呼び出し側の記述方法をイメージしてみてください。
↓現状はこんな実装イメージかと思います。
$db = new PDODatabase( $db_host, $db_user, $db_pass, $db_name, $db_type ) ;
$db->setQuery("select * from table ") ;

これをどういう風な表現に変えたいのでしょう？

変えたくないのであれば、
「★★ここから上を別のクラスに分けたい★★」から上を親クラス
そこから下を子クラスとして分けたら良いと思います。
ちなみに、親クラスのメンバ変数で子クラスで使用したいものはprivateではなくprotectedに替える必要があります。

接続情報を明示的に記述したいのであれば、
$dbh = new ConnectDB( $db_host, $db_user, $db_pass, $db_name, $db_type ) ;
$db = new PDODatabase( $dbh ) ;
$db->setQuery("select * from table ") ;

みたいな書き方をできるように、クラスを分割修正したら良いと思います。

Answer 3

あくまで例なので、使いやすいように修正してください。

class PDOconnnect {
    private  $dbh = NULL; 

    public function __construct( $db_host, $db_user, $db_pass, $db_name, $db_type ) 
    { 
        $this->dbh = $this->connectDB( $db_host, $db_user, $db_pass, $db_name, $db_type ); 
    }

    public function getHandle()
    {
        return $this->dbh;
    }

    private function connectDB( $db_host, $db_user, $db_pass, $db_name, $db_type) 
    { 
        try{ 
            switch( $db_type) 
            { 
            case'mysql': 
                $dsn = 'mysql:host='.$db_host.';dbname='.$db_name; 
                $dbh = new PDO($dsn,$db_user,$db_pass); 
                $dbh->query('SET NAMES utf8'); 
                break;

                case'pgsql'; 
                $dsn = 'pgsql:dbname='.$db_name.'host='.$db_host.'port=5432'; 
                $dbh = new PDO($dsn,$db_user,$db_pass); 
                break; 
            } 
        } 
        catch(PDOException $e) 
        { 
            var_dump($e->getMessage()); 
            exit;

        } 
        return $dbh; 
    } 
}

class PDODatabase {
    private  $dbh     = NULL; 
    private  $order   = ''; 
    private  $limit   = ''; 
    private  $offset  = ''; 
    private  $groupby = '';

    public function __construct( $dbh)
    { 
        $this->dbh = $dbh;
    }

    public function setQuery( $query='', $arrVal = array() ) 
    { 
        $stmt = $this->dbh->prepare($query);
        $stmt->execute($arrVal);
    }
//以下略

//使い方
$obj1 = new PDOconnnect($db_host, $db_user, $db_pass, $db_name, $db_type);
$obj2 = new PDODatabase($obj1->getHandle());