Chunked CSV import with row-level validation, error collection, dry-run mode, and queue support
composer require philiprehberger/laravel-csv-importChunked CSV import with row-level validation, error collection, dry-run mode, and queue support.
composer require philiprehberger/laravel-csv-import
The service provider is registered automatically via Laravel's package auto-discovery.
Optionally publish the config file:
php artisan vendor:publish --tag=csv-import-config
Implement PhilipRehberger\CsvImport\Contracts\ImportHandler:
namespace App\Imports;
use App\Models\User;
use PhilipRehberger\CsvImport\Contracts\ImportHandler;
class UserImportHandler implements ImportHandler
{
public function rules(): array
{
return [
'first_name' => ['required', 'string', 'max:255'],
'last_name' => ['required', 'string', 'max:255'],
'email' => ['required', 'email', 'max:255'],
];
}
public function map(array $row): array
{
return [
'First Name' => 'first_name',
'Last Name' => 'last_name',
'Email' => 'email',
];
}
public function handle(array $row): void
{
User::create($row);
}
public function uniqueBy(): ?string
{
return 'email';
}
}
use PhilipRehberger\CsvImport\CsvImporter;
$result = CsvImporter::make('/path/to/users.csv')
->using(UserImportHandler::class)
->chunkSize(500)
->import();
echo "Imported: {$result->successCount}";
echo "Errors: {$result->errorCount}";
if ($result->hasErrors()) {
foreach ($result->getErrors() as $error) {
echo "Line {$error->lineNumber}: " . implode(', ', $error->errors->all());
}
}
$result = CsvImporter::make('/path/to/users.csv')
->using(UserImportHandler::class)
->dryRun();
CsvImporter::make('/path/to/users.csv')
->using(UserImportHandler::class)
->chunkSize(1000)
->importQueued();
$result = CsvImporter::fromUpload($request->file('csv'))
->using(UserImportHandler::class)
->import();
$result = CsvImporter::make('/path/to/users.csv')
->using(UserImportHandler::class)
->chunkSize(500)
->onChunkComplete(function (int $chunkIndex, int $processedRows, int $successCount, int $errorCount) {
echo "Chunk {$chunkIndex}: {$processedRows} rows, {$successCount} ok, {$errorCount} failed\n";
})
->import();
Apply transformations to mapped columns before validation:
$result = CsvImporter::make('/path/to/users.csv')
->using(UserImportHandler::class)
->transformColumn('email', fn (string $value) => strtolower($value))
->transformColumn('first_name', fn (string $value) => trim($value))
->import();
CsvImporter::make($path)
->using(MyHandler::class)
->delimiter(';')
->import();
| Method | Description |
|---|---|
CsvImporter::make(string $path) | Create an importer from a file path |
CsvImporter::fromUpload(UploadedFile $file) | Create an importer from an uploaded file |
->using(string $handlerClass) | Set the import handler class |
->chunkSize(int $size) | Set chunk size (default: config value) |
->delimiter(string $delimiter) | Set CSV delimiter |
->enclosure(string $enclosure) | Set CSV enclosure character |
->onChunkComplete(callable $callback) | Register a per-chunk progress callback |
->transformColumn(string $column, callable $transformer) | Register a pre-validation column transformer |
->import() | Run import synchronously |
->dryRun() | Validate all rows without persisting |
->importQueued() | Dispatch import as a background job |
| Method | Description |
|---|---|
rules(): array | Laravel validation rules for each mapped row |
map(array $row): array | Map CSV headers to attribute names |
handle(array $row): void | Persist a single validated row |
uniqueBy(): ?string | Attribute name for duplicate detection, or null to disable |
| Property / Method | Type | Description |
|---|---|---|
$totalRows | int | Total data rows in the file |
$successCount | int | Rows successfully handled |
$errorCount | int | Rows that failed validation or handling |
$skippedCount | int | Rows skipped due to duplicate detection |
hasErrors() | bool | True if errorCount > 0 |
getErrors() | RowError[] | All collected row errors |
toArray() | array | Serialisable summary |
| Event | Payload |
|---|---|
ImportStarted | $path, $totalRows, $isDryRun |
ImportChunkProcessed | $path, $chunkIndex, $rowsInChunk, $successCount, $errorCount, $skippedCount |
ImportCompleted | $path, $result (ImportResult), $isDryRun |
composer install
vendor/bin/phpunit
vendor/bin/pint --test
vendor/bin/phpstan analyse
If you find this project useful: