public class TableProxy extends com.streamscape.ds.schema.collection.AbstractDataCollectionProxy implements Table
Title: Dataspace Framework
Description: Table collection proxy implementation.
Copyright: Copyright (c) 2011
Company: StreamScape Technologies
Constructor and Description |
---|
TableProxy() |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Purges the table.
|
void |
clear(boolean force)
Purges all rows from the table.
|
boolean |
containsPrimarykey(java.lang.String key)
Check if the table contains specified column as a primary key.
|
void |
delete(int rowId)
Not implemented.
|
void |
delete(java.lang.String selector)
Deletes rows from the table which match specified selector.
|
void |
deleteAll()
Removes all rows from the table.
|
void |
drainFromQueue(java.util.Queue queue)
Loads collection with data from provided Queue and
purges provided queue.
|
void |
fromMap(java.util.Map map)
Loads collection with data from provided Map
|
void |
fromQueue(java.util.Queue queue)
Loads collection with data from provided Queue
|
void |
fromRowSet(RowSet rowSet)
Loads collection with data from provided RowSet
|
Row |
getRow(java.lang.String rowId)
Not implemented.
|
boolean |
hasForeignKey()
Returns true if table has foreign keys defined.
|
boolean |
hasPrimaryKey()
Returns true if table has primary key defined.
|
void |
insert(java.lang.Object[] rowData)
Insert specified row into the table.
|
void |
insert(Row row)
Insert specified row into the table.
|
void |
insert(RowArray rowArray)
Inserts all rows from the row array into the table.
|
void |
insert(RowSet rowSet)
Inserts all rows from the row set into the table.
|
void |
insertAll(java.lang.String select)
Inserts all rows which are returned as a result of provided
query.
|
void |
insertAll(Table table)
Inserts all rows from specified table into
the current table.
|
boolean |
isEmpty()
Returns true if there are no rows in the table.
|
java.util.Set |
primaryKeySet()
Returns set of columns which primary key consists of.
|
RowSet |
rowSet()
Returns set of rows which table consists of.
|
RowSet |
select(java.lang.String whereClause)
Performs a query against the table.
|
long |
size()
Returns number of rows in the table.
|
java.util.Map |
toMap()
Converts existing collection data into Map.
|
Map |
toMapCollection()
Creates new transient map collection and loads it with the
data from current collection.
|
java.util.Queue |
toQueue()
Converts existing collection data into Map.
|
Queue |
toQueueCollection()
Creates new transient queue collection and loads it with the
data from current collection.
|
RowSet |
toRowSet()
Converts existing collection data into RowSet.
|
Table |
toTableCollection()
Creates new transient table collection and loads it with the
data from current collection.
|
void |
update(int rowId,
Row row)
Not implemented.
|
void |
update(java.lang.String rowId,
java.lang.Object[] rowData)
Not implemented.
|
void |
update(java.lang.String selector,
Row row)
Updated all rows in the table which match specified selector
with the data specified in the SDORow.
|
void |
upsert(java.lang.Object[] rowData)
Inserts or updates row.
|
void |
upsert(Row row)
Inserts or updates row.
|
getCollectionName, getCollectionType, getMemoryModel, listTriggers
getId, setAccessor, setId
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCollectionName, getCollectionType, getMemoryModel, listTriggers
public void clear() throws DataspaceException
Table
clear
in interface Table
DataspaceException
public void clear(boolean force) throws DataspaceException
Table
clear
in interface Table
DataspaceException
public void deleteAll() throws DataspaceException
Table
deleteAll
in interface Table
DataspaceException
public boolean containsPrimarykey(java.lang.String key)
Table
containsPrimarykey
in interface Table
key
- Column name for check.public void delete(java.lang.String selector) throws DataspaceException
Table
delete
in interface Table
selector
- Query Specification for match.DataspaceException
public void delete(int rowId)
Table
public Row getRow(java.lang.String rowId)
Table
public boolean hasForeignKey()
Table
hasForeignKey
in interface Table
public boolean hasPrimaryKey()
Table
hasPrimaryKey
in interface Table
public void insert(java.lang.Object[] rowData)
Table
public void insert(Row row)
Table
public void insert(RowArray rowArray)
Table
public void insert(RowSet rowSet)
Table
public void insertAll(Table table)
Table
public void insertAll(java.lang.String select)
Table
public boolean isEmpty()
Table
public java.util.Set primaryKeySet()
Table
primaryKeySet
in interface Table
public RowSet rowSet()
Table
public RowSet select(java.lang.String whereClause)
Table
public long size()
Table
public void update(int rowId, Row row)
Table
public void update(java.lang.String rowId, java.lang.Object[] rowData)
Table
public void update(java.lang.String selector, Row row)
Table
public void upsert(Row row)
Table
public void upsert(java.lang.Object[] rowData)
Table
public RowSet toRowSet()
Table
public java.util.Map toMap()
Table
public java.util.Queue toQueue()
Table
public void fromRowSet(RowSet rowSet)
Table
fromRowSet
in interface Table
rowSet
- RowSet to load data frompublic void fromQueue(java.util.Queue queue)
Table
public void drainFromQueue(java.util.Queue queue)
Table
drainFromQueue
in interface Table
queue
- Queue to load data frompublic void fromMap(java.util.Map map)
Table
public Table toTableCollection()
Table
toTableCollection
in interface Table
public Map toMapCollection()
Table
toMapCollection
in interface Table
public Queue toQueueCollection()
Table
toQueueCollection
in interface Table
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.