thephpleague/database

PHP library and ORM to handle DB connection, apply C.R.U.D. operations

Database

![Software License][ico-license] ![Coverage Status][ico-scrutinizer] , _(*1)

PHP library and ORM to handle DB connection, apply C.R.U.D. operations., _(*2)

Install

Via Composer, _(*3)

``` bash $ composer require thephpleague/database, <sub>(*4)</sub>

## Usage

``` php
$config = [
    'host'      => 'localhost',
    'port'      => 3306,
    'database'  => 'master_db',
    'username'  => 'root',
    'password'  => '',
];

$connection = new League\Database\ConnectionManager('core', $config);

BulkSql usage

Bulk SQL classes could be useful in scripts, when you need to insert big amount of records., <sub>(*5)</sub>

Example 1:, <sub>(*6)</sub>

``` php use League\Database\BulkSql\BulkInsert;, <sub>(*8)</sub>

$db = $connection->getMasterConnection();, <sub>(*9)</sub>

$bulkInsert = new BulkInsert($db, 'users'); $bulkInsert ->setItemsPerQuery(50) ->useIgnore() ->disableIndexes();, <sub>(*10)</sub>

try { $db->beginTransaction();, <sub>(*11)</sub>

foreach ($users as $user) {
    $bulkInsert->add($user);
}

$bulkInsert->finish();
$affectedCount = $bulkInsert->getAffectedCount();

$db->commit();

} catch (\PDOException $e) { $db->rollBack(); }, <sub>(*12)</sub>

</details>

**Example 2:**

<details>
    <summary>`BulkReplace` and `BulkDelete` usage (could be useful with feeds)</summary>

``` php
use League\Database\BulkSql\BulkReplace;
use League\Database\BulkSql\BulkDelete;

$db = $connection->getMasterConnection();

$bulkReplace = new BulkReplace($db, 'offers');
$bulkReplace->setItemsPerQuery(500);
$bulkDelete = new BulkDelete($db, 'offers');
$bulkDelete->setItemsPerQuery(1000);

try {
    $db->beginTransaction();

    foreach ($offers as $offer) {
        $flag = $offer['deltaStatus'] ?? null;

        switch ($delta) {
            case 'REMOVE':
                $bulkDelete->add(['id' => $data['id']]);
                break;
            case 'ADD':
                $bulkReplace->add($data);
                break;
            default:
                $logger->notice("Unsupported delta flag \"{$flag}\"";
        }
    }

    $bulkReplace->finish();
    $bulkDelete->finish();

    $db->commit();

    $insertsCount = $bulkReplace->getInsertedCount();
    $updatesCount = $bulkReplace->getReplacedCount();
    $deletesCount = $bulkDelete->getAffectedCount();
} catch (\PDOException $e) {
    $db->rollBack();
}

, <sub>(*13)</sub>

Change log

Please see CHANGELOG for more information on what has changed recently., <sub>(*14)</sub>

Testing

bash $ composer test, <sub>(*15)</sub>

Contributing

Please see CONTRIBUTING and CODE_OF_CONDUCT for details., <sub>(*16)</sub>

Security

If you discover any security related issues, please email sergey.podgornyy@yahoo.de instead of using the issue tracker., <sub>(*17)</sub>

Credits

• Sergey Podgornyy
• All Contributors

License

The MIT License (MIT). Please see License File for more information., <sub>(*18)</sub>