events

Author: James Cor

sql/events.go

@@ -28,16 +28,6 @@ import (
 
 const EventDateSpaceTimeFormat = "2006-01-02 15:04:05"
 
-// EventSchedulerStatement represents a SQL statement that requires a EventScheduler
-// (e.g. CREATE / ALTER / DROP EVENT and DROP DATABASE).
-// TODO: consider deleting this interface
-type EventSchedulerStatement interface {
-	Node
-	// WithEventScheduler returns a new instance of this EventSchedulerStatement,
-	// with the event scheduler notifier configured.
-	WithEventScheduler(controller EventScheduler) Node
-}
-
 // EventScheduler is an interface used for notifying the EventSchedulerStatus
 // for querying any events related statements. This allows plan Nodes to communicate
 // to the EventSchedulerStatus.

sql/plan/alter_event.go

@@ -31,7 +31,6 @@ import (
 var _ sql.Node = (*AlterEvent)(nil)
 var _ sql.Expressioner = (*AlterEvent)(nil)
 var _ sql.Databaser = (*AlterEvent)(nil)
-var _ sql.EventSchedulerStatement = (*AlterEvent)(nil)
 
 type AlterEvent struct {
 	ddlNode
@@ -405,13 +404,6 @@ func (a *AlterEvent) WithExpressions(e ...sql.Expression) (sql.Node, error) {
 	return &na, nil
 }
 
-// WithEventScheduler is used to notify EventSchedulerStatus to update the events list for ALTER EVENT.
-func (a *AlterEvent) WithEventScheduler(scheduler sql.EventScheduler) sql.Node {
-	na := *a
-	na.scheduler = scheduler
-	return &na
-}
-
 // alterEventIter is the row iterator for *CreateEvent.
 type alterEventIter struct {
 	once          sync.Once

sql/plan/dbddl.go

@@ -127,7 +127,6 @@ type DropDB struct {
 
 var _ sql.Node = (*DropDB)(nil)
 var _ sql.CollationCoercible = (*DropDB)(nil)
-var _ sql.EventSchedulerStatement = (*DropDB)(nil)
 
 func (d *DropDB) Resolved() bool {
 	return true
@@ -157,13 +156,6 @@ func (d *DropDB) WithChildren(children ...sql.Node) (sql.Node, error) {
 	return NillaryWithChildren(d, children...)
 }
 
-// WithEventScheduler is used to drop all events from EventSchedulerStatus for DROP DATABASE.
-func (d *DropDB) WithEventScheduler(scheduler sql.EventScheduler) sql.Node {
-	na := *d
-	na.Scheduler = scheduler
-	return &na
-}
-
 // CheckPrivileges implements the interface sql.Node.
 func (d *DropDB) CheckPrivileges(ctx *sql.Context, opChecker sql.PrivilegedOperationChecker) bool {
 	return opChecker.UserHasPrivileges(ctx, sql.NewPrivilegedOperation(sql.PrivilegeCheckSubject{}, sql.PrivilegeType_Drop))

sql/plan/ddl_event.go

@@ -32,7 +32,6 @@ import (
 var _ sql.Node = (*CreateEvent)(nil)
 var _ sql.Expressioner = (*CreateEvent)(nil)
 var _ sql.Databaser = (*CreateEvent)(nil)
-var _ sql.EventSchedulerStatement = (*CreateEvent)(nil)
 
 type CreateEvent struct {
 	ddlNode
@@ -258,13 +257,6 @@ func (c *CreateEvent) RowIter(ctx *sql.Context, _ sql.Row) (sql.RowIter, error)
 	}, nil
 }
 
-// WithEventScheduler is used to notify EventSchedulerStatus to update the events list for CREATE EVENT.
-func (c *CreateEvent) WithEventScheduler(scheduler sql.EventScheduler) sql.Node {
-	nc := *c
-	nc.scheduler = scheduler
-	return &nc
-}
-
 // GetEventDefinition returns an EventDefinition object with all of its fields populated from the details
 // of this CREATE EVENT statement.
 func (c *CreateEvent) GetEventDefinition(ctx *sql.Context, eventCreationTime, lastAltered, lastExecuted time.Time, tz string) (sql.EventDefinition, error) {
@@ -583,7 +575,6 @@ func (ost *OnScheduleTimestamp) EvalTime(ctx *sql.Context, tz string) (time.Time
 
 var _ sql.Node = (*DropEvent)(nil)
 var _ sql.Databaser = (*DropEvent)(nil)
-var _ sql.EventSchedulerStatement = (*DropEvent)(nil)
 
 type DropEvent struct {
 	ddlNode
@@ -670,10 +661,3 @@ func (d *DropEvent) WithDatabase(database sql.Database) (sql.Node, error) {
 	nde.Db = database
 	return &nde, nil
 }
-
-// WithEventScheduler is used to notify EventSchedulerStatus to update the events list for DROP EVENT.
-func (d *DropEvent) WithEventScheduler(scheduler sql.EventScheduler) sql.Node {
-	nd := *d
-	nd.scheduler = scheduler
-	return &nd
-}