PHPでDB接続をし、制限時間以内にデータ取得できなかった場合の判定ロジックを実装したい。

Question

いつもお世話になっております。

掲題

PHPでDB接続をし、制限時間以内にデータ取得できなかった場合の判定ロジックを実装したい。

実現したいこと

3種のデータをDB（RDS）に接続して取得する処理があり、最終的に３種のデータを画面に表示します。
（3種のデータ：データA、データB、データCとします。）

3種のデータは、取得可能な時間を設定して、時間内に取得できなかった場合は、NULL扱いにします。
→ 例：1秒と設定した場合、1秒経過した時点で強制的にDB接続を終了し、データはNULLとして次の処理に進みたい。

以下の手順で実行したいです。

①データAを取得します。
②データAを、1秒以内に取得できなかった場合は、NULLのデータとし、次の処理に進みます。
③データBを取得します。
④データBを、1秒以内に取得できなかった場合は、NULLのデータとし、次の処理に進みます。
⑤データCを取得します。
⑥データCを、1秒以内に取得できなかった場合は、NULLのデータとし、次の処理に進みます。
⑦画面を表示します。画面にはデータA〜Cで取得できた情報のみ表示します。

課題

1秒以内に取得できなかった場合 を判定するロジックをどう書けば良いのかわかりません。
是非お知恵をお貸しください。
よろしくお願いします。

やったこと

set_time_limit()を使ってみましたが、致命的なエラーを吐いてしまうため強制的に処理が中断してしまいました。

環境

PHP 5.3
Symfony 1.2
MySQL 5.6(Amazon RDS)

条件

・RDSの設定ではやりたくない。
・PHP.iniの設定ではやりたくない。

Answer 1

PDO::setAttribute で　PDO::ATTR_TIMEOUT を設定する。または、mysqli::optionsでMYSQLI_OPT_CONNECT_TIMEOUT を設定する。
という方法を検索で見つけたけど、使ったことはありません。

microtime() で処理時間の計測を行って、ログを書き出す処理を書いたことはあります。

Sample

<?php

/**
 * DB.class.php
 */
class DB
{

	const DB_NAME = 'sample';
	const DB_USER = 'root';
	const DB_PASSWORD = 'password';

	/**
	 * @var PDO
	 */
	private static $pdo = null;

	/**
	 * @var PDOStatement
	 */
	private static $stmt = null;

	/**
	 * getInstance
	 * @return \PDO
	 */
	public static function getInstance(): \PDO
	{
		if (!is_null(static::$pdo)) {
			return static::$pdo;
		}
		$dsn = sprintf('mysql:host=127.0.0.1;dbname=%s;charset=utf8mb4', self::DB_NAME);
		$pdo = new \PDO($dsn, self::DB_USER, self::DB_PASSWORD);
		$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
		$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
		static::$pdo = $pdo;
		return static::$pdo;
	}

	/**
	 * select
	 * @param string $sql
	 * @param array $params
	 * @return null|array
	 */
	public static function select(string $sql, array $params = [])
	{
		$pdo = self::getInstance();
		self::$stmt = $pdo->prepare($sql);

		// start time
		$start = microtime(true);

		self::$stmt->execute($params);

		// end time
		$end = microtime(true);
		$time = $end - $start;

		if ($time > 1) {
			return null;
		}
		return self::$stmt->fetchAll();
	}

}

<?php

/**
 * index.php
 */
ini_set('display_errors', true);
error_reporting(E_ALL);

require 'classes/DB.class.php';

$rows_table1 = DB::select('select * from Table1');
$rows_table2 = DB::select('select * from Table2');
$rows_table3 = DB::select('select * from Table3');

Comments

[Heidi]

早速ありがとうございます！
ご教示いただいた方法を試してみたいと思います！