Параллельное чтение базы данных в scala с использованием jdb c и сохранение в выводе csv - PullRequest
0 голосов
/ 19 марта 2020

Я пытаюсь прочитать две базы данных параллельно в scala через jdb c библиотека scalikejdb c.

import scalikejdbc._
import scalikejdbc.config._

У меня есть файл application.conf, который определяет следующие записи

# database1 
db.database1 .driver=""
db.database1 .url=""
db.database1 .user=""
db.database1 .password=""
db.database1 .poolInitialSize=5
db.database1 .poolMaxSize=10
db.database1 .poolConnectionTimeoutMillis=1000

И я читаю таблицы базы данных вроде

DBs.setupAll()

NamedDB('database1) readOnly { implicit session =>

  sql"""
    select  * from table1
    """.foreach(rs => println(rs))
}

NamedDB('database2) readOnly { implicit session =>

  sql"""
    select  * from table2
    """.foreach(rs => println(rs))
}

Как сохранить эти выходные данные из базы данных в два текстовых файла csv с заголовками?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...