Data Manipulation Techniques in PHP

Introduction to Data Manipulation

Welcome to our lesson on practical data manipulation techniques using PHP! In this lesson, we will explore how to manipulate data structures with PHP's arrays and associative arrays. Our operations will be conveniently bundled within a PHP class, offering clean and organized code. Let's get our tools ready and dive into data manipulation in PHP. Here's a simple PHP class, DataStream, that will be our toolbox for handling data: PHP<?php class DataStream { private $data; public function __construct(array $data) { $this->data = $data; } } ?><?php class DataStream { private $data; public function __construct(array $data) { $this->data = $data; } } ?>

Data Projection in Practice

Our first stop is data projection, where we focus on extracting specific details from our dataset. Suppose we have data about people and we are interested in only names and ages. We will extend our DataStream class with a project method that uses PHP's array_map to accomplish this task: PHP<?php class DataStream { private $data; public function __construct(array $data) { $this->data = $data; } public function project(callable $projectFunc): DataStream { $projectedData = array_map($projectFunc, $this->data); return new DataStream($projectedData); } public function printData(): void { foreach ($this->data as $entry) { echo join(', ', array_map( fn($value, $key) => "$key: $value", $entry, array_keys($entry) )) . "\n"; } } } $data = [ ['name' => 'Alice', 'age' => '25', 'profession' => 'Engineer'], ['name' => 'Bob', 'age' => '30', 'profession' => 'Doctor'] ]; $ds = new DataStream($data); $projectedDs = $ds->project(function($entry) { return ['name' => $entry['name'], 'age' => $entry['age']]; }); $projectedDs->printData(); // Outputs: // name: Alice, age: 25 // name: Bob, age: 30 ?>

Data Filtering in Practice

Next, we focus on filtering data to select specific entries. We'll extend our DataStream class with a filter method that leverages PHP's array_filter using anonymous functions: PHP<?php class DataStream { private $data; public function __construct(array $data) { $this->data = $data; } public function project(callable $projectFunc): DataStream { $projectedData = array_map($projectFunc, $this->data); return new DataStream($projectedData); } public function filter(callable $testFunc): DataStream { $filteredData = array_filter($this->data, $testFunc); return new DataStream($filteredData); } public function printData(): void { foreach ($this->data as $entry) { echo join(', ', array_map( fn($value, $key) => "$key: $value", $entry, array_keys($entry) )) . "\n"; } } } $data = [ ['name' => 'Alice', 'age' => '25', 'profession' => 'Engineer'], ['name' => 'Bob', 'age' => '30', 'profession' => 'Doctor'] ]; $ds = new DataStream($data); $ageTest = function($entry) { return (int)$entry['age'] > 26; }; $filteredDs = $ds->filter($ageTest); $filteredDs->printData(); // Outputs: // name: Bob, age: 30, profession: Doctor ?>

Data Aggregation in Practice

Finally, we turn to data aggregation to summarize data. We will use PHP's built-in functions to achieve this within our DataStream class. Here's how we can compute the average age, for example: PHP<?php class DataStream { private $data; public function __construct(array $data) { $this->data = $data; } public function project(callable $projectFunc): DataStream { $projectedData = array_map($projectFunc, $this->data); return new DataStream($projectedData); } public function filter(callable $testFunc): DataStream { $filteredData = array_filter($this->data, $testFunc); return new DataStream($filteredData); } public function aggregate(string $key, callable $aggFunc): float { $values = array_map(fn($entry) => $entry[$key], $this->data); return $aggFunc($values); } public function printData(): void { foreach ($this->data as $entry) { echo join(', ', array_map( fn($value, $key) => "$key: $value", $entry, array_keys($entry) )) . "\n"; } } } $data = [ ['name' => 'Alice', 'age' => '25', 'profession' => 'Engineer'], ['name' => 'Bob', 'age' => '30', 'profession' => 'Doctor'] ]; $ds = new DataStream($data); $averageAgeCalculator = function($ages) { $sum = array_sum(array_map('intval', $ages)); return $sum / count($ages); }; $averageAge = $ds->aggregate('age', $averageAgeCalculator); echo $averageAge; // Outputs: 27.5 ?>

