judo-runtimedao-patterns

name: judo-runtime:dao-patterns description: Understand JUDO DAO Core interface patterns including payload processors, statement types, instance collectors, and validation. Use when working with data access operations, implementing custom processors, or understanding the DAO architecture. metadata: author: BlackBelt Technology version: "${project.version}"

JUDO DAO Core Patterns

Guide for understanding and working with the JUDO DAO Core layer patterns including processors, statements, and collectors.

Architecture Overview

flowchart TB
    subgraph "Payload Processing"
        P["Payload<br/>(Transfer Object)"]
        PPD["PayloadDaoProcessor<br/>(Base)"]
        IPP["InsertPayloadDaoProcessor"]
        UPP["UpdatePayloadDaoProcessor"]
        DPP["DeletePayloadDaoProcessor"]
    end
    
    subgraph "Statement Generation"
        IS["InsertStatement"]
        US["UpdateStatement"]
        DS["DeleteStatement"]
        ARS["AddReferenceStatement"]
        RRS["RemoveReferenceStatement"]
        VS["ValidationStatement"]
    end
    
    subgraph "Instance Collection"
        IC["InstanceCollector"]
        IG["InstanceGraph"]
        IR["InstanceReference"]
    end
    
    P --> PPD
    PPD --> IPP
    PPD --> UPP
    PPD --> DPP
    
    IPP --> IS
    IPP --> ARS
    UPP --> US
    UPP --> IS
    UPP --> DS
    UPP --> ARS
    UPP --> RRS
    DPP --> DS
    DPP --> RRS
    DPP --> VS
    
    IC --> IG
    IG --> IR
    UPP --> IC
    DPP --> IC

Payload Processors

PayloadDaoProcessor (Base Class)

The base class provides validation utilities and predicates for all processors.

// Key predicates for structural feature filtering
PayloadDaoProcessor.isSingle          // Single-valued feature
PayloadDaoProcessor.isCollection      // Multi-valued feature  
PayloadDaoProcessor.isMandatory       // Required feature
PayloadDaoProcessor.isDerived         // Derived feature
PayloadDaoProcessor.isChangeable      // Changeable feature
PayloadDaoProcessor.isContainment     // Containment reference
PayloadDaoProcessor.hasOpposite       // Has opposite reference

// Payload inspection predicates
PayloadDaoProcessor.hasPayload(payload)           // Feature present in payload
PayloadDaoProcessor.hasPayloadNotNull(payload)    // Feature present and non-null
PayloadDaoProcessor.hasReferenced(payload, idName) // Contains referenced entity
PayloadDaoProcessor.hasEmbedded(payload, idName)   // Contains embedded entity

Key Constants:

REFERENCE_ID = "__referenceId"    // Client reference identifier
ENTITY_TYPE_KEY = "__entityType"  // Entity type marker
VERSION = "__version"             // Optimistic lock version

InsertPayloadDaoProcessor

Generates insert statements recursively for new entities.

flowchart LR
    subgraph "Insert Flow"
        P["Payload"]
        VS["Validate Structure"]
        AP["Apply Defaults"]
        AA["Add Attributes"]
        PE["Process Embedded"]
        PR["Process References"]
        S["Statements"]
    end
    
    P --> VS --> AP --> AA --> PE --> PR --> S

Rules:

Root type cannot have ID (that would be update)
NULL relations are ignored
Entities with ID are treated as references
Entities without ID are inserted recursively

InsertPayloadDaoProcessor processor = new InsertPayloadDaoProcessor(
    resourceSet, 
    identifierProvider,
    queryFactory, 
    instanceCollector,
    defaultValuesApplier,
    metadata
);

Collection<Statement> statements = processor.insert(
    mappedTransferObjectType,
    payload,
    checkMandatoryFeatures
);

UpdatePayloadDaoProcessor

Handles updates with merge logic for embedded and referenced entities.

flowchart TB
    subgraph "Update Merge Logic"
        OP["Original Payload"]
        UP["Update Payload"]
        CMP["Compare"]
    end
    
    subgraph "Outcomes"
        INS["Insert<br/>(new in update)"]
        UPD["Update<br/>(exists in both)"]
        DEL["Delete<br/>(missing in update)"]
        ADD["Add Reference"]
        REM["Remove Reference"]
    end
    
    OP --> CMP
    UP --> CMP
    CMP --> INS
    CMP --> UPD
    CMP --> DEL
    CMP --> ADD
    CMP --> REM

Merge Scenarios:

Original	Update	Containment Action	Association Action
null	null	None	None
null	with ID	Error	Add reference
null	no ID	Insert new	Error
with ID	null	Delete instance	Remove reference
with ID	same ID	Update recursively	None
with ID	different ID	Error	Replace reference

DeletePayloadDaoProcessor

Handles deletions with cascade and back-reference checking.

flowchart TB
    subgraph "Delete Flow"
        ID["Entity IDs"]
        CG["Collect Graph"]
        CR["Check References"]
        CC["Check Containments"]
        GS["Generate Statements"]
    end
    
    subgraph "Cascade"
        RC["reverseCascadeDelete"]
        MC["Mandatory Check"]
    end
    
    ID --> CG --> CR --> CC --> GS
    CR --> RC
    CR --> MC

Back-reference handling:

reverseCascadeDelete annotation triggers cascade deletion
Mandatory back-references without cascade cause error

