Kotchasan Framework Documentation

Kotchasan Framework Documentation

คู่มือการใช้งานฐานข้อมูลใน Kotchasan

TH 05 Feb 2026 06:23

คู่มือการใช้งานฐานข้อมูลใน Kotchasan

บทนำ

Kotchasan Framework มีระบบฐานข้อมูลที่ยืดหยุ่น รองรับ MySQL, PostgreSQL, MSSQL และ SQLite พร้อม API ที่ปลอดภัย ใช้งานง่าย และเหมาะกับงานจริง

สารบัญ

  1. การตั้งค่าฐานข้อมูล
  2. การเชื่อมต่อฐานข้อมูล
  3. การสร้าง Query
  4. การจัดการ Transaction
  5. การทำ Cache
  6. การปรับปรุงประสิทธิภาพ
  7. ตัวอย่างการใช้งานจริง
  8. Best Practices

การตั้งค่าฐานข้อมูล

การตั้งค่าพื้นฐาน

use Kotchasan\Database;

Database::config([
    'default' => [
        'driver' => 'mysql',
        'host' => 'localhost',
        'database' => 'myapp_db',
        'username' => 'root',
        'password' => 'password',
        'charset' => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix' => 'app'
    ]
]);

การตั้งค่าแบบหลายฐานข้อมูล

use Kotchasan\Database;

Database::config([
    'default' => [
        'driver' => 'mysql',
        'host' => 'localhost',
        'database' => 'main_db',
        'username' => 'root',
        'password' => 'password',
        'charset' => 'utf8mb4',
        'prefix' => 'main'
    ],
    'analytics' => [
        'driver' => 'pgsql',
        'host' => 'analytics.example.com',
        'database' => 'analytics_db',
        'username' => 'analytics_user',
        'password' => 'analytics_pass',
        'charset' => 'utf8'
    ],
    'cache' => [
        'driver' => 'sqlite',
        'database' => ROOT_PATH.DATA_FOLDER.'cache/cache.db',
        'prefix' => 'cache'
    ]
]);

การตั้งค่า Mapping ตาราง

use Kotchasan\Database;

Database::config([
    'default' => [
        // ... connection configuration
    ],
    'tables' => [
        'users' => 'members',
        'posts' => 'articles'
    ]
]);

การเชื่อมต่อฐานข้อมูล

การสร้าง Database Instance

use Kotchasan\Database;

// ใช้ connection ค่าเริ่มต้น
$db = Database::create();

// ใช้ connection ที่ระบุ
$analyticsDb = Database::create('analytics');
$cacheDb = Database::create('cache');

ตรวจสอบสถานะการเชื่อมต่อ

use Kotchasan\Database;

$connection = Database::getConnection('default');

if ($connection && $connection->isConnected()) {
    echo "Database connected successfully";
} else {
    echo "Failed to connect to database";
}

การสร้าง Query

คำสั่ง SELECT

use Kotchasan\Database;

$db = Database::create();

// SELECT พื้นฐาน
$users = $db->select('id', 'name', 'email')
    ->from('users')
    ->where(['status', 'active'])
    ->orderBy('name')
    ->fetchAll();

// SELECT ขั้นสูง
use Kotchasan\Database\Sql;

$userPosts = $db->select(
        'u.name',
        'p.title',
        'p.created_at',
        [Sql::COUNT('p.id'), 'post_count']
    )
    ->from('users u')
    ->leftJoin('posts p', 'p.user_id = u.id')
    ->where(['u.status', 'active'])
    ->where(['p.published', 1])
    ->groupBy('u.id')
    ->having('COUNT(p.id)', '>', 0)
    ->orderBy('u.name')
    ->limit(10)
    ->fetchAll();

คำสั่ง INSERT

// INSERT แถวเดียว
$userId = $db->insert('users')
    ->values([
        'name' => 'John Doe',
        'email' => 'john@example.com',
        'password' => password_hash('secret123', PASSWORD_DEFAULT),
        'status' => 'active',
        'created_at' => date('Y-m-d H:i:s')
    ])
    ->execute();

// INSERT หลายแถว
$db->insert('users')
    ->rows([
        ['name' => 'Jane Smith', 'email' => 'jane@example.com'],
        ['name' => 'Bob Johnson', 'email' => 'bob@example.com'],
        ['name' => 'Alice Brown', 'email' => 'alice@example.com']
    ])
    ->execute();

คำสั่ง UPDATE

use Kotchasan\Database\Sql;

