Package com.facebook.openwifi.rrm.mysql

Class DatabaseManager

java.lang.Object

com.facebook.openwifi.rrm.mysql.DatabaseManager

public class DatabaseManager
extends Object

Database connection manager.

Constructor Summary

Constructors

Constructor	Description
DatabaseManager(String server, String user, String password, String dbName, int dataRetentionIntervalDays)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	addStateRecords(List<StateRecord> records)	Insert state record(s) into the database.
void	addWifiScan(String serialNumber, long timestampSeconds, List<WifiScanEntry> entries)	Insert wifi scan results into the database.
void	close()	Close all database resources.
Map<String,State>	getLatestState()	Return the latest state records for each unique device.
Map<Long,List<WifiScanEntry>>	getLatestWifiScans(String serialNumber, int count)	Return up to the N latest wifiscan results for the given device as a map of timestamp to scan results.
void	init()	Run database initialization.

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseManager

public DatabaseManager(String server,
                       String user,
                       String password,
                       String dbName,
                       int dataRetentionIntervalDays)

Constructor.

Parameters:

server - the database host:port (ex. "localhost:3306")

user - the database user

password - the database password

dbName - the database name

dataRetentionIntervalDays - the data retention interval in days (0 to disable)

Method Detail

init

public void init()
          throws InstantiationException,
                 IllegalAccessException,
                 ClassNotFoundException,
                 SQLException

Run database initialization.

Throws:

InstantiationException

IllegalAccessException

ClassNotFoundException

SQLException

close

public void close()
           throws SQLException

Close all database resources.

Throws:

SQLException

addStateRecords

public void addStateRecords(List<StateRecord> records)
                     throws SQLException

Insert state record(s) into the database.

Throws:

SQLException

getLatestState

public Map<String,State> getLatestState()
                                       throws SQLException

Return the latest state records for each unique device.

Throws:

SQLException

addWifiScan

public void addWifiScan(String serialNumber,
                        long timestampSeconds,
                        List<WifiScanEntry> entries)
                 throws SQLException

Insert wifi scan results into the database.

Parameters:

serialNumber - serial number

timestampSeconds - timestamp (Unix time in seconds).

entries - list of wifiscan entries

Throws:

SQLException

getLatestWifiScans

public Map<Long,List<WifiScanEntry>> getLatestWifiScans(String serialNumber,
                                                              int count)
                                                       throws SQLException

Return up to the N latest wifiscan results for the given device as a map of timestamp to scan results.

Throws:

SQLException