diff --git a/src/lua/oltp_common.lua b/src/lua/oltp_common.lua
index d4d39d4..0207891 100644
--- a/src/lua/oltp_common.lua
+++ b/src/lua/oltp_common.lua
@@ -364,6 +364,7 @@ function thread_done()
    if (stmt.commit ~= nil) then
       stmt.commit:close()
    end
+   con:close()
 end
 
 function cleanup()
diff --git a/src/lua/select_random_points.lua b/src/lua/select_random_points.lua
index 6aa1851..0fd19a7 100755
--- a/src/lua/select_random_points.lua
+++ b/src/lua/select_random_points.lua
@@ -55,6 +55,7 @@ end
 
 function thread_done()
    stmt:close()
+   con:close()
 end
 
 function event()