summaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authormike bayer <mike_mp@zzzcomputing.com>2017-09-18 09:49:50 -0400
committerGerrit Code Review <gerrit@awstats.zzzcomputing.com>2017-09-18 09:49:50 -0400
commit08430e689f1a0190f671636016b12ff2ca08531f (patch)
tree76c733bfdef11507e08bcdc4dd2066071942f085 /test
parentaed2324b4de3c4f3e6cc7f801fc8ddd8e2d9012b (diff)
parent339416b821ed543f289fccff8f6fc9c44dbc9d23 (diff)
downloadsqlalchemy-08430e689f1a0190f671636016b12ff2ca08531f.tar.gz
Merge "Add __next__(), next() to ResultProxy"
Diffstat (limited to 'test')
-rw-r--r--test/sql/test_resultset.py17
1 files changed, 17 insertions, 0 deletions
diff --git a/test/sql/test_resultset.py b/test/sql/test_resultset.py
index 41092efe9..5c7108ca0 100644
--- a/test/sql/test_resultset.py
+++ b/test/sql/test_resultset.py
@@ -61,6 +61,23 @@ class ResultProxyTest(fixtures.TablesTest):
rows.append(row)
eq_(len(rows), 3)
+ def test_row_next(self):
+ users = self.tables.users
+
+ users.insert().execute(
+ {'user_id': 7, 'user_name': 'jack'},
+ {'user_id': 8, 'user_name': 'ed'},
+ {'user_id': 9, 'user_name': 'fred'},
+ )
+ r = users.select().execute()
+ rows = []
+ while True:
+ row = next(r, 'foo')
+ if row == 'foo':
+ break
+ rows.append(row)
+ eq_(len(rows), 3)
+
@testing.requires.subqueries
def test_anonymous_rows(self):
users = self.tables.users