// UPDATE พื้นฐาน
$db->update('users')
    ->set([
        'name' => 'John Doe (Updated)',
        'updated_at' => date('Y-m-d H:i:s')
    ])
    ->where(['id', 1])
    ->execute();

// UPDATE พร้อมการคำนวณ
$db->update('accounts')
    ->set([
        'balance' => Sql::raw('balance - 1000')
    ])
    ->where(['id', 1])
    ->execute();

คำสั่ง DELETE

// DELETE พื้นฐาน
$db->delete('users')
    ->where(['status', 'inactive'])
    ->where(['last_login', '<', date('Y-m-d', strtotime('-1 year'))])
    ->execute();

// DELETE แบบมี LIMIT
$db->delete('logs')
    ->where(['level', 'debug'])
    ->orderBy('created_at', 'ASC')
    ->limit(1000)
    ->execute();

การจัดการ Transaction

Transaction พื้นฐาน

use Kotchasan\Database;
use Kotchasan\Database\Sql;

$db = Database::create();
$db->beginTransaction();

try {
    // Money transfer
    $db->update('accounts')
        ->set(['balance' => Sql::raw('balance - 1000')])
        ->where(['id', 1])
        ->execute();

    $db->update('accounts')
        ->set(['balance' => Sql::raw('balance + 1000')])
        ->where(['id', 2])
        ->execute();

    // Log transaction
    $db->insert('transactions')
        ->values([
            'from_account' => 1,
            'to_account' => 2,
            'amount' => 1000,
            'type' => 'transfer',
            'created_at' => date('Y-m-d H:i:s')
        ])
        ->execute();

    $db->commit();
    echo "Transfer successful";

} catch (Exception $e) {
    $db->rollback();
    echo "Error occurred: " . $e->getMessage();
}

Transaction Helper

$result = $db->transaction(function ($db) {
    // Create new user
    $userId = $db->insert('users')
        ->values([
            'name' => 'New User',
            'email' => 'newuser@example.com'
        ])
        ->execute();

    // Create profile
    $db->insert('user_profiles')
        ->values([
            'user_id' => $userId,
            'bio' => 'New system user',
            'avatar' => 'default.jpg'
        ])
        ->execute();

    return $userId;
});

echo "Created user ID: " . $result;

การทำ Cache

ตั้งค่า Query Cache

use Kotchasan\Database;

Database::configureCache([
    'driver' => 'file',
    'path' => ROOT_PATH.DATA_FOLDER.'cache/'
], 3600); // default TTL 1 hour

Cache ผลลัพธ์ของ Query

$popularPosts = $db->select('*')
    ->from('posts')
    ->where(['views', '>', 1000])
    ->orderBy('views', 'DESC')
    ->limit(10)
    ->cache(1800) // cache 30 นาที
    ->fetchAll();

ล้าง Cache แบบกำหนดเอง

$query = $db->select('*')
    ->from('posts')
    ->where(['views', '>', 1000])
    ->cache(1800);

$posts = $query->fetchAll();

$queryCache = Database::getQueryCache();
if ($queryCache) {
    $queryCache->invalidate($query);
}

การปรับปรุงประสิทธิภาพ

การใช้ Index

$explain = $db->raw("EXPLAIN SELECT * FROM users WHERE email = ?", ['user@example.com']);

foreach ($explain as $row) {
    if ($row['key'] === null) {
        echo "ควรสร้าง index สำหรับคอลัมน์ email";
    }
}

การปรับปรุงตาราง

use Kotchasan\Database;

$connection = Database::getConnection('default');
if ($connection) {
    $connection->optimizeTable('users');
    $connection->optimizeTable('posts');
    $connection->emptyTable('temp_data');
}

การทำงานแบบ Batch

$users = [];
for ($i = 1; $i <= 1000; $i++) {
    $users[] = [
        'name' => "User {$i}",
        'email' => "user{$i}@example.com",
        'created_at' => date('Y-m-d H:i:s')
    ];
}

$batches = array_chunk($users, 100);
foreach ($batches as $batch) {
    $db->insert('users')->rows($batch)->execute();
}

ตัวอย่างการใช้งานจริง

ระบบจัดการผู้ใช้

use Kotchasan\Database;

class UserManager
{
    private $db;

    public function __construct()
    {
        $this->db = Database::create();
    }