Combining Projection, Filtering, and Aggregation

Now, let's see how to combine these powerful techniques using PHP. Our example will demonstrate the workflow: Data Projection: Select specific fields. Data Filtering: Apply conditions to filter data. Data Aggregation: Compute a summary statistic. Here's how you can implement this combination in PHP: PHP<?php class DataStream { private $data; public function __construct(array $data) { $this->data = $data; } public function project(callable $projectFunc): DataStream { $projectedData = array_map($projectFunc, $this->data); return new DataStream($projectedData); } public function filter(callable $testFunc): DataStream { $filteredData = array_filter($this->data, $testFunc); return new DataStream($filteredData); } public function aggregate(string $key, callable $aggFunc): float { $values = array_map(fn($entry) => $entry[$key], $this->data); return $aggFunc($values); } public function printData(): void { foreach ($this->data as $entry) { echo join(', ', array_map( fn($value, $key) => "$key: $value", $entry, array_keys($entry) )) . "\n"; } } } $data = [ ['name' => 'Alice', 'age' => '25', 'profession' => 'Engineer', 'salary' => '70000'], ['name' => 'Bob', 'age' => '30', 'profession' => 'Doctor', 'salary' => '120000'], ['name' => 'Carol', 'age' => '35', 'profession' => 'Artist', 'salary' => '50000'], ['name' => 'David', 'age' => '40', 'profession' => 'Engineer', 'salary' => '90000'] ]; $ds = new DataStream($data); // Step 1: Project to include 'name', 'age', 'salary' $projectedDs = $ds->project(function($entry) { return [ 'name' => $entry['name'], 'age' => $entry['age'], 'salary' => $entry['salary'] ]; }); // Step 2: Filter where age > 30 $filteredDs = $projectedDs->filter(function($entry) { return (int)$entry['age'] > 30; }); // Step 3: Aggregate to compute average salary $averageSalaryCalculator = function($salaries) { $total = array_sum(array_map('intval', $salaries)); return $total / count($salaries); }; $averageSalary = $filteredDs->aggregate('salary', $averageSalaryCalculator); echo $averageSalary; // Outputs: 70000 ?>

Lesson Summary

Congratulations! You've now learned the basics of data projection, filtering, and aggregation utilizing PHP arrays and their associative forms. You've seen how to package these processes in a PHP class for efficient and reusable code. Now, why not try some practice exercises to apply these skills? You're well-equipped to handle data manipulation with PHP. Happy coding!

Previous Lesson

Join the 1M+ learners on CodeSignal

Be a part of our community of 1M+ users who develop and demonstrate their skills on CodeSignal

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }
}

?>

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function project(callable $projectFunc): DataStream {
        $projectedData = array_map($projectFunc, $this->data);
        return new DataStream($projectedData);
    }

    public function printData(): void {
        foreach ($this->data as $entry) {
            echo join(', ', array_map(
                fn($value, $key) => "$key: $value",
                $entry,
                array_keys($entry)
            )) . "\n";
        }
    }
}

$data = [
    ['name' => 'Alice', 'age' => '25', 'profession' => 'Engineer'],
    ['name' => 'Bob', 'age' => '30', 'profession' => 'Doctor']
];

$ds = new DataStream($data);

$projectedDs = $ds->project(function($entry) {
    return ['name' => $entry['name'], 'age' => $entry['age']];
});

$projectedDs->printData();
// Outputs:
// name: Alice, age: 25
// name: Bob, age: 30

