エス技研

WordPress、CakePHP、PHP、baserCMSなどの Web系システムを中心に情報を提供します!


CakePHP4から外部のデータベースにアクセスする方法解説

      2024/08/10

CakePHP4から外部のデータベースにアクセスする方法解説

 
CakePHP4では標準(デフォルト)でデータベースにアクセスする方法が用意されていますが、標準で接続するデータベース以外の、他のシステムのデータベースに接続する方法について解説します。
 
CakePHP4から外部のデータベースにアクセスする方法解説
 
 
他のシステムのデータベースに接続する方法は下記の 2つあります。
 
・CakePHP4 の標準設定をコピペして使用する方法
・MySQL の接続コマンドを利用する方法
 
いずれも簡単な記述で接続できます。
また、接続を確立した後の SQL文の実行はどちらも同じ手続きになります。
 
それぞれ説明をしていきます。
 
 

CakePHP4 の標準設定をコピペして使用する方法

 

データベースへの接続情報を記述・app.php

 
/config/app.php の 285行目付近の「Datasources」にデータベースの接続が記述されています。
この接続情報の中の 340行目付近の「test」の配列をコピペし、下記の 14行目の配列のキーを「sample」のように変更します。
 
複数の単語からなる文字列にする場合は、ローワーキャメルケース(「sampleTestTest」のような 1文字目は小文字のキャメルケース)を使用するようです。
 
また、接続するデータベースの設定に合わせて、「timezone」や「encoding」を変更します。
 

'test' => [
  'className' => Connection::class,
  'driver' => Mysql::class,
  'persistent' => false,
  'timezone' => 'UTC',
  //'encoding' => 'utf8mb4',
  'flags' => [],
  'cacheMetadata' => true,
  'quoteIdentifiers' => false,
  'log' => false,
  //'init' => ['SET GLOBAL innodb_stats_on_metadata = 0'],
],

'sample' => [
  'className' => Connection::class,
  'driver' => Mysql::class,
  'persistent' => false,
  'timezone' => 'UTC',
  //'encoding' => 'utf8mb4',
  'flags' => [],
  'cacheMetadata' => true,
  'quoteIdentifiers' => false,
  'log' => false,
  //'init' => ['SET GLOBAL innodb_stats_on_metadata = 0'],
],

 
 

データベースへの接続情報を記述・app_local.php

 
続けて、/config/app_local.php の 40行目付近から始まる「Datasources」の中にある「test」をコピペして、下記の 11行目の配列のキーを「sample」のように変更します。
 
加えて、接続するデータベースの接続情報を記載します。
(DBの接続情報を「app_local.php」を使わず、「app.php」に直接記述している場合や、「.env」を利用している場合はそれぞれ読み替えて設定をしてください。)
 

'test' => [
  'host' => 'localhost',
  //'port' => 'non_standard_port_number',
  'username' => 'my_app',
  'password' => 'secret',
  'database' => 'test_myapp',
  //'schema' => 'myapp',
  'url' => env('DATABASE_TEST_URL', 'sqlite://127.0.0.1/tmp/tests.sqlite'),
],

'sample' => [
  'host' => 'localhost',
  'port' => '33060',
  'username' => 'sample_user',
  'password' => '123456',
  'database' => 'sample_db',
  //'schema' => 'myapp',
  'url' => env('DATABASE_SAMPLE_URL', null),
],

 
 

データベースへの接続と SQLの実行

 
データベースの接続を実行する記述方法はシンプルで、下記の記述で接続ができます。
 
ConnectionManager::get()」のパラメータに、前項で指定した「sample」を記述することで接続ができます。
 

// データベースへの接続
$sampleConnection = ConnectionManager::get('sample');

// SQL の SELECT文の実行
$sampleResults = $sampleConnection
  ->execute('SELECT * FROM sample_table')
  ->fetchAll('assoc');

 
上記の内容は、SQLを実行するコントローラー内に記述します。
 
 

MySQL の接続コマンドを利用する方法

 

データベースへの接続情報を記述

 
データベースの接続情報を設定します。
 

define("SAMPLE", [
  "host"      => "localhost",
  "port"      => "33060",
  "users"     => "sample_user",
  "password"  => "123456",
  "database"  => "sample_db",
]);

 
上記の定数は、コントローラ内に記述してもいいですし、下記の記事にあるように、定数ファイルを作成し、そこに記述する方法もあるかと思います。
CakePHP4で定数の設定と呼び出し方法の解説(defineとConfigure)
CakePHP4の定数定義ファイルを環境変数によって本番と開発を振り分ける方法解説
 
 
また、今回はサンプルとして、データベース接続情報を定数として設定していますが、下記の「データベースの接続」のところに直書きしても問題ありません。
 
 

データベースへの接続と SQLの実行

 
続けて、データベースに接続し、SQLを実行する処理が下記となります。
 

// データベースへの接続
$dsn = 'mysql://' . SAMPLE["users"] . ':' . SAMPLE["password"] . '@' . SAMPLE["host"] . ":" . SAMPLE["port"] . '/' . SAMPLE["database"];
ConnectionManager::setConfig('sample', ['url' => $dsn]);
$sampleConnection = ConnectionManager::get('sample');

