Package org.hibernate.ogm.model.key.spi

Examples of org.hibernate.ogm.model.key.spi.EntityKey

48
49
50
51
52
53
54
55
56
57
58
  @Override
  public void lock(Serializable id, Object version, Object object, int timeout, SessionImplementor session)
      throws StaleObjectStateException, JDBCException {
    AdvancedCache advCache = getProvider( session ).getCache( ENTITY_CACHE ).getAdvancedCache();
    EntityKey key = EntityKeyBuilder.fromData(
        ( (OgmEntityPersister) lockable).getRootEntityKeyMetadata(),
        identifierGridType,
        id,
        session );
    advCache.lock( key );
View Full Code Here
60
61
62
63
64
65
66
    String tableName = input.readUTF();
    String[] columnNames = (String[]) input.readObject();
    Object[] values = (Object[]) input.readObject();

    return new EntityKey( new EntityKeyMetadata( tableName, columnNames ), values );
  }
View Full Code Here
45
46
47
48
49
50
51
        id,
        identifierGridType,
        entityKeyMetadata.getColumnNames(),
        session
    );
    return new EntityKey( entityKeyMetadata, values );
  }
View Full Code Here
179
180
181
182
183
184
185
    return new EntityDocument( createEntityKey( "tableName", new String[] { "id", "name" }, new String[] { "1",
        "Andrea" } ) );
  }

  private EntityKey createEntityKey(String tableName, String[] columnNames, Object[] values) {
    return new EntityKey( new EntityKeyMetadata( tableName, columnNames ), values );
  }
View Full Code Here
800
801
802
803
804
805
806
807
808
809
810
      queue.close();
    }
  }

  private void executeBatchRemove(Map<DBCollection, BatchInsertionTask> inserts, RemoveTupleOperation tupleOperation) {
    EntityKey entityKey = tupleOperation.getEntityKey();
    DBCollection collection = getCollection( entityKey );
    BatchInsertionTask batchedInserts = inserts.get( collection );

    if ( batchedInserts != null && batchedInserts.containsKey( entityKey ) ) {
      batchedInserts.remove( entityKey );
View Full Code Here
813
814
815
816
817
818
819
820
821
822
823
      removeTuple( entityKey, tupleOperation.getTupleContext() );
    }
  }

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

    if ( INSERT == snapshot.getSnapshotType() ) {
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
  private AssociationKey getAssociationKey() {
    if ( associationKey == null ) {
      final Object[] columnValues = getKeyColumnValues();

      EntityKey ownerEntityKey;
      if ( key != null ) {
        ownerEntityKey = EntityKeyBuilder.fromPersister(
            (OgmEntityPersister) getHostingEntityPersister(),
            (Serializable) key,
            session );
      }
      else {
        ownerEntityKey  = new EntityKey(
            ((OgmEntityPersister) getHostingEntityPersister()).getEntityKeyMetadata(),
            columnValues
        );
      }
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
    transaction = session.beginTransaction();
    b = (Bookmark) session.get( Bookmark.class, b.getId() );

    //Check directly in the cache the values stored
    EntityKeyMetadata keyMetadata = new EntityKeyMetadata( "Bookmark", new String[]{ "id" } );
    EntityKey key = new EntityKey( keyMetadata, new Object[]{ "42" } );
    Map<String, Object> entity = extractEntityTuple( sessions, key );

    assertEquals( "Entity visits count incorrect", entity.get( "visits_count" ), "444" );
    assertEquals( "Entity serial number incorrect", entity.get( "serialNumber" ), serialNumber.toString() );
    assertEquals( "Entity URL incorrect", entity.get( "url" ), "http://www.hibernate.org/" );
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
  }

  @Override
  public void lock(Serializable id, Object version, Object object, int timeout, SessionImplementor session) throws StaleObjectStateException, JDBCException {
    MapDatastoreProvider dataStore = getProvider( session );
    EntityKey key = EntityKeyBuilder.fromData(
        ( (OgmEntityPersister) lockable).getRootEntityKeyMetadata(),
        identifierGridType,
        id,
        session );
    dataStore.writeLock( key, timeout );
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
  }

  @Override
  public void lock(Serializable id, Object version, Object object, int timeout, SessionImplementor session) throws StaleObjectStateException, JDBCException {
    MapDatastoreProvider dataStore = getProvider( session );
    EntityKey key = EntityKeyBuilder.fromData(
        ( (OgmEntityPersister) lockable ).getRootEntityKeyMetadata(),
        identifierGridType,
        id,
        session );
    dataStore.readLock( key, timeout );
View Full Code Here
TOP

Related Classes of org.hibernate.ogm.model.key.spi.EntityKey

  • org.hibernate.ogm.backendtck.loader.LoaderFromTupleTest
  • org.hibernate.ogm.backendtck.type.BuiltInTypeTest
  • org.hibernate.ogm.datastore.couchdb.test.dialect.backend.impl.CouchDBDatastoreTest
  • org.hibernate.ogm.datastore.couchdb.test.dialect.CouchDBDialectTest
  • org.hibernate.ogm.datastore.infinispan.dialect.impl.EntityKeyExternalizer
  • org.hibernate.ogm.datastore.infinispan.dialect.impl.InfinispanPessimisticWriteLockingStrategy
  • org.hibernate.ogm.datastore.infinispan.test.dialect.impl.EntityKeyExternalizerTest
  • org.hibernate.ogm.datastore.infinispan.test.dialect.impl.InfinispanDialectWithClusteredConfigurationTest
  • org.hibernate.ogm.datastore.map.impl.MapPessimisticReadLockingStrategy
  • org.hibernate.ogm.datastore.map.impl.MapPessimisticWriteLockingStrategy
    • 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.