Package org.hibernate.ogm.datastore.mongodb.dialect.impl

Examples of org.hibernate.ogm.datastore.mongodb.dialect.impl.MongoDBTupleSnapshot

308
309
310
311
312
313
314
315
316
317
318
    }
    return dbObject;
  }

  private DBObject objectForUpdate(Tuple tuple, EntityKey key, DBObject idObject) {
    MongoDBTupleSnapshot snapshot = (MongoDBTupleSnapshot) tuple.getSnapshot();

    BasicDBObject updater = new BasicDBObject();
    for ( TupleOperation operation : tuple.getOperations() ) {
      String column = operation.getColumn();
      if ( notInIdField( snapshot, column ) ) {
View Full Code Here
726
727
728
729
730
731
732
733
734
735
736
737
738
739
  }

  private void executeBatchUpdate(Map<DBCollection, BatchInsertionTask> inserts, UpdateTupleOperation tupleOperation) {
    EntityKey entityKey = tupleOperation.getEntityKey();
    Tuple tuple = tupleOperation.getTuple();
    MongoDBTupleSnapshot snapshot = (MongoDBTupleSnapshot) tupleOperation.getTuple().getSnapshot();
    WriteConcern writeConcern = getWriteConcern( tupleOperation.getTupleContext() );

    if ( INSERT == snapshot.getOperationType() && columnNamesAllowBatchInsert( tupleOperation ) ) {
      prepareForInsert( inserts, snapshot, entityKey, tuple, writeConcern );
    }
    else {
      // Object already exists in the db or has invalid fields:
      updateTuple( tuple, entityKey, tupleOperation.getTupleContext() );
View Full Code Here
90
91
92
93
94
95
96
          keyMetaData.getTable(),
          keyMetaData.getColumnNames(),
          new Object[] { dbObject.get( MongoDBDialect.ID_FIELDNAME ) }
          );

      return new Tuple( new MongoDBTupleSnapshot( dbObject, rowKey, SnapshotType.SELECT) );
    }
View Full Code Here
861
862
863
864
865
866
867
    }

    @Override
    public Tuple next() {
      DBObject dbObject = cursor.next();
      return new Tuple( new MongoDBTupleSnapshot( dbObject, metadata ) );
    }
View Full Code Here
597
598
599
600
601
602
603
604
605
  public void forEachTuple(Consumer consumer, EntityKeyMetadata... entityKeyMetadatas) {
    DB db = provider.getDatabase();
    for ( EntityKeyMetadata entityKeyMetadata : entityKeyMetadatas ) {
      DBCollection collection = db.getCollection( entityKeyMetadata.getTable() );
      for ( DBObject dbObject : collection.find() ) {
        consumer.consume( new Tuple( new MongoDBTupleSnapshot( dbObject, entityKeyMetadata) ) );
      }
    }
  }
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
  @Override
  public Tuple getTuple(EntityKey key, TupleContext tupleContext) {
    DBObject found = this.getObject( key, tupleContext );
    if ( found != null ) {
      return new Tuple( new MongoDBTupleSnapshot( found, key, UPDATE ) );
    }
    else if ( isInTheQueue( key, tupleContext ) ) {
      // The key has not been inserted in the db but it is in the queue
      return new Tuple( new MongoDBTupleSnapshot( prepareIdObject( key ), key, INSERT ) );
    }
    else {
      return null;
    }
  }
View Full Code Here
160
161
162
163
164
165
166
  }

  @Override
  public Tuple createTuple(EntityKey key) {
    DBObject toSave = this.prepareIdObject( key );
    return new Tuple( new MongoDBTupleSnapshot( toSave, key, SnapshotType.INSERT ) );
  }
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
    getCollection( key ).update( idObject, updater, true, false );
  }

  // Creates a dbObject that can be pass to the mongoDB batch insert function
  private DBObject objectForInsert(Tuple tuple, EntityKey key, BasicDBObject dbObject) {
    MongoDBTupleSnapshot snapshot = (MongoDBTupleSnapshot) tuple.getSnapshot();
    for ( TupleOperation operation : tuple.getOperations() ) {
      String column = operation.getColumn();
      if ( notInIdField( snapshot, column ) ) {
        switch ( operation.getType() ) {
          case PUT_NULL:
View Full Code Here
286
287
288
289
290
291
292
293
294
295
296
    }
    return dbObject;
  }

  private DBObject objectForUpdate(Tuple tuple, EntityKey key, DBObject idObject) {
    MongoDBTupleSnapshot snapshot = (MongoDBTupleSnapshot) tuple.getSnapshot();

    BasicDBObject updater = new BasicDBObject();
    for ( TupleOperation operation : tuple.getOperations() ) {
      String column = operation.getColumn();
      if ( notInIdField( snapshot, column ) ) {
View Full Code Here
704
705
706
707
708
709
710
711
712
713
714
715
  }

  private void executeBatchUpdate(Map<DBCollection, Map<DBObject, DBObject>> inserts, UpdateTupleOperation tupleOperation) {
    EntityKey entityKey = tupleOperation.getEntityKey();
    Tuple tuple = tupleOperation.getTuple();
    MongoDBTupleSnapshot snapshot = (MongoDBTupleSnapshot) tupleOperation.getTuple().getSnapshot();
    if ( INSERT == snapshot.getOperationType() && columnNamesAllowBatchInsert( tupleOperation ) ) {
      prepareForInsert( inserts, snapshot, entityKey, tuple );
    }
    else {
      // Object already exists in the db or has invalid fields:
      updateTuple( tuple, entityKey );
View Full Code Here
TOP

Related Classes of org.hibernate.ogm.datastore.mongodb.dialect.impl.MongoDBTupleSnapshot

  • org.hibernate.ogm.datastore.mongodb.impl.MongoDBResultTupleIterable$MongoDBResultsCursorIterator
  • org.hibernate.ogm.datastore.mongodb.MongoDBDialect
  • org.hibernate.ogm.datastore.mongodb.MongoDBDialect$MongoDBResultsCursor
  • org.hibernate.ogm.datastore.mongodb.test.loading.LoadSelectedColumnsCollectionTest
    • 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.