SqlQueryResult

Instance Constructors

new SqlQueryResult(resultSet: ManagedResource[ResultSet])

create a result with a result set
create a result with a result set
resultSet
Result set from executed query

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
def as[T](parser: ResultSetParser[T])(implicit connection: Connection): T

Converts this query result as T, using parser.
Converts this query result as T, using parser.

Definition Classes
WithResult
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def fold[T](z: ⇒ T)(op: (T, Row) ⇒ T)(implicit connection: Connection): Either[List[Throwable], T]

Aggregates over all rows using the specified operator.
Aggregates over all rows using the specified operator.
z
the start value
op
Aggregate operator
returns
Either list of failures at left, or aggregated value

Definition Classes
WithResult
See also
#withResult
#foldWhile
def foldWhile[T](z: ⇒ T)(op: (T, Row) ⇒ (T, Boolean))(implicit connection: Connection): Either[List[Throwable], T]

Aggregates over part of or the while row stream, using the specified operator.
Aggregates over part of or the while row stream, using the specified operator.
z
the start value
op
Aggregate operator. Returns aggregated value along with true if aggregation must process next value, or false to stop with current value.
returns
Either list of failures at left, or aggregated value

Definition Classes
WithResult
See also
#withResult
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def resultSet(c: Connection): ManagedResource[ResultSet]

Returns underlying result set
Returns underlying result set

Attributes
protected
Definition Classes
SqlQueryResult → WithResult
val resultSet: ManagedResource[ResultSet]

Result set from executed query
val statement: ManagedResource[Statement]

Query statement already executed

def statementWarning: Option[SQLWarning]

Returns statement warning if there is some for this result.

val res = SQL("EXEC stored_proc {p}").on("p" -> paramVal).executeQuery()
res.statementWarning match {
  case Some(warning) =>
    warning.printStackTrace()
    None

  case None =>
    // go on with row parsing ...
    res.as(scalar[String].singleOpt)
}

final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

def withResult[T](op: (Option[Cursor]) ⇒ T)(implicit connection: Connection): Either[List[Throwable], T]

Processes all or some rows from current result.

op

Operation applied with row cursor

@annotation.tailrec
def go(c: Option[Cursor], l: List[Row]): List[Row] = c match {
  case Some(cursor) => go(cursor.next, l :+ cursor.row)
  case _ => l
}

val l: Either[List[Throwable], List[Row]] =
  SQL"SELECT * FROM Test".withResult(go)

Definition Classes: WithResult

Deprecated Value Members

def apply()(implicit connection: Connection): Stream[Row]

Executes this SQL statement as query, returns result as Row stream.
Executes this SQL statement as query, returns result as Row stream.

Definition Classes
WithResult
Annotations
@deprecated
Deprecated
(Since version 2.4) Use fold, foldWhile or withResult instead, which manages resources and memory
def list[A](rowParser: RowParser[A])(implicit connection: Connection): Seq[A]

Applies current parser with optionnal list of rows (0..n).
Applies current parser with optionnal list of rows (0..n).

Annotations
@deprecated
Deprecated
(Since version 2.3.5) Use SQL("...").executeQuery().as(parser.*)
def parse[T](parser: ResultSetParser[T])(implicit connection: Connection): T

Annotations
@deprecated
Deprecated
(Since version 2.3.2) Use as
def single[A](rowParser: RowParser[A])(implicit connection: Connection): A

Applies current parser to exactly on row.
Applies current parser to exactly on row.

Annotations
@deprecated
Deprecated
(Since version 2.3.5) Use SQL("...").executeQuery().as(parser.single)
def singleOpt[A](rowParser: RowParser[A])(implicit connection: Connection): Option[A]

Applies current parser to one optional row.
Applies current parser to one optional row.

Annotations
@deprecated
Deprecated
(Since version 2.3.5) Use SQL("...").executeQuery().as(parser.singleOpt)

final case class SqlQueryResult(resultSet: ManagedResource[ResultSet]) extends WithResult with Product with Serializable

Instance Constructors

new SqlQueryResult(resultSet: ManagedResource[ResultSet])

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

def as[T](parser: ResultSetParser[T])(implicit connection: Connection): T

final def asInstanceOf[T0]: T0

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def finalize(): Unit

def fold[T](z: ⇒ T)(op: (T, Row) ⇒ T)(implicit connection: Connection): Either[List[Throwable], T]

def foldWhile[T](z: ⇒ T)(op: (T, Row) ⇒ (T, Boolean))(implicit connection: Connection): Either[List[Throwable], T]

final def getClass(): Class[_]

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def resultSet(c: Connection): ManagedResource[ResultSet]

val resultSet: ManagedResource[ResultSet]

val statement: ManagedResource[Statement]

def statementWarning: Option[SQLWarning]

final def synchronized[T0](arg0: ⇒ T0): T0

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def withResult[T](op: (Option[Cursor]) ⇒ T)(implicit connection: Connection): Either[List[Throwable], T]

Deprecated Value Members

def apply()(implicit connection: Connection): Stream[Row]

def list[A](rowParser: RowParser[A])(implicit connection: Connection): Seq[A]

def parse[T](parser: ResultSetParser[T])(implicit connection: Connection): T

def single[A](rowParser: RowParser[A])(implicit connection: Connection): A

def singleOpt[A](rowParser: RowParser[A])(implicit connection: Connection): Option[A]

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from WithResult

Inherited from AnyRef

Inherited from Any

Ungrouped