Package com.illumon.iris.db.util
Class IrisDbPythonSession
java.lang.Object
com.illumon.iris.db.util.IrisDbPythonSession
- All Implemented Interfaces:
ScriptSession
public class IrisDbPythonSession extends Object implements ScriptSession
A ScriptSession that uses a JPy cpython interpreter internally.
This is used for persistent queries or the DB console; Python code running remotely uses WorkerPythonEnvironment
for it's supporting structures.
-
Field Summary
Fields Modifier and Type Field Description static String
SCRIPT_TYPE
-
Constructor Summary
Constructors Constructor Description IrisDbPythonSession(com.fishlib.io.logger.Logger log, Database database, boolean runInitScripts)
Create a Python ScriptSession.IrisDbPythonSession(PythonScope<?> scope)
Creates a Python "ScriptSession
", for use where we should only be reading from the scope, such as an IPython kernel session. -
Method Summary
Modifier and Type Method Description void
clearScriptPathLoader()
Removes the currently configured script path loader from this script.void
evaluate(String command)
Evaluates command in the context of the current ScriptSession.void
evaluate(String command, String scriptName)
Evaluates command in the context of the current ScriptSession.Object
getVariable(String name)
Retrieve a variable from the script session's bindings.<T> T
getVariable(String name, T defaultValue)
Retrieve a variable from the script session's bindings.Set<String>
getVariableNames()
Retrieves all of the variable names present in the session's scopeMap<String,Object>
getVariables()
Retrieves all of the variables present in the session's scope (e.g., Groovy binding, Python globals()).boolean
hasVariableName(String name)
Check if the scope has the given variable namevoid
onPersistentQueryInitializationBegin(Supplier<ScriptPathLoader> pathLoader, ScriptPathLoaderState scriptLoaderState)
Called before PersistentQuery initialization, should setup sourcing from the controller (as required).void
onPersistentQueryInitializationEnd()
Called after PersistentQuery initialization.String
scriptType()
void
setScriptPathLoader(Supplier<ScriptPathLoader> scriptPathLoader, boolean caching)
Sets the scriptPathLoader that is in use for this session.boolean
setUseOriginalScriptLoaderState(boolean useOriginal)
Informs the session whether or not we should be using the original ScriptLoaderState for source commands.void
setVariable(String name, Object value)
Inserts a value into the script's scope.
-
Field Details
-
Constructor Details
-
IrisDbPythonSession
public IrisDbPythonSession(com.fishlib.io.logger.Logger log, Database database, boolean runInitScripts) throws IOExceptionCreate a Python ScriptSession.- Parameters:
log
- the log to use for script session errors, info; as well as the Python interpreter's stdout/stderrdatabase
- the database to insert into the script session's bindings.runInitScripts
- if init scripts should be executed- Throws:
IOException
- if an IO error occurs running initialization scripts
-
IrisDbPythonSession
Creates a Python "ScriptSession
", for use where we should only be reading from the scope, such as an IPython kernel session.
-
-
Method Details
-
getVariable
Description copied from interface:ScriptSession
Retrieve a variable from the script session's bindings.- Specified by:
getVariable
in interfaceScriptSession
- Parameters:
name
- the variable to retrieve- Returns:
- the variable
- Throws:
QueryScope.MissingVariableException
- if the variable does not exist
-
getVariable
Description copied from interface:ScriptSession
Retrieve a variable from the script session's bindings. If the variable is not present, return defaultValue. If the variable is present, but is not of type (T), a ClassCastException may result.- Specified by:
getVariable
in interfaceScriptSession
- Type Parameters:
T
- the type of the variable- Parameters:
name
- the variable to retrievedefaultValue
- the value to use when no value is present in the session's scope- Returns:
- the value of the variable, or defaultValue if not present
-
evaluate
Description copied from interface:ScriptSession
Evaluates command in the context of the current ScriptSession.- Specified by:
evaluate
in interfaceScriptSession
- Parameters:
command
- the command to evaluate
-
evaluate
Description copied from interface:ScriptSession
Evaluates command in the context of the current ScriptSession.- Specified by:
evaluate
in interfaceScriptSession
- Parameters:
command
- the command to evaluatescriptName
- an optional script name, which may be ignored by the implementation, or used improve error messages or for other internal purposes
-
getVariables
Description copied from interface:ScriptSession
Retrieves all of the variables present in the session's scope (e.g., Groovy binding, Python globals()).- Specified by:
getVariables
in interfaceScriptSession
- Returns:
- an unmodifiable map with variable names as the keys, and the Objects as the result
-
getVariableNames
Description copied from interface:ScriptSession
Retrieves all of the variable names present in the session's scope- Specified by:
getVariableNames
in interfaceScriptSession
- Returns:
- an unmodifiable set of variable names
-
hasVariableName
Description copied from interface:ScriptSession
Check if the scope has the given variable name- Specified by:
hasVariableName
in interfaceScriptSession
- Parameters:
name
- the variable name- Returns:
- True iff the scope has the given variable name
-
setVariable
Description copied from interface:ScriptSession
Inserts a value into the script's scope.- Specified by:
setVariable
in interfaceScriptSession
- Parameters:
name
- the variable name to setvalue
- the new value of the variable
-
scriptType
- Specified by:
scriptType
in interfaceScriptSession
- Returns:
- a textual description of this script session's language for use in messages.
-
onPersistentQueryInitializationBegin
public void onPersistentQueryInitializationBegin(Supplier<ScriptPathLoader> pathLoader, ScriptPathLoaderState scriptLoaderState)Description copied from interface:ScriptSession
Called before PersistentQuery initialization, should setup sourcing from the controller (as required).- Specified by:
onPersistentQueryInitializationBegin
in interfaceScriptSession
-
onPersistentQueryInitializationEnd
public void onPersistentQueryInitializationEnd()Description copied from interface:ScriptSession
Called after PersistentQuery initialization.- Specified by:
onPersistentQueryInitializationEnd
in interfaceScriptSession
-
setScriptPathLoader
Description copied from interface:ScriptSession
Sets the scriptPathLoader that is in use for this session.- Specified by:
setScriptPathLoader
in interfaceScriptSession
- Parameters:
scriptPathLoader
- a supplier of a script path loadercaching
- whether the source operation should cache results
-
clearScriptPathLoader
public void clearScriptPathLoader()Description copied from interface:ScriptSession
Removes the currently configured script path loader from this script.- Specified by:
clearScriptPathLoader
in interfaceScriptSession
-
setUseOriginalScriptLoaderState
public boolean setUseOriginalScriptLoaderState(boolean useOriginal)Description copied from interface:ScriptSession
Informs the session whether or not we should be using the original ScriptLoaderState for source commands.- Specified by:
setUseOriginalScriptLoaderState
in interfaceScriptSession
- Parameters:
useOriginal
- whether to use the script loader state at persistent query initialization
-