sqlv

sqlv

sqlv is a wrapper for sqlx where there is a master connection and multiple readonly/slave connections.

This is still in beta. Any Feedback / Suggestions will be appreciated. Have not preformed any go tests yet. Will add those soon.

Get started

// create master connection
master := sqlv.Connection{
    Username:     "master_username",
    Password:     "foo!bar",
    DatabaseName: "foo_bar_db",
    Host:         "192.168.0.1",
    Port:         "3306",
    Type:         "master",
    TLS: sqlv.TLSConfig{ // optional
        Enabled:    true,
        Cert:       "/etc/...",
        Key:        "/etc/...",
        CA:         "/etc/...",
        ServerName: "master_server_name",
    },
}

// create one or more slave connections to master

// slave 1
slaveOne := sqlv.Connection{
    Username:     "slave_username",
    Password:     "foo!bar",
    DatabaseName: "foo_bar_db",
    Host:         "192.168.0.2",
    Port:         "3306",
    Type:         "slave",
    TLS: sqlv.TLSConfig{ // optional
        Enabled:    true,
        Cert:       "/etc/...",
        Key:        "/etc/...",
        CA:         "/etc/...",
        ServerName: "slave_server_name_one",
    },
}

// slave 2
slaveTwo := sqlv.Connection{
    Username:     "slave_username",
    Password:     "foo!bar",
    DatabaseName: "foo_bar_db",
    Host:         "192.168.0.3",
    Port:         "3306",
    Type:         "slave",
    TLS: sqlv.TLSConfig{ // optional
        Enabled:    true,
        Cert:       "/etc/...",
        Key:        "/etc/...",
        CA:         "/etc/...",
        ServerName: "slave_server_name_two",
    },
}

// init mysql connections and assign global variable of 'db'
db, err = sqlv.Open([]sqlv.Connection{
    master,
    slaveOne,
    slaveTwo,
})
if err != nil {
    log.Fatalf("database connections failed: %s", err.Error())
}

use db as you would for sqlx. select and get will load balance between each slave instance and write operations will use the master connection. If no slave connections master will be used for all connections.