使用 spark.sql(sql).collectAsList() 或者其他方法将数据收集到列表中,然后将列表转换为数据集进行分批入库。