Package org.opennms.core.test.db
Class MockDatabase
- java.lang.Object
-
- org.opennms.core.test.db.TemporaryDatabasePostgreSQL
-
- org.opennms.core.test.db.MockDatabase
-
- All Implemented Interfaces:
java.sql.Wrapper
,javax.sql.CommonDataSource
,javax.sql.DataSource
,javax.sql.XADataSource
,TemporaryDatabase
,EventWriter
public class MockDatabase extends TemporaryDatabasePostgreSQL implements EventWriter
This class provides additional utility methods on top of the basicTemporaryDatabasePostgreSQL
class. For instance, it can be populated from aMockNetwork
.- Author:
- brozow
-
-
Field Summary
-
Fields inherited from class org.opennms.core.test.db.TemporaryDatabasePostgreSQL
LIQUIBASE_RELATIVE_PATH, MAX_DATABASE_DROP_ATTEMPTS, TEMPLATE_DATABASE_NAME_PREFIX
-
Fields inherited from interface org.opennms.core.test.db.TemporaryDatabase
ADMIN_PASSWORD_PROPERTY, ADMIN_USER_PROPERTY, DEFAULT_ADMIN_PASSWORD, DEFAULT_ADMIN_USER, DEFAULT_DRIVER, DEFAULT_URL, DRIVER_PROPERTY, URL_PROPERTY
-
-
Constructor Summary
Constructors Constructor Description MockDatabase()
MockDatabase(boolean createNow)
MockDatabase(java.lang.String dbName)
MockDatabase(java.lang.String name, boolean createNow)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
acknowledgeNoticesForEvent(Event e)
int
countOpenOutages()
int
countOpenOutagesForInterface(MockInterface iface)
int
countOpenOutagesForService(MockService svc)
int
countOutages()
int
countOutages(java.lang.String criteria)
int
countOutagesForInterface(MockInterface iface)
int
countOutagesForInterface(MockInterface iface, java.lang.String criteria)
int
countOutagesForService(MockService svc)
int
countOutagesForService(MockService svc, java.lang.String criteria)
void
createOutage(MockService svc, int eventId, java.sql.Timestamp time)
void
createOutage(MockService svc, Event svcLostEvent)
java.util.Collection<java.lang.Integer>
findNoticesForEvent(Event event)
java.lang.Integer
getAlarmCount(java.lang.String reductionKey)
java.lang.Integer
getAlarmId(java.lang.String reductionKey)
java.util.Collection<Outage>
getClosedOutages(MockService svc)
char
getInterfaceStatus(MockInterface iface)
java.lang.Integer
getNextEventId()
java.lang.String
getNextEventIdStatement()
protected java.lang.Integer
getNextId(java.lang.String nxtIdStmt)
java.lang.String
getNextNotifIdSql()
java.lang.Integer
getNextOutageId()
java.lang.String
getNextOutageIdStatement()
java.lang.String
getNextSequenceValStatement(java.lang.String seqName)
java.lang.Integer
getNextServiceId()
java.lang.String
getNextServiceIdStatement()
java.lang.Integer
getNextSnmpInterfaceId()
java.lang.String
getNextSnmpInterfaceIdStatement()
java.lang.String
getNextUserNotifIdSql()
java.util.Collection<Outage>
getOpenOutages(MockService svc)
java.util.Collection<Outage>
getOutages()
java.util.Collection<Outage>
getOutages(java.lang.String criteria, java.lang.Object... values)
java.util.Collection<Outage>
getOutages(MockService svc)
java.lang.Integer
getServiceID(java.lang.String serviceName)
java.lang.String
getServiceName(int serviceId)
char
getServiceStatus(MockService svc)
boolean
hasOpenOutage(MockService svc)
void
populate(MockNetwork network)
void
reparentInterface(java.lang.String ipAddr, int oldNode, int newNode)
void
resolveOutage(MockService svc, int eventId, java.sql.Timestamp timestamp)
void
resolveOutage(MockService svc, Event svcRegainEvent)
void
setInterfaceStatus(MockInterface iface, char newStatus)
void
setServiceStatus(MockService svc, char newStatus)
void
writeEvent(Event e)
void
writeInterface(MockInterface iface)
void
writeNode(MockNode node)
void
writePathOutage(MockPathOutage out)
void
writeService(MockService svc)
java.lang.Integer
writeSnmpInterface(MockInterface iface)
-
Methods inherited from class org.opennms.core.test.db.TemporaryDatabasePostgreSQL
countRows, create, createIntegrationTestTemplateDatabase, drop, dumpThreads, failIfUnitTest, generateLiquibaseHash, getAdminDataSource, getAdminXADataSource, getConnection, getConnection, getDatabaseName, getDataSource, getIntegrationTestTemplateDatabaseName, getJdbcTemplate, getLoginTimeout, getLogWriter, getParentLogger, getTestDatabase, getXAConnection, getXAConnection, getXADataSource, isWrapperFor, setClassName, setLoginTimeout, setLogWriter, setMethodName, setPlpgsqlIplike, setPopulateSchema, setTestDetails, setupBlame, setupDatabase, unwrap, update
-
-
-
-
Constructor Detail
-
MockDatabase
public MockDatabase(java.lang.String dbName) throws java.lang.Exception
- Throws:
java.lang.Exception
-
MockDatabase
public MockDatabase() throws java.lang.Exception
- Throws:
java.lang.Exception
-
MockDatabase
public MockDatabase(boolean createNow) throws java.lang.Exception
- Throws:
java.lang.Exception
-
MockDatabase
public MockDatabase(java.lang.String name, boolean createNow) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-
Method Detail
-
populate
public void populate(MockNetwork network)
-
writeNode
public void writeNode(MockNode node)
-
writeInterface
public void writeInterface(MockInterface iface)
-
writeSnmpInterface
public java.lang.Integer writeSnmpInterface(MockInterface iface)
- Returns:
- The ID of the inserted snmpinterface record
-
writeService
public void writeService(MockService svc)
-
writePathOutage
public void writePathOutage(MockPathOutage out)
-
getNextOutageIdStatement
public java.lang.String getNextOutageIdStatement()
-
getNextOutageId
public java.lang.Integer getNextOutageId()
-
getNextEventIdStatement
public java.lang.String getNextEventIdStatement()
-
getNextEventId
public java.lang.Integer getNextEventId()
-
getNextServiceIdStatement
public java.lang.String getNextServiceIdStatement()
-
getNextServiceId
public java.lang.Integer getNextServiceId()
-
getNextSnmpInterfaceIdStatement
public java.lang.String getNextSnmpInterfaceIdStatement()
-
getNextSnmpInterfaceId
public java.lang.Integer getNextSnmpInterfaceId()
-
getServiceID
public java.lang.Integer getServiceID(java.lang.String serviceName)
-
getServiceName
public java.lang.String getServiceName(int serviceId)
-
countOutagesForService
public int countOutagesForService(MockService svc)
-
countOpenOutagesForService
public int countOpenOutagesForService(MockService svc)
-
countOutagesForService
public int countOutagesForService(MockService svc, java.lang.String criteria)
-
createOutage
public void createOutage(MockService svc, Event svcLostEvent)
-
createOutage
public void createOutage(MockService svc, int eventId, java.sql.Timestamp time)
-
resolveOutage
public void resolveOutage(MockService svc, Event svcRegainEvent)
-
resolveOutage
public void resolveOutage(MockService svc, int eventId, java.sql.Timestamp timestamp)
-
writeEvent
public void writeEvent(Event e)
- Specified by:
writeEvent
in interfaceEventWriter
- Parameters:
e
-
-
setServiceStatus
public void setServiceStatus(MockService svc, char newStatus)
-
getServiceStatus
public char getServiceStatus(MockService svc)
-
setInterfaceStatus
public void setInterfaceStatus(MockInterface iface, char newStatus)
-
getInterfaceStatus
public char getInterfaceStatus(MockInterface iface)
-
countOutages
public int countOutages()
-
countOpenOutages
public int countOpenOutages()
-
countOutages
public int countOutages(java.lang.String criteria)
-
countOutagesForInterface
public int countOutagesForInterface(MockInterface iface)
-
countOpenOutagesForInterface
public int countOpenOutagesForInterface(MockInterface iface)
-
countOutagesForInterface
public int countOutagesForInterface(MockInterface iface, java.lang.String criteria)
-
hasOpenOutage
public boolean hasOpenOutage(MockService svc)
-
getOutages
public java.util.Collection<Outage> getOutages()
-
getOutages
public java.util.Collection<Outage> getOutages(java.lang.String criteria, java.lang.Object... values)
-
getOpenOutages
public java.util.Collection<Outage> getOpenOutages(MockService svc)
-
getOutages
public java.util.Collection<Outage> getOutages(MockService svc)
-
getClosedOutages
public java.util.Collection<Outage> getClosedOutages(MockService svc)
-
reparentInterface
public void reparentInterface(java.lang.String ipAddr, int oldNode, int newNode)
- Parameters:
ipAddr
-nodeId
-nodeId2
-
-
getNextNotifIdSql
public java.lang.String getNextNotifIdSql()
- Returns:
-
acknowledgeNoticesForEvent
public void acknowledgeNoticesForEvent(Event e)
- Parameters:
e
-
-
findNoticesForEvent
public java.util.Collection<java.lang.Integer> findNoticesForEvent(Event event)
- Parameters:
event
-- Returns:
-
getAlarmCount
public java.lang.Integer getAlarmCount(java.lang.String reductionKey)
-
getAlarmId
public java.lang.Integer getAlarmId(java.lang.String reductionKey)
-
getNextUserNotifIdSql
public java.lang.String getNextUserNotifIdSql()
-
getNextSequenceValStatement
public java.lang.String getNextSequenceValStatement(java.lang.String seqName)
-
getNextId
protected java.lang.Integer getNextId(java.lang.String nxtIdStmt)
-
-