doc/org.eclipse.emf.teneo.doc/tutorials/jpox/tutorial1/Tutorial1.java - teneo/org.eclipse.emf.teneo - Git at Google

 /**
  * <copyright>
  *
  * Copyright (c) 2005, 2006, 2007 Springsite BV (The Netherlands) and others
  * All rights reserved. This program and the accompanying materials
  * are made available under the terms of the Eclipse Public License v1.0
  * which accompanies this distribution, and is available at
  * http://www.eclipse.org/legal/epl-v10.html
  *
  * Contributors:
  *   Martin Taal
  * </copyright>
  *
  * $Id: Tutorial1.java,v 1.11 2007/02/05 20:12:02 mtaal Exp $
  */

 package jpoxtutorial;

 import java.io.IOException;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.Iterator;
 import java.util.Properties;

 import javax.jdo.Extent;
 import javax.jdo.PersistenceManager;
 import javax.jdo.Query;
 import javax.jdo.Transaction;

 import org.eclipse.emf.common.util.URI;
 import org.eclipse.emf.ecore.EPackage;
 import org.eclipse.emf.ecore.resource.Resource;
 import org.eclipse.emf.ecore.resource.ResourceSet;
 import org.eclipse.emf.ecore.resource.impl.ResourceSetImpl;
 import org.eclipse.example.library.Book;
 import org.eclipse.example.library.BookCategory;
 import org.eclipse.example.library.Library;
 import org.eclipse.example.library.LibraryFactory;
 import org.eclipse.example.library.LibraryPackage;
 import org.eclipse.example.library.Writer;
 import org.eclipse.example.library.impl.BookImpl;
 import org.eclipse.example.library.impl.LibraryImpl;
 import org.eclipse.example.library.impl.WriterImpl;
 import org.eclipse.emf.teneo.jpox.JpoxDataStore;
 import org.eclipse.emf.teneo.jpox.JpoxHelper;
 import org.eclipse.emf.teneo.jpox.resource.JPOXResource;
 import org.jpox.PMFConfiguration;

 /**
  * Tutorial
  *
  * @author <a href="mailto:mtaal@elver.org">Martin Taal</a>
  * @version $Revision: 1.11 $
  */
 public class Tutorial1 {

 	/**
 	 * @param args
 	 */
 	public static void main(String[] args) {

 		// At this position you can add your own specific types for jpox
 		// This should be done before creating the persistence manager factory, e.g.
 		// TypeManager.getTypeManager().addType(MyNiceType.class.getName(), MyNiceTypeMapping.class,
 		// MyNiceTypeWrapper.class);

 		// set the database connection info, PMFConfiguration is org.jpox.PMFConfiguration
 		Properties properties = new Properties();
 		properties.setProperty(PMFConfiguration.JDO_DATASTORE_DRIVERNAME_PROPERTY, "com.mysql.jdbc.Driver");
 		properties.setProperty(PMFConfiguration.JDO_DATASTORE_URL_PROPERTY, "jdbc:mysql://127.0.0.1:3306/mylibrary");
 		properties.setProperty(PMFConfiguration.JDO_DATASTORE_USERNAME_PROPERTY, "root");
 		properties.setProperty(PMFConfiguration.JDO_DATASTORE_PASSWORD_PROPERTY, "root");

 		// create/register the JpoxDataStore, set the db props and the epackages to persist, initialize creates
 		// the database
 		String pmfName = "MyPMF"; // the name of the JpoxDataStore
 		JpoxDataStore jpoxDataStore = JpoxHelper.INSTANCE.createRegisterDataStore(pmfName);
 		jpoxDataStore.setProperties(properties);
 		jpoxDataStore.setEPackages(new EPackage[] { LibraryPackage.eINSTANCE });
 		jpoxDataStore.initialize();

 		// create a persistence manager and a transaction
 		PersistenceManager pm = jpoxDataStore.getPMF().getPersistenceManager();
 		Transaction tx = pm.currentTransaction();

 		// start a transaction, create a library and make it persistent
 		tx.begin();
 		Library lib = LibraryFactory.eINSTANCE.createLibrary();
 		lib.setName("My Library");
 		pm.makePersistent(lib);

 		// create a writer
 		Writer writer = LibraryFactory.eINSTANCE.createWriter();
 		writer.setName("JRR Tolkien");

 		// and one of his books
 		Book book = LibraryFactory.eINSTANCE.createBook();
 		book.setAuthor(writer);
 		book.setPages(305);
 		book.setTitle("The Hobbit");
 		book.setCategory(BookCategory.SCIENCE_FICTION_LITERAL);

 		// add the writer/book to the library. The writer and book are automatically
 		// made persistent because they are added to the library which is already
 		// made persistent
 		lib.getWriters().add(writer);
 		lib.getBooks().add(book);

 		// at commit the objects will be present in the database
 		tx.commit();
 		pm.close(); // empty the cache

 		// at this point the database contains one library, one book and one writer
 		// Reopen the transaction and query for the library objects
 		pm = jpoxDataStore.getPMF().getPersistenceManager();
 		tx = pm.currentTransaction();
 		tx.begin();

 		// NOTE: here you see one drawback of the current JPOX implementation:
 		// for querying you require the concrete implementation instead of the
 		// interface!
 		// retrieve all LibraryImpl classes and subclasses.
 		Extent e = pm.getExtent(LibraryImpl.class, true);
 		Query q = pm.newQuery(e);

 		// there is only one library
 		Collection c = (Collection) q.execute();
 		lib = (Library) c.iterator().next();

 		// read the writer and book
 		writer = (Writer) lib.getWriters().get(0);
 		System.out.println(writer.getName());
 		book = (Book) lib.getBooks().get(0);
 		System.out.println(book.getTitle());

 		// show that the container is set
 		System.out.println(book.eContainer() == lib);
 		System.out.println(writer.getBooks().get(0) == book);

 		// Now add a new writer and book
 		Writer george = LibraryFactory.eINSTANCE.createWriter();
 		george.setName("G. Orwell");

 		// create a new book and set the writer and library
 		Book georgesBook = LibraryFactory.eINSTANCE.createBook();
 		georgesBook.setPages(250);
 		georgesBook.setTitle("1984");
 		georgesBook.setCategory(BookCategory.SCIENCE_FICTION_LITERAL);
 		georgesBook.setAuthor(george);

 		lib.getBooks().add(georgesBook);
 		lib.getWriters().add(george);

 		// and close of
 		tx.commit();
 		pm.close();

 		// reopen the pm/transaction
 		pm = jpoxDataStore.getPMF().getPersistenceManager();
 		tx = pm.currentTransaction();
 		tx.begin();

 		// retrieve all books
 		Query qry = pm.newQuery("SELECT FROM " + BookImpl.class.getName());
 		Collection coll = (Collection) qry.execute();
 		System.out.println(((Book) coll.iterator().next()).getTitle()); // show a title
 		System.out.println(((Book) coll.iterator().next()).getTitle()); // show a title

 		// retrieve a book which has a writer with the name of G. Orwell
 		qry = pm.newQuery("SELECT FROM " + BookImpl.class.getName() + " WHERE "
 				+ " title==\"1984\" && author == writ && writ.name == \"G. Orwell\" " + "VARIABLES "
 				+ WriterImpl.class.getName() + " writ");
 		coll = (Collection) qry.execute();
 		System.out.println(coll.size()); // should be 1
 		Book bk = (Book) coll.iterator().next();
 		System.out.println(bk.getTitle()); // should be 1984
 		System.out.println(bk.getAuthor().getName()); // should be G. Orwell

 		// read the library with a name ending on Library
 		qry = pm.newQuery("SELECT FROM " + LibraryImpl.class.getName() + " WHERE name.endsWith(\"Library\")");
 		coll = (Collection) qry.execute();
 		lib = (Library) coll.iterator().next();

 		qry = pm.newQuery("SELECT FROM " + JpoxHelper.INSTANCE.getInstanceClass(Book.class).getName() + " WHERE "
 				+ " title==\"1984\" && author == writ && writ.name == \"G. Orwell\" " + "VARIABLES "
 				+ WriterImpl.class.getName() + " writ");
 		System.err.println(((Collection) qry.execute()).size());

 		// retrieving all books
 		qry = pm.newQuery("SELECT FROM " + JpoxHelper.INSTANCE.getInstanceClass(Book.class).getName());
 		System.err.println(((Collection) qry.execute()).size());

 		// retrieving all libraries with a name ending on library
 		qry = pm.newQuery("SELECT FROM " + JpoxHelper.INSTANCE.getInstanceClass(Library.class).getName()
 				+ " WHERE name.endsWith(\"Library\")");
 		System.err.println(((Collection) qry.execute()).size());

 		// and really close of
 		tx.commit();
 		pm.close();

 		try {
 			String uriStr = "jpox://?" + JPOXResource.DS_NAME_PARAM + "=MyPMF";
 			final URI uri = URI.createURI(uriStr);
 			ResourceSet resourceSet = new ResourceSetImpl();
 			final Resource res = resourceSet.createResource(uri);

 			res.load(Collections.EMPTY_MAP);
 			Iterator it = res.getContents().iterator();
 			Library libTest;
 			while (it.hasNext()) {
 				libTest = (Library) it.next();
 				System.out.println(libTest.getName());
 			}

 			Library libNew = LibraryFactory.eINSTANCE.createLibrary();
 			libNew.setName("My Second Library");

 			// create a writer
 			Writer writerNew = LibraryFactory.eINSTANCE.createWriter();
 			writerNew.setName("I. Asimov");

 			// and one of his books
 			Book bookNew = LibraryFactory.eINSTANCE.createBook();
 			bookNew.setAuthor(writerNew);
 			bookNew.setPages(305);
 			bookNew.setTitle("Foundation and Empire");
 			bookNew.setCategory(BookCategory.SCIENCE_FICTION_LITERAL);

 			// add the writer/book to the library.
 			libNew.getWriters().add(writerNew);
 			libNew.getBooks().add(bookNew);

 			// Add the top-level object to the resource
 			res.getContents().add(libNew);

 			// and save them all
 			res.save(Collections.EMPTY_MAP);
 		} catch (IOException i) {
 			throw new RuntimeException("IOException " + i.getMessage(), i);
 		}

 		jpoxDataStore.close();
 	}
 }
	/**
	* <copyright>
	*
	* Copyright (c) 2005, 2006, 2007 Springsite BV (The Netherlands) and others
	* All rights reserved. This program and the accompanying materials
	* are made available under the terms of the Eclipse Public License v1.0
	* which accompanies this distribution, and is available at
	* http://www.eclipse.org/legal/epl-v10.html
	*
	* Contributors:
	* Martin Taal
	* </copyright>
	*
	* $Id: Tutorial1.java,v 1.11 2007/02/05 20:12:02 mtaal Exp $
	*/

	package jpoxtutorial;

	import java.io.IOException;
	import java.util.Collection;
	import java.util.Collections;
	import java.util.Iterator;
	import java.util.Properties;

	import javax.jdo.Extent;
	import javax.jdo.PersistenceManager;
	import javax.jdo.Query;
	import javax.jdo.Transaction;

	import org.eclipse.emf.common.util.URI;
	import org.eclipse.emf.ecore.EPackage;
	import org.eclipse.emf.ecore.resource.Resource;
	import org.eclipse.emf.ecore.resource.ResourceSet;
	import org.eclipse.emf.ecore.resource.impl.ResourceSetImpl;
	import org.eclipse.example.library.Book;
	import org.eclipse.example.library.BookCategory;
	import org.eclipse.example.library.Library;
	import org.eclipse.example.library.LibraryFactory;
	import org.eclipse.example.library.LibraryPackage;
	import org.eclipse.example.library.Writer;
	import org.eclipse.example.library.impl.BookImpl;
	import org.eclipse.example.library.impl.LibraryImpl;
	import org.eclipse.example.library.impl.WriterImpl;
	import org.eclipse.emf.teneo.jpox.JpoxDataStore;
	import org.eclipse.emf.teneo.jpox.JpoxHelper;
	import org.eclipse.emf.teneo.jpox.resource.JPOXResource;
	import org.jpox.PMFConfiguration;

	/**
	* Tutorial
	*
	* @author <a href="mailto:mtaal@elver.org">Martin Taal</a>
	* @version $Revision: 1.11 $
	*/
	public class Tutorial1 {

	/**
	* @param args
	*/
	public static void main(String[] args) {

	// At this position you can add your own specific types for jpox
	// This should be done before creating the persistence manager factory, e.g.
	// TypeManager.getTypeManager().addType(MyNiceType.class.getName(), MyNiceTypeMapping.class,
	// MyNiceTypeWrapper.class);

	// set the database connection info, PMFConfiguration is org.jpox.PMFConfiguration
	Properties properties = new Properties();
	properties.setProperty(PMFConfiguration.JDO_DATASTORE_DRIVERNAME_PROPERTY, "com.mysql.jdbc.Driver");
	properties.setProperty(PMFConfiguration.JDO_DATASTORE_URL_PROPERTY, "jdbc:mysql://127.0.0.1:3306/mylibrary");
	properties.setProperty(PMFConfiguration.JDO_DATASTORE_USERNAME_PROPERTY, "root");
	properties.setProperty(PMFConfiguration.JDO_DATASTORE_PASSWORD_PROPERTY, "root");

	// create/register the JpoxDataStore, set the db props and the epackages to persist, initialize creates
	// the database
	String pmfName = "MyPMF"; // the name of the JpoxDataStore
	JpoxDataStore jpoxDataStore = JpoxHelper.INSTANCE.createRegisterDataStore(pmfName);
	jpoxDataStore.setProperties(properties);
	jpoxDataStore.setEPackages(new EPackage[] { LibraryPackage.eINSTANCE });
	jpoxDataStore.initialize();

	// create a persistence manager and a transaction
	PersistenceManager pm = jpoxDataStore.getPMF().getPersistenceManager();
	Transaction tx = pm.currentTransaction();

	// start a transaction, create a library and make it persistent
	tx.begin();
	Library lib = LibraryFactory.eINSTANCE.createLibrary();
	lib.setName("My Library");
	pm.makePersistent(lib);

	// create a writer
	Writer writer = LibraryFactory.eINSTANCE.createWriter();
	writer.setName("JRR Tolkien");

	// and one of his books
	Book book = LibraryFactory.eINSTANCE.createBook();
	book.setAuthor(writer);
	book.setPages(305);
	book.setTitle("The Hobbit");
	book.setCategory(BookCategory.SCIENCE_FICTION_LITERAL);

	// add the writer/book to the library. The writer and book are automatically
	// made persistent because they are added to the library which is already
	// made persistent
	lib.getWriters().add(writer);
	lib.getBooks().add(book);

	// at commit the objects will be present in the database
	tx.commit();
	pm.close(); // empty the cache

	// at this point the database contains one library, one book and one writer
	// Reopen the transaction and query for the library objects
	pm = jpoxDataStore.getPMF().getPersistenceManager();
	tx = pm.currentTransaction();
	tx.begin();

	// NOTE: here you see one drawback of the current JPOX implementation:
	// for querying you require the concrete implementation instead of the
	// interface!
	// retrieve all LibraryImpl classes and subclasses.
	Extent e = pm.getExtent(LibraryImpl.class, true);
	Query q = pm.newQuery(e);

	// there is only one library
	Collection c = (Collection) q.execute();
	lib = (Library) c.iterator().next();

	// read the writer and book
	writer = (Writer) lib.getWriters().get(0);
	System.out.println(writer.getName());
	book = (Book) lib.getBooks().get(0);
	System.out.println(book.getTitle());

	// show that the container is set
	System.out.println(book.eContainer() == lib);
	System.out.println(writer.getBooks().get(0) == book);

	// Now add a new writer and book
	Writer george = LibraryFactory.eINSTANCE.createWriter();
	george.setName("G. Orwell");

	// create a new book and set the writer and library
	Book georgesBook = LibraryFactory.eINSTANCE.createBook();
	georgesBook.setPages(250);
	georgesBook.setTitle("1984");
	georgesBook.setCategory(BookCategory.SCIENCE_FICTION_LITERAL);
	georgesBook.setAuthor(george);

	lib.getBooks().add(georgesBook);
	lib.getWriters().add(george);

	// and close of
	tx.commit();
	pm.close();

	// reopen the pm/transaction
	pm = jpoxDataStore.getPMF().getPersistenceManager();
	tx = pm.currentTransaction();
	tx.begin();

	// retrieve all books
	Query qry = pm.newQuery("SELECT FROM " + BookImpl.class.getName());
	Collection coll = (Collection) qry.execute();
	System.out.println(((Book) coll.iterator().next()).getTitle()); // show a title
	System.out.println(((Book) coll.iterator().next()).getTitle()); // show a title

	// retrieve a book which has a writer with the name of G. Orwell
	qry = pm.newQuery("SELECT FROM " + BookImpl.class.getName() + " WHERE "
	+ " title==\"1984\" && author == writ && writ.name == \"G. Orwell\" " + "VARIABLES "
	+ WriterImpl.class.getName() + " writ");
	coll = (Collection) qry.execute();
	System.out.println(coll.size()); // should be 1
	Book bk = (Book) coll.iterator().next();
	System.out.println(bk.getTitle()); // should be 1984
	System.out.println(bk.getAuthor().getName()); // should be G. Orwell

	// read the library with a name ending on Library
	qry = pm.newQuery("SELECT FROM " + LibraryImpl.class.getName() + " WHERE name.endsWith(\"Library\")");
	coll = (Collection) qry.execute();
	lib = (Library) coll.iterator().next();

	qry = pm.newQuery("SELECT FROM " + JpoxHelper.INSTANCE.getInstanceClass(Book.class).getName() + " WHERE "
	+ " title==\"1984\" && author == writ && writ.name == \"G. Orwell\" " + "VARIABLES "
	+ WriterImpl.class.getName() + " writ");
	System.err.println(((Collection) qry.execute()).size());

	// retrieving all books
	qry = pm.newQuery("SELECT FROM " + JpoxHelper.INSTANCE.getInstanceClass(Book.class).getName());
	System.err.println(((Collection) qry.execute()).size());

	// retrieving all libraries with a name ending on library
	qry = pm.newQuery("SELECT FROM " + JpoxHelper.INSTANCE.getInstanceClass(Library.class).getName()
	+ " WHERE name.endsWith(\"Library\")");
	System.err.println(((Collection) qry.execute()).size());

	// and really close of
	tx.commit();
	pm.close();

	try {
	String uriStr = "jpox://?" + JPOXResource.DS_NAME_PARAM + "=MyPMF";
	final URI uri = URI.createURI(uriStr);
	ResourceSet resourceSet = new ResourceSetImpl();
	final Resource res = resourceSet.createResource(uri);

	res.load(Collections.EMPTY_MAP);
	Iterator it = res.getContents().iterator();
	Library libTest;
	while (it.hasNext()) {
	libTest = (Library) it.next();
	System.out.println(libTest.getName());
	}

	Library libNew = LibraryFactory.eINSTANCE.createLibrary();
	libNew.setName("My Second Library");

	// create a writer
	Writer writerNew = LibraryFactory.eINSTANCE.createWriter();
	writerNew.setName("I. Asimov");

	// and one of his books
	Book bookNew = LibraryFactory.eINSTANCE.createBook();
	bookNew.setAuthor(writerNew);
	bookNew.setPages(305);
	bookNew.setTitle("Foundation and Empire");
	bookNew.setCategory(BookCategory.SCIENCE_FICTION_LITERAL);

	// add the writer/book to the library.
	libNew.getWriters().add(writerNew);
	libNew.getBooks().add(bookNew);

	// Add the top-level object to the resource
	res.getContents().add(libNew);

	// and save them all
	res.save(Collections.EMPTY_MAP);
	} catch (IOException i) {
	throw new RuntimeException("IOException " + i.getMessage(), i);
	}

	jpoxDataStore.close();
	}
	}