diff --git a/prepare_stmt.go b/prepare_stmt.go
index a59552d2..7591e533 100644
--- a/prepare_stmt.go
+++ b/prepare_stmt.go
@@ -47,7 +47,8 @@ func (db *PreparedStmtDB) Close() {
 func (db *PreparedStmtDB) Reset() {
 	db.Mux.Lock()
 	defer db.Mux.Unlock()
-	for _, stmt := range db.Stmts {
+	for query, stmt := range db.Stmts {
+		delete(db.Stmts, query)
 		go stmt.Close()
 	}