diff --git a/asyncdbconnection.cpp b/asyncdbconnection.cpp
index c2e64f6..da5e3cc 100644
--- a/asyncdbconnection.cpp
+++ b/asyncdbconnection.cpp
@@ -9,6 +9,10 @@ ASyncDBConnection::ASyncDBConnection()
 
 void ASyncDBConnection::setupConnection(const std::string &connstring)
 {
+	if (m_thread.joinable()) {
+		m_threadData.stop();
+		m_thread.join();
+	}
 	m_threadData.m_initString = connstring;
 	m_thread = std::thread([this] () { m_threadData.run(); });
 }