db-connector
A jobworker connector with database for go-job-worker-development-kit/jobworker package.
Supported databases:
Requirements
Go 1.13+
Installation
This package can be installed with the go get command:
$ go get -u github.com/go-job-worker-development-kit/db-connector
Usage
MySQL:
import "github.com/go-job-worker-development-kit/jobworker"
import _ "github.com/go-job-worker-development-kit/db-connector/mysql"
conn, err := jobworker.Open("mysql", map[string]interface{}{
"DSN": "user:password@/dbname",
"MaxOpenConns": 3,
"MaxMaxIdleConns": 3,
"ConnMaxLifetime": time.Minute,
"NumMaxRetries": 3,
})
Postgres:
import "github.com/go-job-worker-development-kit/jobworker"
import _ "github.com/go-job-worker-development-kit/db-connector/postgres"
conn, err := jobworker.Open("postgres", map[string]interface{}{
"DSN": "user=pqgotest dbname=pqgotest sslmode=verify-full",
"MaxOpenConns": 3,
"MaxMaxIdleConns": 3,
"ConnMaxLifetime": time.Minute,
"NumMaxRetries": 3,
})
SQLite3:
import "github.com/go-job-worker-development-kit/jobworker"
import _ "github.com/go-job-worker-development-kit/db-connector/sqlite3"
conn, err := jobworker.Open("sqlite3", map[string]interface{}{
"DSN": "file:test.db?cache=shared&mode=memory",
"MaxOpenConns": 3,
"MaxMaxIdleConns": 3,
"ConnMaxLifetime": time.Minute,
"NumMaxRetries": 3,
})