org.botlibre.knowledge.database

Class DatabaseMemory

java.lang.Object

org.botlibre.knowledge.BasicMemory

org.botlibre.knowledge.database.DatabaseMemory

All Implemented Interfaces:

Memory

Direct Known Subclasses:

DerbyMemory

public class DatabaseMemory
extends BasicMemory

Uses JPA to store the memory to a PostgresQL database.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DatabaseMemory.SessionInfo

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CACHE_SIZE
static java.lang.String	DATABASE_DRIVER
static java.lang.String	DATABASE_PASSWORD
static java.lang.String	DATABASE_TEST_URL
static java.lang.String	DATABASE_URL
static java.lang.String	DATABASE_URL_PREFIX
static java.lang.String	DATABASE_USER
static boolean	RECREATE_DATABASE
static java.lang.String	SCHEMA_URL_PREFIX
static java.util.concurrent.ConcurrentMap<java.lang.String,DatabaseMemory.SessionInfo>	sessions
static boolean	TEST

Constructor Summary

Constructors

Constructor and Description
DatabaseMemory()

Method Summary

Modifier and Type	Method and Description
void	abort() Clear the memory.
void	awake() Load any properties and init.
int	cacheSize()
void	checkSchemaVersion()
void	clearProperties(java.lang.String propertySet) Delete the property set.
void	createMemory(java.lang.String database) Create the database.
void	createMemory(java.lang.String database, boolean schema) Create the database.
void	createMemoryFromTemplate(java.lang.String database, boolean isSchema, java.lang.String template, boolean templateIsSchema) Create the database.
void	deleteMemory() Delete all content from the database.
void	destroyMemory(java.lang.String database, boolean isSchema) Drop the database.
boolean	executeDDL(java.lang.String ddl)
void	fastRestore(java.lang.String database, boolean isSchema) Connect and create the EntityManager.
static void	forceShutdown(java.lang.String name)
void	freeMemory()
javax.persistence.EntityManager	getEntityManager()
javax.persistence.EntityManagerFactory	getFactory()
java.lang.String	getMemoryName() Return the current connected database name.
void	importMemory(java.lang.String database) Import the database into this instance.
void	initialize(java.util.Map<java.lang.String,java.lang.Object> properties) Initialize any configurable settings from the properties.
void	initMemory()
boolean	isSchema()
void	loadProperties(java.lang.String propertySet) Load the property set.
Network	newMemory() Return an isolated transactional memory.
void	pool() Reset state when instance is pooled.
void	restore() This implementation does not support persistence.
void	restore(java.lang.String database, boolean isSchema) Connect and create the EntityManager.
void	restore(java.lang.String database, boolean isSchema, boolean recreateDatabase) Connect and create the EntityManager.
void	save() Commit short-term memory to the database.
void	setEntityManager(javax.persistence.EntityManager entityManager)
void	setFactory(javax.persistence.EntityManagerFactory factory)
void	setSchema(boolean isSchema)
void	shutdown() Shutdown the database.
void	switchMemory(java.lang.String database) Switch to a different database.
void	switchMemory(java.lang.String database, boolean isSchema) Switch to a different database.

Methods inherited from class org.botlibre.knowledge.BasicMemory

addActiveMemory, addListener, createMemoryFromTemplate, destroyMemory, find, findInstances, findInstances, findReferences, findReferencesBy, getActiveMemory, getBot, getListeners, getLongTermMemory, getProperties, getProperty, getShortTermMemory, removeListener, removeProperty, setActiveMemory, setBot, setLongTermMemory, setProperties, setProperty, setShortTermMemory, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DATABASE_USER

public static java.lang.String DATABASE_USER

DATABASE_PASSWORD

public static java.lang.String DATABASE_PASSWORD

DATABASE_URL_PREFIX

public static java.lang.String DATABASE_URL_PREFIX

SCHEMA_URL_PREFIX

public static java.lang.String SCHEMA_URL_PREFIX

DATABASE_URL

public static java.lang.String DATABASE_URL

DATABASE_TEST_URL

public static java.lang.String DATABASE_TEST_URL

DATABASE_DRIVER

public static java.lang.String DATABASE_DRIVER

CACHE_SIZE

public static java.lang.String CACHE_SIZE

TEST

public static boolean TEST

RECREATE_DATABASE

public static boolean RECREATE_DATABASE

sessions

public static java.util.concurrent.ConcurrentMap<java.lang.String,DatabaseMemory.SessionInfo> sessions

Constructor Detail

DatabaseMemory

public DatabaseMemory()

Method Detail

initialize

public void initialize(java.util.Map<java.lang.String,java.lang.Object> properties)

Initialize any configurable settings from the properties.

Specified by:

