Examples of com.google.apphosting.api.DatastorePb.PutRequest.addEntity()

Package com.google.apphosting.api.DatastorePb

Class com.google.apphosting.api.DatastorePb.PutRequest

Examples of com.google.apphosting.api.DatastorePb.PutRequest.addEntity()

com.google.apphosting.api.DatastorePb.PutRequest.addEntity()

            throw new IllegalStateException("The transaction must be active.");
        }
        assignKeyIfNecessary(entity);
        EntityProto entityProto = EntityTranslator.convertToPb(entity);
        PutRequest req = createPutRequest(tx);
        req.addEntity(entityProto);
        putUsingLowerApi(req);
        return entity.getKey();
    }


    /**

View Full Code Here

                || req.entitySize() >= MAX_NUMBER_OF_ENTITIES) {
                putUsingLowerApi(req);
                req = createPutRequest(tx);
                totalSize = 0;
            }
            req.addEntity(e);
            totalSize += size + EXTRA_SIZE;
        }
        if (req.entitySize() > 0) {
            putUsingLowerApi(req);
        }

View Full Code Here

            List<Key> deleteList =
                (List<Key>) entity.getProperty(DELETE_LIST_PROPERTY);
            List<Entity> putEntities = new ArrayList<Entity>();
            if (putList != null) {
                for (Blob blob : putList) {
                    EntityProto proto = putReq.addEntity();
                    proto.mergeFrom(blob.getBytes());
                    putEntities.add(EntityTranslator.createFromPb(proto));
                }
            }
            if (putEntities.size() > 0) {

View Full Code Here

        encodedReqSize = baseEncodedReqSize;
        req = baseReq.clone();
      }


      encodedReqSize += encodedEntitySize;
      req.addEntity(proto);
    }


    if (req.entitySize() > 0) {
      futures.add(makeAsyncCall(apiConfig, "Put", req, new PutResponse()));
    }

View Full Code Here

    public void datastorePutAsync() throws Exception {
        tester.setUp();
        Environment env = ApiProxy.getCurrentEnvironment();
        Delegate<Environment> delegate = ApiProxy.getDelegate();
        PutRequest reqPb = new PutRequest();
        reqPb.addEntity(EntityTranslator.convertToPb(new Entity("Hoge")));
        Future<byte[]> future =
            delegate.makeAsyncCall(
                env,
                AppEngineTester.DATASTORE_SERVICE,
                AppEngineTester.PUT_METHOD,

View Full Code Here

            List<Key> deleteList =
                (List<Key>) entity.getProperty(DELETE_LIST_PROPERTY);
            List<Entity> putEntities = new ArrayList<Entity>();
            if (putList != null) {
                for (Blob blob : putList) {
                    EntityProto proto = putReq.addEntity();
                    proto.mergeFrom(blob.getBytes());
                    putEntities.add(EntityTranslator.createFromPb(proto));
                }
            }
            if (putEntities.size() > 0) {

View Full Code Here

TOP

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.