diff --git a/pkg/sqlcmd/sqlcmd.go b/pkg/sqlcmd/sqlcmd.go
index 5e572a94..ba6a74e4 100644
--- a/pkg/sqlcmd/sqlcmd.go
+++ b/pkg/sqlcmd/sqlcmd.go
@@ -431,6 +431,9 @@ func (s *Sqlcmd) runQuery(query string) (int, error) {
 	}
 	retmsg := &sqlexp.ReturnMessage{}
 	rows, qe := s.db.QueryContext(ctx, query, retmsg)
+	if rows != nil {
+		defer rows.Close()
+	}
 	if qe != nil {
 		s.Format.AddError(qe)
 	}