Package ru.dest.library.database

Class SimplePool

java.lang.Object

ru.dest.library.database.SimplePool

All Implemented Interfaces:

IDatabase

public class SimplePool
extends Object
implements IDatabase

Constructor Summary

Constructors

Constructor	Description
SimplePool(@NotNull ConnectionSettings settings, ILogger logger, int poolSize)

Method Summary

Modifier and Type	Method	Description
void	end()	Closing all connections
IConnectionProvider	getConnectionProvider()
void	putback(Connection c)
<T> T	query(String sql, Object[] data, ResultSetHandler<T> rsh)	Execute select query in parallel thread
Connection	retrieve()
int	update(String sql, Object[] data)	Execute update query in parallel thread

Methods inherited from class java.lang.Object

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

Methods inherited from interface ru.dest.library.database.IDatabase

query, update

Constructor Detail

SimplePool

public SimplePool(@NotNull
                  @NotNull ConnectionSettings settings,
                  ILogger logger,
                  int poolSize)
           throws Exception

Throws:

Exception

Method Detail

retrieve

public Connection retrieve()
                    throws SQLException

Throws:

SQLException

putback

public void putback(Connection c)
             throws NullPointerException

Throws:

NullPointerException

getConnectionProvider

public IConnectionProvider getConnectionProvider()

Specified by:

getConnectionProvider in interface IDatabase

update

public int update(String sql,
                  Object[] data)

Description copied from interface: IDatabase

Execute update query in parallel thread

Specified by:

update in interface IDatabase

Parameters:

sql - query

data - Array of Object for completing specified query

Returns:

result of query;

query

public <T> T query(String sql,
                   Object[] data,
                   ResultSetHandler<T> rsh)

Description copied from interface: IDatabase

Execute select query in parallel thread

Specified by:

query in interface IDatabase

Type Parameters:

T - expected result type

Parameters:

sql - query

data - Array of Object for completing specified query

rsh - ResultSetHandler for getting result

Returns:

Queried result or null

end

public void end()
         throws SQLException

Description copied from interface: IDatabase

Closing all connections

Specified by:

end in interface IDatabase

Throws:

SQLException - if error occupied during disconnecting from database