From a3bc47abb3618a63220db762e0bff73bd433e7b8 Mon Sep 17 00:00:00 2001
From: vlad <vlad@driver.xyz>
Date: Fri, 26 Jan 2018 09:24:41 -0800
Subject: Cleanup

---
 .../pdsuicommon/db/PostgresQueryBuilder.scala      | 98 ----------------------
 1 file changed, 98 deletions(-)
 delete mode 100644 src/main/scala/xyz/driver/pdsuicommon/db/PostgresQueryBuilder.scala

(limited to 'src/main/scala/xyz/driver/pdsuicommon/db/PostgresQueryBuilder.scala')

diff --git a/src/main/scala/xyz/driver/pdsuicommon/db/PostgresQueryBuilder.scala b/src/main/scala/xyz/driver/pdsuicommon/db/PostgresQueryBuilder.scala
deleted file mode 100644
index 8ef1829..0000000
--- a/src/main/scala/xyz/driver/pdsuicommon/db/PostgresQueryBuilder.scala
+++ /dev/null
@@ -1,98 +0,0 @@
-package xyz.driver.pdsuicommon.db
-
-import java.sql.ResultSet
-
-import io.getquill.{PostgresDialect, PostgresEscape}
-
-import scala.collection.breakOut
-
-object PostgresQueryBuilder {
-
-  import xyz.driver.pdsuicommon.db.QueryBuilder._
-
-  type Escape = PostgresEscape
-  val Escape = PostgresEscape
-
-  def apply[T](tableName: String,
-               lastUpdateFieldName: Option[String],
-               nullableFields: Set[String],
-               links: Set[TableLink],
-               runner: Runner[T],
-               countRunner: CountRunner): PostgresQueryBuilder[T] = {
-    val parameters = PostgresQueryBuilderParameters(
-      tableData = TableData(tableName, lastUpdateFieldName, nullableFields),
-      links = links.map(x => x.foreignTableName -> x)(breakOut)
-    )
-    new PostgresQueryBuilder[T](parameters)(runner, countRunner)
-  }
-
-  def apply[T](tableName: String,
-               lastUpdateFieldName: Option[String],
-               nullableFields: Set[String],
-               links: Set[TableLink],
-               extractor: ResultSet => T)(implicit sqlContext: PostgresContext): PostgresQueryBuilder[T] = {
-    apply(tableName, QueryBuilderParameters.AllFields, lastUpdateFieldName, nullableFields, links, extractor)
-  }
-
-  def apply[T](tableName: String,
-               fields: Set[String],
-               lastUpdateFieldName: Option[String],
-               nullableFields: Set[String],
-               links: Set[TableLink],
-               extractor: ResultSet => T)(implicit sqlContext: PostgresContext): PostgresQueryBuilder[T] = {
-
-    val runner: Runner[T] = { parameters =>
-      val (sql, binder) = parameters.toSql(countQuery = false, fields = fields, namingStrategy = PostgresEscape)
-      sqlContext.executeQuery[T](sql, binder, { resultSet =>
-        extractor(resultSet)
-      })
-    }
-
-    val countRunner: CountRunner = { parameters =>
-      val (sql, binder) = parameters.toSql(countQuery = true, namingStrategy = PostgresEscape)
-      sqlContext
-        .executeQuery[CountResult](
-          sql,
-          binder, { resultSet =>
-            val count = resultSet.getInt(1)
-            val lastUpdate = if (parameters.tableData.lastUpdateFieldName.isDefined) {
-              Option(resultSet.getTimestamp(2)).map(sqlContext.timestampToLocalDateTime)
-            } else None
-
-            (count, lastUpdate)
-          }
-        )
-        .head
-    }
-
-    apply[T](
-      tableName = tableName,
-      lastUpdateFieldName = lastUpdateFieldName,
-      nullableFields = nullableFields,
-      links = links,
-      runner = runner,
-      countRunner = countRunner
-    )
-  }
-}
-
-class PostgresQueryBuilder[T](parameters: PostgresQueryBuilderParameters)(implicit runner: QueryBuilder.Runner[T],
-                                                                          countRunner: QueryBuilder.CountRunner)
-    extends QueryBuilder[T, PostgresDialect, PostgresQueryBuilder.Escape](parameters) {
-
-  def withFilter(newFilter: SearchFilterExpr): QueryBuilder[T, PostgresDialect, PostgresEscape] = {
-    new PostgresQueryBuilder[T](parameters.copy(filter = newFilter))
-  }
-
-  def withSorting(newSorting: Sorting): QueryBuilder[T, PostgresDialect, PostgresEscape] = {
-    new PostgresQueryBuilder[T](parameters.copy(sorting = newSorting))
-  }
-
-  def withPagination(newPagination: Pagination): QueryBuilder[T, PostgresDialect, PostgresEscape] = {
-    new PostgresQueryBuilder[T](parameters.copy(pagination = Some(newPagination)))
-  }
-
-  def resetPagination: QueryBuilder[T, PostgresDialect, PostgresEscape] = {
-    new PostgresQueryBuilder[T](parameters.copy(pagination = None))
-  }
-}
-- 
cgit v1.2.3