Řešení konfliktů

Ke konfliktu dochází, když obě strany sloučení změní stejná data neslučitelným způsobem. merql zjišťuje čtyři typy konfliktů a nabízí strategie automatického i ručního řešení.

$result = $merge->merge($base, $ours, $theirs);

if (!$result->isClean()) {
    foreach ($result->conflicts() as $conflict) {
        echo "{$conflict->table()}.{$conflict->column()}: "
           . "{$conflict->oursValue()} vs {$conflict->theirsValue()}\n";
    }
}

Typy konfliktů

update_update

Obě strany změnily stejný sloupec stejného řádku na různé hodnoty. Jde o nejběžnější typ konfliktu.

Base:    posts #42  title = "Hello"
Ours:    posts #42  title = "Welcome"
Theirs:  posts #42  title = "Greetings"

Konflikt uvádí: tabulku posts, klíč řádku 42, sloupec title, hodnotu naší strany Welcome, hodnotu jejich strany Greetings, základní hodnotu Hello.

update_delete

Jedna strana řádek aktualizovala, druhá jej odstranila. merql nedokáže určit, zda má zvítězit aktualizace, nebo odstranění.

Ours:    posts #42  title = "Updated Title"    (updated)
Theirs:  posts #42  (deleted)

Konflikt uvádí: tabulku posts, klíč řádku 42, typ update_delete. Hodnota naší strany obsahuje celý aktualizovaný řádek. Hodnota jejich strany je null.

delete_update

Opak konfliktu update_delete. Jejich strana řádek aktualizovala, naše jej odstranila.

Ours:    posts #42  (deleted)
Theirs:  posts #42  title = "Updated Title"    (updated)

Konflikt uvádí: typ delete_update. Hodnota naší strany je null, hodnota jejich strany obsahuje celý aktualizovaný řádek.

insert_insert

Obě strany vložily řádek se stejným primárním klíčem. Protože jsou oba řádky nové (v základu nejsou), merql je nedokáže sloučit.

Base:    (no row #99)
Ours:    posts #99  { title: "My Post" }
Theirs:  posts #99  { title: "Their Post" }

Konflikt uvádí: typ insert_insert. Hodnota naší strany obsahuje data našeho řádku a hodnota jejich strany obsahuje data jejich řádku.

Třída Conflict

Každý konflikt je objekt jen pro čtení s těmito přístupovými metodami:

$conflict->table();      // string: table name
$conflict->rowKey();     // string: encoded row identity key
$conflict->type();       // string: "update_update"|"update_delete"|"delete_update"|"insert_insert"
$conflict->column();     // ?string: column name (null for structural conflicts)
$conflict->oursValue();  // mixed: our value (null for delete side, full row for structural)
$conflict->theirsValue(); // mixed: their value (null for delete side, full row for structural)
$conflict->baseValue();  // mixed: base value (null for inserts)

Metoda column() vrací název sloupce pro konflikty update_update a null pro strukturální konflikty (update_delete, delete_update, insert_insert).

Dekódování primárního klíče

Klíč řádku je zakódovaný řetězec. Chcete-li získat pojmenované pole primárních klíčů, předejte sloupce identity:

$pk = $conflict->primaryKey(['id']);
// ['id' => '42']

$pk = $conflict->primaryKey(['tenant_id', 'user_id']);
// ['tenant_id' => '1', 'user_id' => '99']

Automatické řešení pomocí ConflictPolicy

ConflictResolver použije zásadu k vyřešení všech konfliktů najednou:

use Merql\Merge\ConflictPolicy;
use Merql\Merge\ConflictResolver;

// One side wins everywhere.
$resolved = ConflictResolver::resolve($result, ConflictPolicy::OursWins);
$resolved = ConflictResolver::resolve($result, ConflictPolicy::TheirsWins);

// Manual: return the result unchanged (inspect conflicts yourself).
$resolved = ConflictResolver::resolve($result, ConflictPolicy::Manual);

Výčet ConflictPolicy

Jak funguje řešení

U konfliktů update_update upraví řešič existující operaci sloučení daného řádku a nahradí hodnotu konfliktního sloupce hodnotou vítězné strany.

U strukturálních konfliktů (update_delete, delete_update, insert_insert) přidá řešič do výsledku novou operaci:

• update_delete s OursWins přidá operaci UPDATE.
• update_delete s TheirsWins přidá operaci DELETE.
• delete_update s OursWins přidá operaci DELETE.
• delete_update s TheirsWins přidá operaci UPDATE.
• insert_insert použije hodnoty řádku vítězné strany.

Vyřešené MergeResult má prázdný seznam konfliktů a lze je rovnou použít.

Ruční řešení

Chcete-li mít přesnou kontrolu, prohlédněte si každý konflikt a vytvořte vlastní řešení:

foreach ($result->conflicts() as $conflict) {
    echo "Table:  {$conflict->table()}\n";
    echo "Row:    {$conflict->rowKey()}\n";
    echo "Type:   {$conflict->type()}\n";

    if ($conflict->column() !== null) {
        echo "Column: {$conflict->column()}\n";
        echo "Base:   " . var_export($conflict->baseValue(), true) . "\n";
        echo "Ours:   " . var_export($conflict->oursValue(), true) . "\n";
        echo "Theirs: " . var_export($conflict->theirsValue(), true) . "\n";
    }
}

Použití s nevyřešenými konflikty

Applier odmítne použít výsledek sloučení, který obsahuje nevyřešené konflikty. Vyvolá výjimku ConflictException:

use Merql\Exceptions\ConflictException;

try {
    $applier->apply($result);
} catch (ConflictException $e) {
    echo $e->getMessage();
    // "Cannot apply merge with 3 unresolved conflicts"
}

Před použitím vždy vyřešte konflikty, buď pomocí ConflictResolver::resolve(), nebo ručním sestavením čistého MergeResult.