initialize in interface Memory

Overrides:

initialize in class BasicMemory

getFactory

public javax.persistence.EntityManagerFactory getFactory()

setFactory

public void setFactory(javax.persistence.EntityManagerFactory factory)

getEntityManager

public javax.persistence.EntityManager getEntityManager()

setEntityManager

public void setEntityManager(javax.persistence.EntityManager entityManager)

isSchema

public boolean isSchema()

setSchema

public void setSchema(boolean isSchema)

save

public void save()

Commit short-term memory to the database.

Specified by:

save in interface Memory

Overrides:

save in class BasicMemory

pool

public void pool()

Reset state when instance is pooled.

Specified by:

pool in interface Memory

Overrides:

pool in class BasicMemory

shutdown

public void shutdown()

Shutdown the database.

Specified by:

shutdown in interface Memory

Overrides:

shutdown in class BasicMemory

restore

public void restore()

This implementation does not support persistence.

Specified by:

restore in interface Memory

Overrides:

restore in class BasicMemory

restore

public void restore(java.lang.String database,
                    boolean isSchema)

Connect and create the EntityManager.

Specified by:

restore in interface Memory

Overrides:

restore in class BasicMemory

checkSchemaVersion

public void checkSchemaVersion()

restore

public void restore(java.lang.String database,
                    boolean isSchema,
                    boolean recreateDatabase)

Connect and create the EntityManager.

forceShutdown

public static void forceShutdown(java.lang.String name)

initMemory

public void initMemory()

Overrides:

initMemory in class BasicMemory

fastRestore

public void fastRestore(java.lang.String database,
                        boolean isSchema)

Connect and create the EntityManager.

Specified by:

fastRestore in interface Memory

Overrides:

fastRestore in class BasicMemory

awake

public void awake()

Load any properties and init.

Specified by:

awake in interface Memory

Overrides:

awake in class BasicMemory

loadProperties

public void loadProperties(java.lang.String propertySet)

Load the property set.

Specified by:

loadProperties in interface Memory

Overrides:

loadProperties in class BasicMemory

clearProperties

public void clearProperties(java.lang.String propertySet)

Delete the property set.

Specified by:

clearProperties in interface Memory

Overrides:

clearProperties in class BasicMemory

executeDDL

public boolean executeDDL(java.lang.String ddl)

newMemory

public Network newMemory()

Return an isolated transactional memory. Can be used by senses or sub-conscious thought for concurrent processing.

Specified by:

newMemory in interface Memory

Overrides:

newMemory in class BasicMemory

getMemoryName

public java.lang.String getMemoryName()

Return the current connected database name.

Specified by:

getMemoryName in interface Memory

Overrides:

getMemoryName in class BasicMemory

createMemory

public void createMemory(java.lang.String database)

Create the database.

Specified by:

createMemory in interface Memory

Overrides:

createMemory in class BasicMemory

createMemory

public void createMemory(java.lang.String database,
                         boolean schema)

Create the database.

Specified by:

createMemory in interface Memory

Overrides:

createMemory in class BasicMemory

createMemoryFromTemplate

public void createMemoryFromTemplate(java.lang.String database,
                                     boolean isSchema,
                                     java.lang.String template,
                                     boolean templateIsSchema)

Create the database.

Specified by:

createMemoryFromTemplate in interface Memory

Overrides:

createMemoryFromTemplate in class BasicMemory

destroyMemory

public void destroyMemory(java.lang.String database,
                          boolean isSchema)

Drop the database.

Specified by:

destroyMemory in interface Memory

Overrides:

destroyMemory in class BasicMemory

deleteMemory

public void deleteMemory()

Delete all content from the database.

Specified by:

deleteMemory in interface Memory

Overrides:

deleteMemory in class BasicMemory

switchMemory

public void switchMemory(java.lang.String database)

Switch to a different database.

Specified by:

switchMemory in interface Memory

Overrides:

switchMemory in class BasicMemory

switchMemory

public void switchMemory(java.lang.String database,
                         boolean isSchema)

Switch to a different database.

Specified by:

switchMemory in interface Memory

Overrides:

switchMemory in class BasicMemory

importMemory

public void importMemory(java.lang.String database)

Import the database into this instance.

Specified by:

importMemory in interface Memory

Overrides:

importMemory in class BasicMemory

abort

public void abort()

Clear the memory.

Specified by:

abort in interface Memory

Overrides:

abort in class BasicMemory

cacheSize

public int cacheSize()

Specified by:

cacheSize in interface Memory

Overrides:

cacheSize in class BasicMemory

freeMemory

public void freeMemory()

Specified by:

freeMemory in interface Memory

Overrides:

freeMemory in class BasicMemory