Package io.datarouter.client.mysql.op
Class BaseMysqlOp<T>
java.lang.Object
io.datarouter.client.mysql.op.BaseMysqlOp<T>
- Direct Known Subclasses:
BaseMysqlDeleteOp,FunctorParallelTransactionWrapper,MysqlDeleteAllOp,MysqlGetByIndexOp,MysqlGetIndexOp,MysqlGetKeysOp,MysqlGetOp,MysqlGetPrimaryKeyRangesOp,MysqlGetRangesOp,MysqlLookupUniqueOp,MysqlManagedIndexGetDatabeanRangesOp,MysqlManagedIndexGetKeyRangesOp,MysqlManagedIndexGetRangesOp,MysqlPutOp
public abstract class BaseMysqlOp<T>
extends java.lang.Object
-
Constructor Summary
Constructors Constructor Description BaseMysqlOp(io.datarouter.storage.Datarouter datarouter, io.datarouter.storage.client.ClientId clientId)BaseMysqlOp(io.datarouter.storage.Datarouter datarouter, io.datarouter.storage.client.ClientId clientId, Isolation isolation, boolean autoCommit) -
Method Summary
Modifier and Type Method Description io.datarouter.storage.client.ClientIdgetClientId()java.sql.ConnectiongetConnection()IsolationgetIsolation()booleanisAutoCommit()abstract TrunOnce()
-
Constructor Details
-
BaseMysqlOp
public BaseMysqlOp(io.datarouter.storage.Datarouter datarouter, io.datarouter.storage.client.ClientId clientId, Isolation isolation, boolean autoCommit) -
BaseMysqlOp
public BaseMysqlOp(io.datarouter.storage.Datarouter datarouter, io.datarouter.storage.client.ClientId clientId)
-
-
Method Details
-
runOnce
-
getConnection
public java.sql.Connection getConnection() -
getIsolation
-
isAutoCommit
public boolean isAutoCommit() -
getClientId
public io.datarouter.storage.client.ClientId getClientId()
-