MySQL trigger component for Hyperf, Based on a great work of creators：krowinski/php-mysql-replication
- Request
composer require friendsofhyperf/trigger- Publish
php bin/hyperf.php vendor:publish friendsofhyperf/trigger// config/autoload/listeners.phpreturn [
FriendsOfHyperf\Trigger\Listener\BindTriggerProcessesListener::class => PHP_INT_MAX,
];namespaceApp\Trigger;
useFriendsOfHyperf\Trigger\Annotation\Trigger;
useFriendsOfHyperf\Trigger\Trigger\AbstractTrigger;
useMySQLReplication\Event\DTO\EventDTO;
#[Trigger(table:"table", events:["*"], connection:"default")]
class FooTrigger extends AbstractTrigger
{
publicfunctiononWrite(array$new)
{
var_dump($new);
}
publicfunctiononUpdate(array$old, array$new)
{
var_dump($old, $new);
}
publicfunctiononDelete(array$old)
{
var_dump($old);
}
}namespaceApp\Subscriber;
useFriendsOfHyperf\Trigger\Annotation\Subscriber;
useFriendsOfHyperf\Trigger\Subscriber\AbstractSubscriber;
useMySQLReplication\Event\DTO\EventDTO;
#[Subscriber(connection:"default")]
class BarSubscriber extends AbstractSubscriber
{
protectedfunctionallEvents(EventDTO$event): void
{
// some code
}
}