PHP | WordPressの投稿や設定情報に対して置換などの処理をする

/**
 * mysql エラーフラグ 設定
 */
mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
/**
 * mysql 接続
 */
$mysqli = new mysqli('localhost', '_USERNAME_', '_PASSWORD_', '_DB_NAME_');
if ($mysqli->connect_error) {
	echo $mysqli->connect_error;
	exit;
}


// 対象 Table
$TABLE = 'wp_posts';
// Table 主キー
$PRIMARY = 'ID';
// 文字列の含まれるカラム
$CONTENT = 'post_content';

/**
 * Query
 */
// 取得用クエリ
$QuerySelect = <<<TXT
SELECT 
	$PRIMARY,
	$CONTENT
FROM 
	$TABLE
WHERE 
	$CONTENT != ''
TXT;
// 更新用クエリ
$QueryUpdate = <<<TXT
UPDATE 
	$TABLE 
SET 
	$CONTENT = ? WHERE $PRIMARY = ?;
TXT;

/**
 * 処理用関数
 */
function Method($value) {
	/**
	 * 処理
	 */
	return $value;
}


/**
 * 対象取得
 */
$PostRows = [];
$result = $mysqli->query($QuerySelect, MYSQLI_USE_RESULT);
while ($row = $result->fetch_assoc()) {
	$PostRows[] = $row;
}
/**
 * 結果の開放
 */
mysqli_free_result($result);

/**
 * トランザクション 開始
 */
$mysqli->begin_transaction();

try {
	/**
	 * 全取得Row置換処理
	 */
	foreach ($PostRows as $row) {
		$primary_key = $row[$PRIMARY];
		$org_content_value = $content_value = $row[$CONTENT];

		/**
		 * シリアライズ 戻す
		 *   成功すると 配列
		 *   失敗すると false
		 */
		$valueData = @unserialize($content_value);
		if ($valueData) {
			/**
			 * シリアライズデータ だったら
			 * 
			 * 全配列要素を再帰処理
			 */
			array_walk_recursive($valueData, function(&$value, $key) {
				/**
				 * 置換処理
				 */
				$value = Method($value);
			});

			/**
			 * シリアライズ化
			 */
			$content_value = @serialize($valueData);
		}
		else {
			/**
			 * 普通のデータ だったら
			 *
			 * 置換処理
			 */
			$content_value = Method($content_value);
		}


		if ($org_content_value !== $content_value) {
			/**
			 * 変更されてたら
			 * UPDATE
			 */
			$stmt = mysqli_prepare($mysqli, $QueryUpdate);
			$stmt->bind_param('si', $content_value, $primary_key);
			if ($stmt->execute()) {
			}
			else {
				/**
				 * 失敗したらやり直し
				 */
				throw new \Exception('primary_key：'.$primary_key.'で、エラーが発生しました。');
			}
		}
	}

	/**
	 * 全部完了 コミット
	 */
	$mysqli->commit();

} 
catch (\Exception $ex) {
	/**
	 * どこかで失敗 ロールバック
	 */
	$mysqli->rollback();

	echo $ex->getMessage();
}

/**
 * 終了
 */
$mysqli->close();