Package edu.gsu.cs.dmlab.solgrind.database

Class SolgrindDBConnectionPostgres

java.lang.Object

edu.gsu.cs.dmlab.solgrind.database.SolgrindDBConnectionPostgres

All Implemented Interfaces:

SolgrindDBConnection

public class SolgrindDBConnectionPostgres
extends Object
implements SolgrindDBConnection

Created by ahmetkucuk on 19/08/16.

Author:

berkay - Sep 23, 2016

Constructor Summary

Constructors

Constructor	Description
SolgrindDBConnectionPostgres(DataSource source)

Method Summary

Modifier and Type	Method	Description
boolean	createTable(String tableName)
boolean	dropTable(String tableName)
List<Instance>	getAllInstances(String tableName, String eventType)
Instance	getInstance(String tableName, InstanceData instanceData)	get trajectory with given trajectory identifier
Set<Instance>	getInstances(InstanceData[] instanceDatas)	//get a set of trajectories given an array of identifiers
boolean	insertInstance(Instance ins, String tablename)	TODO modify method to do followings This method creates a table for instance (exp: ar_head_tracks_by_event or ar_tail_tracks_by_event) if it does not exists and creates a table for event (exp: ar_head, ar_tail)
boolean	insertInstances(Set<Instance> instances, String tablename)	this inserts a set of trajectories to a table in batch
Set<Instance>	searchInstances(org.joda.time.Interval twindow, org.locationtech.jts.geom.Envelope mbr, String eventType)	//this is spatiotemporal windows search on an event type
HashMap<Instance,Instance>	stJoin(String predicate, String table1, String table2)	TODO create enum for predicate

Methods inherited from class java.lang.Object

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

Constructor Detail

SolgrindDBConnectionPostgres

public SolgrindDBConnectionPostgres(DataSource source)

Method Detail

getInstance

public Instance getInstance(String tableName,
                            InstanceData instanceData)

Description copied from interface: SolgrindDBConnection

get trajectory with given trajectory identifier

Specified by:

getInstance in interface SolgrindDBConnection

Returns:

getAllInstances

public List<Instance> getAllInstances(String tableName,
                                      String eventType)

Specified by:

getAllInstances in interface SolgrindDBConnection

Returns:

set of instances

getInstances

public Set<Instance> getInstances(InstanceData[] instanceDatas)

Description copied from interface: SolgrindDBConnection

//get a set of trajectories given an array of identifiers

Specified by:

getInstances in interface SolgrindDBConnection

Returns:

searchInstances

public Set<Instance> searchInstances(org.joda.time.Interval twindow,
                                     org.locationtech.jts.geom.Envelope mbr,
                                     String eventType)

Description copied from interface: SolgrindDBConnection

//this is spatiotemporal windows search on an event type

Specified by:

searchInstances in interface SolgrindDBConnection

Returns:

insertInstance

public boolean insertInstance(Instance ins,
                              String tablename)

TODO modify method to do followings This method creates a table for instance (exp: ar_head_tracks_by_event or ar_tail_tracks_by_event) if it does not exists and creates a table for event (exp: ar_head, ar_tail)

Specified by:

insertInstance in interface SolgrindDBConnection

Parameters:

ins -

tablename -

Returns:

return True if insertion succeed

insertInstances

public boolean insertInstances(Set<Instance> instances,
                               String tablename)

Description copied from interface: SolgrindDBConnection

this inserts a set of trajectories to a table in batch

Specified by:

insertInstances in interface SolgrindDBConnection

Returns:

stJoin

public HashMap<Instance,Instance> stJoin(String predicate,
                                               String table1,
                                               String table2)

TODO create enum for predicate

Specified by:

stJoin in interface SolgrindDBConnection

Parameters:

predicate -

table1 -

table2 -

Returns:

Map of the join results

createTable

public boolean createTable(String tableName)

Specified by:

createTable in interface SolgrindDBConnection

dropTable

public boolean dropTable(String tableName)

Specified by:

dropTable in interface SolgrindDBConnection