- added an implicit close() on the cursor in ResultProxy

when the result closes
- added scalar() method to ComposedSQLEngine

1 files changed, 5 insertions, 0 deletions

diff --git a/lib/sqlalchemy/engine/base.py b/lib/sqlalchemy/engine/base.py
index fad84eef8..cf321bca2 100644
--- a/lib/sqlalchemy/engine/base.py
+++ b/lib/sqlalchemy/engine/base.py
@@ -466,6 +466,10 @@ class ComposedSQLEngine(sql.Engine, Connectable):
     def execute(self, statement, *multiparams, **params):
         connection = self.contextual_connect(close_with_result=True)
         return connection.execute(statement, *multiparams, **params)
+
+    def scalar(self, statement, *multiparams, **params):
+        connection = self.contextual_connect(close_with_result=True)
+        return connection.scalar(statement, *multiparams, **params)
         
     def execute_compiled(self, compiled, *multiparams, **params):
         connection = self.contextual_connect(close_with_result=True)
@@ -564,6 +568,7 @@ class ResultProxy:
     def close(self):
         if not self.closed:
             self.closed = True
+            self.cursor.close()
             if self.connection.should_close_with_result and self.dialect.supports_autoclose_results:
                 self.connection.close()