public void testCreatePersist() throws Exception {
        // first create an address and persist it
        final String addressName = "name " + System.currentTimeMillis(); //$NON-NLS-1$
        {
            CDOSession session = openSession();
            CDOTransaction transaction = session.openTransaction();
            // get/create a resource
            final CDOResource resource = transaction.getOrCreateResource("/res1"); //$NON-NLS-1$

            // clear any previous data
            resource.getContents().clear();

            final Company address = CompanyFactory.eINSTANCE.createCompany();
            address.setCity("test"); //$NON-NLS-1$
            address.setName(addressName);
            address.setStreet("test"); //$NON-NLS-1$
            resource.getContents().add(address);

            transaction.commit();

            // change the street name again
            session = openSession();
            transaction = session.openTransaction();
            address.setStreet("street");
            resource.getContents().add(address);
            transaction.commit();
        }

        // read back and do some tests
        {
            final CDOSession session = openSession();
            final CDOTransaction transaction = session.openTransaction();
            final CDOResource resource = transaction.getResource("/res1"); //$NON-NLS-1$
            assertEquals(true, resource.getContents().get(0) instanceof Company);
            assertEquals(1, resource.getContents().size());
            final Company address = (Company) resource.getContents().get(0);
            assertEquals(addressName, address.getName());
            transaction.commit();
        }
    }

public class PersistenceManager {

    public void saveCompany(final Company company) {
        final CDOSession session = openSession();
        final CDOTransaction transaction = session.openTransaction();
        final CDOResource resource = transaction.getOrCreateResource(RESOURCE_NAME);

        resource.getContents().add(company);

        try {
            transaction.commit();
        } catch (final CommitException e) {
            throw new RuntimeException(e);
        }

    }

    // .... other read/write methods like the above...

    // all this should move into a persistence manager base class...

    private static final String REPO_NAME = "repo1"; //$NON-NLS-1$

    private static final String RESOURCE_NAME = "res1"; //$NON-NLS-1$

    private static final String CONNECTION_ADDRESS = "localhost:2036"; //$NON-NLS-1$

    private CDOSessionConfiguration sessionConfiguration = null;

    /**
     * Opens a CDOSession, does not register an EPackage with the session. This should be done by the caller.
     */
    private CDOSession openSession() {
        if (sessionConfiguration == null) {
            initialize();
        }
        final CDOSession cdoSession = sessionConfiguration.openSession();
        cdoSession.getPackageRegistry().putEPackage(CompanyPackage.eINSTANCE);
        return cdoSession;
    }

    /**
     * Initializes the connection and creates a {@link CDOSessionConfiguration} which is stored in a member of this
     * class.
     */
    private void initialize() {
        OMPlatform.INSTANCE.setDebugging(true);
        OMPlatform.INSTANCE.addLogHandler(PrintLogHandler.CONSOLE);
        OMPlatform.INSTANCE.addTraceHandler(PrintTraceHandler.CONSOLE);

        // Prepare container
        final IManagedContainer container = ContainerUtil.createContainer();
        Net4jUtil.prepareContainer(container); // Register Net4j factories
        TCPUtil.prepareContainer(container); // Register TCP factories
        CDONet4jUtil.prepareContainer(container); // Register CDO factories
        // LifecycleUtil.activate(container);
        container.activate();

        // Create connector
        final IConnector connector = TCPUtil.getConnector(container, CONNECTION_ADDRESS);

        // Create configuration
        sessionConfiguration = CDONet4jUtil.createSessionConfiguration();
        sessionConfiguration.setConnector(connector);
        sessionConfiguration.setRepositoryName(REPO_NAME);
    }

}