public SchemaRecordInfo getBySubject()

in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/JdbcStorageService.java [84:97]

• 13 lines of code
• 5 McCabe index (conditional complexity)

    public SchemaRecordInfo getBySubject(StorageServiceContext context, QualifiedName qualifiedName) {
        if (qualifiedName.getVersion() == null) {
            SchemaRecordInfo result = handler.getBySubject(qualifiedName.subjectFullName());
            return result;
        }
        // schema version is given
        SchemaInfo schemaInfo = handler.getSchemaInfoBySubject(qualifiedName.subjectFullName());
        if (schemaInfo == null || schemaInfo.getDetails() == null || schemaInfo.getDetails().getSchemaRecords() == null) {
            return null;
        }
        Map<Long, SchemaRecordInfo> versionSchemaMap = schemaInfo.getDetails().getSchemaRecords()
            .stream().collect(Collectors.toMap(SchemaRecordInfo::getVersion, Function.identity()));
        return versionSchemaMap.get(qualifiedName.getVersion());
    }