private void callCommand()

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);
		}
	}