s2core/src/main/scala/com/daumkakao/s2graph/core/ServiceColumns.scala

package com.daumkakao.s2graph.core

import scalikejdbc._
import play.api.libs.json.Json
object ServiceColumn extends LocalCache[ServiceColumn] {

  def apply(rs: WrappedResultSet): ServiceColumn = {
    ServiceColumn(rs.intOpt("id"), rs.int("service_id"), rs.string("column_name"), rs.string("column_type"))
  }

  def findById(id: Int): ServiceColumn = {
    val cacheKey = s"id=$id"
    withCache(cacheKey)(sql"""select * from service_columns where id = ${id}""".map { x => ServiceColumn(x) }.single.apply).get
  }
  def find(serviceId: Int, columnName: String): Option[ServiceColumn] = {
    val cacheKey = s"serviceId=$serviceId:columnName=$columnName"
    withCache(cacheKey)(sql"""
        select * from service_columns where service_id = ${serviceId} and column_name = ${columnName}
    """.map { rs => ServiceColumn(rs) }.single.apply())
  }
  def insert(serviceId: Int, columnName: String, columnType: Option[String]) = {
    sql"""insert into service_columns(service_id, column_name, column_type) values(${serviceId}, ${columnName}, ${columnType})""".execute.apply()
  }
  def delete(id: Int) = {
    val serviceColumn = findById(id)
    val (serviceId, columnName) = (serviceColumn.serviceId, serviceColumn.columnName)
    sql"""delete from service_columns where id = ${id}""".execute.apply()
    val cacheKeys = List(s"id=$id", s"serviceId=$serviceId:columnName=$columnName")
    cacheKeys.foreach(expireCache(_))
  }
  def findOrInsert(serviceId: Int, columnName: String, columnType: Option[String]): ServiceColumn = {
    find(serviceId, columnName) match {
      case Some(sc) => sc
      case None =>
        insert(serviceId, columnName, columnType)
        val cacheKey = s"serviceId=$serviceId:columnName=$columnName"
        expireCache(cacheKey)
        find(serviceId, columnName).get
    }
  }
}
case class ServiceColumn(id: Option[Int], serviceId: Int, columnName: String, columnType: String) extends JSONParser {

  lazy val service = Service.findById(serviceId)
  lazy val toJson = Json.obj("serviceName" -> service.serviceName, "columnName" -> columnName, "columnType" -> columnType)
  lazy val metas = ColumnMeta.findAllByColumn(id.get)
  lazy val metaNamesMap = (ColumnMeta.lastModifiedAtColumn :: metas).map(x => (x.seq, x.name)) toMap

  import HBaseElement.InnerVal
  import play.api.libs.json._

}