Chuyển tới nội dung chính
Phiên bản: 8.0.0

Query Builder

File: packages/skilldo/framework/src/Database/DB.php
Namespace: SkillDo\Database\DB
Tài liệu tham khảo: Laravel Query Builder

1. Query Builder là gì?​

Query Builder là một giao diện lập trình linh hoạt và an toàn để tương tác với Database mà không cần viết câu lệnh SQL thuần. Mọi giá trị đầu vào đều được tự động escaped (thoát ký tự) để chặn tấn công SQL Injection.

Lớp SkillDo\Database\DB là một Wrapper nhẹ của Illuminate\Database\Query\Builder (Laravel 12). Tất cả phương thức của Laravel Query Builder đều khả dụng trong SkillDo.

2. Khởi Tạo Query​

Dùng DB::table('tên_bảng') để bắt đầu một Query Builder mới trỏ đến bảng cụ thể. Lưu ý: Hệ thống tự động thêm prefix bảng (vd: cle_) vào tên bảng nếu đã cấu hình DB_PREFIX trong .env.

use SkillDo\Database\DB;

$query = DB::table('post');

3. Truy Vấn Dữ Liệu (SELECT)​

Lấy Tất Cả Bản Ghi​

$posts = DB::table('post')->get();

// Duyệt qua danh sách
foreach ($posts as $post) {
    echo $post->title;
}

Lấy Một Bản Ghi​

// Lấy bản ghi đầu tiên khớp với điều kiện
$post = DB::table('post')->where('id', 1)->first();

echo $post->title;

Chỉ Lấy Một Số Cột​

$posts = DB::table('post')
    ->select('id', 'title', 'created')
    ->get();

// Thêm cột vào câu SELECT đã khởi tạo
$posts = DB::table('post')
    ->select('id', 'title')
    ->addSelect('status')
    ->get();

Lấy Giá Trị Của Một Cột (Pluck)​

// Trả về Collection chứa mỗi giá trị của cột 'title'
$titles = DB::table('post')->pluck('title');

// Dùng cột 'id' làm key của mảng kết quả
$titlesById = DB::table('post')->pluck('title', 'id');

Raw Expressions (Biểu Thức SQL Thô)​

Dùng DB::raw() khi cần nhúng SQL thuần vào giữa các câu Query Builder (vẫn cần cẩn thận SQL injection với đầu vào người dùng):

$posts = DB::table('post')
    ->select(DB::raw('COUNT(*) as post_count, status'))
    ->groupBy('status')
    ->get();

4. Điều Kiện Lọc (WHERE)​

Điều Kiện Cơ Bản​

// Toán tử so sánh mặc định là '='
DB::table('post')->where('status', 'public')->get();

// Các toán tử khác: '>', '<>', 'like', '>=', '<=', 'LIKE'
DB::table('post')->where('id', '>', 10)->get();
DB::table('post')->where('title', 'like', '%skilldo%')->get();

Nhiều Điều Kiện (AND / OR)​

// Nhiều where() = AND
$posts = DB::table('post')
    ->where('status', 'public')
    ->where('post_type', 'article')
    ->get();

// orWhere = OR
$posts = DB::table('post')
    ->where('status', 'public')
    ->orWhere('status', 'featured')
    ->get();

whereIn / whereNotIn​

$posts = DB::table('post')
    ->whereIn('id', [1, 2, 3, 4])
    ->get();

$posts = DB::table('post')
    ->whereNotIn('status', ['trash', 'pending'])
    ->get();

whereNull / whereNotNull​

// Tìm bản ghi chưa được xóa mềm (trash = null)
DB::table('post')->whereNull('trash')->get();

// Tìm bản ghi đã bị xóa mềm
DB::table('post')->whereNotNull('trash')->get();

whereBetween (Trong Khoảng)​

$posts = DB::table('post')
    ->whereBetween('id', [10, 50])
    ->get();

whereDate / whereYear / whereMonth (Lọc Theo Thời Gian)​

