in flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java [269:381]
private void callCommand(SqlCommandCall cmdCall) {
switch (cmdCall.command) {
case QUIT:
callQuit();
break;
case CLEAR:
callClear();
break;
case RESET:
callReset();
break;
case SET:
callSet(cmdCall);
break;
case HELP:
callHelp();
break;
case SHOW_CATALOGS:
callShowCatalogs();
break;
case SHOW_CURRENT_CATALOG:
callShowCurrentCatalog();
break;
case SHOW_DATABASES:
callShowDatabases();
break;
case SHOW_CURRENT_DATABASE:
callShowCurrentDatabase();
break;
case SHOW_TABLES:
callShowTables();
break;
case SHOW_FUNCTIONS:
callShowFunctions();
break;
case SHOW_MODULES:
callShowModules();
break;
case SHOW_PARTITIONS:
callShowPartitions(cmdCall);
break;
case USE_CATALOG:
callUseCatalog(cmdCall);
break;
case USE:
callUseDatabase(cmdCall);
break;
case DESC:
case DESCRIBE:
callDescribe(cmdCall);
break;
case EXPLAIN:
callExplain(cmdCall);
break;
case SELECT:
callSelect(cmdCall);
break;
case INSERT_INTO:
case INSERT_OVERWRITE:
callInsert(cmdCall);
break;
case CREATE_TABLE:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_TABLE_CREATED);
break;
case DROP_TABLE:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_TABLE_REMOVED);
break;
case CREATE_VIEW:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_VIEW_CREATED);
break;
case DROP_VIEW:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_VIEW_REMOVED);
break;
case ALTER_VIEW:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_ALTER_VIEW_SUCCEEDED, CliStrings.MESSAGE_ALTER_VIEW_FAILED);
break;
case CREATE_FUNCTION:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_FUNCTION_CREATED);
break;
case DROP_FUNCTION:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_FUNCTION_REMOVED);
break;
case ALTER_FUNCTION:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_ALTER_FUNCTION_SUCCEEDED,
CliStrings.MESSAGE_ALTER_FUNCTION_FAILED);
break;
case SOURCE:
callSource(cmdCall);
break;
case CREATE_DATABASE:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_DATABASE_CREATED);
break;
case DROP_DATABASE:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_DATABASE_REMOVED);
break;
case ALTER_DATABASE:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_ALTER_DATABASE_SUCCEEDED,
CliStrings.MESSAGE_ALTER_DATABASE_FAILED);
break;
case ALTER_TABLE:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_ALTER_TABLE_SUCCEEDED,
CliStrings.MESSAGE_ALTER_TABLE_FAILED);
break;
case CREATE_CATALOG:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_CATALOG_CREATED);
break;
case DROP_CATALOG:
callDdl(cmdCall.operands[0], CliStrings.MESSAGE_CATALOG_REMOVED);
break;
default:
throw new SqlClientException("Unsupported command: " + cmdCall.command);
}
}