losizm / little-sql   8.0.0

Apache License 2.0 Website GitHub

The Scala library that provides extension methods for java.sql.

Scala versions: 3.x 2.13 2.12


Maven Central

The Scala library that provides extension methods for java.sql.

Getting Started

To get started, add little-sql as a dependency to your project:

libraryDependencies += "com.github.losizm" %% "little-sql" % "8.0.0"

NOTE: Starting with version 1.0, little-sql is written for Scala 3. See previous releases for compatibility with Scala 2.12 and Scala 2.13.

A Taste of little-sql

Here's a taste of what little-sql offers.

Getting Connection and Executing Statements

The example below uses a Connector, which is an implementation of javax.sql.DataSource. It obtains a database connection and executes a series SQL statements. After executing each statement, a subclass of Execution is passed to a supplied handler. The execution is either an Update providing a count or a Query holding a ResultSet.

import java.sql.{ PreparedStatement, ResultSet }
import little.sql.{ *, given }
import scala.language.implicitConversions

case class User(id: Int, name: String)

def getUser(rs: ResultSet): User = {
  User(rs.getInt("id"), rs.getString("name"))

// Define database connector
val connector = Connector("jdbc:h2:~/little-sql", "gza", "1iquid5w0rd5", "org.h2.Driver")

// Create connection, pass it to function, and close connection when done
connector.withConnection { conn =>
  val statements = Seq(
    "drop table if exists users",
    "create table users (id int, name varchar(32))",
    "insert into users (id, name) values (0, 'root'), (500, 'guest')",
    "select id, name from users",
    "drop table if exists passwords",
    "create table passwords (id int, password varchar(32))",
    "insert into passwords (id, password) values (0, 'repus'), (500, 'esuom')"

  // Loop thru statements executing each one
  statements.foreach { sql =>
    println(s"Executing $sql ...")

    // Execute SQL, handle result, and close statement and result set (if any)
    conn.execute(sql) {
      // If update was executed, print number of rows affected
      case Update(count) => println(s"Rows affected: $count")

      // If query was executed, print first row of result set
      case Query(resultSet) => if resultSet.next() then println(getUser(resultSet))

Setting Parameters in Prepared Statement

If you're executing a statement with input parameters, you can pass the SQL along with the parameter values allowing them to be set based on their value types.

// Get connection, run update with parameters, and print number of rows inserted
connector.withConnection { conn =>
  val sql = "insert into users (id, name) values (?, ?)"

  conn.update(sql, Seq(501, "ghostface")) { count =>
    println(s"Rows inserted: $count")

Looping thru Result Set

little-sql adds a foreach method to Connection, Statement, and PreparedStatement, which cuts down the boilerplate of executing a query and looping through the ResultSet.

// Get connection, run select, and print each row in result set
connector.withConnection { conn =>
  conn.foreach("select * from users") { rs =>

Mapping First Row of Result Set

At times, you may want only the first row in a result set. Perhaps you're running a query knowing it will return at most one row. With pure Java, you use a Connection to create a Statement, you execute the statement which returns a ResultSet, and then you check the result set to see whether it has a row. If so, you proceed to get values from the result set. When you're done, you close the result set and statement.

With little-sql, ditch the ceremony and get straight to the point.

val user: Option[User] = connector.withConnection { conn =>
  conn.first("select * from users where id = 501")(getUser)

Mapping All Rows of Result Set

You can also map over an entire result set.

val users: Seq[User] = connector.withConnection { conn =>
  conn.map("select * from users")(getUser)

Or, if you're particular about which rows to map, you can flatMap the result set instead.

val regUsers: Seq[User] = connector.withConnection { conn =>
  conn.flatMap("select * from users") {
    getUser(_) match
      case User(_, "root") => None
      case user            => Some(user)

The above example is not necessarily the best use case. You could've instead written the query to exclude the root user – but you get the point.

Getting Custom Values from Result Set

You can define an implementation of GetValue to retrieve custom values from a ResultSet.

import little.sql.GetValue

case class Secret(text: String)

// Get Secret from ResultSet
given GetSecret: GetValue[Secret] with
  // Get value by index
  def apply(rs: ResultSet, index: Int): Secret =

  // Get value by label
  def apply(rs: ResultSet, label: String): Secret =

  private def decrypt(text: String): Secret =
    text == null match
      case true  => Secret("")
      case false => Secret(text.reverse)

// Get connection, run select, and print each user's password
connector.withConnection { conn =>
  val sql = """
    select u.name, p.password
    from passwords p join users u
    on p.id = u.id

  conn.foreach(sql) { rs =>
    val name = rs.getString("name")
    val password = rs.get[Secret]("password")

    printf("%s's password is %s%n", name, password.text)

Setting Custom Values in Prepared Statement

To set a parameter to a custom value, you can define an implicit conversion to convert the value to an InParam.

import scala.language.implicitConversions

import little.sql.InParam

// Convert Secret to InParam
given Conversion[Secret, InParam] with
  def apply(value: Secret) =
    value == null match
      case true  => InParam.Null
      case false => InParam(value.text.reverse)

// Get connection, run update with parameters, and print number of rows inserted
connector.withConnection { conn =>
  val sql = "insert into passwords (id, password) values (?, ?)"

  conn.update(sql, Seq(501, Secret("ironm@n"))) { count =>
    println(s"Rows inserted: $count")

Using QueryBuilder to Build and Execute Statements

QueryBuilder provides an interface for incrementally building SQL statements. And, for executing them, it has a familiar list of combinators, such as foreach, map, flatMap, and fold.

import little.sql.QueryBuilder

connector.withConnection { implicit conn =>
  val sum = QueryBuilder("select * from users where id != ? and name != ?")
    .params(0, "root") // Set input parameters
    .queryTimeout(5)   // Set query timeout to 5 seconds
    .maxRows(10)       // Limit result set to 10 rows
    .fetchSize(10)     // Fetch 10 rows at a time
    // Fold over all rows summing the user IDs
    // Executes using implicit connection
    .fold(0) { (sum, rs) => sum + rs.getInt("id") }

  println(s"Sum: $sum")

You can also supply parameters as a map or a sequence of tuples. In the example below, note the parameter placeholders in SQL and how the corresponding parameter values are supplied.

connector.withConnection { implicit conn =>
  QueryBuilder("select * from users where id != ${userId} and name != ${userName}")
    .params("userId" -> 0, "userName" -> "root")
    .foreach(rs => println(rs.getString("name")))

Working with Data Source

If you have access to an instance of javax.sql.DataSource, you can use extension methods for automatic resource management.

import javax.naming.InitialContext
import javax.sql.DataSource
import little.sql.DataSourceMethods

val dataSource = InitialContext()

// Get connection, run update with parameters, and print number of rows inserted
dataSource.withConnection { conn =>
  val sql = "insert into users (id, name) values (?, ?)"
  val params = Seq(502, "raekwon")

  conn.update(sql, params) { count =>
    println(s"Rows inserted: $count")

// Or if you need to provide user and password
dataSource.withConnection("gza", "1iquid5w0rd5") { conn =>
  conn.foreach("select name from users") { rs =>

API Documentation

See scaladoc for additional details.


little-sql is licensed under the Apache License, Version 2. See LICENSE for more information.