// SQL の SELECT文の実行
$sampleResults = $sampleConnection
  ->execute('SELECT * FROM sample_table')
  ->fetchAll('assoc');

 
上記の内容は、SQLを実行するコントローラー内に記述します。
「SQL の SELECT文の実行」の部分の記述は、先に説明した「CakePHP4 の標準設定をコピペして使用する方法」の処理と同一です。
 
 

CakePHP4から外部のデータベースにアクセスする方法の違い

 
この記事では、CakePHP4から外部のデータベースにアクセスする方法が 2つあることを解説しました。
 
・CakePHP4 の標準設定をコピペして使用する方法
・MySQL の接続コマンドを利用する方法
 
上記の 2つのどちらがいいか、は好みの問題だと思います。
 
CakePHP4 Cookbook データベースの基本
https://book.cakephp.org/4/ja/orm/database-basics.html
 
ただ、上記のオフィシャルサイトには「データベース接続を作る一番簡単な方法」として「MySQL の接続コマンドを利用する方法」の方が紹介されています。
 
接続方法としてはどちらもかなり簡単なので、どちらでもいいかと思いますが、開発環境と本番環境でデータベースの接続先を変更するような場合は、「MySQL の接続コマンドを利用する方法」を利用し、データベースの接続先を環境ごとの定数ファイルで管理する方法がより簡単なのかな、と思います。
 
先にも紹介しましたが、環境ごとに定数ファイルを作成する方法については下記の記事を参考にしてください。
CakePHP4で定数の設定と呼び出し方法の解説(defineとConfigure)
CakePHP4の定数定義ファイルを環境変数によって本番と開発を振り分ける方法解説
 
 

データベースの接続情報オブジェクトを利用して SQL文を実行する

 

select文実行の標準形

 
データベースの接続情報を持つオブジェクトを利用し、SQLの実行は下記のように記述を行います。
 

// SQL の SELECT文の実行
$sampleResults = $sampleConnection
  ->execute("SELECT * FROM sample_table")
  ->fetchAll("assoc");

 
 

select文実行・where句はプリペアドステートメントを使用する

 
where句で条件を追加する際は、セキュリティを考慮してプリペアドステートメントを使用します。
 

// SQL の SELECT文の実行
$sampleResults = $sampleConnection
  ->execute('SELECT * FROM sample_table where height = :height and weight = :weight',
  ["height" => 170, "weight" => 60])
  ->fetchAll("assoc");

 
 

select文実行・CakePHPのクリエビルダーを使用する

 
SQL文を書かずに、クリエービルダーを使用することもできます。
 

$sampleResults = $sampleConnection
    ->newQuery()
    ->select("*")
    ->from("sample_table")
    ->where(["height" => 170, "weight" => 60])
    ->order(["name" => "ASC"])
    ->execute()
    ->fetchAll("assoc");

 
 

Insert文実行の標準形

 
Insertの処理も非常に簡単です。
Insertの SQLを実行してもいいのですが、下記のように記述することで Insertを実行することができます。
 

$insertData = [
  "id"      => 1,
  "name"    => "名前1",
  "height"  => "171",
  "weight"  => "61",
];
$sampleConnection->insert("sample_table", $insertData);

 
ちなみに、上記の Insertを実行しても自動的に「created」「modified」のカラムを編集する処理はありませんので、必要に応じて「created」「modified」の値を編集しておく必要があります。
 
 

Update文実行の標準形

 
Updateの処理も非常に簡単です。
 

$updateData = [
  "height"  => "176",
  "weight"  => "66",
];
$sampleConnection->update("sample_table", $updateData, ["id" => 1]);

 
上記を SQLに書き直すと下記になります。

update sample_table set height = 176, weight = 66 where id = 1;

 
 

Delete文実行の標準形

 
Deleteの処理も非常に簡単です。
 

$sampleConnection->delete("sample_table", ["id" => 1]);

 
 

SQL文実行に際しては「try – catch」を利用する

 
SQL文の実行処理は簡単ですが、この記述だけで処理をすると、エラーが発生したときに処理が止まってしまいます。
そのため、プログラムとして実装する場合は「try – catch」を利用してエラーへの対処をしておく必要があるかと思います。
 

try {
  // SQL の SELECT文の実行
  $sampleResults = $sampleConnection
    ->execute("SELECT * FROM sample_table")
    ->fetchAll("assoc");
} catch (\Exception $e) {
  // エラーが発生したときはログを出力
  $this->log($e->getMessage(), "error", ['scope' => ['sqlError']]);
}

 
上記のサンプルは Selectの実行ですが、同様に Insert、Update、Deleteを実行するときも「try – catch」を利用してエラーの対処をするものかと思います。
 
 
また、ログ出力に関しては下記に記事を書いていますので参考にしてください。
CakePHP4でロギングスコープやログレベルを使用してログを出し分ける方法を解説
 
 

