diff --git a/mysql/mysql.go b/mysql/mysql.go index d1052cc3..a9c5f706 100644 --- a/mysql/mysql.go +++ b/mysql/mysql.go @@ -81,7 +81,7 @@ func New(config ...Config) *Storage { sqlSelect: fmt.Sprintf("SELECT v, e FROM %s WHERE k=?;", cfg.Table), sqlInsert: fmt.Sprintf("INSERT INTO %s (k, v, e) VALUES (?,?,?) ON DUPLICATE KEY UPDATE v = ?, e = ?", cfg.Table), sqlDelete: fmt.Sprintf("DELETE FROM %s WHERE k=?", cfg.Table), - sqlReset: fmt.Sprintf("DELETE FROM %s;", cfg.Table), + sqlReset: fmt.Sprintf("TRUNCATE TABLE %s;", cfg.Table), sqlGC: fmt.Sprintf("DELETE FROM %s WHERE e <= ? AND e != 0", cfg.Table), } diff --git a/postgres/postgres.go b/postgres/postgres.go index 87fa0aeb..34201c74 100644 --- a/postgres/postgres.go +++ b/postgres/postgres.go @@ -99,7 +99,7 @@ func New(config ...Config) *Storage { sqlSelect: fmt.Sprintf(`SELECT v, e FROM %s WHERE k=$1;`, cfg.Table), sqlInsert: fmt.Sprintf("INSERT INTO %s (k, v, e) VALUES ($1, $2, $3) ON CONFLICT (k) DO UPDATE SET v = $4, e = $5", cfg.Table), sqlDelete: fmt.Sprintf("DELETE FROM %s WHERE k=$1", cfg.Table), - sqlReset: fmt.Sprintf("DELETE FROM %s;", cfg.Table), + sqlReset: fmt.Sprintf("TRUNCATE TABLE %s;", cfg.Table), sqlGC: fmt.Sprintf("DELETE FROM %s WHERE e <= $1 AND e != 0", cfg.Table), }