package/storage
1
0
Fork 0
mirror of https://github.com/gofiber/storage.git synced 2025-10-05 16:48:25 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

🎁 fix tests

Browse Source
This commit is contained in:
Fenny
2020-11-05 05:26:05 +01:00
parent 687d8ed82a
commit f047848660
11 changed files with 19 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
memcache/memcache_test.go
View File

@@ -39,14 +39,13 @@ func Test_Memcache_Set_Expiration(t *testing.T) {
var ( var (
key = "john" key = "john"
val = []byte("doe") val = []byte("doe")
exp = 500 * time.Millisecond exp = 1 * time.Second
) )
err := testStore.Set(key, val, exp) err := testStore.Set(key, val, exp)
utils.AssertEqual(t, nil, err) utils.AssertEqual(t, nil, err)
time.Sleep(1 * time.Second) time.Sleep(1100 * time.Millisecond)
} }
func Test_Memcache_Get_Expired(t *testing.T) { func Test_Memcache_Get_Expired(t *testing.T) {

6
memory/memory_test.go
View File

@@ -39,14 +39,13 @@ func Test_Memory_Set_Expiration(t *testing.T) {
var ( var (
key = "john" key = "john"
val = []byte("doe") val = []byte("doe")
exp = 500 * time.Millisecond exp = 1 * time.Second
) )
err := testStore.Set(key, val, exp) err := testStore.Set(key, val, exp)
utils.AssertEqual(t, nil, err) utils.AssertEqual(t, nil, err)
time.Sleep(1 * time.Second) time.Sleep(1100 * time.Millisecond)
} }
func Test_Memory_Get_Expired(t *testing.T) { func Test_Memory_Get_Expired(t *testing.T) {
@@ -61,7 +60,6 @@ func Test_Memory_Get_Expired(t *testing.T) {
func Test_Memory_Get_NotExist(t *testing.T) { func Test_Memory_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist") result, err := testStore.Get("notexist")
utils.AssertEqual(t, ErrNotExist, err) utils.AssertEqual(t, ErrNotExist, err)
utils.AssertEqual(t, true, len(result) == 0) utils.AssertEqual(t, true, len(result) == 0)

5
mongodb/mongodb_test.go
View File

@@ -41,14 +41,13 @@ func Test_MongoDB_Set_Expiration(t *testing.T) {
var ( var (
key = "john" key = "john"
val = []byte("doe") val = []byte("doe")
exp = 500 * time.Millisecond exp = 1 * time.Second
) )
err := testStore.Set(key, val, exp) err := testStore.Set(key, val, exp)
utils.AssertEqual(t, nil, err) utils.AssertEqual(t, nil, err)
time.Sleep(1 * time.Second) time.Sleep(1100 * time.Millisecond)
} }
func Test_MongoDB_Get_Expired(t *testing.T) { func Test_MongoDB_Get_Expired(t *testing.T) {

2
mysql/mysql.go
View File

@@ -76,7 +76,7 @@ func New(config ...Config) *Storage {
gcInterval: cfg.GCInterval, gcInterval: cfg.GCInterval,
db: db, db: db,
sqlSelect: fmt.Sprintf(`SELECT data, exp FROM %s WHERE id=?;`, cfg.Table), sqlSelect: fmt.Sprintf(`SELECT data, exp FROM %s WHERE id=?;`, cfg.Table),
sqlInsert: fmt.Sprintf("INSERT INTO %s (id, data, exp) VALUES (?,?,?)", cfg.Table), sqlInsert: fmt.Sprintf("INSERT OR REPLACE INTO %s (id, data, exp) VALUES (?,?,?)", cfg.Table),
sqlDelete: fmt.Sprintf("DELETE FROM %s WHERE id=?", cfg.Table), sqlDelete: fmt.Sprintf("DELETE FROM %s WHERE id=?", cfg.Table),
sqlClear: fmt.Sprintf("DELETE FROM %s;", cfg.Table), sqlClear: fmt.Sprintf("DELETE FROM %s;", cfg.Table),
sqlGC: fmt.Sprintf("DELETE FROM %s WHERE exp <= ?", cfg.Table), sqlGC: fmt.Sprintf("DELETE FROM %s WHERE exp <= ?", cfg.Table),

5
mysql/mysql_test.go
View File

@@ -45,14 +45,13 @@ func Test_MYSQL_Set_Expiration(t *testing.T) {
var ( var (
key = "john" key = "john"
val = []byte("doe") val = []byte("doe")
exp = 500 * time.Millisecond exp = 1 * time.Second
) )
err := testStore.Set(key, val, exp) err := testStore.Set(key, val, exp)
utils.AssertEqual(t, nil, err) utils.AssertEqual(t, nil, err)
time.Sleep(1 * time.Second) time.Sleep(1100 * time.Millisecond)
} }
func Test_MYSQL_Get_Expired(t *testing.T) { func Test_MYSQL_Get_Expired(t *testing.T) {

2
postgres/postgres.go
View File

@@ -99,7 +99,7 @@ func New(config ...Config) *Storage {
db: db, db: db,
gcInterval: cfg.GCInterval, gcInterval: cfg.GCInterval,
sqlSelect: fmt.Sprintf(`SELECT data, exp FROM %s WHERE key=$1;`, cfg.Table), sqlSelect: fmt.Sprintf(`SELECT data, exp FROM %s WHERE key=$1;`, cfg.Table),
sqlInsert: fmt.Sprintf("INSERT INTO %s (key, data, exp) VALUES ($1, $2, $3)", cfg.Table), sqlInsert: fmt.Sprintf("INSERT OR REPLACE INTO %s (key, data, exp) VALUES ($1, $2, $3)", cfg.Table),
sqlDelete: fmt.Sprintf("DELETE FROM %s WHERE key=$1", cfg.Table), sqlDelete: fmt.Sprintf("DELETE FROM %s WHERE key=$1", cfg.Table),
sqlClear: fmt.Sprintf("DELETE FROM %s;", cfg.Table), sqlClear: fmt.Sprintf("DELETE FROM %s;", cfg.Table),
sqlGC: fmt.Sprintf("DELETE FROM %s WHERE exp <= $1", cfg.Table), sqlGC: fmt.Sprintf("DELETE FROM %s WHERE exp <= $1", cfg.Table),

7
postgres/postgres_test.go
View File

@@ -45,14 +45,13 @@ func Test_Postgres_Set_Expiration(t *testing.T) {
var ( var (
key = "john" key = "john"
val = []byte("doe") val = []byte("doe")
exp = 500 * time.Millisecond exp = 1 * time.Second
) )
err := testStore.(key, val, exp) err := testStore.Set(key, val, exp)
utils.AssertEqual(t, nil, err) utils.AssertEqual(t, nil, err)
time.Sleep(1 * time.Second) time.Sleep(1100 * time.Millisecond)
} }
func Test_Postgres_Get_Expired(t *testing.T) { func Test_Postgres_Get_Expired(t *testing.T) {

5
redis/redis_test.go
View File

@@ -41,14 +41,13 @@ func Test_Redis_Set_Expiration(t *testing.T) {
var ( var (
key = "john" key = "john"
val = []byte("doe") val = []byte("doe")
exp = 500 * time.Millisecond exp = 1 * time.Second
) )
err := testStore.Set(key, val, exp) err := testStore.Set(key, val, exp)
utils.AssertEqual(t, nil, err) utils.AssertEqual(t, nil, err)
time.Sleep(1 * time.Second) time.Sleep(1100 * time.Millisecond)
} }
func Test_Redis_Get_Expired(t *testing.T) { func Test_Redis_Get_Expired(t *testing.T) {

BIN
sqlite3/fiber.sqlite3 Normal file
View File

Binary file not shown.

6
sqlite3/sqlite3.go
View File

@@ -81,7 +81,7 @@ func New(config ...Config) *Storage {
db: db, db: db,
gcInterval: cfg.GCInterval, gcInterval: cfg.GCInterval,
sqlSelect: fmt.Sprintf(`SELECT data, exp FROM %s WHERE key=?;`, cfg.Table), sqlSelect: fmt.Sprintf(`SELECT data, exp FROM %s WHERE key=?;`, cfg.Table),
sqlInsert: fmt.Sprintf("INSERT INTO %s (key, data, exp) VALUES (?,?,?)", cfg.Table), sqlInsert: fmt.Sprintf("INSERT OR REPLACE INTO %s (key, data, exp) VALUES (?,?,?)", cfg.Table),
sqlDelete: fmt.Sprintf("DELETE FROM %s WHERE key=?", cfg.Table), sqlDelete: fmt.Sprintf("DELETE FROM %s WHERE key=?", cfg.Table),
sqlClear: fmt.Sprintf("DELETE FROM %s;", cfg.Table), sqlClear: fmt.Sprintf("DELETE FROM %s;", cfg.Table),
sqlGC: fmt.Sprintf("DELETE FROM %s WHERE exp <= ?", cfg.Table), sqlGC: fmt.Sprintf("DELETE FROM %s WHERE exp <= ?", cfg.Table),
@@ -96,7 +96,6 @@ func New(config ...Config) *Storage {
// Get value by key // Get value by key
func (s *Storage) Get(key string) ([]byte, error) { func (s *Storage) Get(key string) ([]byte, error) {
row := s.db.QueryRow(s.sqlSelect, key) row := s.db.QueryRow(s.sqlSelect, key)
// Add db response to data // Add db response to data
var ( var (
data = []byte{} data = []byte{}
@@ -108,10 +107,9 @@ func (s *Storage) Get(key string) ([]byte, error) {
} }
return nil, err return nil, err
} }
// If the expiration time has already passed, then return nil // If the expiration time has already passed, then return nil
if exp != 0 && exp <= time.Now().Unix() { if exp != 0 && exp <= time.Now().Unix() {
return nil, nil return nil, ErrNotExist
} }
return data, nil return data, nil

5
sqlite3/sqlite3_test.go
View File

@@ -42,14 +42,13 @@ func Test_SQLite3_Set_Expiration(t *testing.T) {
var ( var (
key = "john" key = "john"
val = []byte("doe") val = []byte("doe")
exp = 500 * time.Millisecond exp = 1 * time.Second
) )
err := testStore.Set(key, val, exp) err := testStore.Set(key, val, exp)
utils.AssertEqual(t, nil, err) utils.AssertEqual(t, nil, err)
time.Sleep(1 * time.Second) time.Sleep(1100 * time.Millisecond)
} }
func Test_SQLite3_Get_Expired(t *testing.T) { func Test_SQLite3_Get_Expired(t *testing.T) {