Ignite - использовать переменную в команде sql? - PullRequest
Новая
       26

Ignite - использовать переменную в команде sql?

0 голосов
/ 17 ноября 2018

Я не хочу читать из кеш-памяти с помощью команды sql. Поскольку команды sql являются динамическими каждый раз, мне нужно вводить их как переменные, но использование переменной в команде sql не поддерживается. Вот мой код: 

import com.typesafe.config.{Config, ConfigFactory}
import com.zaxxer.hikari.{HikariConfig, HikariDataSource}
import javax.sql.DataSource
import scalikejdbc._

  //load config from application.conf
  lazy val config: Config = ConfigFactory.load("application.conf")
  val md: DataSource = {
val hikariConfig = new HikariConfig()
hikariConfig.setJdbcUrl(config.getString("jdbc.ignite.url"))
hikariConfig.setUsername(config.getString("jdbc.ignite.username"))
hikariConfig.setPassword(config.getString("jdbc.ignite.password"))
hikariConfig.setDriverClassName(config.getString("jdbc.ignite.driver"))

val ds = new HikariDataSource(hikariConfig)
ds
}

ConnectionPool.singleton(new 
DataSourceConnectionPool(inMemoryDataSource))
val inMemoryDbName: String = config.getString("jdbc.ignite.name")
ConnectionPool.add(inMemoryDbName, new 
DataSourceConnectionPool(inMemoryDataSource))

lazy val inMemorySession: DBSession = AutoSession
lazy val inMemoryDatabaseExecutorContext: ExecutionContext =
ExecutionContext.fromExecutorService(Executors.newFixedThreadPool(1))

def getAggResult(query: String) = DB readOnly {
  implicit session =>
      sql"$query".map(_.toMap()).list().apply()   
}

Проблема в том, что я использовал '$', и ошибка говорит: 

  java.sql.SQLException: Failed to parse query. Syntax error in SQL 
  statement "?[*]"; expected "[, ::, ="; SQL statement:

query - это команда выбора, подобная select field1, field2 from table name where condition1 like value1

Как это решить?

1 Ответ

0 голосов
/ 17 ноября 2018

Srry, это была моя ошибка, я изменил 

 sql"$query".map(_.toMap()).list().apply()

на 

SQL(s"${query}").map(_.toMap()).list().apply()

, и это сработало

...