Skip to content

Commit

Permalink
Add logging about database creation/shutdown into database managers.
Browse files Browse the repository at this point in the history
Add log messages about particular database creation/shutdown.
Introduce TestCommercialGraphDatabaseFactory.
  • Loading branch information
MishaDemianenko committed Aug 28, 2018
1 parent 4f83c8a commit 27f0c24
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 8 deletions.
Expand Up @@ -39,16 +39,16 @@ public final class DefaultDatabaseManager extends LifecycleAdapter implements Da
private final PlatformModule platform; private final PlatformModule platform;
private final EditionModule edition; private final EditionModule edition;
private final Procedures procedures; private final Procedures procedures;
private final Logger msgLog; private final Logger log;
private final GraphDatabaseFacade graphDatabaseFacade; private final GraphDatabaseFacade graphDatabaseFacade;


public DefaultDatabaseManager( PlatformModule platform, EditionModule edition, Procedures procedures, public DefaultDatabaseManager( PlatformModule platform, EditionModule edition, Procedures procedures,
Logger msgLog, GraphDatabaseFacade graphDatabaseFacade ) Logger log, GraphDatabaseFacade graphDatabaseFacade )
{ {
this.platform = platform; this.platform = platform;
this.edition = edition; this.edition = edition;
this.procedures = procedures; this.procedures = procedures;
this.msgLog = msgLog; this.log = log;
this.graphDatabaseFacade = graphDatabaseFacade; this.graphDatabaseFacade = graphDatabaseFacade;
} }


Expand All @@ -59,12 +59,12 @@ public Optional<GraphDatabaseFacade> getDatabaseFacade( String name )
} }


@Override @Override
public GraphDatabaseFacade createDatabase( String name ) public GraphDatabaseFacade createDatabase( String databaseName )
{ {
checkState( database == null, "Database is already created, fail to create another one." ); checkState( database == null, "Database is already created, fail to create another one." );

log.log( "Creating '%s' database.", databaseName );
DataSourceModule dataSource = new DataSourceModule( name, platform, edition, procedures, graphDatabaseFacade ); DataSourceModule dataSource = new DataSourceModule( databaseName, platform, edition, procedures, graphDatabaseFacade );
ClassicCoreSPI spi = new ClassicCoreSPI( platform, dataSource, msgLog, dataSource.getCoreAPIAvailabilityGuard(), edition.threadToTransactionBridge ); ClassicCoreSPI spi = new ClassicCoreSPI( platform, dataSource, log, dataSource.getCoreAPIAvailabilityGuard(), edition.threadToTransactionBridge );
graphDatabaseFacade.init( spi, edition.threadToTransactionBridge, platform.config, dataSource.neoStoreDataSource.getTokenHolders() ); graphDatabaseFacade.init( spi, edition.threadToTransactionBridge, platform.config, dataSource.neoStoreDataSource.getTokenHolders() );
platform.dataSourceManager.register( dataSource.neoStoreDataSource ); platform.dataSourceManager.register( dataSource.neoStoreDataSource );
database = graphDatabaseFacade; database = graphDatabaseFacade;
Expand All @@ -87,6 +87,7 @@ private void shutdownDatabase()
{ {
if ( database != null ) if ( database != null )
{ {
log.log( "Shutdown '%s' database.", database.databaseLayout().getDatabaseName() );
database.shutdown(); database.shutdown();
} }
} }
Expand Down
Expand Up @@ -84,7 +84,7 @@ protected LogService createLogService( LogProvider userLogProvider )
LogProvider logProvider = ((TestGraphDatabaseFactoryState) state).getInternalLogProvider(); LogProvider logProvider = ((TestGraphDatabaseFactoryState) state).getInternalLogProvider();
if ( logProvider != null ) if ( logProvider != null )
{ {
return new SimpleLogService( logProvider, logProvider ); return new SimpleLogService( logProvider );
} }
} }
return super.createLogService( userLogProvider ); return super.createLogService( userLogProvider );
Expand Down

0 comments on commit 27f0c24

Please sign in to comment.