Adding Composite to inProgress instead of branch

Author: phpfui

inProgress/Composite/Employee.php

@@ -0,0 +1,41 @@
+<?php declare(strict_types=1);
+
+namespace SOB\Composite;
+
+use Composite\DB\Attributes\Table;
+use Composite\DB\Attributes\PrimaryKey;
+use Composite\Sync\Attributes\Index;
+use Composite\Entity\AbstractEntity;
+
+#[Table(connection: 'sqlite', name: 'employee')]
+#[Index(columns: ['city'], name: 'employee_city')]
+#[Index(columns: ['company'], name: 'employee_company')]
+#[Index(columns: ['first_name'], name: 'employee_first_name')]
+#[Index(columns: ['last_name'], name: 'employee_last_name')]
+#[Index(columns: ['zip_postal_code'], name: 'employee_zip_postal_code')]
+#[Index(columns: ['state_province'], name: 'employee_state_province')]
+class Employee extends AbstractEntity
+{
+    #[PrimaryKey(autoIncrement: true)]
+    public int $employee_id;
+
+    public function __construct(
+        public ?string $company = null,
+        public ?string $last_name = null,
+        public ?string $first_name = null,
+        public ?string $email_address = null,
+        public ?string $job_title = null,
+        public ?string $business_phone = null,
+        public ?string $home_phone = null,
+        public ?string $mobile_phone = null,
+        public ?string $fax_number = null,
+        public ?string $address = null,
+        public ?string $city = null,
+        public ?string $state_province = null,
+        public ?string $zip_postal_code = null,
+        public ?string $country_region = null,
+        public ?string $web_page = null,
+        public ?string $notes = null,
+        public ?string $attachments = null,
+    ) {}
+}

inProgress/Composite/UsersTable.php renamed to inProgress/Composite/EmployeeTable.php

@@ -1,18 +1,18 @@
 <?php declare(strict_types=1);
 
-namespace App\Composite;
+namespace SOB\Composite;
 
 use Composite\DB\AbstractTable;
 use Composite\DB\TableConfig;
 
-class UsersTable extends AbstractTable
+class EmployeeTable extends AbstractTable
 {
     protected function getConfig(): TableConfig
     {
-        return TableConfig::fromEntitySchema(User::schema());
+        return TableConfig::fromEntitySchema(Employee::schema());
     }
 
-    public function findOne(int $id): ?User
+    public function findOne(int $id): ?Employee
     {
         return $this->_findByPk($id);
     }

inProgress/Composite/TestsOld.php

@@ -0,0 +1,119 @@
+<?php
+
+namespace SOB\Composite;
+
+class Tests extends \SOB\Test
+	{
+
+	protected EmployeeTable $employeeTable;
+
+	public function closeConnection() : void
+		{
+		}
+
+	/**
+	 * class must delete one record with id=$id
+	 */
+	public function delete(int $id) : bool
+		{
+		$employee = new Employee();
+		$employee->fromArray(['employee_id' => $id]);
+		$this->employeeTable->delete($employee);
+
+		return true;
+		}
+
+	/**
+	 * Initialize Responsibilities:
+	 *
+	 *  * Initialize the orm
+	 *  * open the database
+	 *  * initialize the database schema
+	 */
+	public function init(\SOB\Configuration $config) : static
+		{
+		$dir = __DIR__ . '/scaffolding/config.php';
+		putenv('CONNECTIONS_CONFIG_FILE=' . $dir);
+		$connection = $config->getDriver();
+
+		if (\str_contains($connection, 'sqlite'))
+			{
+			$connection = 'sqlite';
+			$lines = \file(__DIR__ . '/../../northwind/northwind-schema.sqlite');
+			\fclose(\fopen($config->getNamespace() . '.sqlite', 'w'));
+			}
+		else
+			{
+			$lines = \file(__DIR__ . '/../../northwind/northwind-schema.sql');
+			}
+		$connectionParams = [
+			'dbname' => $config->getDatabase(),
+			'user' => $config->getUser(),
+			'password' => $config->getPassword(),
+			'host' => $config->getHost(),
+			'driver' => $config->getDriver(),
+			'port' => $config->getPort(),
+		];
+		$connection = \Doctrine\DBAL\DriverManager::getConnection($connectionParams);
+
+		$this->employeeTable = new EmployeeTable();
+
+		$sql = '';
+
+		foreach ($lines as $line)
+			{
+			// Ignoring comments from the SQL script
+			if (\str_starts_with((string)$line, '--') || '' == $line)
+				{
+				continue;
+				}
+
+			$sql .= $line;
+
+			if (\str_ends_with(\trim((string)$line), ';'))
+				{
+				$connection->executeStatement($sql);
+				$sql = '';
+				}
+			} // end foreach
+
+		return $this;
+		}
+
+	/**
+	 * class must insert one record with id=$id
+	 *
+	 * @return int $id inserted
+	 */
+	public function insert(int $id) : int
+		{
+		$employee = new Employee();
+		$employee->company = "Company {$id}";
+		$employee->last_name = "Last {$id}";
+		$employee->first_name = "First {$id}";
+
+		$this->employeeTable->save($employee);
+
+		return $employee->employee_id;
+		}
+
+	/**
+	 * class must read and return one record with id=$id or null on no matching record
+	 */
+	public function read(int $id) : ?object
+		{
+		return $this->employeeTable->findOne($id);
+		}
+
+	/**
+	 * class must update one record with id=$id to have $to in the data
+	 */
+	public function update(int $id, int $to) : bool
+		{
+		$employee = $this->read($id);
+		$employee->last_name = "Updated {$to}";
+		$this->employeeTable->save($employee);
+
+		return true;
+		}
+	}

inProgress/Composite/User.php

@@ -0,0 +1,16 @@
+<?php
+
+include '../../../vendor/autoload.php';
+
+use Composite\Sync\Commands;
+use Symfony\Component\Console\Application;
+
+$dir = __DIR__ . '/config.php';
+putenv('CONNECTIONS_CONFIG_FILE=' . $dir);
+
+$app = new Application();
+$app->addCommands([
+    new Commands\GenerateEntityCommand(), //to initialize $dbManager see example above
+    new Commands\GenerateTableCommand(),
+]);
+$app->run();