Add huge select example to basic example v2

Author: vgvoleg

examples/basic_example_v2/basic_example.py

@@ -191,6 +191,25 @@ def callee(session: ydb.QuerySessionSync):
     return pool.retry_operation_sync(callee)
 
 
+def huge_select(pool: ydb.QuerySessionPool, path: str):
+    def callee(session: ydb.QuerySessionSync):
+        query = f"""
+        PRAGMA TablePathPrefix("{path}");
+        SELECT * from episodes;
+        """
+
+        with session.transaction().execute(
+            query,
+            commit_tx=True,
+        ) as result_sets:
+            print("\n> Huge SELECT call")
+            for result_set in result_sets:
+                for row in result_set.rows:
+                    print("episode title:", row.title, ", air date:", row.air_date)
+
+    return pool.retry_operation_sync(callee)
+
+
 def drop_tables(pool: ydb.QuerySessionPool, path: str):
     print("\nCleaning up existing tables...")
     pool.execute_with_retries(DropTablesQuery.format(path))
@@ -301,3 +320,4 @@ def run(endpoint, database, path):
 
             explicit_transaction_control(pool, full_path, 2, 6, 1)
             select_with_parameters(pool, full_path, 2, 6, 1)
+            huge_select(pool, full_path)

examples/basic_example_v2/basic_example_async.py

@@ -193,6 +193,25 @@ async def callee(session: ydb.aio.QuerySessionAsync):
     return await pool.retry_operation_async(callee)
 
 
+async def huge_select(pool: ydb.aio.QuerySessionPoolAsync, path: str):
+    async def callee(session: ydb.aio.QuerySessionAsync):
+        query = f"""
+        PRAGMA TablePathPrefix("{path}");
+        SELECT * from episodes;
+        """
+
+        async with await session.transaction().execute(
+            query,
+            commit_tx=True,
+        ) as result_sets:
+            print("\n> Huge SELECT call")
+            async for result_set in result_sets:
+                for row in result_set.rows:
+                    print("episode title:", row.title, ", air date:", row.air_date)
+
+    return await pool.retry_operation_async(callee)
+
+
 async def drop_tables(pool: ydb.aio.QuerySessionPoolAsync, path: str):
     print("\nCleaning up existing tables...")
     await pool.execute_with_retries(DropTablesQuery.format(path))
@@ -303,3 +322,4 @@ async def run(endpoint, database, path):
 
             await explicit_transaction_control(pool, full_path, 2, 6, 1)
             await select_with_parameters(pool, full_path, 2, 6, 1)
+            await huge_select(pool, full_path)