diff options
Diffstat (limited to 'sandbox/rfeng/helloworld-jsp-google-appengine/src/org/apache/tuscany/sca/gae/services/DatastoreServiceImpl.java')
-rw-r--r-- | sandbox/rfeng/helloworld-jsp-google-appengine/src/org/apache/tuscany/sca/gae/services/DatastoreServiceImpl.java | 130 |
1 files changed, 130 insertions, 0 deletions
diff --git a/sandbox/rfeng/helloworld-jsp-google-appengine/src/org/apache/tuscany/sca/gae/services/DatastoreServiceImpl.java b/sandbox/rfeng/helloworld-jsp-google-appengine/src/org/apache/tuscany/sca/gae/services/DatastoreServiceImpl.java new file mode 100644 index 0000000000..5d58358b76 --- /dev/null +++ b/sandbox/rfeng/helloworld-jsp-google-appengine/src/org/apache/tuscany/sca/gae/services/DatastoreServiceImpl.java @@ -0,0 +1,130 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +package org.apache.tuscany.sca.gae.services; + +import java.util.Collection; +import java.util.List; +import java.util.Map; + +import org.oasisopen.sca.annotation.Scope; +import org.oasisopen.sca.annotation.Service; + +import com.google.appengine.api.datastore.DatastoreService; +import com.google.appengine.api.datastore.DatastoreServiceFactory; +import com.google.appengine.api.datastore.Entity; +import com.google.appengine.api.datastore.EntityNotFoundException; +import com.google.appengine.api.datastore.Key; +import com.google.appengine.api.datastore.KeyRange; +import com.google.appengine.api.datastore.PreparedQuery; +import com.google.appengine.api.datastore.Query; +import com.google.appengine.api.datastore.Transaction; + +/** + * + */ +@Service(DatastoreService.class) +@Scope("COMPOSITE") +public class DatastoreServiceImpl implements DatastoreService { + private DatastoreService delegate; + + public void init() { + delegate = DatastoreServiceFactory.getDatastoreService(); + } + + public KeyRange allocateIds(Key parent, String kind, long num) { + return delegate.allocateIds(parent, kind, num); + } + + public KeyRange allocateIds(String kind, long num) { + return delegate.allocateIds(kind, num); + } + + public Transaction beginTransaction() { + return delegate.beginTransaction(); + } + + public void delete(Iterable<Key> keys) { + delegate.delete(keys); + } + + public void delete(Key... keys) { + delegate.delete(keys); + } + + public void delete(Transaction txn, Iterable<Key> keys) { + delegate.delete(txn, keys); + } + + public void delete(Transaction txn, Key... keys) { + delegate.delete(txn, keys); + } + + public Map<Key, Entity> get(Iterable<Key> keys) { + return delegate.get(keys); + } + + public Entity get(Key key) throws EntityNotFoundException { + return delegate.get(key); + } + + public Map<Key, Entity> get(Transaction txn, Iterable<Key> keys) { + return delegate.get(txn, keys); + } + + public Entity get(Transaction txn, Key key) throws EntityNotFoundException { + return delegate.get(txn, key); + } + + public Collection<Transaction> getActiveTransactions() { + return delegate.getActiveTransactions(); + } + + public Transaction getCurrentTransaction() { + return delegate.getCurrentTransaction(); + } + + public Transaction getCurrentTransaction(Transaction returnedIfNoTxn) { + return delegate.getCurrentTransaction(returnedIfNoTxn); + } + + public PreparedQuery prepare(Query query) { + return delegate.prepare(query); + } + + public PreparedQuery prepare(Transaction txn, Query query) { + return delegate.prepare(txn, query); + } + + public Key put(Entity entity) { + return delegate.put(entity); + } + + public List<Key> put(Iterable<Entity> entities) { + return delegate.put(entities); + } + + public Key put(Transaction txn, Entity entity) { + return delegate.put(txn, entity); + } + + public List<Key> put(Transaction txn, Iterable<Entity> entities) { + return delegate.put(txn, entities); + } +} |