CRUD fix and xdebug

Author: rxcod9

.gitignore

@@ -2,7 +2,10 @@
 /.php-cs-fixer.cache
 /.phpunit.result.cache
 /.idea/
-/.vscode/
 /build/
 ab*.log
-*.log
+*.log
+
+# vscode
+.vscode/*
+!.vscode/launch.json

.vscode/launch.json

@@ -0,0 +1,16 @@
+{
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Listen for Xdebug",
+            "type": "php",
+            "request": "launch",
+            "port": 9003,
+            "stopOnEntry": false,
+            "log": true,
+            "pathMappings": {
+                "/app": "${workspaceFolder}" // container path → local path
+            }
+        }
+    ]
+}

Dockerfile

@@ -30,6 +30,9 @@ RUN docker-php-ext-install pdo pdo_mysql pdo_sqlite
 RUN pecl install redis \
  && docker-php-ext-enable redis
 
+RUN pecl install xdebug \
+    && docker-php-ext-enable xdebug
+
 # --- Composer ---
 COPY --from=composer:2 /usr/bin/composer /usr/bin/composer
 

docker-compose.yml

@@ -4,6 +4,9 @@ services:
       context: .
       dockerfile: Dockerfile
     image: php-swoole-crud-microservice:latest
+    volumes:
+      - .:/app
+      - ./docker/php/xdebug.ini:/usr/local/etc/php/conf.d/xdebug.ini
     environment:
       APP_ENV: prod
       DB_DRIVER: mysql
@@ -19,6 +22,8 @@ services:
       SWOOLE_WORKER_NUM: 4
       SWOOLE_TASK_WORKER_NUM: 4
       SWOOLE_MAX_REQUEST: 10000
+      XDEBUG_MODE: debug
+      XDEBUG_CONFIG: client_host=host.docker.internal client_port=9003
     ports:
       - "9501:9501"
     depends_on: [mysql, redis]
@@ -51,8 +56,8 @@ services:
     image: prom/mysqld-exporter:latest
     container_name: mysqld_exporter
     environment:
-      # DATA_SOURCE_NAME: "root:root@(mysql:3306)/"
-      - DATA_SOURCE_NAME=exporter:exporter@(mysql:3306)/
+      DATA_SOURCE_NAME: "root:root@(mysql:3306)/"
+      # - DATA_SOURCE_NAME=exporter:exporter@(mysql:3306)/
     volumes:
       - ./docker/mysql/.my.cnf:/etc/mysql/.my.cnf:ro
     command:

docker/php/xdebug.ini

@@ -0,0 +1,33 @@
+zend_extension=xdebug.so
+
+[xdebug]
+xdebug.mode=debug
+xdebug.start_with_request=yes
+xdebug.client_host=host.docker.internal  ; for Mac/Windows
+; for Linux, set to your host IP (e.g., 172.17.0.1)
+xdebug.client_port=9003                  ; VS Code default
+xdebug.log_level=5
+xdebug.log=/tmp/xdebug.log
+xdebug.discover_client_host=true
+; xdebug.idekey=VSCODE
+xdebug.max_nesting_level=512
+xdebug.output_dir=/tmp
+; xdebug.var_display_max_depth=5
+; xdebug.var_display_max_children=256
+; xdebug.var_display_max_data=1024
+; xdebug.profiler_enable_trigger=1
+; xdebug.profiler_output_dir=/tmp
+; xdebug.trace_output_dir=/tmp
+; xdebug.collect_params=4
+; xdebug.collect_return=1
+; xdebug.collect_vars=1
+; xdebug.show_local_vars=1
+; xdebug.show_mem_delta=1
+; xdebug.cli_color=1
+; xdebug.file_link_format="vscode://file/%f:%l"
+;xdebug.halt_level=E_WARNING
+;xdebug.halt_on_warning=1
+xdebug.halt_on_error=1
+xdebug.halt_on_exception=1
+xdebug.halt_on_fatal_error=1
+xdebug.halt_on_parse_error=1

scripts/migrate.php

@@ -0,0 +1,33 @@
+<?php
+$cfg = require __DIR__ . "/../config/config.php";
+$db  = $cfg["db"]["mysql"];
+
+$conn = mysqli_init();
+mysqli_real_connect(
+    $conn,
+    $db["host"],
+    $db["user"],
+    $db["pass"],
+    $db["dbname"],
+    $db["port"]
+);
+
+if (mysqli_connect_errno()) {
+    fwrite(STDERR, "MySQL connect error: " . mysqli_connect_error() . PHP_EOL);
+    exit(1);
+}
+
+$migrations = require __DIR__ . "/../config/database.php";
+
+foreach ($migrations as $k => $migs) {
+    foreach ($migs as $m) {
+        $sql = file_get_contents($m);
+        if (!mysqli_multi_query($conn, $sql)) {
+            fwrite(STDERR, "Error running $m: " . mysqli_error($conn) . PHP_EOL);
+            exit(1);
+        }
+        while (mysqli_more_results($conn) && mysqli_next_result($conn)) {;}
+    }
+}
+
+echo "migrated\n";

src/Repositories/ItemRepository.php

@@ -3,35 +3,88 @@
 namespace App\Repositories;
 
 use App\Core\DbContext;
-use PDO;
 
 final class ItemRepository
 {
     public function __construct(private DbContext $ctx) {}
+
     public function create(array $d): int
     {
-        $stmt = $this->ctx->conn()->prepare("INSERT INTO items (sku,title,price) VALUES (?,?,?)");
-        $stmt->execute([$d['sku'], $d['title'], $d['price']]);
-        return (int)$this->ctx->conn()->lastInsertId();
+        $conn = $this->ctx->conn(); // returns Swoole\Coroutine\MySQL
+
+        $stmt = $conn->prepare("INSERT INTO items (sku, title, price) VALUES (?, ?, ?)");
+        if ($stmt === false) {
+            throw new \RuntimeException("Failed to prepare statement: " . $conn->error);
+        }
+
+        $result = $stmt->execute([$d['sku'], $d['title'], (float)$d['price']]);
+        if ($result === false) {
+            throw new \RuntimeException("Insert failed: " . $stmt->error);
+        }
+
+        return (int)$conn->insert_id;
     }
+
     public function find(int $id): ?array
     {
-        $stmt = $this->ctx->conn()->prepare("SELECT * FROM items WHERE id=?");
-        $stmt->execute([$id]);
-        return $stmt->fetch(PDO::FETCH_ASSOC) ?: null;
+        $conn = $this->ctx->conn();
+
+        $stmt = $conn->prepare("SELECT id, sku, title, price, created_at, updated_at FROM items WHERE id=? LIMIT 1");
+        if ($stmt === false) {
+            throw new \RuntimeException("Failed to prepare statement: " . $conn->error);
+        }
+
+        $rows = $stmt->execute([$id]);
+        if ($rows === false) {
+            throw new \RuntimeException("Query failed: " . $stmt->error);
+        }
+
+        return $rows[0] ?? null;
     }
+
     public function list(): array
     {
-        return $this->ctx->conn()->query("SELECT * FROM items ORDER BY id DESC limit 100")->fetchAll(PDO::FETCH_ASSOC);
+        $conn = $this->ctx->conn();
+
+        $rows = $conn->query("SELECT id, sku, title, price, created_at, updated_at FROM items ORDER BY id DESC LIMIT 100");
+        if ($rows === false) {
+            throw new \RuntimeException("Query failed: " . $conn->error);
+        }
+
+        return $rows;
     }
+
     public function update(int $id, array $d): bool
     {
-        $stmt = $this->ctx->conn()->prepare("UPDATE items SET sku=?, title=?, price=? WHERE id=?");
-        return $stmt->execute([$d['sku'], $d['title'], $d['price'], $id]);
+        $conn = $this->ctx->conn();
+
+        $stmt = $conn->prepare("UPDATE items SET sku=?, title=?, price=? WHERE id=?");
+        if ($stmt === false) {
+            throw new \RuntimeException("Failed to prepare statement: " . $conn->error);
+        }
+
+        $result = $stmt->execute([$d['sku'], $d['title'], (float)$d['price'], $id]);
+        if ($result === false) {
+            throw new \RuntimeException("Update failed: " . $stmt->error);
+        }
+
+        return (bool)($result['affected_rows'] ?? 0);
     }
+
     public function delete(int $id): bool
     {
-        $stmt = $this->ctx->conn()->prepare("DELETE FROM items WHERE id=?");
-        return $stmt->execute([$id]);
+        $conn = $this->ctx->conn();
+
+        $stmt = $conn->prepare("DELETE FROM items WHERE id=?");
+        if ($stmt === false) {
+            throw new \RuntimeException("Failed to prepare statement: " . $conn->error);
+        }
+
+        $result = $stmt->execute([$id]);
+        if ($result === false) {
+            throw new \RuntimeException("Delete failed: " . $stmt->error);
+        }
+
+        return (bool)($result['affected_rows'] ?? 0);
     }
 }

src/Repositories/UserRepository.php

@@ -3,43 +3,91 @@
 namespace App\Repositories;
 
 use App\Core\DbContext;
-use PDO;
 
 final class UserRepository
 {
     public function __construct(private DbContext $ctx)
     {
         //
     }
+
     public function create(array $d): int
     {
-        $conn = $this->ctx->conn();
-        $stmt = $conn->prepare("INSERT INTO users (name,email) VALUES (?,?)");
-        $stmt->execute([$d['name'], $d['email']]);
-        return (int)$conn->lastInsertId();
+        $conn = $this->ctx->conn(); // returns Swoole\Coroutine\MySQL
+
+        $stmt = $conn->prepare("INSERT INTO users (name, email) VALUES (?, ?)");
+        if ($stmt === false) {
+            throw new \RuntimeException("Failed to prepare statement: " . $conn->error);
+        }
+
+        $result = $stmt->execute([$d['name'], $d['email']]);
+        if ($result === false) {
+            throw new \RuntimeException("Insert failed: " . $stmt->error);
+        }
+
+        return (int)$conn->insert_id;
     }
+
     public function find(int $id): ?array
     {
-        $stmt = $this->ctx->conn()->prepare("SELECT id,name,email,created_at,updated_at FROM users WHERE id=?");
-        $stmt->execute([$id]);
-        $row = $stmt->fetch(PDO::FETCH_ASSOC);
-        return $row ?: null;
+        $conn = $this->ctx->conn();
+
+        $stmt = $conn->prepare("SELECT id, name, email, created_at, updated_at FROM users WHERE id=? LIMIT 1");
+        if ($stmt === false) {
+            throw new \RuntimeException("Failed to prepare statement: " . $conn->error);
+        }
+
+        $rows = $stmt->execute([$id]);
+        if ($rows === false) {
+            throw new \RuntimeException("Query failed: " . $stmt->error);
+        }
+
+        return $rows[0] ?? null;
     }
+
     public function list(): array
     {
-        return $this->ctx
-            ->conn()
-            ->query("SELECT id,name,email,created_at,updated_at FROM users ORDER BY id DESC LIMIT 100")
-            ->fetchAll(PDO::FETCH_ASSOC);
+        $conn = $this->ctx->conn();
+
+        $rows = $conn->query("SELECT id, name, email, created_at, updated_at FROM users ORDER BY id DESC LIMIT 100");
+        if ($rows === false) {
+            throw new \RuntimeException("Query failed: " . $conn->error);
+        }
+
+        return $rows;
     }
+
     public function update(int $id, array $d): bool
     {
-        $stmt = $this->ctx->conn()->prepare("UPDATE users SET name=?, email=? WHERE id=?");
-        return $stmt->execute([$d['name'], $d['email'], $id]);
+        $conn = $this->ctx->conn();
+
+        $stmt = $conn->prepare("UPDATE users SET name=?, email=? WHERE id=?");
+        if ($stmt === false) {
+            throw new \RuntimeException("Failed to prepare statement: " . $conn->error);
+        }
+
+        $result = $stmt->execute([$d['name'], $d['email'], $id]);
+        if ($result === false) {
+            throw new \RuntimeException("Update failed: " . $stmt->error);
+        }
+
+        return (bool)($result['affected_rows'] ?? 0);
     }
+
     public function delete(int $id): bool
     {
-        $stmt = $this->ctx->conn()->prepare("DELETE FROM users WHERE id=?");
-        return $stmt->execute([$id]);
+        $conn = $this->ctx->conn();
+
+        $stmt = $conn->prepare("DELETE FROM users WHERE id=?");
+        if ($stmt === false) {
+            throw new \RuntimeException("Failed to prepare statement: " . $conn->error);
+        }
+
+        $result = $stmt->execute([$id]);
+        if ($result === false) {
+            throw new \RuntimeException("Delete failed: " . $stmt->error);
+        }
+
+        return (bool)($result['affected_rows'] ?? 0);
     }
 }