1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.proxy.frontend.postgresql.command.generic;
19
20 import lombok.RequiredArgsConstructor;
21 import org.apache.shardingsphere.db.protocol.packet.DatabasePacket;
22 import org.apache.shardingsphere.db.protocol.postgresql.constant.PostgreSQLMessageSeverityLevel;
23 import org.apache.shardingsphere.db.protocol.postgresql.packet.generic.PostgreSQLErrorResponsePacket;
24 import org.apache.shardingsphere.infra.exception.postgresql.vendor.PostgreSQLVendorError;
25 import org.apache.shardingsphere.proxy.frontend.command.executor.CommandExecutor;
26
27 import java.util.Collection;
28 import java.util.Collections;
29
30
31
32
33 @RequiredArgsConstructor
34 public final class PostgreSQLUnsupportedCommandExecutor implements CommandExecutor {
35
36 @Override
37 public Collection<DatabasePacket> execute() {
38
39 PostgreSQLErrorResponsePacket packet = PostgreSQLErrorResponsePacket.newBuilder(PostgreSQLMessageSeverityLevel.ERROR, PostgreSQLVendorError.FEATURE_NOT_SUPPORTED,
40 PostgreSQLVendorError.FEATURE_NOT_SUPPORTED.getReason()).build();
41 return Collections.singleton(packet);
42 }
43 }