Package com.complexible.stardog.api
Class KernelAdminConnection
- java.lang.Object
-
- com.complexible.stardog.api.admin.AbstractAdminConnection
-
- com.complexible.stardog.api.KernelAdminConnection
-
- All Implemented Interfaces:
AdminConnection,java.lang.AutoCloseable
public final class KernelAdminConnection extends AbstractAdminConnection
- Since:
- 5.0
- Version:
- 5.0
- Author:
- Michael Grove
-
-
Field Summary
-
Fields inherited from interface com.complexible.stardog.api.admin.AdminConnection
NO_TIMEOUT
-
-
Constructor Summary
Constructors Constructor Description KernelAdminConnection(com.complexible.stardog.Kernel theKernel)KernelAdminConnection(com.complexible.stardog.Kernel theKernel, org.apache.shiro.subject.Subject theSubject, Options theOptions, Views<AdminConnection> theViews)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void_close()protected Metadata_get(java.lang.String theName, java.lang.Iterable<? extends MetaProperty<?>> theOptions)protected <T> java.lang.String_set(java.lang.String theName, MetaProperty<T> theOption, T theValue)java.lang.Stringbackup(java.lang.String theDatabase, java.util.Optional<java.lang.String> theBackupUrl, Options theOptions)Create a backup of the given database in the specified location.java.lang.StringbackupAll(Options theOptions)Create a backup of the server in the specified location.<T> Tcall(java.util.concurrent.Callable<T> theAction)java.util.Collection<java.lang.String>checkpoint(java.lang.String theDatabase, Options theOptions)Perform a checkpoint operation (list, create, restore) against selected database.java.util.Map<java.lang.String,java.lang.Object>currentStatus(Options theOptions)Return the server status information, including Server/Protocols running, Stardog Home path, OS, etc.java.lang.Stringdrop(java.lang.String theName)Drop the database with the given name.java.io.FilegenerateDiagnosticReport(com.complexible.stardog.util.report.DiagnosticsReport theDiagnosticsReport)java.nio.file.PathgetLogs(Options options)Generates a zip file containing the server logs.PermissionManagergetPermissionManager()Return thePermissionManagerfor changing user & role permissionscom.complexible.stardog.process.ProcessManagergetProcessManager()MetadatagetProperty(java.util.Collection<java.lang.String> thePropertyNames)Gets the property value for a server configuration option.QueryManagergetQueryManager()Return theQueryManagerfor managing running queriesRoleManagergetRoleManager()Return theRoleManagerto be used for role-centric security changescom.complexible.stardog.StoredFunctionsgetStoredFunctions()Returns the stored functions in this server.StoredQueriesgetStoredQueries()Returns the stored queries in this server.com.complexible.stardog.security.TokenManagergetTokenManager()Return a link to the object that will allow clients to interact with JWT bearer tokensUserManagergetUserManager()Return theUserManagerto be used for user-centric security changesjava.util.Collection<java.lang.String>list()List all the databases in the Stardog serverDatabaseBuildernewDatabaseBuilder()java.lang.Stringoffline(java.lang.String theName, long theTime, java.util.concurrent.TimeUnit theTimeUnit)Take the database offline waiting up to the specified timeout before performing a hard off-line.java.lang.Stringonline(java.lang.String theName)Makes the database online according to the default strategyjava.lang.Stringoptimize(java.lang.String theName, Metadata theOptions)Optimizes the indexes of a given database for query answering and disk utilization after the database has been heavily modified.voidrenameDatabase(java.lang.String theOldName, java.lang.String theNewName)Rename an existing database to a new onejava.lang.Stringrepair(java.lang.String theName)Repairs the specified database if it is corrupted.java.lang.Stringrestore(java.io.File theBackup, boolean theOverwrite, java.lang.String theName)Restore the database backed up to the given locationjava.lang.Stringrestore(java.lang.String theBackup, boolean theOverwrite, java.lang.String theName)voidrun(java.lang.Runnable theAction)java.lang.StringsetProperty(java.lang.String thePropertyName, java.lang.String theNewValue)Requests that the specified server configuration option value be changed to the new value.voidshutdown()Shutdown the remote Stardog server.java.lang.Stringverify(java.lang.String theName)Verify the integrity of specified database's index.java.lang.Stringwhoami()Returns the username associated with this connection.-
Methods inherited from class com.complexible.stardog.api.admin.AbstractAdminConnection
as, assertOpen, assertValidName, builder, close, disk, get, get, isOpen, newDatabase, offline, set
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.complexible.stardog.api.admin.AdminConnection
backup, backup, backup, currentStatus, optimize
-
-
-
-
Constructor Detail
-
KernelAdminConnection
public KernelAdminConnection(com.complexible.stardog.Kernel theKernel)
-
KernelAdminConnection
public KernelAdminConnection(com.complexible.stardog.Kernel theKernel, org.apache.shiro.subject.Subject theSubject, Options theOptions, Views<AdminConnection> theViews)
-
-
Method Detail
-
_close
protected void _close()
- Specified by:
_closein classAbstractAdminConnection
-
newDatabaseBuilder
public DatabaseBuilder newDatabaseBuilder()
- Specified by:
newDatabaseBuilderin classAbstractAdminConnection
-
renameDatabase
public void renameDatabase(java.lang.String theOldName, java.lang.String theNewName) throws StardogExceptionDescription copied from interface:AdminConnectionRename an existing database to a new one- Parameters:
theOldName- the old database nametheNewName- the new database name- Throws:
StardogException- if the database name is invalid or if the database is not offline.
-
_get
protected Metadata _get(java.lang.String theName, java.lang.Iterable<? extends MetaProperty<?>> theOptions) throws StardogException
- Specified by:
_getin classAbstractAdminConnection- Throws:
StardogException
-
_set
protected <T> java.lang.String _set(java.lang.String theName, MetaProperty<T> theOption, T theValue) throws StardogException- Specified by:
_setin classAbstractAdminConnection- Throws:
StardogException
-
getProperty
public Metadata getProperty(java.util.Collection<java.lang.String> thePropertyNames) throws StardogException
Gets the property value for a server configuration option. This value will be the default for the option or the override in the properties file.- Parameters:
thePropertyNames- filter for the properties to return. Empty set will match all properties.- Returns:
- Metadata created with config values "MetaProperty.config(key, value).temporary().build()"
- Throws:
StardogException
-
setProperty
public java.lang.String setProperty(java.lang.String thePropertyName, java.lang.String theNewValue) throws StardogExceptionRequests that the specified server configuration option value be changed to the new value. This method will notify any listening server modules about the change request. It is not guaranteed that the listening module will update the value.- Returns:
- Throws:
StardogException
-
offline
public java.lang.String offline(java.lang.String theName, long theTime, java.util.concurrent.TimeUnit theTimeUnit) throws StardogExceptionTake the database offline waiting up to the specified timeout before performing a hard off-line. A database going offline will allow open connections to complete, but will not accept new, incoming connections.
Offline databases cannot be queried or updated and will be unaccessible to users.
Specifying a timeout of 0 will immediately shut down the database severing all open connections, i.e. a hard shutdown.
- Parameters:
theName- name of the databasetheTime- timeout duration, must be a positive numbertheTimeUnit- the unit of time for the timeout, cannot be null- Returns:
- the server output of offline
- Throws:
StardogException- if there was an error while offlining the database
-
online
public java.lang.String online(java.lang.String theName) throws StardogExceptionMakes the database online according to the default strategy- Parameters:
theName- the name of the database- Returns:
- the server output of onlining the database
- Throws:
StardogException- if there was an error while onlining the database
-
optimize
public java.lang.String optimize(java.lang.String theName, Metadata theOptions) throws StardogExceptionOptimizes the indexes of a given database for query answering and disk utilization after the database has been heavily modified. If a database has been modified with a large number of additions or removals, some internal structures may become less optimized for query answering. This utility will perform several operations that will help with query answering performance. Which operations are performed depends on the options given.Optimization will NOT modify the database contents. The data layout, indexes and other internal structures might change but the data stored in the database will remain same.
- Parameters:
theName- the name of the database to optimizetheOptions- options specifying the specific optimization steps to perform or empty for default optimizations- Returns:
- the server output of optimize
- Throws:
StardogException- if an error occurs during optimization
-
list
public java.util.Collection<java.lang.String> list() throws StardogExceptionList all the databases in the Stardog server- Returns:
- the list of databases
- Throws:
StardogException- if there was an error getting the list
-
repair
public java.lang.String repair(java.lang.String theName) throws StardogExceptionRepairs the specified database if it is corrupted. If the database is not corrupted, nothing will be repaired.- Parameters:
theName- the name of the database to repair- Returns:
- the server output of the repair
- Throws:
StardogException- if there was an error while repairing
-
verify
public java.lang.String verify(java.lang.String theName) throws StardogExceptionVerify the integrity of specified database's index.- Parameters:
theName- the name of the database to verify- Returns:
- the output of the verify operation
- Throws:
StardogException- if there was an error while verifying the database
-
whoami
public java.lang.String whoami()
Description copied from interface:AdminConnectionReturns the username associated with this connection. Useful when API tokens are used to establish the connection.- Returns:
- username
-
shutdown
public void shutdown() throws com.complexible.stardog.security.StardogSecurityExceptionShutdown the remote Stardog server. You must be connected to the server as a super-user.- Throws:
com.complexible.stardog.security.StardogSecurityException- if you are attempting to shut down the embedded server or if you are not a super-user and are trying to shut down a remote server.
-
drop
public java.lang.String drop(java.lang.String theName) throws StardogExceptionDrop the database with the given name.- Parameters:
theName- the name of the database to drop- Returns:
- the Result of the invocation
- Throws:
StardogException- if there was an error while dropping the database
-
backup
public java.lang.String backup(java.lang.String theDatabase, java.util.Optional<java.lang.String> theBackupUrl, Options theOptions) throws StardogExceptionDescription copied from interface:AdminConnectionCreate a backup of the given database in the specified location. The location can be a file path on the server or a URL pointing to S3 or GCP.Configuration optionscan be specified for the backup operation.- Parameters:
theDatabase- the name of the database to back uptheBackupUrl- where to store the backup or empty if the default location should be usedtheOptions- configuration options to use for backups- Returns:
- Throws:
StardogException
-
backupAll
public java.lang.String backupAll(Options theOptions) throws StardogException
Create a backup of the server in the specified location.- Parameters:
theOptions- Collection of BackupOptions- Returns:
- the output of the backup process
- Throws:
StardogException- if there is an error performing the backup.
-
restore
public java.lang.String restore(java.io.File theBackup, boolean theOverwrite, java.lang.String theName) throws StardogExceptionRestore the database backed up to the given location- Parameters:
theBackup- the location of the backuptheOverwrite- whether or not to overwrite any existing databasetheName- a new name for the restored database- Returns:
- the output of the restore process
- Throws:
StardogException- if there was an error restoring the database from a backup
-
restore
public java.lang.String restore(java.lang.String theBackup, boolean theOverwrite, java.lang.String theName) throws StardogException- Throws:
StardogException
-
checkpoint
public java.util.Collection<java.lang.String> checkpoint(java.lang.String theDatabase, Options theOptions) throws StardogExceptionDescription copied from interface:AdminConnectionPerform a checkpoint operation (list, create, restore) against selected database.- Parameters:
theDatabase- the name of the database for checkpoint operationtheOptions- configuration options for the checkpoint- Returns:
- Throws:
StardogException
-
getUserManager
public UserManager getUserManager()
Return theUserManagerto be used for user-centric security changes- Returns:
- the UserManager
-
getRoleManager
public RoleManager getRoleManager()
Return theRoleManagerto be used for role-centric security changes- Returns:
- the RoleManager
-
getPermissionManager
public PermissionManager getPermissionManager()
Return thePermissionManagerfor changing user & role permissions- Returns:
- the PermissionManager
-
getQueryManager
public QueryManager getQueryManager()
Return theQueryManagerfor managing running queries
-
getProcessManager
public com.complexible.stardog.process.ProcessManager getProcessManager()
- Returns:
- The
ProcessManagerfor managing running queries
-
getTokenManager
public com.complexible.stardog.security.TokenManager getTokenManager()
Return a link to the object that will allow clients to interact with JWT bearer tokens- Returns:
- the TokenManager
-
currentStatus
public java.util.Map<java.lang.String,java.lang.Object> currentStatus(Options theOptions) throws StardogException
Return the server status information, including Server/Protocols running, Stardog Home path, OS, etc. Theoptionscan be used to configure which metrics will be included in the results.- Parameters:
theOptions-- Returns:
- the metrics showing the server status
- Throws:
StardogException- if there was an error retrieving the DBMS info- See Also:
MetricOptions
-
generateDiagnosticReport
public java.io.File generateDiagnosticReport(com.complexible.stardog.util.report.DiagnosticsReport theDiagnosticsReport)
-
getLogs
public java.nio.file.Path getLogs(Options options)
Generates a zip file containing the server logs.- Parameters:
options- thelog options- Returns:
- a zip file containing the server logs
-
getStoredQueries
public StoredQueries getStoredQueries()
Returns the stored queries in this server. Returned object can be used to add and remove stored queries.- Returns:
- the stored queries
-
getStoredFunctions
public com.complexible.stardog.StoredFunctions getStoredFunctions()
Returns the stored functions in this server. Returned object can be used to add and remove stored functions.- Returns:
- the stored functions
-
run
public void run(java.lang.Runnable theAction)
-
call
public <T> T call(java.util.concurrent.Callable<T> theAction)
-
-