CakePHP4の関連記事

CakePHPのpostlinkで生成した削除リンクをクリックしても処理が実行されない対処法
CakePHP4系でJSONレスポンスの処理ではwithStringBodyを使う。3との違い解説
CakePHP4、CakePHP5の「warning: DebugKit is disabling...」の対処方法
MySQL+CakePHPのdate型、datetime型項目は「2999-12-31」までしか扱えない
CakePHP4のFrozenDateで1ヵ月前、先月、今月1日、来月末の日付などを算出する方法
CakePHP4のcake cache clear_allでPermission deniedはパーミッションの変更が必要
CakePHP4のクリエビルダーを使用してOR条件をAND条件でつなぐSQL文を作る方法
CakePHP4のController内でViewテンプレート、レイアウトの変更設定を記述する方法
CakePHP4から外部のデータベースにアクセスする方法解説
CakePHP4の数値項目は「like %10%」の部分一致検索(find select)はできない
 
その他の「CakePHP4」に関する記事一覧
 
 

 - CakePHP 3.x 4.x 5.x

最後までお読みいただきましてありがとうございます。
この記事が参考になったと思いましたらソーシャルメディアで共有していただけると嬉しいです!

Message

メールアドレスが公開されることはありません。 が付いている欄は必須項目です

下記の空欄を埋めてください。 * Time limit is exhausted. Please reload CAPTCHA.

日本語が含まれない投稿は無視されますのでご注意ください。(スパム対策)

※入力いただいたコメントは管理者の承認後に掲載されます。

  関連記事

CakePHP3で /Layout/defult.ctpにある titleタグ、h1タグを編集する方法
CakePHP3で /Layout/defult.ctpにある titleタグ、h1タグを編集する方法

CakePHP3でtitleタグ、h1タグのテキストをデフォルトから変更する方法を解説。テンプレートファイルに「$this->assign()」でテキストを指定して「/Layout/defult.ctp」で受け取る。

CakePHPで同一テーブル内の値を比較する条件でレコードを取得する方法
CakePHPで同一テーブル内の値を比較する条件でレコードを取得する方法

CakePHPの同一テーブルにある項目の値を比較し条件に合致するレコードを取得する方法を解説。[”項目名”=>”値”]ではなく[”項目名 = 項目名”]と書くところがポイント。

CakePHP4の定数定義ファイルを環境変数によって本番と開発を振り分ける方法解説
CakePHP4の定数定義ファイルを環境変数によって本番と開発を振り分ける方法解説

CakePHP4で開発環境と本番環境とで違う設定ファイルを読み込ませて環境ごとに定数を切り替える方法を解説。Apacheのhttpd.confに環境変数を設定しそれを読み込み判別する。

CakePHP3のOGPはHTMLヘルパーの$this->Html->meta()を使って設定
CakePHP3のOGPはHTMLヘルパーの$this->Html->meta()を使って設定

CakePHP3でOGPを設定する方法を解説。metaタグを編集するHTMLヘルパーを利用してOGPのタグを編集する。また、エレメントとして分割することでメンテナンス性も向上させる。

CakePHP4のユーザ管理・ログイン認証プラグインCakeDC/Usersのインストール解説
CakePHP4のユーザ管理・ログイン認証プラグインCakeDC/Usersのインストール解説

CakePHP4のユーザ管理プラグイン Usersは、ユーザ登録、メール認証、ログイン認証、ユーザ管理、権限管理、reCAPTCHAなど会員制のサイトを簡単に実現可能。その導入方法、カスタマイズ方法を解説。

CakePHP4系でJSONレスポンスの処理ではwithStringBodyを使う。3との違い解説
CakePHP4系でJSONレスポンスの処理ではwithStringBodyを使う。3との違い解説

responseの値を指定する方法は3系では「body」だが、4系では「withStringBody」になりる。加えてJSON形式なら「withType」で指定するなど4系では結構異なる処理がある。

CakePHP 2.3 Search Pluginで検索処理 その1設置方法

CakePHPの検索プラグイン Search Pluginの設置方法と基本的な検索処理の解説です。

CakePHP 2.3 Model、Controllerの見たい変数の中身をログ出力

CakePHPの Modelや Controllerの変数の中身をログとして出力して見る方法を提供します。

CakePHP3で Ajaxを使う方法の解説。3.6以降対応。Successとthenの両方を解説。
CakePHP3で Ajaxを使う方法の解説。3.6以降対応。Successとthenの両方を解説。

CakePHP3でajaxを利用する処理の実装方法を解説。プルダウンを変更するとデータベースの値を取得し検索結果の内容を変更するというような処理を想定。CakePHP3.6以降の CSRF対策対応済。

CakePHP4でcontrollerで実行したバリデーションエラーをmodelのにマージする方法
CakePHP4でcontrollerで実行したバリデーションエラーをmodelのにマージする方法

CakePHP4でcontrollerで実行したバリデーションの結果をModelのバリデーション結果に追加するメソッド「setError()」「setErrors()」の使い方の解説。