Modifier and Type | Field and Description |
---|---|
protected Protocol |
MariaDbStatement.protocol
the protocol used to talk to the server.
|
Modifier and Type | Method and Description |
---|---|
Protocol |
MariaDbStatement.getProtocol()
returns the protocol.
|
Modifier and Type | Method and Description |
---|---|
static MariaDbConnection |
MariaDbConnection.newConnection(Protocol protocol,
ReentrantLock lock) |
Modifier and Type | Field and Description |
---|---|
protected Protocol |
AbstractMastersListener.currentProtocol |
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<Protocol> |
AbstractMastersSlavesListener.waitNewMasterProtocol |
protected AtomicReference<Protocol> |
AbstractMastersSlavesListener.waitNewSecondaryProtocol |
Modifier and Type | Method and Description |
---|---|
Protocol |
Listener.getCurrentProtocol() |
Protocol |
AbstractMastersListener.getCurrentProtocol() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMastersListener.closeConnection(Protocol protocol)
Utility to close existing connection.
|
void |
Listener.foundActiveMaster(Protocol protocol) |
abstract void |
AbstractMastersSlavesListener.foundActiveSecondary(Protocol newSecondaryProtocol) |
protected boolean |
AbstractMastersListener.pingMasterProtocol(Protocol protocol) |
protected void |
AbstractMastersListener.setSessionReadOnly(boolean readOnly,
Protocol protocol) |
void |
Listener.syncConnection(Protocol from,
Protocol to) |
void |
AbstractMastersListener.syncConnection(Protocol from,
Protocol to)
When switching between 2 connections, report existing connection parameter to the new used connection.
|
Modifier and Type | Field and Description |
---|---|
protected Protocol |
MastersSlavesListener.masterProtocol |
protected Protocol |
MastersSlavesListener.secondaryProtocol |
Modifier and Type | Method and Description |
---|---|
void |
MastersSlavesListener.foundActiveMaster(Protocol newMasterProtocol)
Method called when a new Master connection is found after a fallback.
|
void |
MastersFailoverListener.foundActiveMaster(Protocol protocol)
method called when a new Master connection is found after a fallback.
|
void |
MastersSlavesListener.foundActiveSecondary(Protocol newSecondaryProtocol)
Method called when a new secondary connection is found after a fallback.
|
void |
MastersSlavesListener.lockAndSwitchMaster(Protocol newMasterProtocol)
Use the parameter newMasterProtocol as new current master connection.
|
void |
MastersSlavesListener.lockAndSwitchSecondary(Protocol newSecondaryProtocol)
Use the parameter newSecondaryProtocol as new current secondary connection.
|
HostAddress |
AuroraListener.searchByStartName(Protocol secondaryProtocol,
List<HostAddress> loopAddress)
Aurora replica doesn't have the master endpoint but the master instance name.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractConnectProtocol |
class |
AbstractQueryProtocol |
class |
AuroraProtocol |
class |
MasterProtocol |
class |
MastersSlavesProtocol |
Modifier and Type | Field and Description |
---|---|
protected Protocol |
AbstractSelectResultSet.protocol |
Modifier and Type | Method and Description |
---|---|
static ResultSet |
MariaSelectResultSet.createGeneratedData(long[] data,
Protocol protocol,
boolean findColumnReturnsOne)
Create a result set from given data.
|
static MariaSelectResultSet |
MariaSelectResultSet.createResult(Statement statement,
ResultSetPacket packet,
ReadPacketFetcher packetFetcher,
Protocol protocol,
boolean binaryProtocol,
int resultSetScrollType,
int fetchSize,
boolean canBeCallableResult)
Create streaming resultset.
|
static ResultSet |
MariaSelectResultSet.createResultSet(String[] columnNames,
MariaDbType[] columnTypes,
String[][] data,
Protocol protocol)
Create a result set from given data.
|
Constructor and Description |
---|
AbstractSelectResultSet(ColumnInformation[] columnsInformation,
Protocol protocol,
Statement statement)
Create result set.
|
MariaSelectResultSet(ColumnInformation[] columnInformation,
List<ValueObject[]> resultSet,
Protocol protocol,
int resultSetScrollType)
Create filled resultset.
|
MariaSelectResultSet(ColumnInformation[] columnInformation,
Statement statement,
Protocol protocol,
ReadPacketFetcher fetcher,
boolean binaryProtocol,
int resultSetScrollType,
int fetchSize,
boolean callableResult)
Create Streaming resultset.
|
Modifier and Type | Method and Description |
---|---|
static Protocol |
Utils.retrieveProxy(UrlParser urlParser,
ReentrantLock lock)
Retreive protocol corresponding to the failover options.
|
Modifier and Type | Method and Description |
---|---|
static PrepareStatementCache |
PrepareStatementCache.newInstance(int size,
Protocol protocol) |
Copyright © 2016. All rights reserved.