const query = {
    sql: 'SELECT * FROM Singers where SingerId > @id',
    params: {
      id: 1200,
    },
  };

const [partitions] = await transaction.createQueryPartitions(query);
partitions.forEach(partition => {
    transaction.execute(partition).then(results => {
      const rows = results[0].map(row => row.toJSON());
      row_count += rows.length;
  });
});