in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java [145:269]
private static AuditLogOperation judgeLogOperation(StatementType type) {
switch (type) {
case AUTHOR:
case CREATE_USER:
case DELETE_USER:
case MODIFY_PASSWORD:
case GRANT_USER_PRIVILEGE:
case REVOKE_USER_PRIVILEGE:
case GRANT_USER_ROLE:
case REVOKE_USER_ROLE:
case CREATE_ROLE:
case DELETE_ROLE:
case GRANT_ROLE_PRIVILEGE:
case REVOKE_ROLE_PRIVILEGE:
case GRANT_WATERMARK_EMBEDDING:
case REVOKE_WATERMARK_EMBEDDING:
case STORAGE_GROUP_SCHEMA:
case DELETE_STORAGE_GROUP:
case CREATE_TIME_SERIES:
case CREATE_ALIGNED_TIME_SERIES:
case CREATE_MULTI_TIME_SERIES:
case DELETE_TIME_SERIES:
case ALTER_TIME_SERIES:
case CHANGE_ALIAS:
case CHANGE_TAG_OFFSET:
case CREATE_FUNCTION:
case DROP_FUNCTION:
case CREATE_INDEX:
case DROP_INDEX:
case QUERY_INDEX:
case CREATE_TRIGGER:
case DROP_TRIGGER:
case CREATE_TEMPLATE:
case SET_TEMPLATE:
case MERGE:
case FULL_MERGE:
case MNODE:
case MEASUREMENT_MNODE:
case STORAGE_GROUP_MNODE:
case AUTO_CREATE_DEVICE_MNODE:
case TTL:
case FLUSH:
case CLEAR_CACHE:
case DELETE_PARTITION:
case LOAD_CONFIGURATION:
case CREATE_SCHEMA_SNAPSHOT:
case CREATE_CONTINUOUS_QUERY:
case DROP_CONTINUOUS_QUERY:
case SET_SYSTEM_MODE:
case UNSET_TEMPLATE:
case PRUNE_TEMPLATE:
case APPEND_TEMPLATE:
case DROP_TEMPLATE:
case CREATE_PIPESINK:
case DROP_PIPESINK:
case CREATE_PIPE:
case START_PIPE:
case STOP_PIPE:
case DROP_PIPE:
case DEACTIVATE_TEMPLATE:
case CREATE_PIPEPLUGIN:
case DROP_PIPEPLUGIN:
case CREATE_LOGICAL_VIEW:
case ALTER_LOGICAL_VIEW:
case DELETE_LOGICAL_VIEW:
case RENAME_LOGICAL_VIEW:
case CREATE_TOPIC:
case DROP_TOPIC:
return AuditLogOperation.DDL;
case LOAD_DATA:
case INSERT:
case BATCH_INSERT:
case BATCH_INSERT_ROWS:
case BATCH_INSERT_ONE_DEVICE:
case MULTI_BATCH_INSERT:
case PIPE_ENRICHED:
case DELETE:
case SELECT_INTO:
case LOAD_FILES:
case REMOVE_FILE:
case UNLOAD_FILE:
case ACTIVATE_TEMPLATE:
case SETTLE:
case INTERNAL_CREATE_TIMESERIES:
case START_REPAIR_DATA:
case STOP_REPAIR_DATA:
case SET_CONFIGURATION:
return AuditLogOperation.DML;
case LIST_USER:
case LIST_ROLE:
case LIST_USER_PRIVILEGE:
case LIST_ROLE_PRIVILEGE:
case LIST_USER_ROLES:
case LIST_ROLE_USERS:
case QUERY:
case LAST:
case GROUP_BY_TIME:
case GROUP_BY_FILL:
case AGGREGATION:
case FILL:
case UDAF:
case UDTF:
case SHOW:
case SHOW_PIPES:
case SHOW_TOPICS:
case SHOW_SUBSCRIPTIONS:
case SHOW_MERGE_STATUS:
case KILL:
case TRACING:
case SHOW_CONTINUOUS_QUERIES:
case SHOW_SCHEMA_TEMPLATE:
case SHOW_NODES_IN_SCHEMA_TEMPLATE:
case SHOW_PATH_SET_SCHEMA_TEMPLATE:
case SHOW_PATH_USING_SCHEMA_TEMPLATE:
case SHOW_QUERY_RESOURCE:
case FETCH_SCHEMA:
case COUNT:
case SHOW_TRIGGERS:
case SHOW_PIPEPLUGINS:
return AuditLogOperation.QUERY;
default:
logger.error("Unrecognizable operator type ({}) for audit log", type);
return AuditLogOperation.NULL;
}
}