PortableInfobox/includes/services/Helpers/PagePropsProxy.php

<?php

namespace PortableInfobox\Helpers;

use MediaWiki\MediaWikiServices;

class PagePropsProxy {

	protected $atomicStarted;
	protected $manualWrite;

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

	public function get( $id, $property ) {
		$dbLoadBalancer = MediaWikiServices::getInstance()->getDBLoadBalancer();
		$dbr = $dbLoadBalancer->getConnection( DB_REPLICA );
		$propValue = $dbr->selectField(
			'page_props',
			'pp_value',
			[
				'pp_page' => $id,
				'pp_propname' => $property
			],
			__METHOD__
		);
		return $propValue;
	}

	public function set( $id, array $props ) {
		$dbLoadBalancer = MediaWikiServices::getInstance()->getDBLoadBalancer();
		$dbw = $dbLoadBalancer->getConnection( DB_PRIMARY );

		if ( !$this->atomicStarted ) {
			$dbw->startAtomic( __METHOD__ );
			$this->atomicStarted = true;
		}

		foreach ( $props as $sPropName => $sPropValue ) {
			$dbw->replace(
				'page_props',
				[
					[
						'pp_page',
						'pp_propname'
					]
				],
				[
					'pp_page' => $id,
					'pp_propname' => $sPropName,
					'pp_value' => $sPropValue
				],
				__METHOD__
			);
		}

		if ( !$this->manualWrite ) {
			$dbw->endAtomic( __METHOD__ );
			$this->atomicStarted = false;
		}
	}

	public function write() {
		if ( $this->atomicStarted && $this->manualWrite ) {
			$dbLoadBalancer = MediaWikiServices::getInstance()->getDBLoadBalancer();
			$dbLoadBalancer->getConnection( DB_PRIMARY )
				->endAtomic( __CLASS__ . '::set' );

			$this->atomicStarted = false;
		}
	}
}