sub _get_record_by_server
{
	my $self = shift;
	my $packet = shift;
	my $mysql = $self->{socket};

	$self->_get_column_length($packet);
	if(length($packet) >= 512 ){  # added
	while ($self->_has_next_packet($packet)) {
		my $next_result;
		$mysql->recv($next_result, BUFFER_LENGTH, 0);
		$packet .= $next_result;
		$self->_dump_packet($next_result) if Net::MySQL->debug;

	}
	}  # added
	$self->{selected_record} = $packet;
}