co.paralleluniverse.fibers.jdbi

Class FiberDBI

java.lang.Object

co.paralleluniverse.fibers.jdbi.FiberDBI

All Implemented Interfaces:

IDBI

public class FiberDBI
extends Object
implements IDBI

Constructor Summary

Constructors

Constructor and Description
FiberDBI(DataSource dataSource) Constructor for use with a DataSource which will provide using 10 threads fixed pool executor
FiberDBI(DataSource dataSource, ExecutorService es) Constructor for use with a DataSource which will provide
FiberDBI(DataSource dataSource, int threadCount) Constructor for use with a DataSource which will provide using fixed thread pool executor
FiberDBI(IDBI jdbi)

Method Summary

Methods

Modifier and Type	Method and Description
void	close(Object sqlObject)
void	define(String key, Object value)
<ReturnType> ReturnType	inTransaction(TransactionCallback<ReturnType> callback)
<ReturnType> ReturnType	inTransaction(TransactionIsolationLevel isolation, TransactionCallback<ReturnType> callback)
<SqlObjectType> SqlObjectType	onDemand(Class<SqlObjectType> sqlObjectType)
Handle	open()
<SqlObjectType> SqlObjectType	open(Class<SqlObjectType> sqlObjectType)
void	useHandle(HandleConsumer callback)
void	useTransaction(TransactionConsumer callback)
void	useTransaction(TransactionIsolationLevel isolation, TransactionConsumer callback)
<ReturnType> ReturnType	withHandle(HandleCallback<ReturnType> callback)

Methods inherited from class java.lang.Object

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

Constructor Detail

FiberDBI

public FiberDBI(IDBI jdbi)

Parameters:

jdbi - jdbi based on FiberDataSource

FiberDBI

public FiberDBI(DataSource dataSource,
        ExecutorService es)

Constructor for use with a DataSource which will provide

Parameters:

dataSource - may or may not be FiberDataSource

es -

FiberDBI

public FiberDBI(DataSource dataSource,
        int threadCount)

Constructor for use with a DataSource which will provide using fixed thread pool executor

Parameters:

dataSource - may or may not be FiberDataSource

threadCount -

FiberDBI

public FiberDBI(DataSource dataSource)

Constructor for use with a DataSource which will provide using 10 threads fixed pool executor

Parameters:

dataSource - may or may not be FiberDataSource

Method Detail

open

@Suspendable
public Handle open()

Specified by:

open in interface IDBI

withHandle

@Suspendable
public <ReturnType> ReturnType withHandle(HandleCallback<ReturnType> callback)
                      throws CallbackFailedException

Specified by:

withHandle in interface IDBI

Throws:

CallbackFailedException

useHandle

@Suspendable
public void useHandle(HandleConsumer callback)
               throws CallbackFailedException

Specified by:

useHandle in interface IDBI

Throws:

CallbackFailedException

open

@Suspendable
public <SqlObjectType> SqlObjectType open(Class<SqlObjectType> sqlObjectType)

Specified by:

open in interface IDBI

close

@Suspendable
public void close(Object sqlObject)

Specified by:

close in interface IDBI

onDemand

public <SqlObjectType> SqlObjectType onDemand(Class<SqlObjectType> sqlObjectType)

Specified by:

onDemand in interface IDBI

inTransaction

@Suspendable
public <ReturnType> ReturnType inTransaction(TransactionCallback<ReturnType> callback)
                         throws CallbackFailedException

Specified by:

inTransaction in interface IDBI

Throws:

CallbackFailedException

useTransaction

@Suspendable
public void useTransaction(TransactionConsumer callback)
                    throws CallbackFailedException

Specified by:

useTransaction in interface IDBI

Throws:

CallbackFailedException

inTransaction

@Suspendable
public <ReturnType> ReturnType inTransaction(TransactionIsolationLevel isolation,
                                                TransactionCallback<ReturnType> callback)
                         throws CallbackFailedException

Specified by:

inTransaction in interface IDBI

Throws:

CallbackFailedException

useTransaction

@Suspendable
public void useTransaction(TransactionIsolationLevel isolation,
                              TransactionConsumer callback)
                    throws CallbackFailedException

Specified by:

useTransaction in interface IDBI

Throws:

CallbackFailedException

define

public void define(String key,
          Object value)

Specified by:

define in interface IDBI