DB::table('post')->whereDate('created', '2026-01-01')->get();
DB::table('post')->whereYear('created', '2026')->get();
DB::table('post')->whereMonth('created', '3')->get();

Nhóm Điều Kiện Lồng Nhau (Closure)​

$posts = DB::table('post')
    ->where('status', 'public')
    ->where(function ($query) {
        $query->where('post_type', 'post')
              ->orWhere('post_type', 'page');
    })
    ->get();
// Tương đương SQL: WHERE status = 'public' AND (post_type = 'post' OR post_type = 'page')

5. Sắp Xếp & Phân Trang​

// orderBy (mặc định ASC)
DB::table('post')->orderBy('created', 'desc')->get();

// 10 bản ghi mới nhất
DB::table('post')->latest('created')->limit(10)->get();

// Phân trang thủ công
DB::table('post')
    ->limit(10)       // Số bản ghi trên 1 trang
    ->offset(20)      // Bỏ qua 20 bản ghi đầu (trang 3)
    ->get();

// Thứ tự ngẫu nhiên
DB::table('post')->inRandomOrder()->limit(5)->get();

6. JOIN Bảng​

// INNER JOIN
DB::table('post')
    ->join('relationships as r', 'r.object_id', '=', 'post.id')
    ->where('r.object_type', 'post')
    ->select('post.*', 'r.category_id')
    ->get();

// LEFT JOIN
DB::table('post')
    ->leftJoin('gallery_items as g', function ($join) {
        $join->on('g.object_id', '=', 'post.id')
             ->where('g.object_type', 'post');
    })
    ->get();

7. Group By & Having​

$stats = DB::table('post')
    ->select(DB::raw('post_type, COUNT(*) as total'))
    ->groupBy('post_type')
    ->having('total', '>', 5)
    ->get();

8. Các Hàm Tổng Hợp (Aggregate)​

$count = DB::table('post')->where('status', 'public')->count();
$maxId = DB::table('post')->max('id');
$minId = DB::table('post')->min('id');
$sum   = DB::table('orders')->sum('total_price');
$avg   = DB::table('orders')->avg('total_price');

9. Ghi Dữ Liệu​

Insert (Thêm Mới)​

// Chèn 1 bản ghi, trả về số hàng bị ảnh hưởng
DB::table('post_meta')->insert([
    'post_id'    => 5,
    'meta_key'   => 'views',
    'meta_value' => 0,
]);

// Chèn và lấy ID tự tăng vừa được insert
$id = DB::table('post_meta')->insertGetId([
    'post_id'    => 5,
    'meta_key'   => 'featured',
    'meta_value' => 1,
]);

Update (Cập Nhật)​

DB::table('post')
    ->where('id', 5)
    ->update(['status' => 'public', 'title' => 'Tiêu đề mới']);

// Tăng / giảm giá trị số nguyên
DB::table('post_meta')->where('meta_key', 'views')->increment('meta_value', 1);
DB::table('post_meta')->where('meta_key', 'stock')->decrement('meta_value', 5);

Delete (Xóa)​

DB::table('post_meta')
    ->where('post_id', 5)
    ->delete();

10. Transaction (Giao Dịch)​

Dùng Transaction để đảm bảo toàn vẹn dữ liệu. Nếu bất cứ truy vấn nào trong khối thất bại, toàn bộ sẽ được rollback.

use SkillDo\Database\DB;

DB::beginTransaction();

try {
    DB::table('orders')->insert(['user_id' => 1, 'total' => 250000]);
    DB::table('inventory')->where('product_id', 10)->decrement('quantity', 1);

    DB::commit(); // Lưu thành công tất cả thay đổi

} catch (\Exception $e) {
    DB::rollBack(); // Hủy mọi thay đổi nếu có lỗi
    throw $e;
}

11. Debug Câu Lệnh SQL​

// In câu SQL ra màn hình rồi dừng
DB::table('post')->where('status', 'public')->dd();

// Lấy chuỗi SQL để ghi log
$sql = DB::table('post')->where('status', 'public')->toSql();