Package com.google.appengine.api.datastore

Examples of com.google.appengine.api.datastore.Transaction.commit()

83
84
85
86
87
88
89
90
        Transaction tx = Datastore.beginTransaction();
        List<Key> keys = new ArrayList<Key>();
        keys.add(key);
        keys.addAll(Datastore.query(f, key).asKeyList());
        Datastore.delete(tx, keys);
        tx.commit();
    }
}
View Full Code Here
25
26
27
28
29
30
31
32
33
34
35
    }

    public void insert(Blog blog) {
        Transaction tx = Datastore.beginTransaction();
        Datastore.put(tx, blog);
        tx.commit();
    }

    public Blog update(Key key, Long version, Map<String, Object> input) {
        Transaction tx = Datastore.beginTransaction();
        Blog blog = Datastore.get(tx, b, key, version);
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
    public Blog update(Key key, Long version, Map<String, Object> input) {
        Transaction tx = Datastore.beginTransaction();
        Blog blog = Datastore.get(tx, b, key, version);
        BeanUtil.copy(input, blog);
        Datastore.put(tx, blog);
        tx.commit();
        return blog;
    }

    public void delete(Key key, Long version) {
        Transaction tx = Datastore.beginTransaction();
View Full Code Here
41
42
43
44
45
46
47
48
    public void delete(Key key, Long version) {
        Transaction tx = Datastore.beginTransaction();
        Blog blog = Datastore.get(tx, b, key, version);
        Datastore.delete(tx, blog.getKey());
        tx.commit();
    }
}
View Full Code Here
359
360
361
362
363
364
365
366
367
368
369
            Entity entity = DatastoreUtil.getOrNull(ds, tx, key);
            if (entity != null
                && globalTransactionKey.equals(entity
                    .getProperty(GLOBAL_TRANSACTION_KEY_PROPERTY))) {
                DatastoreUtil.delete(ds, tx, key);
                tx.commit();
            }
        } finally {
            if (tx.isActive()) {
                tx.rollback();
            }
View Full Code Here
286
287
288
289
290
291
292
293
294
295
296
        try {
            Lock lock = getOrNull(ds, tx, key);
            if (lock != null
                && globalTransactionKey.equals(lock.globalTransactionKey)) {
                DatastoreUtil.delete(ds, tx, key);
                tx.commit();
            }
        } finally {
            if (tx.isActive()) {
                tx.rollback();
            }
View Full Code Here
511
512
513
514
515
516
517
518
519
520
521
            Lock other = getOrNull(ds, tx, key);
            if (other != null) {
                verify(other);
            }
            DatastoreUtil.put(ds, tx, toEntity());
            tx.commit();
            return;
        } finally {
            if (tx.isActive()) {
                tx.rollback();
            }
View Full Code Here
546
547
548
549
550
551
552
553
554
555
556
            if (otherEntity != null) {
                Lock other = toLock(ds, otherEntity);
                verify(other);
            }
            DatastoreUtil.put(ds, tx, toEntity());
            tx.commit();
            return map;
        } finally {
            if (tx.isActive()) {
                tx.rollback();
            }
View Full Code Here
589
590
591
592
593
594
595
596
597
598
599
                }
                return;
            }
            gtx = new GlobalTransaction(ds, other.globalTransactionKey, false);
            GlobalTransaction.put(ds, tx, gtx);
            tx.commit();
        } catch (ConcurrentModificationException e) {
            throw createConcurrentModificationException(rootKey, e);
        } finally {
            if (tx.isActive()) {
                tx.rollback();
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
            KeyFactory.createKey(GlobalTransaction.KIND, 1);
        Boolean valid = false;
        GlobalTransaction gtx2 =
            new GlobalTransaction(ds, globalTransactionKey, valid);
        GlobalTransaction.put(ds, tx, gtx2);
        tx.commit();
        Entity entity = DatastoreUtil.get(ds, null, globalTransactionKey);
        assertThat(entity, is(notNullValue()));
        assertThat((Boolean) entity
            .getProperty(GlobalTransaction.VALID_PROPERTY), is(valid));
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.