import org.simantics.utils.FileUtils;\r
\r
public class ServerManagerFactory {\r
- public static ServerManager create(String databaseId, String address) throws IOException, DatabaseException {\r
- Driver driver = Manager.getDriver(databaseId);\r
+ public static ServerManager create(String databaseDriverId, String address) throws IOException, DatabaseException {\r
+ Driver driver = Manager.getDriver(databaseDriverId);\r
if (driver == null)\r
- throw new IllegalArgumentException("Database driver with ID " + databaseId + " could not be found!");\r
- System.out.println("ServerManagerFactory.create called with id " + databaseId + ", driver is " + driver.toString());\r
- DatabaseUserAgent agent = Manager.getUserAgent(databaseId);\r
- throw new IllegalArgumentException("Database driver for ID " + databaseDriverId + " Could not be found!");\r
- System.out.println("ServerManagerFactory.create called with databaseId=" + databaseDriverId + " and driver is " + driver.toString());\r
++ throw new IllegalArgumentException("Database driver with ID " + databaseDriverId + " could not be found!");\r
++ System.out.println("ServerManagerFactory.create called with id " + databaseDriverId + ", driver is " + driver.toString());\r
+ DatabaseUserAgent agent = Manager.getUserAgent(databaseDriverId);\r
if (agent != null)\r
driver.setDatabaseUserAgent(address, agent);\r
return new ServerManager(driver);\r
return application != null ? application : UUID.randomUUID().toString();\r
}\r
\r
- private Session setupDatabase(String databaseId, IProgressMonitor progressMonitor, RecoveryPolicy workspacePolicy, PlatformUserAgent userAgent) throws PlatformException {\r
+ private Session setupDatabase(String databaseDriverId, IProgressMonitor progressMonitor, RecoveryPolicy workspacePolicy, PlatformUserAgent userAgent) throws PlatformException {\r
if (progressMonitor == null)\r
progressMonitor = new NullProgressMonitor();\r
File dbLocation = Platform.getLocation().append("db").toFile();\r
ServerManager serverManager;\r
try {\r
- serverManager = ServerManagerFactory.create(databaseId, dbLocation.getAbsolutePath());\r
+ serverManager = ServerManagerFactory.create(databaseDriverId, dbLocation.getAbsolutePath());\r
} catch (DatabaseException | IOException e) {\r
throw new PlatformException("Failed to initialize Server Manager", e);\r
}\r
// Check hash of transferable graph to know whether to update or not.\r
if (platformBundle.getHashcode() == existingBundle.getHashcode())\r
continue;\r
- System.out.println("Ontology hashcodes does not match! platformBundle" + platformBundle.getName() + ".getHashCode()=" + platformBundle.getHashcode() + " existingBundle" + existingBundle.getName() + ".getHashCode()=" + existingBundle.getHashcode());\r
+ System.out.println("Ontology hashcodes do not match: platform bundle="\r
+ + platformBundle.getVersionedId() + ", hash=" + platformBundle.getHashcode()\r
+ + "; existing bundle=" + existingBundle.getVersionedId() + ", hash=" + existingBundle.getHashcode());\r
reinstallTGs.put(platformBundle, existingBundle);\r
}\r
}\r
* startup or <code>null</code> to resort to default measures\r
* @throws PlatformException\r
*/\r
- public SessionContext startUp(String databaseId, IProgressMonitor progressMonitor, RecoveryPolicy workspacePolicy,\r
+ public SessionContext startUp(String databaseDriverId, IProgressMonitor progressMonitor, RecoveryPolicy workspacePolicy,\r
OntologyRecoveryPolicy ontologyPolicy, boolean requireSynchronize, PlatformUserAgent userAgent)\r
throws PlatformException\r
{\r
VariableRepository.clear();\r
\r
// 1. Assert there is a database at <workspace>/db\r
- session = setupDatabase(databaseId, progressMonitor, workspacePolicy, userAgent);\r
+ session = setupDatabase(databaseDriverId, progressMonitor, workspacePolicy, userAgent);\r
TimeLogger.log("Database setup complete");\r
\r
// 2. Assert all graphs, and correct versions, are installed to the database\r
return false;\r
}\r
\r
- public void reconnect(String databaseId) throws Exception {\r
+ public void reconnect(String databaseDriverId) throws Exception {\r
// Starts database server.\r
- SimanticsPlatform.INSTANCE.startUp(databaseId, null, RecoveryPolicy.ThrowError, OntologyRecoveryPolicy.ThrowError, true, null);\r
+ SimanticsPlatform.INSTANCE.startUp(databaseDriverId, null, RecoveryPolicy.ThrowError, OntologyRecoveryPolicy.ThrowError, true, null);\r
}\r
\r
private void dumpPlatformBundleState() {\r