    public function createUser($userData)
    {
        return $this->db->transaction(function ($db) use ($userData) {
            $existing = $db->select('id')
                ->from('users')
                ->where(['email', $userData['email']])
                ->first();

            if ($existing) {
                throw new Exception('Email already exists');
            }

            $userId = $db->insert('users')
                ->values([
                    'name' => $userData['name'],
                    'email' => $userData['email'],
                    'password' => password_hash($userData['password'], PASSWORD_DEFAULT),
                    'status' => 'active',
                    'created_at' => date('Y-m-d H:i:s')
                ])
                ->execute();

            $db->insert('user_profiles')
                ->values([
                    'user_id' => $userId,
                    'bio' => '',
                    'avatar' => 'default.jpg',
                    'created_at' => date('Y-m-d H:i:s')
                ])
                ->execute();

            return $userId;
        });
    }

    public function getUserWithProfile($userId)
    {
        return $this->db->select('u.*', 'p.bio', 'p.avatar')
            ->from('users u')
            ->leftJoin('user_profiles p', 'p.user_id = u.id')
            ->where(['u.id', $userId])
            ->first();
    }

    public function getActiveUsers($page = 1, $limit = 20)
    {
        $offset = ($page - 1) * $limit;

        return $this->db->select('u.*', 'p.avatar')
            ->from('users u')
            ->leftJoin('user_profiles p', 'p.user_id = u.id')
            ->where(['u.status', 'active'])
            ->orderBy('u.created_at', 'DESC')
            ->limit($limit, $offset)
            ->fetchAll();
    }
}

ระบบรายงาน

use Kotchasan\Database;
use Kotchasan\Database\Sql;

class ReportManager
{
    private $db;

    public function __construct()
    {
        $this->db = Database::create();
    }

    public function getUserRegistrationReport($startDate, $endDate)
    {
        return $this->db->select(
                'DATE(created_at) as date',
                [Sql::COUNT('*'), 'registrations']
            )
            ->from('users')
            ->where(['created_at', '>=', $startDate])
            ->where(['created_at', '<=', $endDate])
            ->groupBy('DATE(created_at)')
            ->orderBy('date')
            ->fetchAll();
    }

    public function getPopularPosts($limit = 10)
    {
        return $this->db->select(
                'p.*',
                'u.name as author_name',
                [Sql::COUNT('c.id'), 'comment_count']
            )
            ->from('posts p')
            ->leftJoin('users u', 'u.id = p.user_id')
            ->leftJoin('comments c', 'c.post_id = p.id')
            ->where(['p.status', 'published'])
            ->groupBy('p.id')
            ->orderBy('p.views', 'DESC')
            ->limit($limit)
            ->cache(1800)
            ->fetchAll();
    }
}

Best Practices

1. ความปลอดภัย

// Always use parameter binding
$user = $db->select('*')
    ->from('users')
    ->where(['email', $email])
    ->first();

// Avoid direct raw SQL
// Bad
$result = $db->raw("SELECT * FROM users WHERE email = '{$email}'");

// Good
$result = $db->raw("SELECT * FROM users WHERE email = ?", [$email]);

2. การจัดการ Error

use Kotchasan\Exception\DatabaseException;

try {
    $result = $db->select('*')->from('users')->fetchAll();
} catch (DatabaseException $e) {
    error_log("Database Error: " . $e->getMessage());
    error_log("SQL: " . $e->getQuery());
    error_log("Bindings: " . print_r($e->getBindings(), true));

    throw new Exception('System error occurred. Please try again.');
}

3. การใช้งาน Connection

use Kotchasan\Database;

$mainDb = Database::create('default');
$analyticsDb = Database::create('analytics');
$cacheDb = Database::create('cache');

4. การปรับ Query ให้เหมาะสม

$users = $db->select('id', 'name', 'email')
    ->from('users')
    ->where(['status', 'active'])
    ->where(['created_at', '>', $lastWeek])
    ->orderBy('id')
    ->limit(100)
    ->fetchAll();

5. การใช้ Cache อย่างมีประสิทธิภาพ

$categories = $db->select('*')
    ->from('categories')
    ->where(['status', 'active'])
    ->orderBy('sort_order')
    ->cache(3600)
    ->fetchAll();

$db->update('categories')
    ->set(['name' => 'New Name'])
    ->where(['id', 1])
    ->execute();

$queryCache = Database::getQueryCache();
if ($queryCache) {
    $queryCache->invalidateTable('categories');
}

สรุป

ระบบฐานข้อมูลของ Kotchasan ยืดหยุ่นและปลอดภัย การใช้ QueryBuilder พร้อมการ binding, cache และ transaction จะช่วยให้ระบบน่าเชื่อถือและบำรุงรักษาง่าย

ดูรายละเอียดเพิ่มเติมได้ที่:

Did you spot an improvement?

Enhance the documentation by contributing updates or translations.

Visit project repository