public class JDBC_PING extends Discovery
Discovery protocol using a JDBC connection to a shared database.
Connection options can be defined as configuration properties, or the JNDI
name of a DataSource
can be provided (avoid providing both).
Both the schema and the used SQL statements can be customized; make sure the order of parameters of such customized SQL statements is maintained and that compatible types are used for the columns. The recommended schema uses a single table, with two String columns being used primary key (local address, cluster name) and a third column to store the serialized form of the objects needed by JGroups.
A default table will be created at first connection, errors during this
operation are not considered critical. Set the initialize_sql
to an empty value to prevent this initial table creation, or change it to
create a customized table.
Modifier and Type | Class and Description |
---|---|
protected class |
JDBC_PING.InfoWriter
Class which calls writeOwnInformation a few times.
|
Discovery.DiscoveryCacheDisseminationTask
Modifier and Type | Field and Description |
---|---|
protected String |
clear_sql |
protected boolean |
clear_table_on_view_change |
protected String |
connection_driver |
protected String |
connection_password |
protected String |
connection_url |
protected String |
connection_username |
protected String |
contains_sql |
protected String |
datasource_jndi_name |
protected String |
delete_single_sql |
protected Future<?> |
info_writer |
protected int |
info_writer_max_writes_after_view |
protected long |
info_writer_sleep_time |
protected String |
initialize_sql |
protected String |
insert_single_sql |
protected boolean |
register_shutdown_hook |
protected String |
select_all_pingdata_sql |
always_send_physical_addr_with_discovery_request, async_discovery, async_discovery_use_separate_thread_per_request, break_on_coord_rsp, cluster_name, current_coord, discovery_rsp_expiry_time, force_sending_discovery_rsps, is_coord, is_leaving, is_server, local_addr, max_members_in_discovery_request, members, num_discovery_requests, num_initial_members, num_initial_srv_members, ping_responses, return_entire_cache, send_cache_on_join, stagger_timeout, timeout, timer, transport_supports_multicasting, use_disk_cache, view, WHITESPACE
after_creation_hook, down_prot, ergonomics, id, log, name, stack, stats, up_prot
Constructor and Description |
---|
JDBC_PING() |
Modifier and Type | Method and Description |
---|---|
protected void |
attemptSchemaInitialization() |
protected void |
clearTable() |
protected void |
closeConnection(Connection connection) |
protected boolean |
contains(String cluster_name,
Address addr) |
protected void |
delete(Connection connection,
String clustername,
String addressToDelete) |
protected void |
delete(String clustername,
String addressToDelete) |
protected void |
deleteSelf() |
Object |
down(Event evt)
An event is to be sent down the stack.
|
void |
findMembers(List<Address> members,
boolean initial_discovery,
Responses responses)
Fetches information (e.g.
|
protected Connection |
getConnection() |
protected DataSource |
getDataSourceFromJNDI(String name) |
protected void |
handleView(View new_view,
View old_view,
boolean coord_changed) |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
protected void |
insert(Connection connection,
PingData data,
String clustername,
String address) |
boolean |
isDynamic() |
boolean |
isInfoWriterRunning() |
protected void |
loadDriver() |
protected void |
readAll(Connection connection,
List<Address> members,
String clustername,
Responses rsps) |
protected void |
readAll(List<Address> members,
String clustername,
Responses responses) |
protected void |
remove(String clustername,
Address addr) |
protected void |
startInfoWriter() |
void |
stop()
This method is called on a
Channel.disconnect() . |
protected void |
stopInfoWriter() |
protected void |
verifyconfigurationParameters() |
void |
writeInfo() |
protected void |
writeOwnInformation(boolean overwrite)
Write my own UUID,logical name and physical address to a file
|
protected void |
writeToDB(PingData data,
String clustername,
boolean overwrite) |
addDiscoveryResponseToCaches, addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, deserialize, discoveryRequestReceived, discoveryRspExpiryTime, disseminateDiscoveryInformation, dumpCache, findInitialMembersAsString, findMembers, forceDiscoveryResponses, forceDiscoveryResponses, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getNumInitialMembers, getTimeout, getView, getViewId, handleConnect, handleDisconnect, handleDiscoveryResponse, isCoord, isMergeRunning, marshal, numInitialMembers, numInitialMembers, providedUpServices, read, readPingData, resetStats, returnEntireCache, returnEntireCache, sendCacheInformation, sendDiscoveryResponse, serializeWithoutView, setForceSendingDiscoveryRsps, setNumInitialMembers, setTimeout, staggerTimeout, staggerTimeout, start, startCacheDissemination, timeout, timeout, up, useDiskCache, useDiskCache, weedOutCompletedDiscoveryResponses, write
accept, afterCreationHook, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedDownServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled, up
protected String connection_url
protected String connection_username
protected String connection_password
protected String connection_driver
protected String initialize_sql
protected String insert_single_sql
protected String delete_single_sql
protected String clear_sql
protected String select_all_pingdata_sql
protected String contains_sql
protected String datasource_jndi_name
protected boolean register_shutdown_hook
protected int info_writer_max_writes_after_view
protected long info_writer_sleep_time
protected boolean clear_table_on_view_change
protected Future<?> info_writer
public boolean isInfoWriterRunning()
public void writeInfo()
public void init() throws Exception
Protocol
public void stop()
Protocol
Channel.disconnect()
. Stops work (e.g. by closing multicast socket).
Will be called from top to bottom. This means that at the time of the method invocation the
neighbor protocol below is still working. This method will replace the
STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that
when this method is called all messages in the down queue will have been flushedpublic Object down(Event evt)
Protocol
down_prot.down()
. In case of a GET_ADDRESS event (which tries to
retrieve the stack's address from one of the bottom layers), the layer may need to send
a new response event back up the stack using up_prot.up()
.public void findMembers(List<Address> members, boolean initial_discovery, Responses responses)
Discovery
Responses
object. If Discovery.async_discovery
is true, this method will be called
in a separate thread, otherwise the caller's thread will be used.findMembers
in class Discovery
members
- A list of logical addresses (typically UUID
s). If null, then information
for all members is fetchedinitial_discovery
- Set to true if this is for the initial membership discovery. Some protocols (e.g.
file based ones) may return only the information for the coordinator(s).responses
- The list to which responses should be addedprotected void writeOwnInformation(boolean overwrite)
protected void readAll(Connection connection, List<Address> members, String clustername, Responses rsps) throws SQLException
SQLException
protected void attemptSchemaInitialization()
protected void loadDriver()
protected Connection getConnection()
protected void insert(Connection connection, PingData data, String clustername, String address) throws SQLException
SQLException
protected void delete(Connection connection, String clustername, String addressToDelete) throws SQLException
SQLException
protected void delete(String clustername, String addressToDelete) throws SQLException
SQLException
protected void deleteSelf() throws SQLException
SQLException
protected void clearTable()
protected void closeConnection(Connection connection)
protected DataSource getDataSourceFromJNDI(String name)
protected void verifyconfigurationParameters()
protected void startInfoWriter()
protected void stopInfoWriter()
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.