?>

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function project(callable $projectFunc): DataStream {
        $projectedData = array_map($projectFunc, $this->data);
        return new DataStream($projectedData);
    }

    public function filter(callable $testFunc): DataStream {
        $filteredData = array_filter($this->data, $testFunc);
        return new DataStream($filteredData);
    }

    public function printData(): void {
        foreach ($this->data as $entry) {
            echo join(', ', array_map(
                fn($value, $key) => "$key: $value",
                $entry,
                array_keys($entry)
            )) . "\n";
        }
    }
}

$data = [
    ['name' => 'Alice', 'age' => '25', 'profession' => 'Engineer'],
    ['name' => 'Bob', 'age' => '30', 'profession' => 'Doctor']
];

$ds = new DataStream($data);

$ageTest = function($entry) {
    return (int)$entry['age'] > 26;
};

$filteredDs = $ds->filter($ageTest);
$filteredDs->printData();
// Outputs:
// name: Bob, age: 30, profession: Doctor

?>

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function project(callable $projectFunc): DataStream {
        $projectedData = array_map($projectFunc, $this->data);
        return new DataStream($projectedData);
    }

    public function filter(callable $testFunc): DataStream {
        $filteredData = array_filter($this->data, $testFunc);
        return new DataStream($filteredData);
    }

    public function aggregate(string $key, callable $aggFunc): float {
        $values = array_map(fn($entry) => $entry[$key], $this->data);
        return $aggFunc($values);
    }

    public function printData(): void {
        foreach ($this->data as $entry) {
            echo join(', ', array_map(
                fn($value, $key) => "$key: $value",
                $entry,
                array_keys($entry)
            )) . "\n";
        }
    }
}

$data = [
    ['name' => 'Alice', 'age' => '25', 'profession' => 'Engineer'],
    ['name' => 'Bob', 'age' => '30', 'profession' => 'Doctor']
];

$ds = new DataStream($data);

$averageAgeCalculator = function($ages) {
    $sum = array_sum(array_map('intval', $ages));
    return $sum / count($ages);
};

$averageAge = $ds->aggregate('age', $averageAgeCalculator);
echo $averageAge;  // Outputs: 27.5

?>

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function project(callable $projectFunc): DataStream {
        $projectedData = array_map($projectFunc, $this->data);
        return new DataStream($projectedData);
    }

    public function filter(callable $testFunc): DataStream {
        $filteredData = array_filter($this->data, $testFunc);
        return new DataStream($filteredData);
    }

    public function aggregate(string $key, callable $aggFunc): float {
        $values = array_map(fn($entry) => $entry[$key], $this->data);
        return $aggFunc($values);
    }

    public function printData(): void {
        foreach ($this->data as $entry) {
            echo join(', ', array_map(
                fn($value, $key) => "$key: $value",
                $entry,
                array_keys($entry)
            )) . "\n";
        }
    }
}

$data = [
    ['name' => 'Alice', 'age' => '25', 'profession' => 'Engineer', 'salary' => '70000'],
    ['name' => 'Bob', 'age' => '30', 'profession' => 'Doctor', 'salary' => '120000'],
    ['name' => 'Carol', 'age' => '35', 'profession' => 'Artist', 'salary' => '50000'],
    ['name' => 'David', 'age' => '40', 'profession' => 'Engineer', 'salary' => '90000']
];

$ds = new DataStream($data);

// Step 1: Project to include 'name', 'age', 'salary'
$projectedDs = $ds->project(function($entry) {
    return [
        'name' => $entry['name'],
        'age' => $entry['age'],
        'salary' => $entry['salary']
    ];
});

// Step 2: Filter where age > 30
$filteredDs = $projectedDs->filter(function($entry) {
    return (int)$entry['age'] > 30;
});

// Step 3: Aggregate to compute average salary
$averageSalaryCalculator = function($salaries) {
    $total = array_sum(array_map('intval', $salaries));
    return $total / count($salaries);
};

$averageSalary = $filteredDs->aggregate('salary', $averageSalaryCalculator);
echo $averageSalary;  // Outputs: 70000

?>