diff options
Diffstat (limited to 'cdo/benchmarks/org.eclipse.papyrus.cdo.benchmarks/src/org/eclipse/papyrus/cdo/benchmarks/tests/CDOPapyrusModelCreation.java')
| -rwxr-xr-x | cdo/benchmarks/org.eclipse.papyrus.cdo.benchmarks/src/org/eclipse/papyrus/cdo/benchmarks/tests/CDOPapyrusModelCreation.java | 210 |
1 files changed, 210 insertions, 0 deletions
diff --git a/cdo/benchmarks/org.eclipse.papyrus.cdo.benchmarks/src/org/eclipse/papyrus/cdo/benchmarks/tests/CDOPapyrusModelCreation.java b/cdo/benchmarks/org.eclipse.papyrus.cdo.benchmarks/src/org/eclipse/papyrus/cdo/benchmarks/tests/CDOPapyrusModelCreation.java new file mode 100755 index 00000000..c07e9b14 --- /dev/null +++ b/cdo/benchmarks/org.eclipse.papyrus.cdo.benchmarks/src/org/eclipse/papyrus/cdo/benchmarks/tests/CDOPapyrusModelCreation.java @@ -0,0 +1,210 @@ +/***************************************************************************** + * Copyright (c) 2018 CEA LIST and others. + * + * All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License 2.0 + * which accompanies this distribution, and is available at + * http://www.eclipse.org/legal/epl-2.0/ + * + * SPDX-License-Identifier: EPL-2.0 + * + * Contributors: + * CEA LIST - Initial API and implementation + * + *****************************************************************************/ + +package org.eclipse.papyrus.cdo.benchmarks.tests; + +import java.util.List; +import java.util.Properties; + +import org.eclipse.emf.cdo.common.branch.CDOBranch; +import org.eclipse.emf.cdo.common.branch.CDOBranchPoint; +import org.eclipse.emf.cdo.explorer.CDOExplorerUtil; +import org.eclipse.emf.cdo.explorer.checkouts.CDOCheckout; +import org.eclipse.emf.cdo.explorer.repositories.CDORepository; +import org.eclipse.emf.cdo.internal.explorer.AbstractElement; +import org.eclipse.emf.cdo.internal.explorer.checkouts.CDOCheckoutImpl; +import org.eclipse.emf.cdo.internal.explorer.repositories.CDORepositoryImpl; +import org.eclipse.emf.cdo.internal.explorer.repositories.RemoteCDORepository; +import org.eclipse.emf.cdo.net4j.CDONet4jSessionConfiguration; +import org.eclipse.emf.cdo.net4j.CDONet4jUtil; +import org.eclipse.emf.cdo.session.CDOSession; +import org.eclipse.emf.cdo.transaction.CDOTransaction; +import org.eclipse.emf.common.util.URI; +import org.eclipse.net4j.Net4jUtil; +import org.eclipse.net4j.connector.IConnector; +import org.eclipse.net4j.tcp.TCPUtil; +import org.eclipse.net4j.util.container.ContainerUtil; +import org.eclipse.net4j.util.container.IManagedContainer; +import org.eclipse.net4j.util.security.IPasswordCredentialsProvider; +import org.eclipse.net4j.util.security.PasswordCredentialsProvider; +import org.eclipse.papyrus.infra.core.services.ServiceMultiException; + +/** + * @author VL222926 + * + */ +public class CDOPapyrusModelCreation extends AbstractModelCreation { + + private static final String HOST_AND_PORT = "localhost:2036"; + + private static final String USER_NAME = "Administrator"; + + private static final String PASSWORD = "0000"; + + + private CDOSession session; + private CDOCheckout checkout; + private CDORepository repository; + private CDOTransaction transaction; + + final String PAPYRUS_CDO_SECURED_REPOSITORY = "PapyrusCDOSecuredRepository"; + + + + public final void connect() throws Exception { + connect(getHostAndPort(), getUser(), getPassword()); + } + + /** + * @return + */ + private String getPassword() { + return PASSWORD; + } + + /** + * @return + */ + private String getUser() { + return USER_NAME; + } + + /** + * @return + */ + private String getHostAndPort() { + return HOST_AND_PORT; + } + + private void connect(final String serverURI, final String login, final String password) throws Exception { + try { + // 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 + container.activate(); + + // Create connector + final IConnector connector = TCPUtil.getConnector(container, serverURI); + + // Create configuration + final CDONet4jSessionConfiguration configuration = CDONet4jUtil.createNet4jSessionConfiguration(); + configuration.setConnector(connector); + configuration.setRepositoryName(PAPYRUS_CDO_SECURED_REPOSITORY); + final IPasswordCredentialsProvider credentialsProvider = new PasswordCredentialsProvider(login, password); + configuration.setCredentialsProvider(credentialsProvider); + + final Properties properties = new Properties(); + + properties.setProperty(AbstractElement.PROP_TYPE, CDORepository.TYPE_REMOTE); + properties.setProperty(AbstractElement.PROP_LABEL, PAPYRUS_CDO_SECURED_REPOSITORY); + properties.setProperty(CDORepositoryImpl.PROP_NAME, PAPYRUS_CDO_SECURED_REPOSITORY); + properties.setProperty(RemoteCDORepository.PROP_CONNECTOR_TYPE, "tcp"); //$NON-NLS-1$ + // TODO : is it serverURI? + properties.setProperty(RemoteCDORepository.PROP_CONNECTOR_DESCRIPTION, serverURI); + + repository = CDOExplorerUtil.getRepositoryManager().addRepository(properties, credentialsProvider.getCredentials()); + repository.connect(); + + // Open session + session = configuration.openNet4jSession(); + + this.checkout = createCheckout("PapyrusPerfoTestCheckout"); //$NON-NLS-1$ + + + } catch (final Exception e) { + throw e; + } + + } + + private CDOCheckout createCheckout(final String checkoutName) { + final Properties properties = new Properties(); + properties.setProperty(AbstractElement.PROP_TYPE, CDOCheckout.TYPE_ONLINE_HISTORICAL); + properties.setProperty(AbstractElement.PROP_LABEL, checkoutName); + properties.setProperty(CDOCheckoutImpl.PROP_REPOSITORY, this.repository.getID()); + properties.setProperty(CDOCheckoutImpl.PROP_BRANCH_ID, Integer.toString(CDOBranch.MAIN_BRANCH_ID)); + properties.setProperty(CDOCheckoutImpl.PROP_TIME_STAMP, Long.toString(CDOBranchPoint.UNSPECIFIED_DATE)); + properties.setProperty(CDOCheckoutImpl.PROP_READ_ONLY, Boolean.toString(false)); + + final CDOCheckout checkout = CDOExplorerUtil.getCheckoutManager().addCheckout(properties); + checkout.open(); + return checkout; + } + + /** + * Gets the running session. + * + * @return the running session + */ + protected CDOSession getSession() { + return this.session; + } + + + + public CDOTransaction getOpenTransaction() { + if (transaction != null) { + return transaction; + } + + transaction = session.openTransaction(this.modelSet); + + + return transaction; + } + + + public void closeTransaction() { + if (null != this.transaction) { + this.transaction.close(); + } + transaction = null;// TODO : probably missing in QS + } + + + /** + * @see org.eclipse.papyrus.cdo.perfo.tests.impl.IPapyrusModelCreation#initPapyrusEnvironnement(java.lang.String, java.lang.String, List<String>) + * + * @param folderName + * @param modelName + * @throws Exception + */ + @Override + public void initPapyrusEnvironnement(final String folderName, final String modelName, final List<String> profilesName) throws Exception { + connect(); + createModelSet(folderName, modelName, profilesName); + } + + + protected URI createBaseURI() { + URI uri = URI.createURI("cdo.checkout://1/home"); + return uri.appendSegment(getUser()); + + } + + /** + * @throws ServiceMultiException + * @see org.eclipse.papyrus.cdo.benchmarks.tests.IPapyrusModelCreation#disposeAll() + * + */ + @Override + public void disposeAll() throws ServiceMultiException { + closeTransaction(); + super.disposeAll(); + } + +} |