Hãy viết một hàm 'getSalesByRegion' trong 'ReportsService' (file src/reports/reports.service.ts):
- Không sử dụng Entity. Hãy inject 'DataSource' từ thư viện 'typeorm'.
- Gọi Stored Procedure có tên 'GetSalesByRegion' trong MySQL.
- Truyền vào hai tham số: regionName (string) và minAmount (number).
- Trả về phần tử đầu tiên của mảng kết quả (vì MySQL trả về mảng lồng chứa kết quả thực tế ở index 0).

import { Injectable } from '@nestjs/common';
import { DataSource } from 'typeorm';

@Injectable()
export class ReportsService {
  constructor(private readonly dataSource: DataSource) {}

  async getSalesByRegion(regionName: string, minAmount: number) {
    // Sử dụng cú pháp CALL để kích hoạt Stored Procedure trong MySQL
    const rawResults = await this.dataSource.query(
      'CALL GetSalesByRegion(?, ?)',
      [regionName, minAmount]
    );
    
    // Lấy danh sách kết quả thực tế ở phần tử đầu tiên
    return rawResults[0];
  }
}

Hãy viết một service 'RawProductsService' trong file 'src/products/raw-products.service.ts':
- Sử dụng 'DataSource' để chạy các câu lệnh SQL thuần túy trực tiếp, không sử dụng Entity.
- Cấu hình SQL tương thích với MySQL (sử dụng placeholders dạng '?').
- Viết hàm 'insertProduct(name, price, description)' chạy câu lệnh INSERT INTO vào bảng 'products'.
- Viết hàm 'updateProductPrice(id, newPrice)' chạy câu lệnh UPDATE.
- Viết hàm 'deleteProduct(id)' chạy câu lệnh DELETE FROM.

import { Injectable } from '@nestjs/common';
import { DataSource } from 'typeorm';

@Injectable()
export class RawProductsService {
  constructor(private readonly dataSource: DataSource) {}

  // 1. Thêm mới dữ liệu (INSERT)
  async insertProduct(name: string, price: number, description: string) {
    const sql = `
      INSERT INTO products (name, price, description)
      VALUES (?, ?, ?);
    `;
    // Thực thi câu lệnh ghi dữ liệu xuống MySQL
    const result = await this.dataSource.query(sql, [name, price, description]);
    
    // Trả về thông tin ID của dòng vừa được chèn vào
    return { id: result.insertId, name, price };
  }

  // 2. Cập nhật dữ liệu (UPDATE)
  async updateProductPrice(id: number, newPrice: number) {
    const sql = `
      UPDATE products
      SET price = ?
      WHERE id = ?;
    `;
    const result = await this.dataSource.query(sql, [newPrice, id]);
    return { 
      success: true, 
      affectedRows: result.affectedRows, // Số lượng dòng bị ảnh hưởng
      message: `Cập nhật thành công sản phẩm #${id}` 
    };
  }

  // 3. Xóa dữ liệu (DELETE)
  async deleteProduct(id: number) {
    const sql = `
      DELETE FROM products
      WHERE id = ?;
    `;
    await this.dataSource.query(sql, [id]);
    return { success: true, message: `Xóa thành công sản phẩm #${id}` };
  }
}