コネクション

この章では、データベースに接続するためのコネクション構築方法について説明します。

データベースに接続するためには、コネクションを構築する必要がある。コネクションは、データベースへの接続を管理するためのリソースである。コネクションは、データベースへの接続を開始し、クエリを実行し、接続を閉じるためのリソースを提供する。

ldbcはjdbcとldbc独自のコネクタのどちらかを使ってデータベースに接続する。どちらを使うかは設定する依存関係によって決まる。

Use jdbc connector

まず、依存関係を追加します。

jdbcコネクタを使用する場合、MySQLのコネクタも追加する必要があります。

//> dep "io.github.takapi327::jdbc-connector:0.3.0-beta8"
//> dep "com.mysql":"mysql-connector-j":"8.4.0"

次に、MysqlDataSourceを使用してデータソースを作成します。

val ds = new com.mysql.cj.jdbc.MysqlDataSource()
ds.setServerName("127.0.0.1")
ds.setPortNumber(13306)
ds.setDatabaseName("world")
ds.setUser("ldbc")
ds.setPassword("password")

作成したデータソースを使用してjdbcコネクタのデータソースを作成します。

val datasource = jdbc.connector.MysqlDataSource[IO](ds)

最後に、jdbcコネクタを使用してコネクションを作成します。

val connection: Resource[IO, Connection[IO]] =
  Resource.make(datasource.getConnection)(_.close())

ここではCats EffectのResourceを使用してコネクション使用後にクローズするようにしています。

Use ldbc connector

まず、依存関係を追加します。

//> dep "io.github.takapi327::ldbc-connector:0.3.0-beta8"

次に、Tracerを提供します。ldbcコネクタはTracerを使用してテレメトリデータの収集を行います。 これらは、アプリケーショントレースを記録するために使用されます。

ここでは、Tracer.noopを使用してTracerを提供します。

given Tracer[IO] = Tracer.noop[IO]

最後に、Connectionを作成します。

val connection: Resource[IO, Connection[IO]] =
  ldbc.connector.Connection[IO](
    host     = "127.0.0.1",
    port     = 3306,
    user     = "ldbc",
    password = Some("password"),
    database = Some("ldbc")
  )

コネクションを設定するためのパラメータは以下の通りです。