final class AsJava extends AnyRef
A Java-friendly API for CursoredStatements.
These should be constructed via CursoredStatement.asJava but is package exposed for testing.
- Alphabetic
- By Inheritance
- AsJava
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def execute[T](rowsPerFetch: Int, f: JavaFunction[Row, T], params: Parameter*): Future[CursorResult[T]]
Executes the cursored statement with the given
params
and lazily mapsf
over the rows as they are streamed from the database.Executes the cursored statement with the given
params
and lazily mapsf
over the rows as they are streamed from the database.Use Parameters.of for converting the inputs into Parameters.
import com.twitter.finagle.mysql.Client; import com.twitter.finagle.mysql.CursorResult; import com.twitter.finagle.mysql.CursoredStatement.AsJava; import com.twitter.util.Future; import static com.twitter.finagle.mysql.Parameters.of; Client client = ... CursoredStatement.AsJava cursoredStatement = client .cursor("SELECT int_column FROM a_table WHERE string_column = ?") .asJava(); int rowsToFetch = 10; Future<CursorResult<Integer>> result = cursoredStatement.execute( rowsToFetch, (Row row) -> row.intOrNull("int_column"), of("cool example") );
- Annotations
- @varargs()
- See also
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()