Create a shared Number Pool for each of business number ranges to use native
MySQL / MariaDB FOR UPDATE
atomic locks if you run on a MySQL Master/Master
Replication or on galera cluster or if you have multiple message queue workers
which are consuming the same jobs.
If you're running on replication you're primary auto increments are probably not
reliable for unique ascending numbers. With this Eloquent trait your able to generate
ascending unique numbers while using InnoDB's native FOR UPDATE
row lock.
Example Invoice Table on a Galera Cluster with three nodes:
id | type | number |
---|---|---|
1 | invoice | 1000 |
3 | invoice | 1001 |
6 | invoice | 1002 |
With Master-Master Replication or Galera cluster your primary auto increment is not reliable for any ascending numbers.
This package can be installed through composer:
composer require linushstge/number-pool
After installation, you have to create a new migration with artisan:make migration
for your number pools.
php artisan make:migration CreateNumberPool
Example:
<?php
use Illuminate\Database\Migrations\Migration;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;
return new class extends Migration
{
public function up(): void
{
Schema::create('number_pool', function (Blueprint $table) {
$table->id();
$table->string('key')->unique()->index();
$table->bigInteger('number');
$table->string('description')->nullable();
$table->dateTime('created_at');
$table->dateTime('updated_at');
});
}
public function down(): void
{
Schema::dropIfExists('number_pool');
}
};
Number Pools stores a string identifier key and the last used number of any pool your application is using. With the key you are able to use the same number pools in multiple eloquent models.
Create a new NumberPool
for your first eloquent model and persist it to database.
$numberPool = new NumberPool([
'key' => 'invoice.number',
'number => 999, // latest persisted number
'description' => 'Pool for generating unique ascending invoice numbers'
]);
$numberPool->save();
Add the NumberPool
trait to one of your existing model and implement
the abstract methods numberPoolKey
and numberPoolAttribute
to set up your pool and local
model attribute where you wish to save your ascending unique incremented number.
<?php
namespace App\Models\Account;
use linushstge\NumberPool\Traits\NumberPool;
use Illuminate\Database\Eloquent\Model;
class Invoice extends Model
{
use NumberPool;
public function numberPoolKey(): string
{
// return your number pool key
return 'invoice.number';
}
public function numberPoolAttribute(): string
{
// return your local model attribute where you want to store your number
return 'number';
}
}
On each Model creating
event this trait will perform a native InnoDB FOR UPDATE
lock inside a
dedicated transaction to ensure uniqueness for the new generated number.
If you wish to specify the step size you can implement the public method numberPoolStepSize
to dynamically adjust the step size for any new generated increments. You also can use rand
to implement
random steps between your numbers.
public function numberPoolStepSize(): int
{
// return any positive integer
return rand(10, 50);
}
Please ensure to return a positive integer
for your step size. Otherwise, the NumberPoolException
will be thrown.
As you may already know, laravel supports static booted events to hook inside a creating or created event. You can use them to build custom logic with your newly unique number pool integer.
For example:
<?php
class Invoice
{
// [..]
protected static function booted()
{
static::creating(function ($invoice) {
// your unique incremented number from your number pool is already
//available before the transaction has been committed.
$uniqueNumber = $invoice->number;
});
}
}
Yes, you can use horizon, your own supervisor process monitor or native systemd services. By InnoDB's technology the native ROW READ LOCK is guaranteed.
No, this package only requires InnoDB for your number_pool
table.
No, redis is not required, but preferred for your message queue, especially if your consuming the same jobs on multiple workers.
The MIT License (MIT). Refer to the License for more information.