szurubooru/src/Upgrades/Upgrade11.php

<?php
namespace Szurubooru\Upgrades;

class Upgrade11 implements IUpgrade
{
	public function run(\Szurubooru\DatabaseConnection $databaseConnection)
	{
		$pdo = $databaseConnection->getPDO();
		$driver = $pdo->getAttribute(\PDO::ATTR_DRIVER_NAME);

		$pdo->exec('CREATE TABLE postScores
			(
				id INTEGER PRIMARY KEY ' . ($driver === 'mysql' ? 'AUTO_INCREMENT' : 'AUTOINCREMENT') . ',
				userId INTEGER NOT NULL,
				postId INTEGER NOT NULL,
				time DATETIME NOT NULL,
				score INTEGER NOT NULL,
				UNIQUE (userId, postId)
			)');

		$pdo->exec('
			CREATE TRIGGER postScoresDelete AFTER DELETE ON postScores
			FOR EACH ROW
			BEGIN
				UPDATE posts SET score = (
					SELECT SUM(score) FROM postScores
					WHERE postScores.postId = posts.id)
				WHERE posts.id = OLD.postId;
			END');

		$pdo->exec('
			CREATE TRIGGER postScoresInsert AFTER INSERT ON postScores
			FOR EACH ROW
			BEGIN
				UPDATE posts SET score = (
					SELECT SUM(score) FROM postScores
					WHERE postScores.postId = posts.id)
				WHERE posts.id = NEW.postId;
			END');


		$pdo->exec('
			CREATE TRIGGER postScoresUpdate AFTER UPDATE ON postScores
			FOR EACH ROW
			BEGIN
				UPDATE posts SET score = (
					SELECT SUM(score) FROM postScores
					WHERE postScores.postId = posts.id)
				WHERE posts.id = OLD.postId;

				UPDATE posts SET score = (
					SELECT SUM(score) FROM postScores
					WHERE postScores.postId = posts.id)
				WHERE posts.id = NEW.postId;
			END');

		$pdo->exec('ALTER TABLE posts ADD COLUMN score INTEGER NOT NULL DEFAULT 0');
	}
}