{"id":376,"date":"2009-07-28T14:33:00","date_gmt":"2009-07-28T14:33:00","guid":{"rendered":"http:\/\/www.tutego.de\/blog\/javainsel\/?p=376"},"modified":"2009-07-28T14:33:00","modified_gmt":"2009-07-28T14:33:00","slug":"java-datastore-api-fur-die-google-app-engine","status":"publish","type":"post","link":"https:\/\/www.tutego.de\/blog\/javainsel\/2009\/07\/java-datastore-api-fur-die-google-app-engine\/","title":{"rendered":"Java Datastore API f\u00fcr die Google App Engine"},"content":{"rendered":"

Um in der Google Cloud Daten zu speichern bietet Google drei API an: JPA, JDO und eine Low-Level-API. Infos dazu gibt liefert http:\/\/code.google.com\/intl\/de\/appengine\/docs\/java\/datastore\/. JPA<\/a> und JDO basieren im Kern auf der Low-Level API, die auf die http:\/\/en.wikipedia.org\/wiki\/BigTable<\/a> zur\u00fcckgreift.<\/p>\n

F\u00fcr JPA und JDO gibt es selbst von Google viele Beispiele, aber die Low-Level-API ist nicht so gut dokumentiert und selbst das Beispielprogramm in der JavaDoc enth\u00e4lt Fehler. Zeit daher, ein sehr einfaches Beispiel mit einer 1:n Relationen anzugehen.<\/p>\n

Im Mittelpunkt der API steht der DatastoreService, der ein bisschen an den EntityManager von JPA erinnert. Er bietet Methoden f\u00fcr die CRUD-Operationen. Mein Beispiel geht schon ein bisschen \u201cpseudo-ORM\u201d an die Aufgabe ran, einer Person Nachrichten zuordnen zu k\u00f6nnen:<\/p>\n

Die Personen-Klasse: <\/p>\n

package com.tutego.server.entity; <\/p>\n

import java.util.ArrayList;
import java.util.List; <\/p>\n

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.Query; <\/p>\n

public class Person
{
  private final static String ENTITY_NAME = „Person“;
  Entity personEntity; <\/p>\n

  public enum Gender
  {
    MALE, FEMALE
  } <\/p>\n

  public Person()
  {
    personEntity = new Entity( ENTITY_NAME );
  } <\/p>\n

  private Person( Key key )
  {
    try
    {
      personEntity = DatastoreServiceFactory.getDatastoreService().get( key );
    }
    catch ( EntityNotFoundException e )
    {
    }
  } <\/p>\n

  private Person( Entity entity )
  {
    personEntity = entity;
  } <\/p>\n

  public static Person get( Key key )
  {
    return new Person( key );
  } <\/p>\n

  public void setUsername( String username )
  {
    personEntity.setProperty( „username“, username );
  } <\/p>\n

  public String getUsername()
  {
    return personEntity.getProperty( „username“ ).toString();
  } <\/p>\n

  public void setGender( Gender gender )
  {
    personEntity.setProperty( „gender“, gender.toString() );
  } <\/p>\n

  public Gender getGender()
  {
    return Gender.valueOf( personEntity.getProperty( „gender“ ).toString() );
  } <\/p>\n

  public Key put()
  {
    return DatastoreServiceFactory.getDatastoreService().put( personEntity );
  } <\/p>\n

  public static void deleteAll()
  {
    Query deleteAllQuery = new Query( ENTITY_NAME ); <\/p>\n

    for ( Entity entity : DatastoreServiceFactory.getDatastoreService().prepare( deleteAllQuery ).asIterable() )
      DatastoreServiceFactory.getDatastoreService().delete( entity.getKey() );
  } <\/p>\n

  private static List<Person> executeQuery( Query query )
  {
    List<Person> result = new ArrayList<Person>();
    for ( Entity entity : DatastoreServiceFactory.getDatastoreService().prepare( query ).asIterable() )
      result.add( new Person( entity ) );
    return result; 
  } <\/p>\n

  public static List<Person> findAllPersons()
  {
    Query query = new Query( ENTITY_NAME ); <\/p>\n

    return executeQuery( query );
  } <\/p>\n

  public static List<Person> findPersonByGender( Gender gender )
  {
    Query query = new Query( ENTITY_NAME );
    query.addFilter( „gender“, Query.FilterOperator.EQUAL, gender.toString() ); <\/p>\n

    return executeQuery( query );
  } <\/p>\n

  @Override
  public String toString()
  {
    return String.format( „Person[%s,%s]“, getUsername(), getGender() );
  }
} <\/p>\n

Die Nachrichten-Klasse:<\/p>\n

package com.tutego.server.entity; <\/p>\n

import java.util.ArrayList;
import java.util.Date;
import java.util.List; <\/p>\n

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.Query; <\/p>\n

public class Message
{
  private final static String ENTITY_NAME = „Message“; <\/p>\n

  private Entity messageEntity; <\/p>\n

  public Message()
  {
    messageEntity = new Entity( ENTITY_NAME );
  } <\/p>\n

  private Message( Key key )
  {
    try
    {
      messageEntity = DatastoreServiceFactory.getDatastoreService().get( key );
    }
    catch ( EntityNotFoundException e )
    {
    }
  } <\/p>\n

  private Message( Entity entity )
  {
    messageEntity = entity;
  } <\/p>\n

  public static Message get( Key key )
  {
    return new Message( key );
  } <\/p>\n

  public void setText( String text )
  {
    messageEntity.setProperty( „text“, text );
  } <\/p>\n

  public String getText()
  {
    return messageEntity.getProperty( „text“ ).toString();
  } <\/p>\n

  public void setCreationTime( Date d )
  {
    messageEntity.setProperty( „creationtime“, „“ + d.getTime() );
  } <\/p>\n

  public Date getCreationTime()
  {
    return new Date( Long.parseLong( messageEntity.getProperty( „creationtime“ ).toString() ) );
  } <\/p>\n

  public void setReceiver( Person p )
  {
    messageEntity.setProperty( „person_fk“, p.personEntity.getKey() );
  } <\/p>\n

  public Key put()
  {
    return DatastoreServiceFactory.getDatastoreService().put( messageEntity );
  } <\/p>\n

  private static List<Message> executeQuery( Query query )
  {
    List<Message> result = new ArrayList<Message>(); <\/p>\n

    for ( Entity entity : DatastoreServiceFactory.getDatastoreService().prepare( query ).asIterable() )
      result.add( new Message( entity ) );
    return result; 
  } <\/p>\n

  public static List<Message> findMessagesForPerson( Person p )
  {
    Query query = new Query( ENTITY_NAME );
    query.addFilter( „person_fk“, Query.FilterOperator.EQUAL, p.personEntity.getKey() ); <\/p>\n

    return executeQuery( query );
  } <\/p>\n

  @Override
  public String toString()
  {
    return String.format( „Message[%s,%s]“, getCreationTime(), getText() );
  }
} <\/p>\n

Getestet werden soll das ganze in einer einfachen Server-Funktion: <\/p>\n

StringWriter sw = new StringWriter();
PrintWriter out = new PrintWriter( sw ); <\/p>\n

\/\/ Insert new entity <\/p>\n

Person p1 = new Person();
p1.setUsername( „chris“ );
p1.setGender( Person.Gender.MALE );
Key key1 = p1.put(); <\/p>\n

out.println( „* Key f\u00fcr erste Person “ + p1 );
out.println( KeyFactory.keyToString( key1 ) ); <\/p>\n

Person p2 = new Person();
p2.setUsername( „pallas“ );
p2.setGender( Person.Gender.FEMALE );
p2.put(); <\/p>\n

Person p3 = new Person();
p3.setUsername( „tina“ );
p3.setGender( Person.Gender.FEMALE );
p3.put(); <\/p>\n

\/\/ Search for entity with a given key <\/p>\n

Person p = Person.get( key1 );
out.println( „* Suche mit Schl\u00fcssel “ + key1 );
out.println( p.getUsername() ); <\/p>\n

\/\/ Query <\/p>\n

List<Person> findAll = Person.findAllPersons();
out.println( „* Alle Personen“ );
out.println( findAll.toString() ); <\/p>\n

\/\/ Query <\/p>\n

List<Person> females = Person.findPersonByGender( Gender.FEMALE );
out.println( „* Alle Frauen:“ );
out.println( females.toString() ); <\/p>\n

Message msg1 = new Message();
msg1.setText( „Hallo Maus“ );
msg1.setCreationTime( new Date(1) );
msg1.setReceiver( p );
msg1.put(); <\/p>\n

Message msg2 = new Message();
msg2.setText( „Hallo Ratte“ );
msg2.setCreationTime( new Date(2) );
msg2.setReceiver( p );
msg2.put(); <\/p>\n

out.println( „* Alle Nachrichten f\u00fcr “ + p );
out.println( Message.findMessagesForPerson( p ) );
out.println( „\\n“ ); <\/p>\n

\/\/ Clean up <\/p>\n

Person.deleteAll(); <\/p>\n

out.flush(); <\/p>\n

return sw.toString().replace( „\\n“, „<br\/>“ ); <\/p>\n

Als Ergebnis kommt HTML zur\u00fcck, was der Client zum Testen anschauen kann.<\/p>\n","protected":false},"excerpt":{"rendered":"

Um in der Google Cloud Daten zu speichern bietet Google drei API an: JPA, JDO und eine Low-Level-API. Infos dazu gibt liefert http:\/\/code.google.com\/intl\/de\/appengine\/docs\/java\/datastore\/. JPA und JDO basieren im Kern auf der Low-Level API, die auf die http:\/\/en.wikipedia.org\/wiki\/BigTable zur\u00fcckgreift. F\u00fcr JPA und JDO gibt es selbst von Google viele Beispiele, aber die Low-Level-API ist nicht so […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":"","_links_to":"","_links_to_target":""},"categories":[16],"tags":[],"class_list":["post-376","post","type-post","status-publish","format-standard","hentry","category-gwt"],"jetpack_featured_media_url":"","jetpack_sharing_enabled":true,"_links":{"self":[{"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/posts\/376","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/comments?post=376"}],"version-history":[{"count":0,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/posts\/376\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/media?parent=376"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/categories?post=376"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.tutego.de\/blog\/javainsel\/wp-json\/wp\/v2\/tags?post=376"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}