chore: exoquery, misc update and refactorings

Author: sureshg

backend/jvm/build.gradle.kts

@@ -11,7 +11,7 @@ plugins {
   dev.suresh.plugin.graalvm
   com.gradleup.shadow
   alias(libs.plugins.jetbrains.ktor)
-  // alias(libs.plugins.exoquery)
+  alias(libs.plugins.exoquery)
   dev.suresh.plugin.publishing
   // alias(libs.plugins.jetbrains.exposed)
 }

backend/jvm/src/main/kotlin/dev/suresh/db/Query.kt

@@ -54,22 +54,20 @@ val distinct = sql { people.map { it.name to it.age }.distinct() }
 
 val limitAndOffest = sql { people.drop(1).take(10) }
 
-val union = sql {
-  people.filter { it.name.startsWith("aaa") } union people.filter { it.name.startsWith("bbb") }
-}
+val union = sql { people.filter { it.name == "aaa%" } union people.filter { it.name == "bbb%" } }
 
 data class CommonType(val id: Long, val name: String)
 
 // Map to common type and union
-val commonTyep = sql {
+val commonType = sql {
   people.map { CommonType(it.id, it.name) } union robot.map { CommonType(it.id, it.name) }
 }
 
 fun select() {
   val s =
       sql.select {
         val p = from(people)
-        val a = join(address) { a -> a.id == p.addressId }
+        val a = join(address) { a -> a.id == p.addressId && a.city == "San Francisco%" }
         where { p.age > 10 }
         groupBy(p.name, p.age)
         sortBy(p.name to Ord.Asc, p.age to Ord.Desc)
@@ -93,7 +91,7 @@ fun insert(p: People) {
 fun upsert(p: People) {
   sql {
     insert<People> {
-      setParams(p).onConflictUpdate(id) { excluding -> set(name to "name" + "-" + excluding.name) }
+      setParams(p).onConflictUpdate(id) { excluding -> set(name to name + "-" + excluding.name) }
       // setParams(p).onConflictIgnore(id) - Do nothing
     }
   }

backend/jvm/src/test/kotlin/dev/suresh/LincheckTests.kt

@@ -0,0 +1,22 @@
+package dev.suresh
+
+import junit.framework.TestCase.*
+import kotlin.concurrent.thread
+import org.jetbrains.lincheck.Lincheck
+
+class LincheckTests {
+
+  // @Test
+  fun test() =
+      Lincheck.runConcurrentTest {
+        var counter = 0
+        // Increment the counter concurrently
+        val t1 = thread { counter++ }
+        val t2 = thread { counter++ }
+        // Wait for the threads to finish
+        t1.join()
+        t2.join()
+        // Check both increments have been applied
+        assertEquals(2, counter)
+      }
+}

gradle/build-logic/src/main/kotlin/dev.suresh.plugin.kotlin.jvm.gradle.kts

@@ -254,7 +254,7 @@ dependencies {
   testImplementation(kotlin("reflect"))
   testImplementation(kotlin("test-junit5"))
   testImplementation(libs.junit.jupiter)
-  testImplementation(libs.kotlinx.lincheck)
+  testImplementation(libs.kotlin.lincheck)
   testImplementation(libs.kotlinx.coroutines.test)
   testImplementation(libs.mockk)
   // testImplementation(libs.slf4j.simple)