1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2002, 2015 Oracle and/or its affiliates. All rights reserved.
*
*/
package com.sleepycat.persist.impl;
import java.lang.reflect.Array;
import java.util.Map;
import java.util.Set;
import com.sleepycat.persist.model.EntityModel;
import com.sleepycat.persist.raw.RawObject;
import java.util.IdentityHashMap;
/**
* An array of primitives having one dimension. Multidimensional arrays are
* handled by {@link ObjectArrayFormat}.
*
* @author Mark Hayes
*/
public class PrimitiveArrayFormat extends Format {
private static final long serialVersionUID = 8285299924106073591L;
private SimpleFormat componentFormat;
PrimitiveArrayFormat(Catalog catalog, Class type) {
super(catalog, type);
}
@Override
public boolean isArray() {
return true;
}
@Override
public int getDimensions() {
return 1;
}
@Override
public Format getComponentType() {
return componentFormat;
}
@Override
void collectRelatedFormats(Catalog catalog,
Map<String, Format> newFormats) {
/* Component type is simple and simple type formats are predefined. */
}
@Override
void initialize(Catalog catalog, EntityModel model, int initVersion) {
/*
* getExistingType is allowed (to support raw mode) because primitive
* arrays are always available in Java.
*/
componentFormat = (SimpleFormat)
catalog.getFormat(getExistingType().getComponentType().getName());
}
@Override
Object newArray(int len) {
return Array.newInstance(getType(), len);
}
@Override
public Object newInstance(EntityInput input, boolean rawAccess)
throws RefreshException {
int len = input.readArrayLength();
if (rawAccess) {
return new RawObject(this, new Object[len]);
} else {
return componentFormat.newPrimitiveArray(len, input);
}
}
@Override
public Object readObject(Object o, EntityInput input, boolean rawAccess)
throws RefreshException {
if (rawAccess) {
Object[] a = ((RawObject) o).getElements();
for (int i = 0; i < a.length; i += 1) {
a[i] = componentFormat.newInstance(input, true);
componentFormat.readObject(a[i], input, true);
}
}
/* Else, do nothing -- newInstance reads the value. */
return o;
}
@Override
void writeObject(Object o, EntityOutput output, boolean rawAccess)
throws RefreshException {
if (rawAccess) {
Object[] a = ((RawObject) o).getElements();
output.writeArrayLength(a.length);
for (int i = 0; i < a.length; i += 1) {
componentFormat.writeObject(a[i], output, true);
}
} else {
componentFormat.writePrimitiveArray(o, output);
}
}
@Override
Object convertRawObject(Catalog catalog,
boolean rawAccess,
RawObject rawObject,
IdentityHashMap converted)
throws RefreshException {
RawArrayInput input = new RawArrayInput
(catalog, rawAccess, converted, rawObject, componentFormat);
Object a = newInstance(input, rawAccess);
converted.put(rawObject, a);
return readObject(a, input, rawAccess);
}
@Override
void skipContents(RecordInput input) {
int len = input.readPackedInt();
componentFormat.skipPrimitiveArray(len, input);
}
@Override
void copySecMultiKey(RecordInput input, Format keyFormat, Set results) {
int len = input.readPackedInt();
componentFormat.copySecMultiKeyPrimitiveArray(len, input, results);
}
@Override
boolean evolve(Format newFormat, Evolver evolver) {
evolver.useOldFormat(this, newFormat);
return true;
}
}
|
