org.hrorm

Class SqlRunner<ENTITY,BUILDER>

java.lang.Object

org.hrorm.SqlRunner<ENTITY,BUILDER>

Type Parameters:

ENTITY - the type of object this runner supports

BUILDER - the type of object that can construct new ENTITY instances

public class SqlRunner<ENTITY,BUILDER>
extends Object

This class does the heavy lifting of creating Statements, executing SQL, and parsing ResultSets.

Most users of hrorm will have no need to directly use this.

Constructor Summary

Constructors

Constructor and Description
SqlRunner(Connection connection)
SqlRunner(Connection connection, KeylessDaoDescriptor<ENTITY,BUILDER> daoDescriptor)

Method Summary

Modifier and Type	Method and Description
<T,X> T	foldingSelect(String sql, StatementPopulator statementPopulator, Supplier<BUILDER> supplier, List<? extends ChildrenDescriptor<ENTITY,?,BUILDER,?>> childrenDescriptors, Function<BUILDER,X> buildFunction, T identity, BiFunction<T,X,T> accumulator)
void	insert(String sql, Envelope<ENTITY> envelope)
BigDecimal	runBigDecimalFunction(String sql, Where where)
Long	runLongFunction(String sql, Where where)
void	runPreparedDelete(String sql, Long id)
Set<Long>	runSelectChildIds(String sql, Long id)
long	runSequenceNextValue(String sql)
List<BUILDER>	select(String sql, Supplier<BUILDER> supplier, List<ChildrenDescriptor<ENTITY,?,BUILDER,?>> childrenDescriptors)
List<BUILDER>	selectByColumns(String sql, Supplier<BUILDER> supplier, ColumnSelection<ENTITY,BUILDER> columnSelection, List<? extends ChildrenDescriptor<ENTITY,?,BUILDER,?>> childrenDescriptors, ENTITY item)
<T> List<T>	selectDistinct(String sql, Where where, Function<ResultSet,T> resultParser)
List<BUILDER>	selectWhere(String sql, Supplier<BUILDER> supplier, List<? extends ChildrenDescriptor<ENTITY,?,BUILDER,?>> childrenDescriptors, Where where)
void	update(String sql, Envelope<ENTITY> envelope)

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlRunner

public SqlRunner(Connection connection)

SqlRunner

public SqlRunner(Connection connection,
                 KeylessDaoDescriptor<ENTITY,BUILDER> daoDescriptor)

Method Detail

select

public List<BUILDER> select(String sql,
                            Supplier<BUILDER> supplier,
                            List<ChildrenDescriptor<ENTITY,?,BUILDER,?>> childrenDescriptors)

selectByColumns

public List<BUILDER> selectByColumns(String sql,
                                     Supplier<BUILDER> supplier,
                                     ColumnSelection<ENTITY,BUILDER> columnSelection,
                                     List<? extends ChildrenDescriptor<ENTITY,?,BUILDER,?>> childrenDescriptors,
                                     ENTITY item)

selectWhere

public List<BUILDER> selectWhere(String sql,
                                 Supplier<BUILDER> supplier,
                                 List<? extends ChildrenDescriptor<ENTITY,?,BUILDER,?>> childrenDescriptors,
                                 Where where)

foldingSelect

public <T,X> T foldingSelect(String sql,
                             StatementPopulator statementPopulator,
                             Supplier<BUILDER> supplier,
                             List<? extends ChildrenDescriptor<ENTITY,?,BUILDER,?>> childrenDescriptors,
                             Function<BUILDER,X> buildFunction,
                             T identity,
                             BiFunction<T,X,T> accumulator)

runBigDecimalFunction

public BigDecimal runBigDecimalFunction(String sql,
                                        Where where)

runLongFunction

public Long runLongFunction(String sql,
                            Where where)

selectDistinct

public <T> List<T> selectDistinct(String sql,
                                  Where where,
                                  Function<ResultSet,T> resultParser)

insert

public void insert(String sql,
                   Envelope<ENTITY> envelope)

update

public void update(String sql,
                   Envelope<ENTITY> envelope)

runPreparedDelete

public void runPreparedDelete(String sql,
                              Long id)

runSequenceNextValue

public long runSequenceNextValue(String sql)

runSelectChildIds

public Set<Long> runSelectChildIds(String sql,
                                   Long id)