| /******************************************************************************* |
| * Copyright (c) 2011 EclipseSource 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: |
| * EclipseSource - initial API and implementation |
| ******************************************************************************/ |
| package org.eclipse.rap.rwt.cluster.testfixture.internal.jetty; |
| |
| import java.sql.SQLException; |
| import java.text.MessageFormat; |
| |
| import org.eclipse.rap.rwt.cluster.testfixture.internal.util.SocketUtil; |
| import org.h2.tools.Server; |
| |
| |
| class DatabaseServer { |
| private static final String CONNECTION_URL_PATTERN |
| = "jdbc:h2:tcp://localhost:{0}/mem:sessions;DB_CLOSE_DELAY=-1"; |
| |
| private final org.h2.Driver driver; |
| private Server server; |
| |
| DatabaseServer() { |
| driver = new org.h2.Driver(); |
| } |
| |
| void start() { |
| int port = SocketUtil.getFreePort(); |
| try { |
| String[] args = new String[] { |
| "-tcp", |
| "-tcpAllowOthers", |
| "true", |
| "-tcpPort", |
| String.valueOf( port ) |
| }; |
| server = Server.createTcpServer( args ); |
| server.start(); |
| } catch( SQLException sqle ) { |
| throw new RuntimeException( "Failed to start H2 database.", sqle ); |
| } |
| } |
| |
| void stop() { |
| if( isRunning() ) { |
| server.stop(); |
| server = null; |
| } |
| } |
| |
| java.sql.Driver getDriver() { |
| return driver; |
| } |
| |
| String getConnectionUrl() { |
| checkRunning(); |
| String pattern = CONNECTION_URL_PATTERN; |
| return MessageFormat.format( pattern, String.valueOf( server.getPort() ) ); |
| } |
| |
| private void checkRunning() { |
| if( !isRunning() ) { |
| throw new IllegalStateException( "Database server is not running." ); |
| } |
| } |
| |
| private boolean isRunning() { |
| return server != null; |
| } |
| } |