|
1 | 1 | package sqlancer.citus; |
2 | 2 |
|
3 | | -import java.sql.Connection; |
4 | 3 | import java.sql.DriverManager; |
5 | 4 | import java.sql.ResultSet; |
6 | 5 | import java.sql.SQLException; |
|
44 | 43 | import sqlancer.postgres.gen.PostgresDiscardGenerator; |
45 | 44 | import sqlancer.postgres.gen.PostgresDropIndexGenerator; |
46 | 45 | import sqlancer.postgres.gen.PostgresNotifyGenerator; |
47 | | -import sqlancer.postgres.gen.PostgresQueryCatalogGenerator; |
48 | 46 | import sqlancer.postgres.gen.PostgresReindexGenerator; |
49 | 47 | import sqlancer.postgres.gen.PostgresSequenceGenerator; |
50 | 48 | import sqlancer.postgres.gen.PostgresStatisticsGenerator; |
@@ -104,8 +102,7 @@ public enum Action implements AbstractAction<PostgresGlobalState> { |
104 | 102 | LISTEN((g) -> PostgresNotifyGenerator.createListen()), // |
105 | 103 | UNLISTEN((g) -> PostgresNotifyGenerator.createUnlisten()), // |
106 | 104 | CREATE_SEQUENCE(PostgresSequenceGenerator::createSequence), // |
107 | | - CREATE_VIEW(CitusViewGenerator::create), // |
108 | | - QUERY_CATALOG((g) -> PostgresQueryCatalogGenerator.query()); |
| 105 | + CREATE_VIEW(CitusViewGenerator::create); |
109 | 106 |
|
110 | 107 | private final QueryProvider<PostgresGlobalState> queryProvider; |
111 | 108 |
|
@@ -147,7 +144,6 @@ private static int mapActions(PostgresGlobalState globalState, Action a) { |
147 | 144 | case DELETE: |
148 | 145 | case RESET_ROLE: |
149 | 146 | case SET: |
150 | | - case QUERY_CATALOG: |
151 | 147 | nrPerformed = r.getInteger(0, 5); |
152 | 148 | break; |
153 | 149 | case ANALYZE: |
|
0 commit comments