Package com.twl.xg.service

Class DataFetchingAndMappingService

java.lang.Object

com.twl.xg.service.DataFetchingAndMappingService

@Service
public class DataFetchingAndMappingService
extends java.lang.Object

This is the service layer class that fetches data from repositories.

Version:

1.0

Author:

Xiaozheng Guo

See Also:

BorderRouterRepository, SensorRepository, SensorDataRepository

Field Summary

Fields

Modifier and Type	Field	Description
private BorderRouterRepository	borderRouterRepository
private org.springframework.context.ApplicationContext	context
private static org.apache.log4j.Logger	logger
private PropertyService	propertyService
private SensorDataRepository	sensorDataRepository
private SensorRepository	sensorRepository

Constructor Summary

Constructors

Constructor	Description
DataFetchingAndMappingService()

Method Summary

Modifier and Type	Method	Description
private boolean	allSameElements(java.util.List<java.lang.String> lst1, java.util.List<java.lang.String> lst2)	Check if the input string lists' elements are the same to each other without considering the order.
void	clearDataBase()	Delete all entries in database, basically we just need to clear border_router table
int	clearSensorData()	Delete all sensor data entries in database.
java.util.List<java.lang.String[]>	getAllBorderRouterIpAndName()	Get IP and name of all border router, if there is no border router in database, return an empty list.
DataPackage	getAllDataFromDB(java.util.Date timeStamp)	Fetching all data generated after the given time stamp from database.
java.util.List<java.lang.String>	getAllSensorIp()	Get all sensor IP in database, if there is no sensor in database, return an empty list.
BorderRouterEntity	getBorderRouterEntity(java.lang.String borderRouterIP)	Get border router entity for given border router IP.
long	getBorderRouterNumber()	Get the total number of border router in database.
BorderRouterWrapper	getDataForBorderRouterFromDB(java.lang.String borderRouterIp, java.util.Date timeStamp)	Fetching data from database for given border router.
SensorWrapper	getDataForSensorFromDB(java.lang.String sensorIp, java.util.Date timeStamp)	Fetching data generated after the given time stamp for the given sensor from database.
java.util.List<java.lang.String>	getSensorIpByBorderRouterIp(java.lang.String borderRouterIp)	Get all sensor IP that connected to the given border router IP.
java.util.List<java.lang.String>	setDataTypes(java.lang.String[] dataTypeArray)	Update dataTypeList according to the input array.
boolean	updateSensorName(java.lang.String sensorIp, java.lang.String sensorName)	Update the name of a sensor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

context

@Autowired
private org.springframework.context.ApplicationContext context

sensorDataRepository

@Autowired
private SensorDataRepository sensorDataRepository

sensorRepository

@Autowired
private SensorRepository sensorRepository

borderRouterRepository

@Autowired
private BorderRouterRepository borderRouterRepository

propertyService

@Autowired
private PropertyService propertyService

logger

private static final org.apache.log4j.Logger logger

Constructor Detail

DataFetchingAndMappingService

public DataFetchingAndMappingService()

Method Detail

setDataTypes

@Transactional
public java.util.List<java.lang.String> setDataTypes(java.lang.String[] dataTypeArray)

Update dataTypeList according to the input array. Also update the "dataTypeListString" property in database. ALl data type string must match this pattern: [0-9a-zA-Z]+ ; Every time the dataTypeList gets updated, the sensor_data table in database will be cleared. Because the number of data fields have been changed, and it will be inconsistent. This method need to be synchronized to avoid race condition when this method is called in multi-threads. Return value is the current dataTypeList, return null if the input is invalid. After this initialize operation, the currentDataTypeList is sorted in lexicographic order.

Parameters:

dataTypeArray - An array of data types string

Returns:

Return a list of String which contains all data types name set by user.

Throws:

java.lang.RuntimeException - if the input dataTypeArray contains invalid characters.

allSameElements

private boolean allSameElements(java.util.List<java.lang.String> lst1,
                                java.util.List<java.lang.String> lst2)

Check if the input string lists' elements are the same to each other without considering the order.

getBorderRouterNumber

@Transactional
public long getBorderRouterNumber()

Get the total number of border router in database.

Returns:

the number of border router.

updateSensorName

@Transactional
public boolean updateSensorName(java.lang.String sensorIp,
                                java.lang.String sensorName)

Update the name of a sensor.

Parameters:

sensorIp - IP of the sensor you want to update.

sensorName - The name you want to update for the sensor.

Returns:

true for success, false otherwise.

getAllBorderRouterIpAndName

@Transactional
public java.util.List<java.lang.String[]> getAllBorderRouterIpAndName()

Get IP and name of all border router, if there is no border router in database, return an empty list.

Returns:

a list of String array that contains "IP, name" pair.

getDataForBorderRouterFromDB

@Transactional
public BorderRouterWrapper getDataForBorderRouterFromDB(java.lang.String borderRouterIp,
                                                        java.util.Date timeStamp)

Fetching data from database for given border router. Return all the data that generated later than the given timeStamp; If the input time stamp is null, return all data for the router. Return null if the input border router IP doesn't exist in the database or the size of the results is 0.

Parameters:

borderRouterIp - The IPv6 address of the border router you want to fetch date from.

timeStamp - The earliest time stamp.

Returns:

An instance of BorderRouterWrapper that contains a list of SensorDataEntity.

getDataForSensorFromDB

@Transactional
public SensorWrapper getDataForSensorFromDB(java.lang.String sensorIp,
                                            java.util.Date timeStamp)

Fetching data generated after the given time stamp for the given sensor from database. Return all data if the input time stamp is null. Return null if the result size == 0. Return null if the input sensorIp doesn't exist in database.

Parameters:

sensorIp - he IPv6 address of the sensor you want to fetch from.

timeStamp - The earliest time stamp.

Returns:

An instance of SensorWrapper which contains a list of SensorDataEntity.

getAllDataFromDB

@Transactional
public DataPackage getAllDataFromDB(java.util.Date timeStamp)

Fetching all data generated after the given time stamp from database. If the input time stamp is null, return all data. Return null if the size of result is 0.

Parameters:

timeStamp - The earliest time stamp.

Returns:

An instance of DataPackage which contains all data.

clearDataBase

@Transactional
public void clearDataBase()

Delete all entries in database, basically we just need to clear border_router table

clearSensorData

@Transactional
public int clearSensorData()

Delete all sensor data entries in database. After this operation, ensure there is no sensor data entry in database.

Returns:

the number of entries have been deleted.

getAllSensorIp

@Transactional
public java.util.List<java.lang.String> getAllSensorIp()

Get all sensor IP in database, if there is no sensor in database, return an empty list.

Returns:

a list of sensor IP

getSensorIpByBorderRouterIp

@Transactional
public java.util.List<java.lang.String> getSensorIpByBorderRouterIp(java.lang.String borderRouterIp)

Get all sensor IP that connected to the given border router IP. If there is no sensor connected to the border router or the input borderRouterIP doesn't exist, return an empty list;

Returns:

A list of sensor IP

getBorderRouterEntity

@Transactional
public BorderRouterEntity getBorderRouterEntity(java.lang.String borderRouterIP)

Get border router entity for given border router IP. Return null if the input border router IP doesn't exist in database.

Parameters:

borderRouterIP -

Returns:

An instance of BorderRouterEntity