Package org.apache.isis.objectstore.nosql.db

Examples of org.apache.isis.objectstore.nosql.db.StateReader

118
119
120
121
122
123
124
125
        // assertEquals(null, reader.readField("field-4"));
    }

    @Test
    public void readAggregate() throws Exception {
        final StateReader aggregate = reader.readAggregate("aggregate");
        assertEquals("com.package.ClassName:#2~com.package.AggregatedClassName:#3", aggregate.readOid());
    }
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
    private List<ObjectAdapter> findDefaultr(PersistenceQuery persistenceQuery) {
        final List<ObjectAdapter> instances = Lists.newArrayList();
        final ObjectSpecification specification = persistenceQuery.getSpecification();
        final Iterator<StateReader> instanceData = database.instancesOf(specification.getSpecId());
        while (instanceData.hasNext()) {
            final StateReader reader = instanceData.next();
            final ObjectAdapter instance = objectReader.load(reader, versionCreator, availableDataEncrypters);
            instances.add(instance);
        }
        return instances;
    }
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
    }
   
    private void appendPatternInstances(final PersistenceQueryFindByPattern persistenceQuery, final ObjectSpecification specification, final List<ObjectAdapter> instances) {     
        final Iterator<StateReader> instanceData = database.instancesOf(specification.getSpecId(), persistenceQuery.getPattern());
        while (instanceData.hasNext()) {
            final StateReader reader = instanceData.next();
            final ObjectAdapter instance = objectReader.load(reader, versionCreator, availableDataEncrypters);
            instances.add(instance);
        }
        for (final ObjectSpecification spec : specification.subclasses()) {
            appendPatternInstances(persistenceQuery, spec, instances);
View Full Code Here
179
180
181
182
183
184
185
186
187
188
189
    }

    private void appendInstances(final PersistenceQuery persistenceQuery, final ObjectSpecification specification, final List<ObjectAdapter> instances) {     
        final Iterator<StateReader> instanceData = database.instancesOf(specification.getSpecId());
        while (instanceData.hasNext()) {
            final StateReader reader = instanceData.next();
            final ObjectAdapter instance = objectReader.load(reader, versionCreator, availableDataEncrypters);
           
            // TODO deal with this natively
            if (persistenceQuery instanceof PersistenceQueryBuiltIn) {
                if (!((PersistenceQueryBuiltIn) persistenceQuery).matches(instance)) {
View Full Code Here
201
202
203
204
205
206
207
208
    @Override
    public ObjectAdapter loadInstanceAndAdapt(final TypedOid oid) {
        final String key = keyCreator.getIdentifierForPersistentRoot(oid);
        final ObjectSpecification objectSpec = getSpecificationLookup().lookupBySpecId(oid.getObjectSpecId());
        final StateReader reader = database.getInstance(key, objectSpec.getSpecId());
        return objectReader.load(reader, versionCreator, availableDataEncrypters);
    }
View Full Code Here
233
234
235
236
237
238
239
240
241
    public void resolveImmediately(final ObjectAdapter adapter) {
        final Oid oid = adapter.getOid();
        if (!(oid instanceof AggregatedOid)) {
            final ObjectSpecification objectSpec = adapter.getSpecification();
            final String key = keyCreator.getIdentifierForPersistentRoot(oid);
            final StateReader reader = database.getInstance(key, objectSpec.getSpecId());
            objectReader.update(reader, versionCreator, availableDataEncrypters, adapter);
        }
    }
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
        }
    }

    private void readAggregate(final StateReader reader, final DataEncryption dataEncrypter, final OneToOneAssociation association, final ObjectAdapter parentAdapter) {
        final String id = association.getId();
        final StateReader aggregateReader = reader.readAggregate(id);
       
        final ObjectAdapter fieldObject;
        if (aggregateReader != null) {
            final String oidStr = aggregateReader.readOid();
            final AggregatedOid aggregatedOid = getOidMarshaller().unmarshal(oidStr, AggregatedOid.class);
            fieldObject = restoreAggregatedObject(aggregateReader, aggregatedOid, dataEncrypter);
        } else {
            fieldObject = null;
        }
View Full Code Here
TOP

Related Classes of org.apache.isis.objectstore.nosql.db.StateReader

  • org.apache.isis.objectstore.nosql.db.file.JsonStateReaderTest
  • org.apache.isis.objectstore.nosql.NoSqlObjectStore
  • org.apache.isis.objectstore.nosql.ObjectReader
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.