123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626 |
- package de.tudarmstadt.informatik.hostage.persistence;
- import java.util.ArrayList;
- import java.util.HashMap;
- import android.content.ContentValues;
- import android.content.Context;
- import android.database.Cursor;
- import android.database.sqlite.SQLiteDatabase;
- import android.database.sqlite.SQLiteOpenHelper;
- import android.util.Log;
- import de.tudarmstadt.informatik.hostage.logging.Record;
- import de.tudarmstadt.informatik.hostage.logging.Record.TYPE;
- import de.tudarmstadt.informatik.hostage.persistence.HostageDBContract.AttackEntry;
- import de.tudarmstadt.informatik.hostage.persistence.HostageDBContract.NetworkEntry;
- import de.tudarmstadt.informatik.hostage.persistence.HostageDBContract.PacketEntry;
- public class HostageDBOpenHelper extends SQLiteOpenHelper {
- private static final String DATABASE_NAME = "hostage.db";
- private static final int DATABASE_VERSION = 1;
- static {
- StringBuilder networkSQLBuilder = new StringBuilder("CREATE TABLE ").append(NetworkEntry.TABLE_NAME).append("(");
- networkSQLBuilder.append(NetworkEntry.COLUMN_NAME_BSSID).append(" TEXT PRIMARY KEY,");
- networkSQLBuilder.append(NetworkEntry.COLUMN_NAME_SSID).append(" TEXT,");
- networkSQLBuilder.append(NetworkEntry.COLUMN_NAME_LATITUDE).append(" INTEGER,");
- networkSQLBuilder.append(NetworkEntry.COLUMN_NAME_LONGITUDE).append(" INTEGER,");
- networkSQLBuilder.append(NetworkEntry.COLUMN_NAME_ACCURACY).append(" INTEGER,");
- networkSQLBuilder.append(NetworkEntry.COLUMN_NAME_GEO_TIMESTAMP).append(" INTEGER");
- networkSQLBuilder.append(")");
- SQL_CREATE_NETWORK_ENTRIES = networkSQLBuilder.toString();
- StringBuilder attackSQLBuilder = new StringBuilder("CREATE TABLE ").append(AttackEntry.TABLE_NAME).append("(");
- attackSQLBuilder.append(AttackEntry.COLUMN_NAME_ATTACK_ID).append(" INTEGER PRIMARY KEY,");
- attackSQLBuilder.append(AttackEntry.COLUMN_NAME_PROTOCOL).append(" TEXT,");
- attackSQLBuilder.append(AttackEntry.COLUMN_NAME_EXTERNAL_IP).append(" TEXT,");
- attackSQLBuilder.append(AttackEntry.COLUMN_NAME_LOCAL_IP).append(" BLOB,");
- attackSQLBuilder.append(AttackEntry.COLUMN_NAME_LOCAL_PORT).append(" INTEGER,");
- attackSQLBuilder.append(AttackEntry.COLUMN_NAME_REMOTE_IP).append(" BLOB,");
- attackSQLBuilder.append(AttackEntry.COLUMN_NAME_REMOTE_PORT).append(" INTEGER,");
- attackSQLBuilder.append(AttackEntry.COLUMN_NAME_BSSID).append(" TEXT,");
- attackSQLBuilder.append(String.format("FOREIGN KEY(%s) REFERENCES %s(%s)", AttackEntry.COLUMN_NAME_BSSID, NetworkEntry.TABLE_NAME,
- NetworkEntry.COLUMN_NAME_BSSID));
- attackSQLBuilder.append(")");
- SQL_CREATE_ATTACK_ENTRIES = attackSQLBuilder.toString();
- StringBuilder packetSQLBuilder = new StringBuilder("CREATE TABLE ").append(PacketEntry.TABLE_NAME).append("(");
- packetSQLBuilder.append(PacketEntry.COLUMN_NAME_ID).append(" INTEGER NOT NULL,");
- packetSQLBuilder.append(PacketEntry.COLUMN_NAME_ATTACK_ID).append(" INTEGER NOT NULL,");
- packetSQLBuilder.append(PacketEntry.COLUMN_NAME_TYPE).append(" TEXT,");
- packetSQLBuilder.append(PacketEntry.COLUMN_NAME_PACKET_TIMESTAMP).append(" INTEGER,");
- packetSQLBuilder.append(PacketEntry.COLUMN_NAME_PACKET).append(" TEXT,");
- packetSQLBuilder.append(String.format("PRIMARY KEY(%s,%s)", PacketEntry.COLUMN_NAME_ID, PacketEntry.COLUMN_NAME_ATTACK_ID));
- packetSQLBuilder.append(String.format("FOREIGN KEY(%s) REFERENCES %s(%s)", PacketEntry.COLUMN_NAME_ATTACK_ID, AttackEntry.TABLE_NAME,
- AttackEntry.COLUMN_NAME_ATTACK_ID));
- packetSQLBuilder.append(")");
- SQL_CREATE_PACKET_ENTRIES = packetSQLBuilder.toString();
- }
- private static final String SQL_CREATE_NETWORK_ENTRIES;
- private static final String SQL_CREATE_ATTACK_ENTRIES;
- private static final String SQL_CREATE_PACKET_ENTRIES;
- private static final String SQL_DELETE_PACKET_ENTRIES = "DROP TABLE IF EXISTS " + PacketEntry.TABLE_NAME;
- private static final String SQL_DELETE_ATTACK_ENTRIES = "DROP TABLE IF EXISTS " + AttackEntry.TABLE_NAME;
- private static final String SQL_DELETE_NETWORK_ENTRIES = "DROP TABLE IF EXISTS " + NetworkEntry.TABLE_NAME;
- public HostageDBOpenHelper(Context context) {
- super(context, DATABASE_NAME, null, DATABASE_VERSION);
- }
- @Override
- public void onCreate(SQLiteDatabase db) {
- db.execSQL(SQL_CREATE_PACKET_ENTRIES);
- db.execSQL(SQL_CREATE_ATTACK_ENTRIES);
- db.execSQL(SQL_CREATE_NETWORK_ENTRIES);
- }
- @Override
- public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
- db.execSQL(SQL_DELETE_PACKET_ENTRIES);
- db.execSQL(SQL_DELETE_ATTACK_ENTRIES);
- db.execSQL(SQL_DELETE_NETWORK_ENTRIES);
- onCreate(db);
- }
- /**
- * Adds a given {@link Record} to the database.
- *
- * @param record
- * The added {@link Record} .
- */
- public void addRecord(Record record) {
- SQLiteDatabase db = this.getWritableDatabase();
- HashMap<String, Object> bssidValues = new HashMap<String, Object>();
- bssidValues.put(NetworkEntry.COLUMN_NAME_BSSID, record.getBssid());
- bssidValues.put(NetworkEntry.COLUMN_NAME_SSID, record.getSsid());
- bssidValues.put(NetworkEntry.COLUMN_NAME_LATITUDE, record.getLatitude());
- bssidValues.put(NetworkEntry.COLUMN_NAME_LONGITUDE, record.getLongitude());
- bssidValues.put(NetworkEntry.COLUMN_NAME_ACCURACY, record.getAccuracy());
- bssidValues.put(NetworkEntry.COLUMN_NAME_GEO_TIMESTAMP, record.getTimestampLocation());
- ContentValues attackValues = new ContentValues();
- attackValues.put(AttackEntry.COLUMN_NAME_ATTACK_ID, record.getAttack_id()); // Log
- // Attack
- // ID
- attackValues.put(AttackEntry.COLUMN_NAME_PROTOCOL, record.getProtocol().toString());
- attackValues.put(AttackEntry.COLUMN_NAME_EXTERNAL_IP, record.getExternalIP());
- attackValues.put(AttackEntry.COLUMN_NAME_LOCAL_IP, record.getLocalIP()); // Log
- // Local
- // IP
- attackValues.put(AttackEntry.COLUMN_NAME_LOCAL_PORT, record.getLocalPort());
- attackValues.put(AttackEntry.COLUMN_NAME_REMOTE_IP, record.getRemoteIP()); // Log
- // Remote
- // IP
- attackValues.put(AttackEntry.COLUMN_NAME_REMOTE_PORT, record.getRemotePort()); // Log
- // Remote
- // Port
- attackValues.put(AttackEntry.COLUMN_NAME_BSSID, record.getBssid());
- ContentValues recordValues = new ContentValues();
- recordValues.put(PacketEntry.COLUMN_NAME_ID, record.getId()); // Log
- // Message
- // Number
- recordValues.put(PacketEntry.COLUMN_NAME_ATTACK_ID, record.getAttack_id()); // Log
- // Attack
- // ID
- recordValues.put(PacketEntry.COLUMN_NAME_TYPE, record.getType().name()); // Log
- // Type
- recordValues.put(PacketEntry.COLUMN_NAME_PACKET_TIMESTAMP, record.getTimestamp()); // Log
- // Timestamp
- recordValues.put(PacketEntry.COLUMN_NAME_PACKET, record.getPacket()); // Log
- // Packet
- // Inserting Rows
- db.insertWithOnConflict(AttackEntry.TABLE_NAME, null, attackValues, SQLiteDatabase.CONFLICT_REPLACE);
- db.insert(PacketEntry.TABLE_NAME, null, recordValues);
- db.close(); // Closing database connection
- // Update Network Information
- updateNetworkInformation(bssidValues);
- }
- /**
- * Determines if a network with given BSSID has already been recorded as
- * malicious.
- *
- * @param BSSID
- * The BSSID of the network.
- * @return True if an attack has been recorded in a network with the given
- * BSSID, else false.
- */
- public boolean bssidSeen(String BSSID) {
- String countQuery = "SELECT * FROM " + NetworkEntry.TABLE_NAME + " WHERE " + NetworkEntry.COLUMN_NAME_BSSID + " = " + "'" + BSSID + "'";
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(countQuery, null);
- int result = cursor.getCount();
- cursor.close();
- db.close();
- return result > 0;
- }
- /**
- * Determines if an attack has been recorded on a specific protocol in a
- * network with a given BSSID.
- *
- * @param protocol
- * The
- * {@link de.tudarmstadt.informatik.hostage.protocol.Protocol
- * Protocol} to inspect.
- * @param BSSID
- * The BSSID of the network.
- * @return True if an attack on the given protocol has been recorded in a
- * network with the given BSSID, else false.
- */
- public boolean bssidSeen(String protocol, String BSSID) {
- String countQuery = "SELECT * FROM " + AttackEntry.TABLE_NAME + " NATURAL JOIN " + NetworkEntry.TABLE_NAME + " WHERE "
- + AttackEntry.COLUMN_NAME_PROTOCOL + " = " + "'" + protocol + "'" + " AND " + NetworkEntry.COLUMN_NAME_BSSID + " = " + "'" + BSSID + "'";
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(countQuery, null);
- int result = cursor.getCount();
- cursor.close();
- db.close();
- return result > 0;
- }
- /**
- * Deletes all records from {@link #PacketEntry.TABLE_NAME}.
- */
- public void clearData() {
- SQLiteDatabase db = this.getReadableDatabase();
- db.delete(PacketEntry.TABLE_NAME, null, null);
- db.delete(AttackEntry.TABLE_NAME, null, null);
- db.close();
- }
- /**
- * Deletes all records from {@link #PacketEntry.TABLE_NAME} with a specific BSSID.
- *
- * @param bssid
- * The BSSID to match against.
- */
- public void deleteByBSSID(String bssid) {
- SQLiteDatabase db = this.getReadableDatabase();
- db.delete(NetworkEntry.TABLE_NAME, NetworkEntry.COLUMN_NAME_BSSID + " = ?", new String[] { bssid });
- db.delete(AttackEntry.TABLE_NAME, AttackEntry.COLUMN_NAME_BSSID + " = ?", new String[] { bssid });
- db.close();
- }
- /**
- * Deletes all records from {@link #PacketEntry.TABLE_NAME} with a time stamp smaller
- * then the given
- *
- * @param date
- * A Date represented in milliseconds.
- */
- public void deleteByDate(long date) {
- SQLiteDatabase db = this.getReadableDatabase();
- String deleteQuery = "DELETE FROM " + PacketEntry.TABLE_NAME + " WHERE " + PacketEntry.COLUMN_NAME_PACKET_TIMESTAMP + " < " + date;
- db.execSQL(deleteQuery);
- db.close();
- }
- /**
- * Returns a String array with all BSSIDs stored in the database.
- *
- * @return String[] of all recorded BSSIDs.
- */
- public String[] getAllBSSIDS() {
- String selectQuery = "SELECT * FROM " + NetworkEntry.TABLE_NAME;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- String[] bssidList = new String[cursor.getCount()];
- int counter = 0;
- // looping through all rows and adding to list
- if (cursor.moveToFirst()) {
- do {
- bssidList[counter] = cursor.getString(0);
- counter++;
- } while (cursor.moveToNext());
- }
- cursor.close();
- db.close();
- return bssidList;
- }
- /**
- * Gets all received {@link Record Records} for every attack identified by
- * its attack id and ordered by date.
- *
- * @return A ArrayList with all received {@link Record Records} for each
- * attack id in the Database.
- */
- public ArrayList<Record> getAllReceivedRecordsOfEachAttack() {
- ArrayList<Record> recordList = new ArrayList<Record>();
- String selectQuery = "SELECT * FROM " + PacketEntry.TABLE_NAME + " NATURAL JOIN " + AttackEntry.TABLE_NAME + " NATURAL JOIN "
- + NetworkEntry.TABLE_NAME + " WHERE " + PacketEntry.COLUMN_NAME_TYPE + "='RECEIVE'" + " ORDER BY " + PacketEntry.COLUMN_NAME_PACKET_TIMESTAMP;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- // looping through all rows and adding to list
- if (cursor.moveToFirst()) {
- do {
- Record record = createRecord(cursor);
- // Adding record to list
- recordList.add(record);
- } while (cursor.moveToNext());
- }
- cursor.close();
- // return record list
- db.close();
- return recordList;
- }
- /**
- * Gets all {@link Record Records} saved in the database.
- *
- * @return A ArrayList of all the {@link Record Records} in the Database.
- */
- public ArrayList<Record> getAllRecords() {
- ArrayList<Record> recordList = new ArrayList<Record>();
- // Select All Query
- String selectQuery = "SELECT * FROM " + PacketEntry.TABLE_NAME + " NATURAL JOIN " + AttackEntry.TABLE_NAME + " JOIN " + NetworkEntry.TABLE_NAME
- + " USING (_bssid)";
- SQLiteDatabase db = this.getWritableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- Log.i("Database", "Start loop");
- // looping through all rows and adding to list
- if (cursor.moveToFirst()) {
- do {
- Log.i("Database", "Add Record");
- Record record = createRecord(cursor);
- // Adding record to list
- recordList.add(record);
- } while (cursor.moveToNext());
- }
- cursor.close();
- db.close();
- // return record list
- return recordList;
- }
- /**
- * Determines the number of different attack_ids in the database.
- *
- * @return The number of different attack_ids in the database.
- */
- public int getAttackCount() {
- String countQuery = "SELECT * FROM " + AttackEntry.TABLE_NAME;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(countQuery, null);
- int result = cursor.getCount();
- cursor.close();
- // return count
- db.close();
- return result;
- }
- /**
- * Determines the number of different attack_ids for a specific protocol in
- * the database.
- *
- * @param protocol
- * The String representation of the
- * {@link de.tudarmstadt.informatik.hostage.protocol.Protocol
- * Protocol}
- * @return The number of different attack_ids in the database.
- */
- public int getAttackPerProtocolCount(String protocol) {
- String countQuery = "SELECT * FROM " + AttackEntry.TABLE_NAME + " WHERE " + AttackEntry.COLUMN_NAME_PROTOCOL + " = " + "'" + protocol + "'";
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(countQuery, null);
- int result = cursor.getCount();
- cursor.close();
- // return count
- db.close();
- return result;
- }
- /**
- * Determines the highest attack id stored in the database.
- *
- * @return The highest attack id stored in the database.
- */
- public long getHighestAttackId() {
- String selectQuery = "SELECT MAX(" + AttackEntry.COLUMN_NAME_ATTACK_ID + ") FROM " + AttackEntry.TABLE_NAME;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- int result;
- if (cursor.moveToFirst()) {
- result = cursor.getInt(0);
- } else {
- result = -1;
- }
- cursor.close();
- db.close();
- return result;
- }
- public ArrayList<HashMap<String, Object>> getNetworkInformation() {
- String selectQuery = "SELECT * FROM " + NetworkEntry.TABLE_NAME;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- ArrayList<HashMap<String, Object>> networkInformation = new ArrayList<HashMap<String, Object>>();
- // looping through all rows and adding to list
- if (cursor.moveToFirst()) {
- do {
- HashMap<String, Object> values = new HashMap<String, Object>();
- values.put(NetworkEntry.COLUMN_NAME_BSSID, cursor.getString(0));
- values.put(NetworkEntry.COLUMN_NAME_SSID, cursor.getString(1));
- values.put(NetworkEntry.COLUMN_NAME_LATITUDE, Double.parseDouble(cursor.getString(2)));
- values.put(NetworkEntry.COLUMN_NAME_LONGITUDE, Double.parseDouble(cursor.getString(3)));
- values.put(NetworkEntry.COLUMN_NAME_ACCURACY, Float.parseFloat(cursor.getString(4)));
- values.put(NetworkEntry.COLUMN_NAME_GEO_TIMESTAMP, cursor.getLong(5));
- networkInformation.add(values);
- } while (cursor.moveToNext());
- }
- cursor.close();
- db.close();
- return networkInformation;
- }
- /**
- * Gets a single {@link Record} with the given ID from the database.
- *
- * @param id
- * The ID of the {@link Record};
- * @return The {@link Record}.
- */
- public Record getRecord(int id) {
- String selectQuery = "SELECT * FROM " + PacketEntry.TABLE_NAME + " NATURAL JOIN " + AttackEntry.TABLE_NAME + " NATURAL JOIN "
- + NetworkEntry.TABLE_NAME + " WHERE " + PacketEntry.COLUMN_NAME_ID + " = " + id;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- Record record = null;
- if (cursor.moveToFirst()) {
- record = createRecord(cursor);
- }
- cursor.close();
- db.close();
- // return contact
- return record;
- }
- /**
- * Determines the number of {@link Record Records} in the database.
- *
- * @return The number of {@link Record Records} in the database.
- */
- public int getRecordCount() {
- String countQuery = "SELECT * FROM " + PacketEntry.TABLE_NAME;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(countQuery, null);
- int result = cursor.getCount();
- cursor.close();
- // return count
- db.close();
- return result;
- }
- /**
- * Gets a single {@link Record} with the given attack id from the database.
- *
- * @param attack_id
- * The attack id of the {@link Record};
- * @return The {@link Record}.
- */
- public Record getRecordOfAttackId(long attack_id) {
- String selectQuery = "SELECT * FROM " + PacketEntry.TABLE_NAME + " NATURAL JOIN " + AttackEntry.TABLE_NAME + " NATURAL JOIN "
- + NetworkEntry.TABLE_NAME + " WHERE " + AttackEntry.COLUMN_NAME_ATTACK_ID + " = " + attack_id + " GROUP BY "
- + AttackEntry.COLUMN_NAME_ATTACK_ID;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- Record record = null;
- if (cursor.moveToFirst()) {
- record = createRecord(cursor);
- }
- cursor.close();
- // return record list
- db.close();
- return record;
- }
- /**
- * Gets a representative {@link Record} for every attack identified by its
- * attack id.
- *
- * @return A ArrayList with one {@link Record Records} for each attack id in
- * the Database.
- */
- public ArrayList<Record> getRecordOfEachAttack() {
- ArrayList<Record> recordList = new ArrayList<Record>();
- String selectQuery = "SELECT * FROM " + PacketEntry.TABLE_NAME + " NATURAL JOIN " + AttackEntry.TABLE_NAME + " NATURAL JOIN "
- + NetworkEntry.TABLE_NAME + " GROUP BY " + AttackEntry.COLUMN_NAME_ATTACK_ID;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- // looping through all rows and adding to list
- if (cursor.moveToFirst()) {
- do {
- Record record = createRecord(cursor);
- // Adding record to list
- recordList.add(record);
- } while (cursor.moveToNext());
- }
- cursor.close();
- // return record list
- db.close();
- return recordList;
- }
- /**
- * Gets a representative {@link Record} for every attack with a higher
- * attack id than the specified.
- *
- * @param attack_id
- * The attack id to match the query against.
- * @return A ArrayList with one {@link Record Records} for each attack id
- * higher than the given.
- */
- public ArrayList<Record> getRecordOfEachAttack(long attack_id) {
- ArrayList<Record> recordList = new ArrayList<Record>();
- String selectQuery = "SELECT * FROM " + PacketEntry.TABLE_NAME + " NATURAL JOIN " + AttackEntry.TABLE_NAME + " NATURAL JOIN "
- + NetworkEntry.TABLE_NAME + " WHERE " + AttackEntry.COLUMN_NAME_ATTACK_ID + " > " + attack_id + " GROUP BY "
- + AttackEntry.COLUMN_NAME_ATTACK_ID;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- // looping through all rows and adding to list
- if (cursor.moveToFirst()) {
- do {
- Record record = createRecord(cursor);
- // Adding record to list
- recordList.add(record);
- } while (cursor.moveToNext());
- }
- cursor.close();
- // return count
- db.close();
- return recordList;
- }
- /**
- * Determines the smallest attack id stored in the database.
- *
- * @return The smallest attack id stored in the database.
- */
- public long getSmallestAttackId() {
- String selectQuery = "SELECT MIN(" + AttackEntry.COLUMN_NAME_ATTACK_ID + ") FROM " + AttackEntry.TABLE_NAME;
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- int result;
- if (cursor.moveToFirst()) {
- result = cursor.getInt(0);
- } else {
- result = -1;
- }
- cursor.close();
- db.close();
- return result;
- }
- /**
- * Gets the last recorded SSID to a given BSSID.
- *
- * @param bssid
- * The BSSID to match against.
- * @return A String of the last SSID or null if the BSSID is not in the
- * database.
- */
- public String getSSID(String bssid) {
- String selectQuery = "SELECT " + NetworkEntry.COLUMN_NAME_SSID + " FROM " + NetworkEntry.TABLE_NAME + " WHERE " + NetworkEntry.COLUMN_NAME_BSSID
- + " = " + "'" + bssid + "'";
- SQLiteDatabase db = this.getReadableDatabase();
- Cursor cursor = db.rawQuery(selectQuery, null);
- String ssid = null;
- if (cursor.moveToFirst()) {
- ssid = cursor.getString(0);
- }
- cursor.close();
- db.close();
- return ssid;
- }
- public void updateNetworkInformation(ArrayList<HashMap<String, Object>> networkInformation) {
- Log.i("DatabaseHandler", "Starte updating");
- for (HashMap<String, Object> values : networkInformation) {
- updateNetworkInformation(values);
- }
- }
- public void updateNetworkInformation(HashMap<String, Object> networkInformation) {
- SQLiteDatabase db = this.getReadableDatabase();
- String bssid = (String) networkInformation.get(NetworkEntry.COLUMN_NAME_BSSID);
- String bssidQuery = "SELECT * FROM " + NetworkEntry.TABLE_NAME + " WHERE " + NetworkEntry.COLUMN_NAME_BSSID + " = " + "'" + bssid + "'";
- Cursor cursor = db.rawQuery(bssidQuery, null);
- int result = cursor.getCount();
- if (cursor != null && cursor.moveToFirst()
- && (result <= 0 || cursor.getLong(5) < (Long) networkInformation.get(NetworkEntry.COLUMN_NAME_GEO_TIMESTAMP)))
- ;
- {
- ContentValues bssidValues = new ContentValues();
- bssidValues.put(NetworkEntry.COLUMN_NAME_BSSID, bssid);
- bssidValues.put(NetworkEntry.COLUMN_NAME_SSID, (String) networkInformation.get(NetworkEntry.COLUMN_NAME_SSID));
- bssidValues.put(NetworkEntry.COLUMN_NAME_LATITUDE, (double) (Double) networkInformation.get(NetworkEntry.COLUMN_NAME_LATITUDE));
- bssidValues.put(NetworkEntry.COLUMN_NAME_LONGITUDE, (double) (Double) networkInformation.get(NetworkEntry.COLUMN_NAME_LONGITUDE));
- bssidValues.put(NetworkEntry.COLUMN_NAME_ACCURACY, (float) (Float) networkInformation.get(NetworkEntry.COLUMN_NAME_ACCURACY));
- bssidValues.put(NetworkEntry.COLUMN_NAME_GEO_TIMESTAMP, (Long) networkInformation.get(NetworkEntry.COLUMN_NAME_GEO_TIMESTAMP));
- db.insertWithOnConflict(NetworkEntry.TABLE_NAME, null, bssidValues, SQLiteDatabase.CONFLICT_REPLACE);
- }
- cursor.close();
- db.close();
- }
- /**
- * Creates a {@link Record} from a Cursor. If the cursor does not show to a
- * valid data structure a runtime exception is thrown.
- *
- * @param cursor
- * @return Returns the created {@link Record} .
- */
- private Record createRecord(Cursor cursor) {
- Record record = new Record();
- record.setId(Integer.parseInt(cursor.getString(0)));
- record.setAttack_id(cursor.getLong(1));
- record.setType(TYPE.valueOf(cursor.getString(2)));
- record.setTimestamp(cursor.getLong(3));
- record.setPacket(cursor.getString(4));
- record.setProtocol(cursor.getString(5));
- record.setExternalIP(cursor.getString(6));
- record.setLocalIP(cursor.getString(7));
- record.setLocalPort(Integer.parseInt(cursor.getString(8)));
- record.setRemoteIP(cursor.getString(9));
- record.setRemotePort(Integer.parseInt(cursor.getString(10)));
- record.setBssid(cursor.getString(11));
- record.setSsid(cursor.getString(12));
- record.setLatitude(Double.parseDouble(cursor.getString(13)));
- record.setLongitude(Double.parseDouble(cursor.getString(14)));
- record.setAccuracy(Float.parseFloat(cursor.getString(15)));
- record.setTimestampLocation(cursor.getLong(16));
- return record;
- }
- }
|