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:
Wrapper
,CommonDataSource
,DataSource
,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(String dbName)
MockDatabase(String name, boolean createNow)
-
Method Summary
-
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
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface javax.sql.CommonDataSource
createShardingKeyBuilder
-
Methods inherited from interface javax.sql.DataSource
createConnectionBuilder
-
Methods inherited from interface javax.sql.XADataSource
createXAConnectionBuilder
-
-
-
-
Method Detail
-
populate
public void populate(MockNetwork network)
-
writeNode
public void writeNode(MockNode node)
-
writeInterface
public void writeInterface(MockInterface iface)
-
writeSnmpInterface
public 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 String getNextOutageIdStatement()
-
getNextOutageId
public Integer getNextOutageId()
-
getNextEventIdStatement
public String getNextEventIdStatement()
-
getNextEventId
public Integer getNextEventId()
-
getNextServiceIdStatement
public String getNextServiceIdStatement()
-
getNextServiceId
public Integer getNextServiceId()
-
getNextSnmpInterfaceIdStatement
public String getNextSnmpInterfaceIdStatement()
-
getNextSnmpInterfaceId
public Integer getNextSnmpInterfaceId()
-
getServiceName
public String getServiceName(int serviceId)
-
countOutagesForService
public int countOutagesForService(MockService svc)
-
countOpenOutagesForService
public int countOpenOutagesForService(MockService svc)
-
countOutagesForService
public int countOutagesForService(MockService svc, String criteria)
-
createOutage
public void createOutage(MockService svc, Event svcLostEvent)
-
createOutage
public void createOutage(MockService svc, int eventId, Timestamp time)
-
resolveOutage
public void resolveOutage(MockService svc, Event svcRegainEvent)
-
resolveOutage
public void resolveOutage(MockService svc, int eventId, 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(String criteria)
-
countOutagesForInterface
public int countOutagesForInterface(MockInterface iface)
-
countOpenOutagesForInterface
public int countOpenOutagesForInterface(MockInterface iface)
-
countOutagesForInterface
public int countOutagesForInterface(MockInterface iface, String criteria)
-
hasOpenOutage
public boolean hasOpenOutage(MockService svc)
-
getOutages
public Collection<Outage> getOutages()
-
getOutages
public Collection<Outage> getOutages(String criteria, Object... values)
-
getOpenOutages
public Collection<Outage> getOpenOutages(MockService svc)
-
getOutages
public Collection<Outage> getOutages(MockService svc)
-
getClosedOutages
public Collection<Outage> getClosedOutages(MockService svc)
-
reparentInterface
public void reparentInterface(String ipAddr, int oldNode, int newNode)
- Parameters:
ipAddr
-nodeId
-nodeId2
-
-
getNextNotifIdSql
public String getNextNotifIdSql()
- Returns:
-
acknowledgeNoticesForEvent
public void acknowledgeNoticesForEvent(Event e)
- Parameters:
e
-
-
findNoticesForEvent
public Collection<Integer> findNoticesForEvent(Event event)
- Parameters:
event
-- Returns:
-
getNextUserNotifIdSql
public String getNextUserNotifIdSql()
-
-