org.gridgain.grid.spi.discovery.tcp.ipfinder.jdbc

Class GridTcpDiscoveryJdbcIpFinder

java.lang.Object

org.gridgain.grid.spi.discovery.tcp.ipfinder.GridTcpDiscoveryIpFinderAdapter

org.gridgain.grid.spi.discovery.tcp.ipfinder.jdbc.GridTcpDiscoveryJdbcIpFinder

All Implemented Interfaces:

GridTcpDiscoveryIpFinder

public class GridTcpDiscoveryJdbcIpFinder
extends GridTcpDiscoveryIpFinderAdapter

JDBC-based IP finder.

Configuration

Mandatory

• Data source (see setDataSource(DataSource)).

Optional

There are no optional configuration parameters.

The database will contain 1 table which will hold IP addresses.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHK_QRY Query to check database validity.
static String	CREATE_ADDRS_TABLE_QRY Query to create addresses table.
static String	GET_ADDRS_QRY Query to get addresses.
static String	REG_ADDR_QRY Query to register address.
static String	UNREG_ADDR_QRY Query to unregister address.

Constructor Summary

Constructors

Constructor and Description
GridTcpDiscoveryJdbcIpFinder() Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
Collection<InetSocketAddress>	getRegisteredAddresses() Gets all addresses registered in this finder.
void	registerAddresses(Collection<InetSocketAddress> addrs) Registers new addresses.
void	setDataSource(DataSource dataSrc) Sets data source.
String	toString()
void	unregisterAddresses(Collection<InetSocketAddress> addrs) Unregisters provided addresses.

Methods inherited from class org.gridgain.grid.spi.discovery.tcp.ipfinder.GridTcpDiscoveryIpFinderAdapter

close, initializeLocalAddresses, isShared, onSpiContextDestroyed, onSpiContextInitialized, setShared, spiContext

Methods inherited from class java.lang.Object

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

Field Detail

GET_ADDRS_QRY

public static final String GET_ADDRS_QRY

Query to get addresses.

See Also:

Constant Field Values

REG_ADDR_QRY

public static final String REG_ADDR_QRY

Query to register address.

See Also:

Constant Field Values

UNREG_ADDR_QRY

public static final String UNREG_ADDR_QRY

Query to unregister address.

See Also:

Constant Field Values

CREATE_ADDRS_TABLE_QRY

public static final String CREATE_ADDRS_TABLE_QRY

Query to create addresses table.

See Also:

Constant Field Values

CHK_QRY

public static final String CHK_QRY

Query to check database validity.

See Also:

Constant Field Values

Constructor Detail

GridTcpDiscoveryJdbcIpFinder

public GridTcpDiscoveryJdbcIpFinder()

Constructor.

Method Detail

getRegisteredAddresses

public Collection<InetSocketAddress> getRegisteredAddresses()
                                                     throws GridSpiException

Gets all addresses registered in this finder.

Returns:

All known addresses, potentially empty, but never null.

Throws:

GridSpiException - In case of error.

registerAddresses

public void registerAddresses(Collection<InetSocketAddress> addrs)
                       throws GridSpiException

Registers new addresses.

Implementation should accept duplicates quietly, but should not register address if it is already registered.

Parameters:

addrs - Addresses to register. Not null and not empty.

Throws:

GridSpiException - In case of error.

unregisterAddresses

public void unregisterAddresses(Collection<InetSocketAddress> addrs)
                         throws GridSpiException

Unregisters provided addresses.

Implementation should accept addresses that are currently not registered quietly (just no-op).

Parameters:

addrs - Addresses to unregister. Not null and not empty.

Throws:

GridSpiException - In case of error.

setDataSource

@GridSpiConfiguration(optional=false)
public void setDataSource(DataSource dataSrc)

Sets data source.

Data source should be fully configured and ready-to-use.

Parameters:

dataSrc - Data source.

toString

public String toString()

Overrides:

toString in class GridTcpDiscoveryIpFinderAdapter