1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.proxy.backend.mysql.handler.admin.executor;
19
20 import lombok.RequiredArgsConstructor;
21 import org.apache.shardingsphere.mode.process.event.KillProcessRequestEvent;
22 import org.apache.shardingsphere.proxy.backend.context.ProxyContext;
23 import org.apache.shardingsphere.proxy.backend.handler.admin.executor.DatabaseAdminExecutor;
24 import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
25 import org.apache.shardingsphere.sql.parser.sql.dialect.statement.mysql.dal.MySQLKillStatement;
26
27
28
29
30 @RequiredArgsConstructor
31 public final class KillProcessExecutor implements DatabaseAdminExecutor {
32
33 private final MySQLKillStatement killStatement;
34
35
36
37
38
39
40 @Override
41 public void execute(final ConnectionSession connectionSession) {
42 String processId = killStatement.getProcessId();
43 ProxyContext.getInstance().getContextManager().getInstanceContext().getEventBusContext().post(new KillProcessRequestEvent(processId));
44 }
45 }