Scalikejdbc teradata“连接池尚未初始化。”
问题描述:
我正在尝试在Teradata上使用ScalikeJdbc,但似乎无法使其工作。我有一个配置文件:Scalikejdbc teradata“连接池尚未初始化。”
application.conf
# JDBC settings
db.default.user="user"
db.default.password="pass"
# Connection Pool settings
db.default.poolInitialSize=10
db.default.poolMaxSize=20
db.default.connectionTimeoutMillis=1000
# Teradata
db.default.driver="com.teradata.jdbc.TeraDriver"
db.default.url="jdbc:teradata://url/database=db"
的代码看起来是这样的:
import scalikejdbc._
import scalikejdbc.config._
object DBObject {
DBs.setupAll()
case class Ad(id: Long, siteId: Int)
object Ad extends SQLSyntaxSupport[Ad] {
override val tableName = "ad_table"
def apply(rs: WrappedResultSet) = new Ad(rs.long("id"), rs.int("ad"))
}
ConnectionPool.borrow("default")
val ad = Ad.syntax("ad")
val ads = DB(ConnectionPool.borrow()) readOnly { implicit session =>
withSQL {
select.from(Ad as ad).where.eq(ad.siteId, 3001).limit(10)
}.map(rs => Ad(rs)).list.apply
}
}
当运行这个例子,它抛出一个异常:Connection pool is not yet initialized.
缺少什么我在这里?
答
蒂姆,我想这并不取决于具体的Teradata。只要尝试初始化默认连接池。 Postgres的小例子:
object Main extends App {
def run() = {
Class.forName("org.postgresql.Driver")
val poolSettings = new ConnectionPoolSettings(initialSize = 100, maxSize = 100)
val url = "jdbc:postgresql://localhost:5432/test"
val user = "postgres"
val password = "postgres"
// create singleton(default) connection pool
ConnectionPool.singleton(url, user, password, poolSettings)
DB.localTx { implicit session ⇒
val foos = Foo.findAll()
println(foos)
}
}
run()
}