sql_test.go

package cachita

import (
    "database/sql"
    "os"
    "testing"
    "time"

    _ "github.com/lib/pq"
    "github.com/stretchr/testify/assert"
)

func TestNewSqlCache(t *testing.T) {
    newCache(sc(t), t)
}

func TestSqlCacheExpires(t *testing.T) {
    t.Parallel()
    sqlDriver, err := sql.Open("postgres", "postgres://postgres@localhost/test?sslmode=disable")
    isError(err, t)
    c, err := NewSqlCache(2*time.Minute, time.Second, sqlDriver, "cachita_cache", true)
    isError(err, t)
    cacheExpires(c, t, time.Second, 1200*time.Millisecond)
}

func TestSqlCacheWithInt(t *testing.T) {
    t.Parallel()
    cacheWithInt(sc(t), t)
}
func BenchmarkSqlCacheWithInt(b *testing.B) {
    benchmarkCacheWithInt(sc(b), b)
}

func TestSqlCacheWithString(t *testing.T) {
    t.Parallel()
    cacheWithString(sc(t), t)
}

func BenchmarkSqlCacheWithString(b *testing.B) {
    benchmarkCacheWithString(sc(b), b)
}

func TestSqlCacheWithMapInterface(t *testing.T) {
    t.Parallel()
    cacheWithMapInterface(sc(t), t)
}

func BenchmarkSqlCacheWithMapInterface(b *testing.B) {
    benchmarkCacheWithMapInterface(sc(b), b)
}

func TestSqlCacheWithStruct(t *testing.T) {
    t.Parallel()
    cacheWithStruct(sc(t), t)
}

func BenchmarkSqlCacheWithStruct(b *testing.B) {
    benchmarkCacheWithStruct(sc(b), b)
}

func TestSql_Incr(t *testing.T) {
    t.Parallel()
    cacheIncr(sc(t), t)
}

func BenchmarkSql_Incr(b *testing.B) {
    benchmarkCacheIncr(sc(b), b)
}

func sc(t assert.TestingT) (c Cache) {
    h := "localhost"
    if os.Getenv("POSTGRES_HOST") != "" {
        h = os.Getenv("POSTGRES_HOST")
    }
    p := "5432"
    if os.Getenv("POSTGRES_PORT") != "" {
        h = os.Getenv("POSTGRES_PORT")
    }
    c, err := Sql("postgres", "postgres://postgres@"+h+":"+p+"/test?sslmode=disable")
    isError(err, t)
    return
}

func TestSql_Tag(t *testing.T) {
    t.Parallel()
    cacheTag(sc(t), t)
}

func BenchmarkSql_Tag(b *testing.B) {
    benchmarkCacheTag(sc(b), b)
}