]> git.ipfire.org Git - thirdparty/sqlalchemy/sqlalchemy.git/commitdiff
close cursors: mostly fetchone -> first
authorPhilip Jenvey <pjenvey@underboss.org>
Fri, 11 Sep 2009 22:53:50 +0000 (22:53 +0000)
committerPhilip Jenvey <pjenvey@underboss.org>
Fri, 11 Sep 2009 22:53:50 +0000 (22:53 +0000)
lib/sqlalchemy/dialects/firebird/base.py
lib/sqlalchemy/dialects/informix/base.py
lib/sqlalchemy/dialects/maxdb/base.py
lib/sqlalchemy/dialects/mssql/base.py
lib/sqlalchemy/dialects/oracle/base.py
lib/sqlalchemy/dialects/postgresql/base.py
lib/sqlalchemy/dialects/sybase/base.py
test/engine/test_pool.py

index e89945e0b04b65f5d97830898a2bf8fd188e3cf4..3b323a5ab73dc6370e13747a3e5e8e003974f65d 100644 (file)
@@ -462,8 +462,7 @@ class FBDialect(default.DefaultDialect):
                FROM rdb$dependencies trigdep2
                WHERE trigdep2.rdb$dependent_name = trigdep.rdb$dependent_name) = 2
         """
-        genc = connection.execute(genqry, [tablename, colname])
-        genr = genc.fetchone()
+        genr = connection.execute(genqry, [tablename, colname]).first()
         if genr is not None:
             return dict(name=self.normalize_name(genr['fgenerator']))
 
index b69748fcf1155fe5ea8357b8d67c9e229d98960c..a0ba292698e0dfd6806e1f2a16c6ed00ec80293e 100644 (file)
@@ -225,7 +225,7 @@ class InformixDialect(default.DefaultDialect):
 
     def has_table(self, connection, table_name, schema=None):
         cursor = connection.execute("""select tabname from systables where tabname=?""", table_name.lower() )
-        return bool( cursor.fetchone() is not None )
+        return cursor.first() is not None
 
     def reflecttable(self, connection, table, include_columns):
         c = connection.execute ("select distinct OWNER from systables where tabname=?", table.name.lower() )
index 1ec95e03b4dfa22967123228aa9933ff58dd5c3f..b116d6df61b3d490b8811006aa289660ffdd178e 100644 (file)
@@ -870,9 +870,7 @@ class MaxDBDialect(default.DefaultDialect):
             bind.append(denormalize(schema))
 
         rp = connection.execute(sql, bind)
-        found = bool(rp.fetchone())
-        rp.close()
-        return found
+        return bool(rp.first())
 
     def table_names(self, connection, schema):
         if schema is None:
@@ -1031,10 +1029,7 @@ class MaxDBDialect(default.DefaultDialect):
                "WHERE SEQUENCE_NAME=? ")
 
         rp = connection.execute(sql, denormalize(name))
-        found = bool(rp.fetchone())
-        rp.close()
-        return found
-
+        return bool(rp.first())
 
 
 def _autoserial_column(table):
index fc3236ba92cfef55c3a277c6b14fb1c4386cf5a5..813f42cbb88fbaeb87572947bf7c2fd7abe790fc 100644 (file)
@@ -1200,8 +1200,7 @@ class MSDialect(default.DefaultDialect):
                    )
 
         c = connection.execute(s)
-        row  = c.fetchone()
-        return row is not None
+        return c.first() is not None
 
     @reflection.cache
     def get_schema_names(self, connection, **kw):
@@ -1354,8 +1353,7 @@ class MSDialect(default.DefaultDialect):
                     sql.text("select ident_seed(:seed), ident_incr(:incr)"), 
                     {'seed':table_fullname, 'incr':table_fullname}
                 )
-                row = cursor.fetchone()
-                cursor.close()
+                row = cursor.first()
                 if not row is None:
                     colmap[ic]['sequence'].update({
                         'start' : int(row[0]),
index a5ced0738ac9d81ebd40e89afcfd648bd8b5dc05..454be70f893b223cf31128e5dc6a428c9b0f6a13 100644 (file)
@@ -531,7 +531,7 @@ class OracleDialect(default.DefaultDialect):
             sql.text("SELECT table_name FROM all_tables "
                      "WHERE table_name = :name AND owner = :schema_name"),
             name=self.denormalize_name(table_name), schema_name=self.denormalize_name(schema))
-        return cursor.fetchone() is not None
+        return cursor.first() is not None
 
     def has_sequence(self, connection, sequence_name, schema=None):
         if not schema:
@@ -540,7 +540,7 @@ class OracleDialect(default.DefaultDialect):
             sql.text("SELECT sequence_name FROM all_sequences "
                      "WHERE sequence_name = :name AND sequence_owner = :schema_name"),
             name=self.denormalize_name(sequence_name), schema_name=self.denormalize_name(schema))
-        return cursor.fetchone() is not None
+        return cursor.first() is not None
 
     def normalize_name(self, name):
         if name is None:
@@ -601,7 +601,7 @@ class OracleDialect(default.DefaultDialect):
 
         result = connection.execute(sql.text(q), **params)
         if desired_owner:
-            row = result.fetchone()
+            row = result.first()
             if row:
                 return row['table_name'], row['table_owner'], row['db_link'], row['synonym_name']
             else:
index 7f9cc889a91b433ad701cea329cc9b77bceb7a78..a6fa21f9925f3a9055898035c294f7328239f0f6 100644 (file)
@@ -538,7 +538,7 @@ class PGDialect(default.DefaultDialect):
                         sql.bindparam('schema', unicode(schema), type_=sqltypes.Unicode)] 
                 )
             )
-        return bool(cursor.fetchone())
+        return bool(cursor.first())
 
     def has_sequence(self, connection, sequence_name):
         cursor = connection.execute(
@@ -547,7 +547,7 @@ class PGDialect(default.DefaultDialect):
                         "AND nspname != 'information_schema' AND relname = :seqname)", 
                         bindparams=[sql.bindparam('seqname', unicode(sequence_name), type_=sqltypes.Unicode)]
                     ))
-        return bool(cursor.fetchone())
+        return bool(cursor.first())
 
     def table_names(self, connection, schema):
         result = connection.execute(
index 6f8c648e455e251b07044534127fd204ea126b7b..a15a1fd5bef34e96a444f420779eb6233918479c 100644 (file)
@@ -363,10 +363,7 @@ class SybaseDialect(default.DefaultDialect):
     def has_table(self, connection, tablename, schema=None):
         # FIXME: ignore schemas for sybase
         s = sql.select([tables.c.table_name], tables.c.table_name == tablename)
-
-        c = connection.execute(s)
-        row = c.fetchone()
-        return row is not None
+        return connection.execute(s).first() is not None
 
     def reflecttable(self, connection, table, include_columns):
         # Get base columns
index 68637281e1462c2a69aac712e5962a7df378920e..3f38cda1a29ea381ab118a65d3a8a0d9cb3012a5 100644 (file)
@@ -391,7 +391,7 @@ class PoolTest(PoolTestBase):
         listener.connect = listener
         engine = create_engine(testing.db.url)
         engine.pool.add_listener(listener)
-        engine.execute(select([1]))
+        engine.execute(select([1])).close()
         assert called, "Listener not called on connect"