Adapters¶

package main

import (
    "context"

    _ "github.com/go-sql-driver/mysql"
    "github.com/go-rel/primaryreplica"
    "github.com/go-rel/mysql"
    "github.com/go-rel/rel"
)
func main() {
    // open mysql connections.
    // note: `clientFoundRows=true` is required for update and delete to works correctly.
    adapter := primaryreplica.New(
        mysql.MustOpen("root@(source:3306)/rel_test?charset=utf8&parseTime=True&loc=Local"),
        mysql.MustOpen("root@(replica1:3306)/rel_test?charset=utf8&parseTime=True&loc=Local"),
        mysql.MustOpen("root@(replica2:3306)/rel_test?charset=utf8&parseTime=True&loc=Local"),
    )
    defer adapter.Close()

    // initialize REL's repo.
    repo := rel.New(adapter)
    repo.Ping(context.TODO())
}