Method get_next

engine/src/io/data_provider/sql/MySQLDataProvider.cpp:196–225

}

data_handle mysql_data_provider::get_next(bool open_file) {
  data_handle ret;

  if (open_file == false) {
    ret.sql_handle.table = this->sql.table;
    ret.sql_handle.column_names = this->column_names;
    ret.sql_handle.column_types = this->column_types;
    return ret;
  }

  std::string query = this->build_select_query(this->batch_index);

  // DEBUG
  //std::cout << "\n>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>MYSQL QUERY:\n\n" << query << "\n\n\n";
  ++this->batch_index;
  auto res = execute_mysql_query(this->mysql_connection.get(), query);

  if (res->rowsCount() == 0) {
    this->table_fetch_completed = true;
  }

  ret.sql_handle.table = this->sql.table;
  ret.sql_handle.column_names = this->column_names;
  ret.sql_handle.column_types = this->column_types;
  ret.sql_handle.mysql_resultset = res;
  ret.sql_handle.row_count = res->rowsCount();
  // TODO percy add columns to uri.query
  ret.uri = Uri("mysql", "", this->sql.schema + "/" + this->sql.table, "", "");
  return ret;
}

size_t mysql_data_provider::get_num_handles() {
  size_t ret = this->estimated_table_row_count / this->sql.table_batch_size;