Statement Types

Statement Hierarchy

classDiagram
    class Statement {
        <<abstract>>
        +InstanceValue instance
    }
    
    class InsertStatement {
        +EReference container
        +Object clientReferenceIdentifier
        +Integer version
        +Serializable userId
        +String userName
        +LocalDateTime timestamp
    }
    
    class UpdateStatement {
        +Integer version
        +Serializable userId
        +String userName
        +LocalDateTime timestamp
    }
    
    class DeleteStatement {
    }
    
    class ReferenceStatement {
        <<abstract>>
        +Serializable identifier
        +EReference reference
    }
    
    class AddReferenceStatement {
        +Collection~Serializable~ alreadyReferencingInstances
    }
    
    class RemoveReferenceStatement {
    }
    
    class ValidationStatement {
    }
    
    class InstanceExistsValidationStatement {
    }
    
    Statement <|-- InsertStatement
    Statement <|-- UpdateStatement
    Statement <|-- DeleteStatement
    Statement <|-- ReferenceStatement
    Statement <|-- ValidationStatement
    ReferenceStatement <|-- AddReferenceStatement
    ReferenceStatement <|-- RemoveReferenceStatement
    ValidationStatement <|-- InstanceExistsValidationStatement

Statement Building

// Insert statement
InsertStatement insert = InsertStatement.buildInsertStatement()
    .type(entityType)
    .identifier(identifierProvider.get())
    .clientReferenceIdentifier(payload.get(REFERENCE_ID))
    .container(containerReference)
    .version(1)
    .userId(metadata.getUserId())
    .username(metadata.getUsername())
    .timestamp(metadata.getTimestamp())
    .build();

// Update statement  
UpdateStatement update = UpdateStatement.buildUpdateStatement()
    .type(entityType)
    .identifier(existingId)
    .version(originalVersion)
    .userId(metadata.getUserId())
    .username(metadata.getUsername())
    .timestamp(metadata.getTimestamp())
    .build();

// Delete statement
DeleteStatement delete = new DeleteStatement(
    InstanceValue.buildInstanceValue()
        .type(entityType)
        .identifier(id)
        .build()
);

// Reference statements
AddReferenceStatement addRef = AddReferenceStatement.buildAddReferenceStatement()
    .type(ownerType)
    .reference(reference)
    .identifier(ownerId)
    .referenceIdentifier(targetId)
    .alreadyReferencingInstances(existingRefs)
    .build();

RemoveReferenceStatement removeRef = RemoveReferenceStatement.buildRemoveReferenceStatement()
    .type(ownerType)
    .reference(reference)
    .identifier(ownerId)
    .referenceIdentifier(targetId)
    .build();

// Validation statement
InstanceExistsValidationStatement validation = 
    InstanceExistsValidationStatement.buildInstanceExistsValidationStatement()
        .type(entityType)
        .identifier(id)
        .build();

Instance Collection

InstanceCollector Interface

public interface InstanceCollector {
    // Collect graph for multiple instances
    Map<Serializable, InstanceGraph> collectGraph(
        EClass entityType, 
        Collection<Serializable> ids
    );
    
    // Collect graph for single instance
    InstanceGraph collectGraph(
        EClass entityType, 
        Serializable id
    );
}

InstanceGraph Structure

classDiagram
    class InstanceGraph {
        +Serializable id
        +Collection~InstanceReference~ containments
        +Collection~InstanceReference~ references
        +Collection~InstanceReference~ backReferences
    }
    
    class InstanceReference {
        +EReference reference
        +InstanceGraph referencedElement
    }
    
    InstanceGraph "1" --> "*" InstanceReference : containments
    InstanceGraph "1" --> "*" InstanceReference : references
    InstanceGraph "1" --> "*" InstanceReference : backReferences
    InstanceReference --> InstanceGraph : referencedElement

Usage in DeletePayloadDaoProcessor:

// Collect the full graph of an instance
InstanceGraph graph = instanceCollector.collectGraph(entityType, id);

// Navigate containments
for (InstanceReference containment : graph.getContainments()) {
    EReference ref = containment.getReference();
    InstanceGraph child = containment.getReferencedElement();
    // Process child recursively
}

// Check back-references before deletion
for (InstanceReference backRef : graph.getBackReferences()) {
    if (backRef.getReference().getLowerBound() > 0) {
        // Mandatory reference - cannot delete without cascade
    }
}

Validation Patterns

Mandatory Feature Checking

// Check mandatory attributes
processor.checkMandatoryAttributes(attributes, payload);

// Check mandatory references
processor.checkMandatoryReferences(references, payload);

// Check mapped object structure
processor.checkMappedObjectStructure(transferType, parentReference);

Reference Validation

// Validate reference types match payload types
processor.checkReferences(references, payload);

// Check forbidden updates (opposite with lower bound)
processor.checkForbiddenReferenceUpdates(references, payload);

// Check associations cannot be embedded
processor.checkAssociationCannotBeEmbedded(references, payload);

Optimistic Locking

The UpdatePayloadDaoProcessor supports optimistic locking:

// Version check during update
if (optimisticLockEnabled) {
    Integer updateVersion = updatePayload.getAs(Integer.class, VERSION);
    if (updateVersion != null) {
        checkArgument(
            Objects.equals(updateVersion, originalVersion), 
            "Outdated instance to update"
        );
    }
}