ch.jalu.datasourcecolumns.sqlimplementation

Class SqlColumnsHandler<C,I>

java.lang.Object

ch.jalu.datasourcecolumns.sqlimplementation.SqlColumnsHandler<C,I>

Type Parameters:

C - the context type

I - the identifier type

All Implemented Interfaces:

ColumnsHandler<C,I>

public class SqlColumnsHandler<C,I>
extends Object
implements ColumnsHandler<C,I>

Implementation of ColumnsHandler for a SQL data source.

Constructor Summary

Constructors

Constructor and Description
SqlColumnsHandler(SqlColumnsHandlerConfig<C> config) Constructor.

Method Summary

Modifier and Type	Method and Description
int	count(Predicate<C> predicate) Returns the number of rows that match the provided predicate.
<D> boolean	insert(D dependent, DependentColumn<?,C,D>... columns) Inserts the given values into a new row, as taken from the dependent object.
boolean	insert(UpdateValues<C> updateValues) Inserts the given values into a new row.
protected boolean	performUpdateAction(PreparedStatement pst) Wraps PreparedStatement.executeUpdate() for UPDATE and INSERT statements and returns a boolean based on its return value.
DataSourceValues	retrieve(I identifier, Column<?,C>... columns) Retrieves multiple values from a given row.
<T> DataSourceValue<T>	retrieve(I identifier, Column<T,C> column) Retrieves the given column from a given row.
List<DataSourceValues>	retrieve(Predicate<C> predicate, Column<?,C>... columns) Retrieves the given columns' values from all rows that satisfy the given predicate.
<T> List<T>	retrieve(Predicate<C> predicate, Column<T,C> column) Retrieves a column's value for all rows that satisfy the given predicate.
<T> boolean	update(I identifier, Column<T,C> column, T value) Changes a column from a specific row to the given value.
<D> boolean	update(I identifier, D dependent, DependentColumn<?,C,D>... columns) Updates a row to have the values as retrieved from the dependent object.
boolean	update(I identifier, UpdateValues<C> updateValues) Updates a row to have the given values.
<T> int	update(Predicate<C> predicate, Column<T,C> column, T value) Sets the given value to the provided column for all rows which match the predicate.
int	update(Predicate<C> predicate, UpdateValues<C> updateValues) Updates all rows that match the given predicate with the provided values.

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlColumnsHandler

public SqlColumnsHandler(SqlColumnsHandlerConfig<C> config)

Constructor.

Parameters:

config - the SQL handler config to base the instance on

Method Detail

retrieve

public <T> DataSourceValue<T> retrieve(I identifier,
                                       Column<T,C> column)
                                throws SQLException

Description copied from interface: ColumnsHandler

Retrieves the given column from a given row.

Specified by:

retrieve in interface ColumnsHandler<C,I>

Type Parameters:

T - the column type

Parameters:

identifier - the id of the row to look up

column - the column whose value should be retrieved

Returns:

the result of the lookup

Throws:

SQLException

retrieve

public DataSourceValues retrieve(I identifier,
                                 Column<?,C>... columns)
                          throws SQLException

Description copied from interface: ColumnsHandler

Retrieves multiple values from a given row.

Specified by:

retrieve in interface ColumnsHandler<C,I>

Parameters:

identifier - the id of the row to look up

columns - the columns to retrieve

Returns:

map-like object with the requested values

Throws:

SQLException

retrieve

public <T> List<T> retrieve(Predicate<C> predicate,
                            Column<T,C> column)
                     throws SQLException

Description copied from interface: ColumnsHandler

Retrieves a column's value for all rows that satisfy the given predicate.

Specified by:

retrieve in interface ColumnsHandler<C,I>

Type Parameters:

T - the column's value type

Parameters:

predicate - the predicate to fulfill

column - the column to retrieve from the matching rows

Returns:

the values of the matching rows

Throws:

SQLException

retrieve

public List<DataSourceValues> retrieve(Predicate<C> predicate,
                                       Column<?,C>... columns)
                                throws SQLException

Description copied from interface: ColumnsHandler

