本文整理汇总了Java中com.google.cloud.datastore.Datastore类的典型用法代码示例。如果您正苦于以下问题：Java Datastore类的具体用法？Java Datastore怎么用？Java Datastore使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Datastore类属于com.google.cloud.datastore包，在下文中一共展示了Datastore类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: save
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@Override
public <S extends T> Iterable<S> save(Iterable<S> entities) {
Datastore datastore = this.datastoreOptions.getService();
List<FullEntity<? extends IncompleteKey>> buffer = new ArrayList<>();
for (S entity : entities) {
ID id = this.entityInformation.getId(entity);
Key key = getKey(id);
buffer.add(this.marshaller.toEntity(entity, key));
if (buffer.size() >= BUFFER_SIZE) {
datastore.put(buffer.toArray(new FullEntity[buffer.size()]));
buffer.clear();
}
}
if (buffer.size() > 0) {
datastore.put(buffer.toArray(new FullEntity[buffer.size()]));
}
return entities;
}
开发者ID:tkob，项目名称:spring-data-gclouddatastore，代码行数:23，代码来源:SimpleGcloudDatastoreRepository.java
示例2: deleteKeys
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
private void deleteKeys(Iterable<Key> keys) {
Datastore datastore = this.datastoreOptions.getService();
List<Key> buffer = new ArrayList<>(BUFFER_SIZE);
for (Key key : keys) {
buffer.add(key);
if (buffer.size() >= BUFFER_SIZE) {
datastore.delete(buffer.toArray(new Key[buffer.size()]));
buffer.clear();
}
}
if (buffer.size() > 0) {
datastore.delete(buffer.toArray(new Key[buffer.size()]));
}
}
开发者ID:tkob，项目名称:spring-data-gclouddatastore，代码行数:17，代码来源:SimpleGcloudDatastoreRepository.java
示例3: setAncestorFilter
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
private <U> void setAncestorFilter(StructuredQuery.Builder<U> queryBuilder) {
Datastore datastore = datastoreOptions.getService();
Deque<PathElement> ancestors = Context.getAncestors();
Deque<PathElement> init = new LinkedList<>();
init.addAll(ancestors);
PathElement last = init.pollLast();
if (last != null) {
KeyFactory keyFactory = datastore.newKeyFactory();
keyFactory.addAncestors(init).setKind(last.getKind());
Key key = last.hasId() ? keyFactory.newKey(last.getId())
: keyFactory.newKey(last.getName());
queryBuilder.setFilter(StructuredQuery.PropertyFilter.hasAncestor(key));
}
}
开发者ID:tkob，项目名称:spring-data-gclouddatastore，代码行数:17，代码来源:SimpleGcloudDatastoreRepository.java
示例4: getKey
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
private Key getKey(ID id) {
Datastore datastore = this.datastoreOptions.getService();
KeyFactory keyFactory = datastore.newKeyFactory().setKind(this.kind);
Iterable<PathElement> ancestors = Context.getAncestors();
keyFactory.addAncestors(ancestors);
Key key;
if (id instanceof Number) {
key = keyFactory.newKey(((Number) id).longValue());
}
else {
key = keyFactory.newKey(id.toString());
}
return key;
}
开发者ID:tkob，项目名称:spring-data-gclouddatastore，代码行数:17，代码来源:SimpleGcloudDatastoreRepository.java
示例5: setAncestorFilter
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
protected StructuredQuery.Filter setAncestorFilter(StructuredQuery.Filter filter) {
Datastore datastore = datastoreOptions.getService();
Deque<PathElement> ancestors = Context.getAncestors();
Deque<PathElement> init = new LinkedList<>();
init.addAll(ancestors);
PathElement last = init.pollLast();
if (last == null) {
return filter;
}
else {
KeyFactory keyFactory = datastore.newKeyFactory();
keyFactory.addAncestors(init).setKind(last.getKind());
Key key = last.hasId()
? keyFactory.newKey(last.getId()) : keyFactory.newKey(last.getName());
StructuredQuery.Filter ancestorFilter = StructuredQuery.PropertyFilter.hasAncestor(key);
if (filter == null) {
return ancestorFilter;
}
else {
return StructuredQuery.CompositeFilter.and(filter, ancestorFilter);
}
}
}
开发者ID:tkob，项目名称:spring-data-gclouddatastore，代码行数:26，代码来源:GcloudDatastoreQueryCreator.java
示例6: createEntityManager
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
/**
* Creates and returns an {@link EntityManager} using the specified connection parameters.
*
* @param parameters
* the connection parameters
* @return a new {@link EntityManager} created using the specified connection parameters.
* @throws EntityManagerException
* if any error occurs while creating the EntityManager.
*/
public EntityManager createEntityManager(ConnectionParameters parameters) {
try {
DatastoreOptions.Builder datastoreOptionsBuilder = DatastoreOptions.newBuilder();
datastoreOptionsBuilder.setHost(parameters.getServiceURL());
datastoreOptionsBuilder.setTransportOptions(getHttpTransportOptions(parameters));
String projectId = parameters.getProjectId();
if (!Utility.isNullOrEmpty(projectId)) {
datastoreOptionsBuilder.setProjectId(projectId);
}
String namespace = parameters.getNamespace();
if (namespace != null) {
datastoreOptionsBuilder.setNamespace(namespace);
}
datastoreOptionsBuilder.setCredentials(getCredentials(parameters));
Datastore datastore = datastoreOptionsBuilder.build().getService();
return new DefaultEntityManager(datastore);
} catch (Exception exp) {
throw new EntityManagerFactoryException(exp);
}
}
开发者ID:sai-pullabhotla，项目名称:catatumbo，代码行数:30，代码来源:EntityManagerFactory.java
示例7: testCreateEntityManager_GoodFilePath
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@Test
public void testCreateEntityManager_GoodFilePath() {
EntityManagerFactory emf = EntityManagerFactory.getInstance();
String projectId = System.getenv(TestUtils.ENV_PROJECT_ID);
String jsonFile = System.getenv(TestUtils.ENV_CREDENTIALS);
if (jsonFile == null) {
System.out.printf("Enviornment variable %s is not set, skipping the test case%n",
TestUtils.ENV_CREDENTIALS);
return;
}
EntityManager em = emf.createEntityManager(projectId, jsonFile);
DefaultEntityManager dem = (DefaultEntityManager) em;
Datastore ds = dem.getDatastore();
assertTrue(
ds.getOptions().getProjectId() != null && ds.getOptions().getProjectId().length() != 0
&& ds.getOptions().getNamespace().equals(""));
}
开发者ID:sai-pullabhotla，项目名称:catatumbo，代码行数:18，代码来源:EntityManagerFactoryTest.java
示例8: testCreateEntityManager_Namespace
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@Test
public void testCreateEntityManager_Namespace() {
EntityManagerFactory emf = EntityManagerFactory.getInstance();
try {
String projectId = System.getenv(TestUtils.ENV_PROJECT_ID);
String jsonFile = System.getenv(TestUtils.ENV_CREDENTIALS);
if (jsonFile == null) {
System.out.printf("Enviornment variable %s is not set, skipping the test case%n",
TestUtils.ENV_CREDENTIALS);
return;
}
EntityManager em = emf.createEntityManager(projectId, new File(jsonFile), "junit");
DefaultEntityManager dem = (DefaultEntityManager) em;
Datastore ds = dem.getDatastore();
assertTrue(
ds.getOptions().getProjectId() != null && ds.getOptions().getProjectId().length() != 0
&& ds.getOptions().getNamespace().equals("junit"));
} catch (Exception exp) {
System.out.println(exp);
throw exp;
}
}
开发者ID:sai-pullabhotla，项目名称:catatumbo，代码行数:23，代码来源:EntityManagerFactoryTest.java
示例9: tearDownClass
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@AfterClass
public static void tearDownClass() {
// Clear the datastore
Datastore datastore = DatastoreOptions.getDefaultInstance().getService();
Batch batch = datastore.newBatch();
StructuredQuery<Key> query = Query.newKeyQueryBuilder()
.setKind("Book3").build();
for (QueryResults<Key> keys = datastore.run(query); keys.hasNext(); ) {
batch.delete(keys.next());
}
batch.submit();
// Delete any objects in the bucket
Storage storage = StorageOptions.getDefaultInstance().getService();
Page<Blob> blobs = storage.list(System.getProperty("bookshelf.bucket"));
List<BlobId> blobIds = new ArrayList<BlobId>();
for (Blob b : blobs.iterateAll()) {
blobIds.add(b.getBlobId());
}
storage.delete(blobIds);
service.stop();
}
开发者ID:GoogleCloudPlatform，项目名称:getting-started-java，代码行数:24，代码来源:UserJourneyTestIT.java
示例10: tearDownClass
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@AfterClass
public static void tearDownClass() {
// Clear the datastore if we're not using the local emulator
if (!LOCAL_TEST) {
Datastore datastore = DatastoreOptions.getDefaultInstance().getService();
Batch batch = datastore.newBatch();
StructuredQuery<Key> query = Query.newKeyQueryBuilder()
.setKind("Book5").build();
for (QueryResults<Key> keys = datastore.run(query); keys.hasNext(); ) {
batch.delete(keys.next());
}
batch.submit();
}
service.stop();
}
开发者ID:GoogleCloudPlatform，项目名称:getting-started-java，代码行数:17，代码来源:UserJourneyTestIT.java
示例11: createAndStopService
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@AfterClass
public static void createAndStopService() {
service.stop();
// Clear the datastore if we're not using the local emulator
if (!LOCAL_TEST) {
Datastore datastore = DatastoreOptions.getDefaultInstance().getService();
Batch batch = datastore.newBatch();
StructuredQuery<Key> query = Query.newKeyQueryBuilder()
.setKind("Book2").build();
for (QueryResults<Key> keys = datastore.run(query); keys.hasNext(); ) {
batch.delete(keys.next());
}
batch.submit();
}
}
开发者ID:GoogleCloudPlatform，项目名称:getting-started-java，代码行数:17，代码来源:UserJourneyTestIT.java
示例12: tearDownClass
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@AfterClass
public static void tearDownClass() {
// Delete any objects in the bucket
Storage storage = StorageOptions.getDefaultInstance().getService();
Page<Blob> blobs = storage.list(System.getProperty("bookshelf.bucket"));
List<BlobId> blobIds = new ArrayList<BlobId>();
for (Blob b : blobs.iterateAll()) {
blobIds.add(b.getBlobId());
}
storage.delete(blobIds);
// Clear the datastore if we're not using the local emulator
if (!LOCAL_TEST) {
Datastore datastore = DatastoreOptions.getDefaultInstance().getService();
Batch batch = datastore.newBatch();
StructuredQuery<Key> query = Query.newKeyQueryBuilder()
.setKind("Book3").build();
for (QueryResults<Key> keys = datastore.run(query); keys.hasNext(); ) {
batch.delete(keys.next());
}
batch.submit();
}
service.stop();
}
开发者ID:GoogleCloudPlatform，项目名称:getting-started-java，代码行数:26，代码来源:UserJourneyTestIT.java
示例13: tearDownClass
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@AfterClass
public static void tearDownClass() {
// Clear the datastore if we're not using the local emulator
if (!LOCAL_TEST) {
Datastore datastore = DatastoreOptions.getDefaultInstance().getService();
Batch batch = datastore.newBatch();
StructuredQuery<Key> query = Query.newKeyQueryBuilder()
.setKind("Book4").build();
for (QueryResults<Key> keys = datastore.run(query); keys.hasNext(); ) {
batch.delete(keys.next());
}
batch.submit();
}
service.stop();
}
开发者ID:GoogleCloudPlatform，项目名称:getting-started-java，代码行数:17，代码来源:UserJourneyTestIT.java
示例14: save
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@Override
public void save(Message message) {
// Save message to "messages"
Datastore datastore = getDatastoreInstance();
Key key = datastore.allocateId(keyFactory.newKey());
Entity.Builder messageEntityBuilder = Entity.newBuilder(key)
.set("messageId", message.getMessageId());
if (message.getData() != null) {
messageEntityBuilder = messageEntityBuilder.set("data", message.getData());
}
if (message.getPublishTime() != null) {
messageEntityBuilder = messageEntityBuilder.set("publishTime", message.getPublishTime());
}
datastore.put(messageEntityBuilder.build());
}
开发者ID:GoogleCloudPlatform，项目名称:java-docs-samples，代码行数:19，代码来源:MessageRepositoryImpl.java
示例15: deleteAll
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@Override
public void deleteAll() {
Datastore datastore = this.datastoreOptions.getService();
KeyQuery query = getAllKeyQuery();
deleteKeys(new Iterable<Key>() {
@Override
public Iterator<Key> iterator() {
return datastore.run(query);
}
});
}
开发者ID:tkob，项目名称:spring-data-gclouddatastore，代码行数:12，代码来源:SimpleGcloudDatastoreRepository.java
示例16: findOne
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@Override
public T findOne(ID id) {
Datastore datastore = this.datastoreOptions.getService();
Entity entity = datastore.get(getKey(id));
if (entity == null) {
return null;
}
else {
return this.unmarshaller.unmarshal(entity,
this.entityInformation.getJavaType());
}
}
开发者ID:tkob，项目名称:spring-data-gclouddatastore，代码行数:14，代码来源:SimpleGcloudDatastoreRepository.java
示例17: getNamespaces
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
@Override
public QueryResponse<String> getNamespaces(DatastoreCursor fromCursor, int limit) {
try {
String query = "SELECT __key__ FROM " + ENTITY_NAMESPACES + " ORDER BY __key__";
if (limit > 0) {
query += " LIMIT @Limit";
}
query += " OFFSET @Offset";
GqlQuery.Builder<Key> gqlQueryBuilder = Query.newGqlQueryBuilder(ResultType.KEY, query);
if (limit > 0) {
gqlQueryBuilder.setBinding("Limit", limit);
}
gqlQueryBuilder.setBinding("Offset", Cursor.fromUrlSafe(fromCursor.getEncoded()));
GqlQuery<Key> gqlQuery = gqlQueryBuilder.build();
Datastore datastore = entityManager.getDatastore();
QueryResults<Key> results = datastore.run(gqlQuery);
DefaultQueryResponse<String> response = new DefaultQueryResponse<>();
List<String> namespaces = new ArrayList<>(Math.max(limit, 50));
response.setStartCursor(new DefaultDatastoreCursor(results.getCursorAfter().toUrlSafe()));
while (results.hasNext()) {
Key key = results.next();
String name = key.getName();
namespaces.add(name == null ? "" : name);
}
response.setResults(namespaces);
response.setEndCursor(new DefaultDatastoreCursor(results.getCursorAfter().toUrlSafe()));
return response;
} catch (DatastoreException exp) {
throw new EntityManagerException(exp);
}
}
开发者ID:sai-pullabhotla，项目名称:catatumbo，代码行数:32，代码来源:DefaultDatastoreMetadata.java
示例18: getEntityManager
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
public static EntityManager getEntityManager() throws FileNotFoundException {
if (isCI()) {
return getCIEntityManager();
}
ConnectionParameters parameters = new ConnectionParameters();
parameters.setServiceURL(System.getenv(ENV_SERVICE_URL));
parameters.setProjectId(System.getenv(ENV_PROJECT_ID));
parameters.setNamespace(System.getenv(ENV_NAMESPACE));
String jsonCredentialsPath = System.getenv(ENV_CREDENTIALS);
if (!Utility.isNullOrEmpty(jsonCredentialsPath)) {
parameters.setJsonCredentialsFile(jsonCredentialsPath);
}
String connectionTimeout = System.getenv(ENV_CONNECTION_TIMEOUT);
if (!Utility.isNullOrEmpty(connectionTimeout)) {
parameters.setConnectionTimeout(Integer.parseInt(connectionTimeout));
}
String readTimeout = System.getenv(ENV_READ_TIMEOUT);
if (!Utility.isNullOrEmpty(readTimeout)) {
parameters.setReadTimeout(Integer.parseInt(readTimeout));
}
System.out.println(parameters);
EntityManager em = EntityManagerFactory.getInstance().createEntityManager(parameters);
Datastore ds = ((DefaultEntityManager) em).getDatastore();
DatastoreOptions options = ds.getOptions();
HttpTransportOptions httpTransportOptions = (HttpTransportOptions) options
.getTransportOptions();
System.out.println("***************************");
System.out.println("DATASTORE INFORMATION");
System.out.printf("Host: %s%n", options.getHost());
System.out.printf("Project Id: %s%n", options.getProjectId());
System.out.printf("Namespace: %s%n", options.getNamespace());
System.out.printf("Credentials: %s%n", options.getCredentials());
System.out.printf("Connection Timeout: %d%n", httpTransportOptions.getConnectTimeout());
System.out.printf("Read Timeout: %d%n", httpTransportOptions.getReadTimeout());
System.out.println("***************************");
return em;
}
开发者ID:sai-pullabhotla，项目名称:catatumbo，代码行数:39，代码来源:TestUtils.java
示例19: testCreateDefaultEntityManager
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
/**
* This Test requires default project/auth set up using gcloud.
*/
@Test
public void testCreateDefaultEntityManager() {
if (TestUtils.isCI()) {
// TODO
return;
}
EntityManagerFactory emf = EntityManagerFactory.getInstance();
EntityManager em = emf.createDefaultEntityManager();
DefaultEntityManager dem = (DefaultEntityManager) em;
Datastore ds = dem.getDatastore();
assertTrue(
ds.getOptions().getProjectId() != null && ds.getOptions().getProjectId().length() != 0
&& ds.getOptions().getNamespace().equals(""));
}
开发者ID:sai-pullabhotla，项目名称:catatumbo，代码行数:18，代码来源:EntityManagerFactoryTest.java
示例20: testCreateDefaultEntityManager_Namespace
import com.google.cloud.datastore.Datastore; //导入依赖的package包/类
/**
* This Test requires default project/auth set up using gcloud.
*/
@Test
public void testCreateDefaultEntityManager_Namespace() {
if (TestUtils.isCI()) {
// TODO
return;
}
EntityManagerFactory emf = EntityManagerFactory.getInstance();
EntityManager em = emf.createDefaultEntityManager("junit");
DefaultEntityManager dem = (DefaultEntityManager) em;
Datastore ds = dem.getDatastore();
assertTrue(
ds.getOptions().getProjectId() != null && ds.getOptions().getProjectId().length() != 0
&& ds.getOptions().getNamespace().equals("junit"));
}
开发者ID:sai-pullabhotla，项目名称:catatumbo，代码行数:18，代码来源:EntityManagerFactoryTest.java
注：本文中的com.google.cloud.datastore.Datastore类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论