<h1 align="center">⛓️ PDB</h1> <p align="center">PHP için PDO query-builder</p> <p align="center"> <img src="https://img.shields.io/packagist/v/mlevent/pdb?style=plastic"/> <img src="https://img.shields.io/github/license/mlevent/pdb?style=plastic"/> <img src="https://img.shields.io/github/issues/mlevent/pdb?style=plastic"/> <img src="https://img.shields.io/github/last-commit/mlevent/pdb?style=plastic"/> <img src="https://img.shields.io/github/stars/mlevent/pdb?style=plastic"/> <img src="https://img.shields.io/github/forks/mlevent/pdb?style=plastic"/> </p>

Kurulum

🛠️ Paketi composer ile projenize dahil edin;

composer require mlevent/pdb

Örnek Kullanım

use Mlevent\Pdb;

/**
 * MYSQL
 */
$db = new Pdb([
    'database' => 'ecommerce',
    'username' => 'root',
    'password' => 'test'
]);

/**
 * SQLITE
 */
$db = new Pdb([
    'driver'   => 'sqlite',
    'database' => 'ecommerce.sqlite'
]);

Composer Kullanmadan

Yeni bir dizin oluşturarak src klasörü altındaki tüm dosyaları içine kopyalayın ve autoload.php dosyasını require ile sayfaya dahil ederek sınıfı başlatın.

require '{pdb_dosyalarinin_bulundugu_dizin}/autoload.php';

use Mlevent\Pdb;

$db = new Pdb([
    'database' => 'ecommerce',
    'username' => 'root',
    'password' => 'test'
]);

Yapılandırma

Varsayılan yapılandırma ayarları:

[
    'host'      => 'localhost',
    'driver'    => 'mysql',
    'database'  => '',
    'username'  => 'root',
    'password'  => '',
    'charset'   => 'utf8',
    'collation' => 'utf8_unicode_ci',
    'debug'     => false,
    'cacheTime' => 60,
    'cachePath' => __DIR__ . '/Cache'
]

Şu anda kullanılabilir durumda olan driver listesi:

Mysql
Sqlite (test aşamasında)

Fetch

Kullanılabilecek metodlar: get(), first(), value(), pluck(), find()

Get

Bu yöntem varsayılan olarak bir stdClass nesnesi döndürür. Sonuçlara Array formatında ulaşmak isterseniz toArray() metoduna göz atın.

$products = $db->get('products');

foreach ($products as $product) {
    echo $product->name;
}

get()
get('products')

Bir SQL sorgusu oluşturup, bu sorguyu çalıştırmak için metodları zincir şeklinde kullanabilirsiniz.

$query = $db->select('id, name, code, price, stock')
            ->table('products')
            ->between('price', 900, 1500)
            ->grouped( function($q) {
                $q->like(['code', 'name'], '%iphone%')
                  ->orWhere('featured', 1);
            })
            ->in('categoryId', [1, 2, 3, 4, 5, 6])
            ->order('price')
            ->get();

Yukarıdaki zincirin sorgu çıktısı şu şekilde olacaktır:

SELECT
  id, name, code, price, stock
FROM
  products
WHERE
  price BETWEEN ? AND ?
  AND ((name LIKE ? OR code LIKE ?) OR featured=?)
  AND categoryId IN(?,?,?,?,?,?)
ORDER BY
  price DESC

toArray()

Sonuçlara Array formatında ulaşmak için kullanılır.

$products = $db->table('products')
               ->toArray()
               ->get();

foreach ($products as $product) {
    echo $product['name'];
}

toJson()

Sonuçlara Json formatında ulaşmak için kullanılır.

$products = $db->table('products')
               ->toJson()
               ->get();

First

Bir tablodan sadece tek bir satır almanız gerekiyorsa, first() yöntemini kullanabilirsiniz. Bu yöntem, varsayılan olarak tek bir stdClass nesnesi döndürür.

$user = $db->table('users')
           ->first();

echo $user->email;

Value

Bir satırın tamamına ihtiyacınız yoksa, value yöntemini kullanarak bir kayıttan tek bir değer çıkarabilirsiniz.

$email = $db->table('users')
            ->where('name', 'Walter')
            ->value('email');

echo $email;

Pluck

Tek bir sütunun değerlerini içeren bir dizi istiyorsanız pluck() yöntemini kullanabilirsiniz.

$pluck = $db->table('products')
            ->pluck('name');

Array
(
    [0] => Apple Iphone X 128 GB
    [1] => Apple Iphone X 256 GB
    [2] => Apple Iphone X 512 GB
)

pluck() metoduna ikinci bir parametre göndererek, elde edilen dizinin anahtarları olarak kullanılmasını istediğiniz sütunu belirtebilirsiniz:

$pluck = $db->table('products')
            ->pluck('name', 'code');

Array
(
    [APPLEX128] => Apple Iphone X 128 GB
    [APPLEX256] => Apple Iphone X 256 GB
    [APPLEX512] => Apple Iphone X 512 GB
)

Find

Birincil anahtarla eşleşen kaydı döndürür.

$user = $db->table('users')
           ->find(15);

echo $user->name;

SELECT * FROM users WHERE id=?

find(15)
find(15, 'products')

Total

Toplam satır sayısına ulaşmak için kullanılır.

$total = $db->table('users')
            ->where('userGroup', 'Admin')
            ->total();

total()
total('users')

rowCount()

Etkilenen satır sayısı veya okunan satır sayısına ulaşmak için kullanılır.

echo $db->rowCount();

lastInsertId()

Insert işlemlerinde kaydedilen son satırın birincil anahtarını döndürür.