Retrieves the given columns' values from all rows that satisfy the given predicate.

Specified by:

retrieve in interface ColumnsHandler<C,I>

Parameters:

predicate - the predicate to fulfill

columns - the columns to retrieve from the matching rows

Returns:

the values in the matching rows

Throws:

SQLException

update

public <T> boolean update(I identifier,
                          Column<T,C> column,
                          T value)
                   throws SQLException

Description copied from interface: ColumnsHandler

Changes a column from a specific row to the given value.

Specified by:

update in interface ColumnsHandler<C,I>

Type Parameters:

T - the column type

Parameters:

identifier - the id of the row to modify

column - the column to modify

value - the value to set the column to

Returns:

true upon success, false otherwise

Throws:

SQLException

update

public boolean update(I identifier,
                      UpdateValues<C> updateValues)
               throws SQLException

Description copied from interface: ColumnsHandler

Updates a row to have the given values.

Specified by:

update in interface ColumnsHandler<C,I>

Parameters:

identifier - the id of the row to modify

updateValues - the values to set on the row

Returns:

true upon success, false otherwise

Throws:

SQLException

update

public <D> boolean update(I identifier,
                          D dependent,
                          DependentColumn<?,C,D>... columns)
                   throws SQLException

Description copied from interface: ColumnsHandler

Updates a row to have the values as retrieved from the dependent object.

Specified by:

update in interface ColumnsHandler<C,I>

Type Parameters:

D - the dependent type

Parameters:

identifier - the id of the row to modify

dependent - the dependent to get values from

columns - the columns to update in the row

Returns:

true upon success, false otherwise

Throws:

SQLException

update

public <T> int update(Predicate<C> predicate,
                      Column<T,C> column,
                      T value)
               throws SQLException

Description copied from interface: ColumnsHandler

Sets the given value to the provided column for all rows which match the predicate.

Specified by:

update in interface ColumnsHandler<C,I>

Type Parameters:

T - the column type

Parameters:

predicate - the predicate to filter rows by

column - the column to modify on the matched rows

value - the new value to set

Returns:

number of modified rows

Throws:

SQLException

update

public int update(Predicate<C> predicate,
                  UpdateValues<C> updateValues)
           throws SQLException

Description copied from interface: ColumnsHandler

Updates all rows that match the given predicate with the provided values.

Specified by:

update in interface ColumnsHandler<C,I>

Parameters:

predicate - the predicate to filter rows by

updateValues - the values to set on the matched rows

Returns:

number of modified rows

Throws:

SQLException

insert

public boolean insert(UpdateValues<C> updateValues)
               throws SQLException

Description copied from interface: ColumnsHandler

Inserts the given values into a new row.

Specified by:

insert in interface ColumnsHandler<C,I>

Parameters:

updateValues - the values to insert

Returns:

true upon success, false otherwise

Throws:

SQLException

insert

public <D> boolean insert(D dependent,
                          DependentColumn<?,C,D>... columns)
                   throws SQLException

Description copied from interface: ColumnsHandler

Inserts the given values into a new row, as taken from the dependent object.

Specified by:

insert in interface ColumnsHandler<C,I>

Type Parameters:

D - the dependent type

Parameters:

dependent - the dependent to get values from

columns - the columns to insert

Returns:

true upon success, false otherwise

Throws:

SQLException

count

public int count(Predicate<C> predicate)
          throws SQLException

Description copied from interface: ColumnsHandler

Returns the number of rows that match the provided predicate.

Specified by:

count in interface ColumnsHandler<C,I>

Parameters:

predicate - the predicate to test the rows for

Returns:

number of rows fulfilling the predicate

Throws:

SQLException

performUpdateAction

protected boolean performUpdateAction(PreparedStatement pst)
                               throws SQLException

Wraps PreparedStatement.executeUpdate() for UPDATE and INSERT statements and returns a boolean based on its return value.

Parameters:

pst - the prepared statement

Returns:

true if one row was updated, false otherwise

Throws:

IllegalStateException - if more than one row was updated (should never happen)

SQLException - on SQL errors