Skip to content

Commit 8d7cbfd

Browse files
committed
cleanup
1 parent 7d6639f commit 8d7cbfd

3 files changed

Lines changed: 19 additions & 23 deletions

File tree

cayenne-crypto/src/main/java/org/apache/cayenne/crypto/reader/CryptoRowReaderFactoryDecorator.java

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -65,21 +65,20 @@ public RowReader<?> rowReader(RSColumn[] columns, QueryMetadata metadata, DbAdap
6565

6666
@Override
6767
protected RowReader<?> scalarSegmentReader(RSColumn[] columns, QueryMetadata metadata, ScalarResultSegment segment) {
68-
RowReader<?> scalarRowReader = super.scalarSegmentReader(columns, metadata, segment);
69-
return new DecoratedScalarRowReader(columns[segment.getColumnOffset()], scalarRowReader);
68+
RowReader<?> reader = super.scalarSegmentReader(columns, metadata, segment);
69+
return new DecoratedScalarRowReader(columns[segment.getColumnOffset()], reader);
7070
}
7171

7272
@Override
7373
protected RowReader<?> entitySegmentReader(RSColumn[] columns, QueryMetadata metadata, EntityResultSegment segment) {
74-
RowReader<?> entityRowReader = super.entitySegmentReader(columns, metadata, segment);
75-
return new DecoratedEntityRowReader(columns, entityRowReader, segment);
74+
RowReader<?> reader = super.entitySegmentReader(columns, metadata, segment);
75+
return new DecoratedEntityRowReader(columns, reader, segment);
7676
}
7777

7878
@Override
79-
protected RowReader<?> fullRowReader(RSColumn[] columns, QueryMetadata metadata) {
80-
RowReader<?> fullRowReader = super
81-
.fullRowReader(columns, metadata);
82-
return new DecoratedFullRowReader(columns, fullRowReader);
79+
protected RowReader<?> noSegmentReader(RSColumn[] columns, QueryMetadata metadata) {
80+
RowReader<?> reader = super.noSegmentReader(columns, metadata);
81+
return new DecoratedFullRowReader(columns, reader);
8382
}
8483

8584
protected RSColumn[] encryptedColumns(RSColumn[] columns, ExtendedTypeMap typeMap) {

cayenne/src/main/java/org/apache/cayenne/access/jdbc/reader/DefaultRowReaderFactory.java

Lines changed: 8 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -42,23 +42,23 @@ public RowReader<?> rowReader(RSColumn[] columns, QueryMetadata metadata, DbAdap
4242

4343
List<Object> segments = metadata.getResultSetMapping();
4444
if (segments == null || segments.isEmpty()) {
45-
return fullRowReader(columns, metadata);
45+
return noSegmentReader(columns, metadata);
4646
}
4747

4848
if (metadata.isSingleResultSetMapping()) {
49-
return segmentRowReader(segments.getFirst(), columns, metadata);
49+
return segmentReader(segments.getFirst(), columns, metadata);
5050
}
5151

5252
int w = segments.size();
5353
RowReader<?>[] readers = new RowReader[w];
5454
for (int i = 0; i < w; i++) {
55-
readers[i] = segmentRowReader(segments.get(i), columns, metadata);
55+
readers[i] = segmentReader(segments.get(i), columns, metadata);
5656
}
5757

5858
return new CompoundRowReader(readers);
5959
}
6060

61-
private RowReader<?> segmentRowReader(Object segment, RSColumn[] columns, QueryMetadata metadata) {
61+
private RowReader<?> segmentReader(Object segment, RSColumn[] columns, QueryMetadata metadata) {
6262
return switch (segment) {
6363
case EntityResultSegment ers -> entitySegmentReader(columns, metadata, ers);
6464
case EmbeddableResultSegment ers -> embeddableSegmentReader(columns, ers);
@@ -131,13 +131,10 @@ protected RowReader<?> entitySegmentReader(RSColumn[] columns, QueryMetadata met
131131
return OffsetRowReader.of(relabeled, startIndex, segment.getClassDescriptor());
132132
}
133133

134-
protected RowReader<?> fullRowReader(RSColumn[] columns, QueryMetadata metadata) {
135-
136-
if (metadata.getPageSize() > 0) {
137-
return idReader(columns, metadata, null);
138-
}
139-
140-
return FullRowReader.of(columns, metadata);
134+
protected RowReader<?> noSegmentReader(RSColumn[] columns, QueryMetadata metadata) {
135+
return metadata.getPageSize() > 0
136+
? idReader(columns, metadata, null)
137+
: FullRowReader.of(columns, metadata);
141138
}
142139

143140
private RowReader<?> idReader(RSColumn[] columns, QueryMetadata metadata, EntityResultSegment segment) {

cayenne/src/main/java/org/apache/cayenne/access/jdbc/reader/OffsetRowReader.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -37,21 +37,21 @@ class OffsetRowReader implements RowReader<DataRow> {
3737
private final int offset;
3838
private final int mapCapacity;
3939

40-
// possible inherotance
41-
static RowReader<DataRow> of(RSColumn[] columns, int offset, ClassDescriptor cd) {
40+
// possible inheritance
41+
static OffsetRowReader of(RSColumn[] columns, int offset, ClassDescriptor cd) {
4242
String entityName = cd != null ? cd.getEntity().getName() : null;
4343
return cd != null && cd.hasSubclasses()
4444
? new InheritanceAwareOffsetRowReader(columns, offset, entityName, cd.getEntityInheritanceTree())
4545
: new OffsetRowReader(columns, offset, entityName);
4646
}
4747

4848
// fixed entity name, no inheritance
49-
static RowReader<DataRow> of(RSColumn[] columns, int offset, String entityName) {
49+
static OffsetRowReader of(RSColumn[] columns, int offset, String entityName) {
5050
return new OffsetRowReader(columns, offset, entityName);
5151
}
5252

5353
// no entity name, no inheritance
54-
static RowReader<DataRow> of(RSColumn[] columns, int offset) {
54+
static OffsetRowReader of(RSColumn[] columns, int offset) {
5555
return new OffsetRowReader(columns, offset, null);
5656
}
5757

0 commit comments

Comments
 (0)