Gbase8a实现python流式读取数据

import pymysql

def myhandle(host, port, user, pw, db, flag):
   if flag == 'r':
       c_class=pymysql.cursors.SSCursor
   if flag == 'w':
       c_class=pymysql.cursors.Cursor
   
   connection = pymysql.connect(host=host,
                                user=user,
                                password=pw,
                                database=db,
                                charset='utf8mb4',
                                port=port ,
                                cursorclass=c_class)
   return connection

try:
   
   conn1 = myhandle('192.168.56.195',5258,'root','root123','ssbm','r')
   conn2 = myhandle('192.168.56.195',5258,'root','root123','ssbm','w')
   with conn1.cursor() as cursor1: 
       sql = "SELECT * FROM lineorder"
       cursor1.execute(sql)
       

       while True:
           #流式读取
           row = cursor1.fetchone()
           if not row:
               #处理所读取的的数据

           
finally:
   conn1.close()
   conn2.close()