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 basic TemporaryDatabasePostgreSQL class. For instance, it can be populated from a MockNetwork.

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

Modifier and Type	Method	Description
void	acknowledgeNoticesForEvent(Event e)
int	countOpenOutages()
int	countOpenOutagesForInterface(MockInterface iface)
int	countOpenOutagesForService(MockService svc)
int	countOutages()
int	countOutages(String criteria)
int	countOutagesForInterface(MockInterface iface)
int	countOutagesForInterface(MockInterface iface, String criteria)
int	countOutagesForService(MockService svc)
int	countOutagesForService(MockService svc, String criteria)
void	createOutage(MockService svc, int eventId, Timestamp time)
void	createOutage(MockService svc, Event svcLostEvent)
Collection<Integer>	findNoticesForEvent(Event event)
Integer	getAlarmCount(String reductionKey)
Integer	getAlarmId(String reductionKey)
Collection<Outage>	getClosedOutages(MockService svc)
char	getInterfaceStatus(MockInterface iface)
Integer	getNextEventId()
String	getNextEventIdStatement()
protected Integer	getNextId(String nxtIdStmt)
String	getNextNotifIdSql()
Integer	getNextOutageId()
String	getNextOutageIdStatement()
String	getNextSequenceValStatement(String seqName)
Integer	getNextServiceId()
String	getNextServiceIdStatement()
Integer	getNextSnmpInterfaceId()
String	getNextSnmpInterfaceIdStatement()
String	getNextUserNotifIdSql()
Collection<Outage>	getOpenOutages(MockService svc)
Collection<Outage>	getOutages()
Collection<Outage>	getOutages(String criteria, Object... values)
Collection<Outage>	getOutages(MockService svc)
Integer	getServiceID(String serviceName)
String	getServiceName(int serviceId)
char	getServiceStatus(MockService svc)
boolean	hasOpenOutage(MockService svc)
void	populate(MockNetwork network)
void	reparentInterface(String ipAddr, int oldNode, int newNode)
void	resolveOutage(MockService svc, int eventId, 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)
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

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

Constructor Detail

MockDatabase

public MockDatabase(String dbName)
             throws Exception

Throws:

Exception

MockDatabase

public MockDatabase()
             throws Exception

Throws:

Exception

MockDatabase

public MockDatabase(boolean createNow)
             throws Exception

Throws:

Exception

MockDatabase

public MockDatabase(String name,
                    boolean createNow)
             throws Exception

Throws:

Exception

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()

getServiceID

public Integer getServiceID(String serviceName)

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 interface EventWriter

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:

getAlarmCount

public Integer getAlarmCount(String reductionKey)

getAlarmId

public Integer getAlarmId(String reductionKey)

getNextUserNotifIdSql

public String getNextUserNotifIdSql()

getNextSequenceValStatement

public String getNextSequenceValStatement(String seqName)

getNextId

protected Integer getNextId(String nxtIdStmt)