Installation
Attention! There are some changes to the API in this version. They affect INSERT, UPDATE and DELETE.
For ZIO 1
libraryDependencies += "io.github.karimagnusson" % "kuzminki-zio" % "0.9.4-RC4"
For ZIO 2
libraryDependencies += "io.github.karimagnusson" % "kuzminki-zio-2" % "0.9.4-RC4"
For EC
libraryDependencies += "io.github.karimagnusson" % "kuzminki-ec" % "0.9.4-RC5"
If you need an older version of this documentation:
Example
This example is for ZIO. For ZIO 2 refer to the respective github pages.
import zio._
import zio.console._
import zio.blocking._
import kuzminki.api._
object ExampleApp extends zio.App {
class Client extends Model("client") {
val id = column[Int]("id")
val username = column[String]("username")
val age = column[Int]("age")
def all = (id, username, age)
}
val client = Model.get[Client]
val job = for {
_ <- sql
.insert(client)
.cols2(t => (t.username, t.age))
.values(("Joe", 35))
.run
_ <- sql
.update(client)
.set(_.age ==> 24)
.where(_.id === 4)
.run
_ <- sql.delete(client).where(_.id === 7).run
clients <- sql
.select(client)
.cols3(_.all)
.where(_.age > 25)
.limit(5)
.run
_ <- ZIO.foreach(clients) {
case (id, username, age) =>
putStrLn(s"$id $username $age")
}
} yield ()
val dbConfig = DbConfig.forDb("company")
val dbLayer = Kuzminki.layer(dbConfig)
override def run(args: List[String]): ZIO[ZEnv, Nothing, ExitCode] = {
job.provideCustomLayer(dbLayer).exitCode
}
}
Results
// query
val stm = sql.select(client).cols3(_.all).where(_.age > 25).limit(5)
stm.run: List[T]
stm.runHead: T
stm.runHeadOpt: Option[T]
// modify row
implicit val toMyType: SomeRow => MyType = row => //...
stm.runAs[MyType]: List[MyType]
stm.runHeadAs[MyType]: MyType
stm.runHeadOptAs[MyType]: Option[MyType]
// operation
val stm = sql.update(client).set(_.age ==> 24).where(_.id === 4)
stm.run: Unit
stm.runNum: Int
Config
val dbConfig = DbConfig
.forDb("{DB-NAME}")
.withPoolSize(10) // default = 10
.withHost("{HOST}") // default = localhost
.withPort("{PORT}") // default = 5432
.withUser("{USER}}")
.withPassword("{PASSWORD}")
.withOptions(Map(...))
Layer
Create a layer to make the driver instance accessable under Has[Kuzminki]
For ZIO 1
object MyApp extends zio.App {
val job = // ...
val dbLayer = Kuzminki.layer(DbConfig.forDb("company"))
override def run(args: List[String]): ZIO[ZEnv, Nothing, ExitCode] = {
job.provideCustomLayer(dbLayer).exitCode
}
}
For ZIO 2
object MyApp extends ZIOAppDefault {
// ...
def run = job.provide(dbLayer)
}
Custom connection
for {
db <- Kuzminki.create(dbConfig)
users <- db.query {
sql.select(user).cols1(_.username.all.orderBy(_.id.asc)
}
} yield users
Split connection
If you wish to have two connection pools, one for SELECT and another for INSERT, UPDATE, DELETE, you can use layerSplit. To create an instance rather than a Layer, use createSplit.
// for .query .queryHead .queryHeadOpt
val getConfig = DbConfig.forDb("company").withPoolSize(5)
// for .exec .execNum
val setConfig = DbConfig.forDb("company").withPoolSize(5)
val dbLayer = Kuzminki.layerSplit(getConfig, setConfig)
Creating a model
Column types are listed under Data types
import kuzminki.api._
import java.sql.Timestamp
class User extends Model("user_profile") {
val id = column[Int]("id")
val username = column[String]("username")
val email = column[String]("email")
val name = column[String]("name")
val age = column[Int]("age")
val gender = column[String]("gender")
val country = column[String]("country")
val city = column[String]("city")
val discount = column[Int]("discount")
val isActive = column[Boolean]("is_active")
val created = column[Timestamp]("created")
}
Model.register[User]
Custom methods
You can create custom methods to access columns that you regularly use.
class Customer extends Model("customer") {
val id = column[Int]("id")
val userId = column[Int]("user_id")
val spending = column[Int]("spending")
def all = (id, userId, spending)
}
Create a model instance
Model.register[User] creates an instance of the model for later use and makes sure there is only one instance of the model. Model.register[User] gets an existing instance of the model. If it does not exist, it is created.
Model.register[User]
// ...
val user = Model.get[User]
Select query
You select the columns as tuple of model columns. The query will return tuple of the column types. In this case Seq[Tuple2[Int, String]]. If you need more than 22 columns you can use colsSeq or colsType. To order by ASC rather than DESC use orderBy(_.age.asc).
sql
.select(user)
.cols2(t => (
t.id,
t.username
))
.where(t => Seq(
t.gender === "f",
t.age > 25
))
.orderBy(_.age.desc)
.limit(10)
.run
SELECT
"id",
"username"
FROM "user_profile"
WHERE "gender" = 'f'
AND "age" > 25
ORDER BY "age" DESC
LIMIT 10
Row as case class
case class ProductItem(id: Int, name: String, price: Float)
class Product extends Model("product") {
val id = column[Int]("id")
val name = column[String]("name")
val price = column[Float]("price")
val item = read[ProductItem](id, name, price)
}
val product = Model.get[Product]
sql
.select(product)
.colsType(_.item)
.where(_.price < 100.0)
.run
// returns List[ProductItem]
Row as Seq
sql
.select(user)
.colsSeq(t => Seq(
t.id,
t.username,
t.email
))
.where(_.age < 25)
.run
// returns List[Vector[Any]]
Row as JSON
Get the row as a JSON string.
sql
.select(user)
.colsJson(t => Seq(
t.id,
t.username
))
.where(_.id === 5)
.runHead
// returns {"id": 5, "username": "Joe"}
Pick a name for columns and create a nested object.
.colsJson(t => Seq(
"id" -> t.id,
t.username.as("username"),
Fn.json(Seq(
t.country,
t.city
)).as("location")
))
// returns {"id": 5, "username": "Joe", "location": {"country": "IT", "city": "Rome"}}
Result with a nested array from subquery.
.colsJson(t => Seq(
t.id,
t.username,
sql
.select(travels)
.colsJson(s => Seq(
s.country,
s.year
))
.where(s.userId <=> t.id)
.orderBy(_.year.desc)
.asColumn // if you need the first object instead of an array, you can use .first after .asColumn
.as("travels")
))
Get the result as JSON, using your favorite JSON library.
// See PlayJsonLoader below
implicit val loadJson: Seq[Tuple2[String, Any]] => JsValue = data => PlayJsonLoader.load(data)
sql
.select(user)
.colsNamed(t => Seq(
t.id, // Column name is used as a key.
t.username, // If you want a different key:
t.email // ("user_id" -> t.id)
))
.where(_.age < 25)
.runAs[JsValue]
// returns List[JsValue]
Write something along these lines to use the JSON library of your choosing.
import java.util.UUID
import java.sql.Time
import java.sql.Date
import java.sql.Timestamp
import play.api.libs.json._
import kuzminki.api.Jsonb
object PlayJsonLoader {
val toJsValue: Any => JsValue = {
case v: String => JsString(v)
case v: Boolean => JsBoolean(v)
case v: Short => JsNumber(v)
case v: Int => JsNumber(v)
case v: Long => JsNumber(v)
case v: Float => JsNumber(v)
case v: Double => JsNumber(v)
case v: BigDecimal => JsNumber(v)
case v: Time => Json.toJson(v)
case v: Date => Json.toJson(v)
case v: Timestamp => Json.toJson(v)
case v: UUID => JsString(v.toString)
case v: Jsonb => Json.parse(v.value)
case v: Option[_] => v.map(toJsValue).getOrElse(JsNull)
case v: Seq[_] => JsArray(v.map(toJsValue))
case v: JsValue => v
case _ => throw new Exception("Cannot convert to JsValue")
}
def load(data: Seq[Tuple2[String, Any]]): JsValue = {
JsObject(data.map(p => (p._1, toJsValue(p._2))))
}
}
Where
Refer to Operators for a list of operators.
.where(_.id > 100)
.where(t => Seq(
t.gender === "f",
t.age > 25
))
AND / OR
import kuzminki.fn._
.where(t => Seq(
t.age > 25,
Or(
t.country === "RU",
t.country === "FR"
)
))
// WHERE "age" > 25 AND ("country" == 'RU' OR "country" == 'FR')
.where(t => Or(
And(
t.country === "RU",
t.city === "Moscow"
),
And(
t.country === "FR",
t.city === "Paris"
)
))
// WHERE ("country" == 'RU' AND "city" == 'Moscow') OR ("country" == 'FR' AND "city" == 'Paris')
Optional conditions
Optional conditions for example from http GET request.
.whereOpt(_.id > Some(100))
.whereOpt(t => Seq(
t.gender === None,
t.age > Some(25)
))
// WHERE "age" > 25
.whereOpt(t => Seq(
t.age > Some(25),
Or.opt(
t.country === Some("RU"),
t.country === Some("FR")
)
))
// WHERE "age" > 25 AND ("country" == 'RU' OR "country" == 'FR')
Distinct
sql
.select(user)
.cols2(t => (
t.username,
t.age
))
.distinct
.all
.orderBy(_.age.asc)
.run
SELECT DISTINCT "username", "age"
FROM "user_profile"
ORDER BY "age" ASC
)
sql
.select(user)
.cols2(t => (
t.username,
t.age
))
.distinctOn(_.age)
.all
.orderBy(_.age.asc)
.run
SELECT DISTINCT ON ("age") "username", "age"
FROM "user_profile"
ORDER BY "age" ASC
)
Nested query
class Newsletter extends Model("newsletter") {
val email = column[String]("email")
val isSubscribed = column[Boolean]("is_subscribed")
}
val newsletter = Model.get[Newsletter]
sql
.select(user)
.cols1(_.username)
.where(_.email.in(
sql
.select(newsletter)
.cols1(_.email)
.where(_.isSubscribed === true)
))
.run
SELECT "username"
FROM "user_profile"
WHERE "email" = ANY(
SELECT "email"
FROM "newsletter"
WHERE "is_subscribed" = true
)
Cache
For increased performance and reusability queries can be cached. The SQL string will be created only once and you get the same performance as you get with raw queries.
val stm = sql
.select(user)
.cols1(_.username)
.all
.orderBy(_.age.asc)
.pickWhere2(t => (
t.country.use === Arg,
t.age.use > Arg
))
.cache
stm.run(("CN", 25))
SELECT "username"
FROM "user_profile"
WHERE "country" = 'CN'
AND "age" > 25
ORDER BY "age" ASC
Chche a query with no arguments.
val stm = sql
.select(user)
.col2(t => (
t.username,
t.created
))
.all
.orderBy(_.created.desc)
.cache
stm.run
Cache nested query.
val stm = sql
.select(user)
.cols1(_.username)
.all
.pickWhere(t = (
t.age.use > Arg,
t.email.use.in(
sql
.select(newsletter)
.cols1(_.email)
.all
.pickWhere1(_.isActive.use === Arg)
)
))
.cache
stm.run(25, true)
Cached with WHERE
You can use normal WHERE conditions with cached queries.
val stm = sql
.select(user)
.cols1(_.username)
.where(_.age > 25)
.orderBy(_.age.asc)
.pickWhere1(_.country.use === Arg)
.cache
stm.run("CN")
SELECT "username"
FROM "user_profile"
WHERE "age" > 25
AND "country" = 'CN'
ORDER BY "age" ASC
Select join
To do Joins you just put two model instances as arguments and the models will be accessable under a and b
sql
.select(user, customer)
.cols3(t => (
t.a.id,
t.a.username,
t.b.spending
))
.joinOn(_.id, _.userId)
.where(t => Seq(
t.a.age > 25,
t.b.spending > 1000
))
.orderBy(_.b.spending.desc)
.limit(10)
.run
// returns List[Tuple3[Int, String, Int]]
SELECT
"a"."id",
"a"."username",
"b"."spending"
FROM "user_profile" "a"
INNER JOIN "customer" "b"
ON "a"."id" = "b"."user_id"
WHERE "a"."age" > 25
AND "b"."spending" > 1000
ORDER BY "b"."spending" DESC
LIMIT 10
Join result types
You can have a join query return a case class.
case class UserSpending(userId: Int, username: String, spending: Int)
class UserCustomer extends JoinRead[User, Customer] {
val userSpending = read[UserSpending](a.id, a.username, b.spending)
}
val userCustomer = new UserCustomer
implicit val userCustomerConv = userCustomer.convert
sql
.select(userCustomer)
.colsType(_.userSpending)
.joinOn(_.id, _.userId)
.where(_.a.age > 25)
.orderBy(_.b.spending.desc)
.limit(10)
.run
// returns List[UserCustomer]
You can also define results as tuples or a Vector
class UserCustomer extends JoinRead[User, Customer] {
val userSpending = read[UserSpending](a.id, a.username, b.spending)
// colsType(_.userSpending)
val userSpendingTuple = (a.id, a.username, b.spending)
// cols3(_.userSpendingTuple)
val userSpendingVector = Vector(a.id, a.username, b.spending)
// colsVector(_.userSpendingVector)
}
SELECT
"a"."id",
"a"."username",
"b"."spending"
FROM "user_profile" "a"
INNER JOIN "customer" "b"
ON "a"."id" = "b"."user_id"
WHERE "a"."age" > 25
ORDER BY "b"."spending" DESC
LIMIT 10
Join types
The following joins are available. Refer to the section Null values to avoid problems that may come up with joins.
.joinOn(_.id, _.userId) // INNER JOIN
.innerJoinOn(_.id, _.userId) // INNER JOIN
.leftJoinOn(_.id, _.userId) // LEFT JOIN
.leftOuterJoinOn(_.id, _.userId) // LEFT OUTER JOIN
.rightJoinOn(_.id, _.userId) // RIGHT JOIN
.rightOuterJoinOn(_.id, _.userId) // RIGHT OUTER JOIN
.fullOuterJoinOn(_.id, _.userId) // FULL OUTER JOIN
.crossJoin // CROSS JOIN
Basic insert
sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.values(("bob", "bob@mail.com"))
.run
If you need to insert more than the tuple limit of 22.
sql
.insert(user)
.data(t => Seq(
t.username ==> "bob",
t.email ==> "bob@mail.com"
))
.run
For increased performance and reusability queries can be cached.
val stm = sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.cache
stm.run(("bob", "bob@mail.com"))
INSERT INTO "user_profile" ("username", "email") VALUES ('bob', 'bob@mail.com')
Insert case class
case class AddProduct(name: String, price: Float)
class Product extends Model("product") {
val id = column[Int]("id")
val name = column[String]("name")
val price = column[Float]("price")
val add = write[AddProduct](name, price)
}
val product = Model.get[Product]
sql
.insert(product)
.colsType(_.add)
.values(AddProduct("Banana", 12.5))
.run
// cache
val stm = sql
.insert(product)
.colsType(_.add)
.cache
stm.run(AddProduct("Banana", 12.5))
INSERT INTO "product" ("name", "price") VALUES ('Banana', 12.5)
Insert returning
sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.values(("bob", "bob@mail.com"))
.returning3(t => (
t.id,
t.username,
t.email
))
.runHead
// cache
val stm = sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.returning3(t => (
t.id,
t.username,
t.email
))
.cache
stm.run(("bob", "bob@mail.com"))
INSERT INTO "user_profile"
("username", "email")
VALUES ('bob', 'bob@mail.com')
RETURNING
"id",
"username",
"email"
Insert on conflict do nothing
You can take advantage of ON CONFLICT DO NOTHING to avoid errors on columns with UNIQUE constraint.
sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.values(("bob", "bob@mail.com"))
.onConflictDoNothing
.run
// cache
val stm = sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.onConflictDoNothing
.cache
stm.run(("bob", "bob@mail.com"))
INSERT INTO "user_profile"
("username", "email")
VALUES ('bob', 'bob@mail.com')
ON CONFLICT DO NOTHING
Upsert
The updated column has to be one of the columns you intend to insert.
sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.values(("bob", "bob@hotmail.com"))
.onConflictOnColumn(_.username)
.doUpdate(_.email) // .doNothing is also an option
.run
// cache
val stm = sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.onConflictOnColumn(_.username)
.doUpdate(_.email)
.cache
stm.run(("bob", "bob@hotmail.com"))
INSERT INTO "user_profile"
("username", "email")
VALUES ('bob', 'bob@mail.com')
ON CONFLICT ("username")
DO UPDATE SET "email" = 'bob@mail.com'
Insert where not exists
If you need to avoid duplication on a column that does not have a unique constraint you can use whereNotExists. Also, if you are makeing multible insert statements concurrently, from a stream for example, you will run into problems using onConflictDoNothing.
sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.values(("bob", "bob@mail.com"))
.whereNotExists(_.username)
.run
// cache
val stm = sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.whereNotExists(_.username)
.cache
stm.run(("bob", "bob@mail.com"))
INSERT INTO "user_profile"
("username", "email")
SELECT 'bob', 'bob@mail.com'
WHERE NOT EXISTS (
SELECT 1
FROM "user_profile"
WHERE "username" = 'bob'
)
Insert from select
sql
.insert(newsletter)
.cols1(_.email)
.fromSelect(
sql
.select(user)
.cols1(_.email)
.where(_.isActive === true)
)
.run
// cache
val stm = sql
.insert(newsletter)
.cols1(_.email)
.pickSelect(
sql
.select(user)
.cols1(_.email)
.pickWhere1(_.isActive.use === Arg)
)
.cache
stm.run(true)
INSERT INTO "newsletter" ("email")
SELECT "email"
FROM "user_profile"
WHERE "is_active" = true
Insert many
val stm = sql
.insert(user)
.cols2(t => (
t.username,
t.email
))
.cache
stm.runList(Seq(
("bob", "bob@mail.com"),
("jane", "jane@mail.com"),
("jack", "jack@mail.com")
))
Stream from the database
Streaming is done in batches. By default a batch of 100. For a larger batch use .streamBatch(1000)
sql
.select(client)
.cols3(_.all)
.all
.orderBy(_.id.asc)
.stream // .streamBatch(1000)
.map(makeLine)
.run(fileSink(Paths.get("clints.txt")))
Stream into the database
The same logic can be used for UPDATE and DELETE.
val insertStm = sql
.insert(client)
.cols2(t => (t.username, t.age))
.cache
// insert one at a time.
readFileIntoStream("clints.txt")
.map(makeTupleFromLine)
.run(insertStm.asSink)
// insert in chunks of 100 using transaction.
readFileIntoStream("clints.txt")
.map(makeTupleFromLine)
.transduce(insertStm.collect(100))
.run(insertStm.asChunkSink)
Execute multiple operations
Do INSERT, UPDATE and DELETE in one transaction.
sql.transaction(
sql.insert(user).cols2(t => (t.username, t.age)).values(("Joe", 25)),
sql.update(user).set(_.age ==> 31).where(_.id === 45),
sql.delete(user).where(_.id === 83)
).run
Execute a list of cached statements
val stm = sql
.delete(user)
.pickWhere1(_.id)
.cache
val statements = (1 to 10).map(id => stm.render(id))
sql.transactionList(Seq(statements)).run
Jsonb field
https://www.postgresql.org/docs/11/functions-json.html
{
"name": "Angela Barton",
"is_active": true,
"company": "Magnafone",
"address": "178 Howard Place, Gulf, Washington, 702",
"latitude": 19.793713,
"longitude": 86.513373,
"tags": ["enim", "aliquip", "qui"],
"residents": {
"name": "Rick",
"age": 31
}
}
class Customer extends Model("customer") {
val data = column[Jsonb]("data")
}
sql
.insert(customer)
.cols1(_.data)
.values(Jsonb(jsonString))
.run
// select
sql
.select(customer)
.cols1(_.data ->> "company")
.where(_.id === 3)
.runHead // "Magnafone"
sql
.select(customer)
.cols1(_.data #>> Seq("residents", "name"))
.where(_.id === 3)
.runHead // "Rick"
sql
.select(customer)
.cols1(_.data -> "tags" ->> 1)
.where(_.id === 3)
.runHead // "aliquip"
sql
.select(customer)
.cols1(_.data -> "residents")
.where(_.id === 3)
.runHead // Jsonb({"name" : "Rick", "age" : 31})
sql
.select(customer)
.cols1(_.data - "residents")
.where(_.id === 3)
.runHead
sql
.select(customer)
.cols1(t => t.data || t.other)
.where(_.id === 3)
.runHead
// update
sql
.update(customer)
.set(_.data += Json.obj("address" -> "Somewhere 12"))
.where(_.id === 3)
.run
sql
.update(customer)
.set(_.data -= "address")
.where(_.id === 3)
.run
sql
.update(customer)
.set(_.data #-= Seq("residents", "age"))
.where(_.id === 3)
.run
Array field
Array fields can be created for all the available types.
class Nums extends Model("demo") {
val id = column[Int]("id")
val numbers = column[Seq[Int]]("numbers")
}
val nums = Model.get[Nums]
for {
id <- sql
.insert(nums)
.cols1(_.numbers)
.values(List(1, 2, 3))
.returning1(_.id)
.run
_ <- sql
.update(nums)
.set(_.numbers += 4)
.where(_.id === id)
.run
numbers <- sql
.select(nums)
.cols1(_.numbers)
.where(_.numbers ? 2)
.run
} yield numbers // List[Vector[Int]]
Unique and sorted
// add element and and make sure it is unique
.set(_.numbers.add(4))
// add list of element and and make sure they are unique
.set(_.numbers.add(List(8, 7, 7, 2)))
// same as add but sorted
.set(_.numbers.addAsc(4))
.set(_.numbers.addDesc(4))
// for jsonb array, a key has to be provided that should be unique and used for sorting
.set(_.numbers.addDesc(jsonObj, "index"))
// cache
.set(_.numbers.addAsc(Arg))
// to use a list as argument
.set(_.numbers.addAsc(ArgSeq))
Timestamp, Date, Time
class Demo extends Model("demo") {
val id = column[Int]("id")
val eventTime = column[Time]("event_time")
val eventDate = column[Date]("event_date")
val updatedAt = column[Timestamp]("updated_at")
}
val demo = Model.get[Demo]
sql
.update(demo)
.set(t => Seq(
t.eventTime += Fn.interval(hours = 3, minutes = 10),
t.eventDate += Fn.interval(years = 1, days = 2),
t.updatedAt += Fn.interval(months = 4, hours = 5)
))
.where(_.id === 25)
.run
sql
.select(demo)
.cols3(t => (
t.eventTime.format("MM:HH"),
t.eventDate.format("DD Mon YYYY"),
t.updatedAt.format("DD Mon YYYY MM:HH")
))
.where(_.id === 25)
.runHead
sql
.select(demo)
.cols4(t => (
t.id,
t.eventDate.month,
t.updatedAt.week
t.updatedAt + Fn.interval(days = 10)
))
.where(t => Seq(
t.eventDate.year === 2022,
t.eventDate.quarter === 2
))
.run
Postgres functions
Use postgres functions to modify results.
import kuzminki.api._
import kuzminki.fn._
class Profile extends Model("profile") {
val firstName = column[String]("first_name")
val lastName = column[String]("last_name")
val bigNum = column[BigDecimal]("big_num")
}
val profile = Model.get[Profile]
sql
.select(profile)
.cols3(t => (
Fn.concatWs(" ", t.firstName, t.lastName),
Fn.initcap(t.lastName),
Cast.asString(t.bigNum)
))
.all
.run
Create functions
Create your own function classes.
import kuzminki.fn.StringFn
case class FullName(
title: String,
first: TypeCol[String],
second: TypeCol[String]
) extends StringFn {
val name = "full_name"
val template = s"concat_ws(' ', '$title', %s, %s)"
val cols = Vector(first, second)
}
sql
.select(user)
.cols2(t => (
t.id,
FullName("Mr", t.firstName, t.lastName)
))
.where(_.id === 10)
.runHead
// If you need to have the driver fill in arguments:
case class FullNameParam(
title: String,
first: TypeCol[String],
second: TypeCol[String]
) extends StringParamsFn {
val name = "full_name"
val template = s"concat_ws(' ', ?, %s, %s)"
val cols = Vector(first, second)
val params = Vector(title)
}
Available functions
https://www.postgresql.org/docs/current/functions-string.html
| Function |
Column type |
| Fn.coalesce(col, default) |
String |
| Fn.concat(col, ...) |
String |
| Fn.concatWs(glue, col, ...) |
String |
| Fn.substr(col, start) |
String |
| Fn.substr(col, start, len) |
String |
| Fn.trim(col) |
String |
| Fn.upper(col) |
String |
| Fn.lower(col) |
String |
| Fn.initcap(col) |
String |
| Fn.round(col) |
BigDecimal |
| Fn.roundStr(col) |
BigDecimal |
| Cast.asString(col) |
Any |
| Cast.asShort(col) |
Any |
| Cast.asInt(col) |
Any |
| Cast.asLong(col) |
Any |
| Cast.asFloat(col) |
Any |
| Cast.asDouble(col) |
Any |
| Cast.asBigDecimal(col) |
Any |