mysql-async/com.github.mauricio.async.db.mysql/MySQLConnection

MySQLConnection

class MySQLConnection(configuration: Configuration, charsetMapper: CharsetMapper, group: EventLoopGroup, val executionContext: ExecutionContext) extends MySQLHandlerDelegate with Connection with TimeoutScheduler
Companion
object
trait TimeoutScheduler
trait Connection
class Object
trait Matchable
class Any

Value members

Concrete methods

def close: Future[Connection]
def connect: Future[Connection]
override def connected(ctx: ChannelHandlerContext): Unit
Definition Classes
def count: Long
def disconnect: Future[Connection]
override def eventLoopGroup: EventLoopGroup
Definition Classes
TimeoutScheduler
override def exceptionCaught(throwable: Throwable): Unit
Definition Classes
def isConnected: Boolean
def isQuerying: Boolean
def lastException: Throwable
def onEOF(message: EOFMessage): Unit
override def onError(message: ErrorMessage): Unit
Definition Classes
override def onHandshake(message: HandshakeMessage): Unit
Definition Classes
override def onOk(message: OkMessage): Unit
Definition Classes
def onResultSet(resultSet: ResultSet, message: EOFMessage): Unit
override def onTimeout: Unit
Definition Classes
TimeoutScheduler
def sendPreparedStatement(query: String, values: Seq[Any]): Future[QueryResult]
def sendQuery(query: String): Future[QueryResult]
override def switchAuthentication(message: AuthenticationSwitchRequest): Unit
Definition Classes
override def toString: String
Definition Classes
Any
def version: Version

Inherited methods

def addTimeout[A](promise: Promise[A], durationOption: Option[Duration])(implicit executionContext: ExecutionContext): Option[ScheduledFuture[_]]
Inherited from
TimeoutScheduler
def inTransaction[A](f: Connection => Future[A])(implicit executionContext: ExecutionContext): Future[A]

Executes an (asynchronous) function within a transaction block. If the function completes successfully, the transaction is committed, otherwise it is aborted.

Executes an (asynchronous) function within a transaction block. If the function completes successfully, the transaction is committed, otherwise it is aborted.

Value Params
f

operation to execute on this connection

Returns

result of f, conditional on transaction operations succeeding

Inherited from
Connection
def isTimeouted: Boolean

We need this property as isClosed takes time to complete and we don't want the connection to be used again.

We need this property as isClosed takes time to complete and we don't want the connection to be used again.

Inherited from
TimeoutScheduler
def schedule(block: => Unit, duration: Duration): ScheduledFuture[_]
Inherited from
TimeoutScheduler

Implicits

Implicits

implicit val executionContext: ExecutionContext