diff --git a/src/lua/oltp_common.lua b/src/lua/oltp_common.lua
index 0207891..b8be4e0 100644
--- a/src/lua/oltp_common.lua
+++ b/src/lua/oltp_common.lua
@@ -364,7 +364,7 @@ function thread_done()
    if (stmt.commit ~= nil) then
       stmt.commit:close()
    end
-   con:close()
+   con:disconnect()
 end
 
 function cleanup()
diff --git a/src/lua/select_random_points.lua b/src/lua/select_random_points.lua
index 0fd19a7..f1f71ad 100755
--- a/src/lua/select_random_points.lua
+++ b/src/lua/select_random_points.lua
@@ -55,7 +55,7 @@ end
 
 function thread_done()
    stmt:close()
-   con:close()
+   con:disconnect()
 end
 
 function event()
diff --git a/src/lua/select_random_ranges.lua b/src/lua/select_random_ranges.lua
index 30e6d1a..165068f 100755
--- a/src/lua/select_random_ranges.lua
+++ b/src/lua/select_random_ranges.lua
@@ -58,6 +58,7 @@ end
 
 function thread_done()
    stmt:close()
+   con:disconnect()
 end
 
 function event()