Package com.github.longdt.vertxorm.repository.postgresql

Class AbstractCrudRepository<ID,E>

java.lang.Object

com.github.longdt.vertxorm.repository.postgresql.AbstractCrudRepository<ID,E>

All Implemented Interfaces:

CrudRepository<ID,E>

public abstract class AbstractCrudRepository<ID,E>
extends Object
implements CrudRepository<ID,E>

Field Summary

Fields

Modifier and Type	Field	Description
protected io.vertx.sqlclient.Pool	pool
protected RowMapperImpl<ID,E>	rowMapper

Constructor Summary

Constructors

Constructor	Description
AbstractCrudRepository()

Method Summary

Modifier and Type	Method	Description
void	count(io.vertx.sqlclient.SqlConnection conn, Query<E> query, io.vertx.core.Handler<io.vertx.core.AsyncResult<Long>> resultHandler)
void	delete(io.vertx.sqlclient.SqlConnection conn, ID id, io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
void	find(io.vertx.sqlclient.SqlConnection conn, Query<E> query, io.vertx.core.Handler<io.vertx.core.AsyncResult<Optional<E>>> resultHandler)
void	find(io.vertx.sqlclient.SqlConnection conn, ID id, io.vertx.core.Handler<io.vertx.core.AsyncResult<Optional<E>>> resultHandler)
void	findAll(io.vertx.sqlclient.SqlConnection conn, Query<E> query, PageRequest pageRequest, io.vertx.core.Handler<io.vertx.core.AsyncResult<Page<E>>> resultHandler)
void	findAll(io.vertx.sqlclient.SqlConnection conn, Query<E> query, io.vertx.core.Handler<io.vertx.core.AsyncResult<List<E>>> resultHandler)
void	findAll(io.vertx.sqlclient.SqlConnection conn, io.vertx.core.Handler<io.vertx.core.AsyncResult<List<E>>> resultHandler)
io.vertx.sqlclient.Pool	getPool()
RowMapper<ID,E>	getRowMapper()
protected io.vertx.sqlclient.Tuple	getSqlParams(Query<E> query)
void	init(io.vertx.sqlclient.Pool pool, RowMapperImpl<ID,E> rowMapper)
void	insert(io.vertx.sqlclient.SqlConnection conn, E entity, io.vertx.core.Handler<io.vertx.core.AsyncResult<E>> resultHandler)
void	save(io.vertx.sqlclient.SqlConnection conn, E entity, io.vertx.core.Handler<io.vertx.core.AsyncResult<E>> resultHandler)
protected io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.sqlclient.RowSet<E>>>	toEntity(io.vertx.core.Handler<io.vertx.core.AsyncResult<Optional<E>>> resultHandler)
protected io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.sqlclient.SqlResult<List<E>>>>	toList(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<E>>> resultHandler)
protected String	toSQL(String sql, Query<E> query)
void	update(io.vertx.sqlclient.SqlConnection conn, E entity, io.vertx.core.Handler<io.vertx.core.AsyncResult<E>> resultHandler)
protected String	where(String sql, Query<E> query)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.github.longdt.vertxorm.repository.CrudRepository

count, count, count, delete, delete, delete, find, find, find, find, find, find, findAll, findAll, findAll, findAll, findAll, findAll, findAll, findAll, findAll, findAll, findAll, findAll, findAll, insert, insert, insert, save, save, save, update, update, update

Field Detail

pool

protected io.vertx.sqlclient.Pool pool

rowMapper

protected RowMapperImpl<ID,E> rowMapper

Constructor Detail

AbstractCrudRepository

public AbstractCrudRepository()

Method Detail

init

public void init(io.vertx.sqlclient.Pool pool,
                 RowMapperImpl<ID,E> rowMapper)

save

public void save(io.vertx.sqlclient.SqlConnection conn,
                 E entity,
                 io.vertx.core.Handler<io.vertx.core.AsyncResult<E>> resultHandler)

Specified by:

save in interface CrudRepository<ID,E>

insert

public void insert(io.vertx.sqlclient.SqlConnection conn,
                   E entity,
                   io.vertx.core.Handler<io.vertx.core.AsyncResult<E>> resultHandler)

Specified by:

insert in interface CrudRepository<ID,E>

update

public void update(io.vertx.sqlclient.SqlConnection conn,
                   E entity,
                   io.vertx.core.Handler<io.vertx.core.AsyncResult<E>> resultHandler)

Specified by:

update in interface CrudRepository<ID,E>

delete

public void delete(io.vertx.sqlclient.SqlConnection conn,
                   ID id,
                   io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)

Specified by:

delete in interface CrudRepository<ID,E>

find

public void find(io.vertx.sqlclient.SqlConnection conn,
                 ID id,
                 io.vertx.core.Handler<io.vertx.core.AsyncResult<Optional<E>>> resultHandler)

Specified by:

find in interface CrudRepository<ID,E>

toList

protected io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.sqlclient.SqlResult<List<E>>>> toList(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<E>>> resultHandler)

toEntity

protected io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.sqlclient.RowSet<E>>> toEntity(io.vertx.core.Handler<io.vertx.core.AsyncResult<Optional<E>>> resultHandler)

findAll

public void findAll(io.vertx.sqlclient.SqlConnection conn,
                    io.vertx.core.Handler<io.vertx.core.AsyncResult<List<E>>> resultHandler)

Specified by:

findAll in interface CrudRepository<ID,E>

findAll

public void findAll(io.vertx.sqlclient.SqlConnection conn,
                    Query<E> query,
                    io.vertx.core.Handler<io.vertx.core.AsyncResult<List<E>>> resultHandler)

Specified by:

findAll in interface CrudRepository<ID,E>

find

public void find(io.vertx.sqlclient.SqlConnection conn,
                 Query<E> query,
                 io.vertx.core.Handler<io.vertx.core.AsyncResult<Optional<E>>> resultHandler)

Specified by:

find in interface CrudRepository<ID,E>

findAll

public void findAll(io.vertx.sqlclient.SqlConnection conn,
                    Query<E> query,
                    PageRequest pageRequest,
                    io.vertx.core.Handler<io.vertx.core.AsyncResult<Page<E>>> resultHandler)

Specified by:

findAll in interface CrudRepository<ID,E>

count

public void count(io.vertx.sqlclient.SqlConnection conn,
                  Query<E> query,
                  io.vertx.core.Handler<io.vertx.core.AsyncResult<Long>> resultHandler)

Specified by:

count in interface CrudRepository<ID,E>

where

protected String where(String sql,
                       Query<E> query)

toSQL

protected String toSQL(String sql,
                       Query<E> query)

getSqlParams

protected io.vertx.sqlclient.Tuple getSqlParams(Query<E> query)

getRowMapper

public RowMapper<ID,E> getRowMapper()

getPool

public io.vertx.sqlclient.Pool getPool()

Specified by:

getPool in interface CrudRepository<ID,E>