echo $db->lastInsertId();

Raw Query

Salt sql sorgusu çalıştırmak için kullanılır.

Raw Fecth

$results = $db->raw('SELECT * FROM products WHERE active = ? AND MONTH(created) = MONTH(NOW())', 1)
              ->get();

Raw Exec

$update = $db->raw('UPDATE payments SET active = !active WHERE status = ?', ['paid'])
             ->exec();

Pager

Parametre olarak sayfa başına listelenecek kayıt sayısı gönderilmelidir. pager() metodu salt sorgularda çalışmaz.

$posts = $db->table('posts')
            ->pager(25)
            ->get();

foreach ($posts as $post) {
    echo $post->title;
}

echo $db->pagerLinks();

pager() fonksiyonu 2 parametre alır. İlk parametre sayfa başına listelenecek kayıt sayısı, İkinci parametre sayfa bilgisinin aktarılacağı $_GET parametresidir. Örneğin link yapısı ?page=3 şeklinde kurgulanacaksa, örnek kullanım şu şekilde olmalıdır;

$db->pager(25, 'page');

pagerLinks()

Linklerin çıktısını almak için kullanılır.

echo $db->pagerLinks();

« ‹ 1 2 3 4 5 6 ... › »

pagerData()

Toplam sonuç, sayfa sayısı, limit, ofset ve aktif sayfa gibi bilgilere ulaşmak için kullanılır.

var_dump($db->pagerData());

Array
(
    [count] => 255
    [limit] => 10
    [offset] => 0
    [total] => 26
    [current] => 1
)

setPagerTemplate()

Link çıktısına ait HTML şablonu düzenlemek için kullanılır.

$db->setPagerTemplate('<li>
        <a class="{active}" href="{url}">
            {text}
        </a>
    </li>');

Cache

Sonuçları önbelleğe almak için kullanılır. Çok sık değişmesi gerekmeyen ve yoğun kullanımda performans sorunu oluşturabilecek sorgular için kullanılabilir.

Disk Cache

comments tablosundaki verileri mysql'den okur ve diske kaydeder. Sonuçlar 30 saniye boyunca diskten okunur.

$results = $db->cache(30)->get('comments');

fromDisk() metodu; son sorgu diskten okunuyorsa true, mysql'den okunuyorsa false döner.

Redis Cache

comments tablosundaki verileri mysql'den okur ve redis veritabanına kayder. Sonuçlar 30 saniye boyunca Redis üzerinden okunur.

$results = $db->redis(30)->get('comments');

fromRedis() metodu; son sorgu Redisten okunuyorsa true, mysql'den okunuyorsa false döner.

$redisConnect = (function(){
    $redis = new \Redis();
    $redis->connect('127.0.0.1', 6379, 1, NULL, 0, 0, ['auth' => ['default', '']]);
    return $redis;
});

$db->setRedis($redisConnect());

setRedis() metodu ile Redis sınıfı dışarıdan dahil edilebilir.

Not: Redis ile önbellekleme işlemi yapabilmek için sunucunuzda Redis yüklü olması gerekir.

Insert

Tabloya yeni bir satır eklemek için kullanılır. insert() metoduyla tek veya birden fazla kayıt eklenebilir.

Tekli Kayıt

$db->table('products')->insert([
    'name'  => 'Apple Iphone X 128 Gb',
    'code'  => 'APPLEX128',
    'price' => '999.9'
]);

Çoklu Kayıt

$db->table('products')->insert([
    ['name' => 'Apple Iphone X 128 Gb', 'code' => 'APPLEX128', 'price' => '999.9'],
    ['name' => 'Apple Iphone X 256 Gb', 'code' => 'APPLEX256', 'price' => '1149.9'],
    ['name' => 'Apple Iphone X 512 Gb', 'code' => 'APPLEX512', 'price' => '1349.9']
]);

Son kaydedilen satırın birincil anahtarına ulaşmak için lastInsertId() metodunu, toplam etkilenen satır sayısı için rowCount() metodunu kullanabilirsiniz.

Upsert

$db->table('products')->upsert([
    'name'  => 'Apple Iphone X 128 Gb',
    'code'  => 'APPLEX128',
    'price' => '999.9'
]);

Benzersiz anahtarlara eşleşen veri bulunursa var olan kayıt güncellenir, yoksa yeni kayıt eklenir.

Henüz Sqlite desteği yok.

Insert Ignore

$db->table('products')->insertIgnore([
    'name'  => 'Apple Iphone X 128 Gb',
    'code'  => 'APPLEX128',
    'price' => '999.9'
]);

Benzersiz anahtarlara eşleşen veri bulunursa kayıt eklenmez, yoksa yeni kayıt eklenir.

Insert Replace

$db->table('products')->insertReplace([
    'name'  => 'Apple Iphone X 128 Gb',
    'code'  => 'APPLEX128',
    'price' => '999.9'
]);

Benzersiz anahtarlara eşleşen veri bulunursa var olan kayıt silinir ve yeni kayıt eklenir, yoksa yeni kayıt eklenir. Her replace işleminde auto_increment olarak tanımlanan birincil anahtara (Genellikle ID) ait değer değişir. Değerin korunmasını istiyorsanız upsert() metodunu kullanmanız önerilir.

Update

Bir veya birden fazla kaydı güncellemek için kullanılır.

$update = $db->table('products')
             ->where('id', 11255)
             ->update(['active' => 1]);

Etkilenen satır sayısı döner.

Touch

active sütunu 1 ise 0, 0 ise 1 değerini alır.

$touch = $db->table('products')
            ->touch('active');

`touch('activ

Pdb

Install / Use

README