resolved #16

.editorconfig

@@ -0,0 +1,6 @@
+root = true
+
+[README.md]
+charset = utf-8
+indent_style = tab
+tab_width = 2

README.md

@@ -2,8 +2,8 @@
 Lightweight binary database by pure PHP<br>
 
 ## Dependencies
-1. ![PHP 8.4](https://www.php.net/releases/8.4/en.php)
-2. ![Composer](https://getcomposer.org/) (php package manager)
+1. [PHP 8.4](https://www.php.net/releases/8.4/en.php)
+2. [Composer](https://getcomposer.org/) (php package manager)
 
 ## Installation
 `composer require mirzaev/baza`
@@ -12,29 +12,29 @@ Lightweight binary database by pure PHP<br>
 ```php
 <?php
 
-use use mirzaev\baza\database,
-	mirzaev\baza\column,
-	mirzaev\baza\record,
-	mirzaev\baza\enumerations\encoding,
-	mirzaev\baza\enumerations\type;
+use mirzaev\baza\database,
+    mirzaev\baza\column,
+    mirzaev\baza\record,
+    mirzaev\baza\enumerations\encoding,
+    mirzaev\baza\enumerations\type;
 
 // Initializing the database
 $database = new database()
-	->encoding(encoding::utf8)
-	->columns(
-		new column('name', type::string, ['length' => 32]),
-		new column('second_name', type::string, ['length' => 64]),
-		new column('age', type::integer),
-		new column('height', type::float)
-	)
-	->connect(__DIR__ . DIRECTORY_SEPARATOR . 'database.ba');
+    ->encoding(encoding::utf8)
+    ->columns(
+        new column('name', type::string, ['length' => 32]),
+        new column('second_name', type::string, ['length' => 64]),
+        new column('age', type::integer),
+        new column('height', type::float)
+    )
+    ->connect(__DIR__ . DIRECTORY_SEPARATOR . 'database.ba');
 
 // Initializing the record
 $record = $database->record(
-	'Arsen',
-	'Mirzaev',
-	23,
-	(float) 165
+    'Arsen',
+    'Mirzaev',
+    23,
+    (float) 165
 );
 
 if ($database->write($record)) {
@@ -66,4 +66,4 @@ if ($database->write($record)) {
 ## Used by
 - My site-article about how i was kidnapped by PMC Wagner operatives [mirzaev/repression](https://git.svoboda.works/mirzaev/repression)
 - My decentralized P2P blockchain chats project [mirzaev/notchat](https://git.svoboda.works/mirzaev/notchat)
-- Svoboda Telegram chat-robot [svoboda/negotiator](https://git.svoboda.works/svoboda/negotiator)
+- Svoboda Telegram chat-robot negotiator [svoboda/negotiator](https://git.svoboda.works/svoboda/negotiator)

mirzaev/baza/system/database.php

@@ -48,7 +48,7 @@ class database
 	 *
 	 * @var string $database Path to the database file
 	 */
-	public protected(set) string $database = __DIR__ . DIRECTORY_SEPARATOR . 'database.ba';
+	public protected(set) string $database = __DIR__ . DIRECTORY_SEPARATOR . 'database.baza';
 
 	/**
 	 * Backups
@@ -259,48 +259,42 @@ class database
 	 */
 	public function unpack(array $binaries): record
 	{
-		if (count($binaries) === count($this->columns)) {
-			// Amount of binery values matches amount of columns
+		// Declaring the buffer of unpacked values
+		$unpacked = [];
 
-			// Declaring the buffer of unpacked values
-			$unpacked = [];
+		foreach ($this->columns as $index => $column) {
+			// Iterating over columns
 
-			foreach (array_combine($binaries, $this->columns) as $binary => $column) {
-				// Iterating over columns
+			// Initializing link to the binary value
+			$binary = $binaries[$index] ?? null;
 
-				if ($column->type === type::string) {
-					// String
+			if ($column->type === type::string) {
+				// String
 
-					// Unpacking the value
-					$value = unpack($column->type->value . $column->length, $binary)[1];
+				// Unpacking the value
+				$value = unpack($column->type->value . $column->length, $binary ?? str_repeat("\0", $column->length))[1];
 
-					// Deleting NULL-characters
-					$unnulled = str_replace("\0", '', $value);
+				// Deleting NULL-characters
+				$unnulled = str_replace("\0", '', $value);
 
-					// Encoding the unpacked value
-					$encoded = mb_convert_encoding($unnulled, $this->encoding->value);
+				// Encoding the unpacked value
+				$encoded = mb_convert_encoding($unnulled, $this->encoding->value);
 
-					// Writing into the buffer of readed values
-					$unpacked[] = $encoded;
-				} else {
-					// Other types
+				// Writing into the buffer of readed values
+				$unpacked[] = $encoded;
+			} else {
+				// Other types
 
-					// Writing into the buffer of readed values
-					$unpacked[] = unpack($column->type->value, $binary)[1];
-				}
+				// Writing into the buffer of readed values
+				$unpacked[] = unpack($column->type->value, $binary ?? "\0")[1];
 			}
-
-			// Implementing the record
-			$record = $this->record(...$unpacked);
-
-			// Exit (success)
-			return $record;
-		} else {
-			// Amount of binery values not matches amount of columns
-
-			// Exit (fail)
-			throw new exception_invalid_argument('Amount of binary values not matches amount of columns');
 		}
+
+		// Implementing the record
+		$record = $this->record(...$unpacked);
+
+		// Exit (success)
+		return $record;
 	}
 
 	/**
@@ -374,10 +368,15 @@ class database
 	 *
 	 * @return array|null Readed records
 	 */
-	public function read(?callable $filter = null, ?callable $update = null, bool $delete = false, int $amount = 1, int $offset = 0): ?array
-	{
+	public function read(
+		?callable $filter = null,
+		?callable $update = null,
+		bool $delete = false,
+		int $amount = 1,
+		int $offset = 0
+	): ?array {
 		// Opening the database file
-		$file = fopen($this->database, 'r+b');
+		$file = fopen($this->database, 'c+b');
 
 		if (flock($file, LOCK_EX)) {
 			// The file was locked
@@ -408,6 +407,9 @@ class database
 						// Reading the binary value from the database
 						$binaries[] = fread($file, $column->type->size());
 					}
+
+					// Terminate loop when end of file is reached
+					/* if (feof($file)) break 2; */
 				}
 
 				// Terminate loop when end of file is reached
@@ -417,52 +419,60 @@ class database
 					// Unpacking the record
 					$record = $this->unpack($binaries);
 
-					if (is_null($filter) || $filter($record, $records)) {
-						// Passed the filter
+					if ((bool) array_filter($record->values())) {
+						// The record contains at least one non-empty value
 
-						if ($offset-- <= 0) {
-							// Offsetted
+						if (is_null($filter) || $filter($record, $records)) {
+							// Passed the filter
 
-							if ($delete) {
-								// Requested deleting
+							if ($offset-- <= 0) {
+								// Offsetted
 
-								// Moving to the beginning of the row
-								fseek($file, -$this->length, SEEK_CUR);
+								if ($delete) {
+									// Requested deleting
 
-								// Writing NUL-characters instead of the record to the database file
-								fwrite($file, str_repeat("\0", $this->length));
+									// Moving to the beginning of the row
+									fseek($file, -$this->length, SEEK_CUR);
 
-								// Moving to the end of the row
-								fseek($file, $this->length, SEEK_CUR);
-							} else if ($update) {
-								// Requested updating
+									// Writing NUL-characters instead of the record to the database file
+									fwrite($file, str_repeat("\0", $this->length));
 
-								// Updating the record
-								$update($record);
+									// Moving to the end of the row
+									fseek($file, $this->length, SEEK_CUR);
+								} else if ($update) {
+									// Requested updating
 
-								// Packing the updated record
-								$packed = $this->pack($record);
+									// Updating the record
+									$update($record);
 
-								// Moving to the beginning of the row
-								fseek($file, -$this->length, SEEK_CUR);
+									// Packing the updated record
+									$packed = $this->pack($record);
 
-								// Writing to the database file
-								fwrite($file, $packed);
+									// Moving to the beginning of the row
+									fseek($file, -$this->length, SEEK_CUR);
 
-								// Moving to the end of the row
-								fseek($file, $this->length, SEEK_CUR);
+									// Writing to the database file
+									fwrite($file, $packed);
+
+									// Moving to the end of the row
+									fseek($file, $this->length, SEEK_CUR);
+								}
+
+								// Writing into the buffer of records
+								$records[] = $record;
+
+								// Decreasing the amount iterator
+								--$amount;
 							}
-
-							// Writing into the buffer of records
-							$records[] = $record;
-
-							// Decreasing the amount iterator
-							--$amount;
 						}
+					} else {
+						// The record contains only empty values
 					}
-				} catch (exception_logic | exception_invalid_argument $exception) {
+				} catch (exception_logic | exception_invalid_argument | exception_domain $exception) {
 					// Writing into the buffer of failed to reading records
-					/* $failed[] = $record; */
+
+					// Exit (fail)
+					throw new exception_runtime('Failed to processing the record', previous: $exception);
 				}
 			}
 
@@ -480,6 +490,16 @@ class database
 		return null;
 	}
 
+	/**
+	 * Count
+	 *
+	 * @return int Amount of records
+	 */
+	public function count(): int{
+		// Exit (success)
+		return $this->length > 0 && file_exists($this->database) ? filesize($this->database) / $this->length : 0;
+	}
+
 	/**
 	 * Backups
 	 *

mirzaev/baza/system/enumerations/type.php

@@ -45,8 +45,8 @@ enum type: string
 	{
 		// Exit (success)
 		return match ($this) {
-			type::char, type::string, type::short => 'string',
-			type::char_unsigned, type::short_unsigned, type::integer, type::integer_unsigned, type::long, type::long_unsigned, type::long_long, type::long_long_unsigned => 'integer',
+			type::string, type::short => 'string',
+			type::char, type::char_unsigned, type::short_unsigned, type::integer, type::integer_unsigned, type::long, type::long_unsigned, type::long_long, type::long_long_unsigned => 'integer',
 			type::float, type::double => 'double',
 			type::null => 'NULL',
 			default => throw new exception_unexpected_value('Not found the type')

mirzaev/baza/system/record.php

@@ -4,6 +4,9 @@ declare(strict_types=1);
 
 namespace mirzaev\baza;
 
+// Built-in libraries
+use DomainException as exception_domain;
+
 /**
  * Record
  *
@@ -63,12 +66,23 @@ class record
 	 * @param string $name Name of the parameter
 	 * @param mixed $value Content of the parameter
 	 *
+	 * @throws exception_domain if not found the parameter
+	 *
 	 * @return void
 	 */
 	public function __set(string $name, mixed $value = null): void
 	{
-		// Writing the value and exit
-		$this->values[$name] = $value;
+		if (isset($this->values[$name])) {
+			// Initialized the parameter
+
+			// Writing the value and exit
+			$this->values[$name] = $value;
+		} else {
+			// Not initialized the parameter
+
+			// Exit (fail)
+			throw new exception_domain("Not found the parameter: $name"); 
+		}
 	}
 
 	/**

mirzaev/baza/tests/.gitignore

@@ -1 +1 @@
-temporary
+temporary/*

mirzaev/baza/tests/record.php

@@ -1,16 +1,38 @@
 <?php
 
+declare(strict_types=1);
+
 use mirzaev\baza\database,
 	mirzaev\baza\record,
 	mirzaev\baza\column,
 	mirzaev\baza\enumerations\encoding,
 	mirzaev\baza\enumerations\type;
 
+// Initializing path to the composer loader file (main project)
+$autoload = 
+	__DIR__ . DIRECTORY_SEPARATOR . 
+	'..' . DIRECTORY_SEPARATOR . 
+	'..' . DIRECTORY_SEPARATOR . 
+	'..' . DIRECTORY_SEPARATOR . 
+	'vendor' . DIRECTORY_SEPARATOR . 
+	'autoload.php';
+
+// Reinitializing path to the composer loaded file (depencendy project)
+if (!file_exists($autoload)) 
+	$autoload = 
+		__DIR__ . DIRECTORY_SEPARATOR . 
+		'..' . DIRECTORY_SEPARATOR . 
+		'..' . DIRECTORY_SEPARATOR . 
+		'..' . DIRECTORY_SEPARATOR . 
+		'..' . DIRECTORY_SEPARATOR . 
+		'..' . DIRECTORY_SEPARATOR . 
+		'autoload.php';
+
 // Importing files of thr project and dependencies
-require(__DIR__ . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'vendor' . DIRECTORY_SEPARATOR . 'autoload.php');
+require($autoload);
 
 // Initializing path to the database file
-$file = __DIR__ . DIRECTORY_SEPARATOR . 'temporary' . DIRECTORY_SEPARATOR . 'database.ba';
+$file = __DIR__ . DIRECTORY_SEPARATOR . 'temporary' . DIRECTORY_SEPARATOR . 'database.baza';
 
 echo "Started testing\n\n\n";
 
@@ -37,9 +59,10 @@ $database = (new database())
 		new column('name', type::string, ['length' => 32]),
 		new column('second_name', type::string, ['length' => 64]),
 		new column('age', type::integer),
-		new column('height', type::float)
+		new column('height', type::float),
+		new column('active', type::char)
 	)
-	->connect(__DIR__ . DIRECTORY_SEPARATOR . 'temporary' . DIRECTORY_SEPARATOR . 'database.ba');
+	->connect($file);
 
 echo '[' . ++$action . "] Initialized the database\n";
 
@@ -48,7 +71,8 @@ $record = $database->record(
 	'Arsen',
 	'Mirzaev',
 	24,
-	165.5
+	165.5,
+	1
 );
 
 echo '[' . ++$action . "] Initialized the record\n";
@@ -60,6 +84,7 @@ echo '[' . ++$action . '][' . ++$test . '][' . ($record->name === 'Arsen' ? 'SUC
 echo '[' . $action . '][' . ++$test . '][' . ($record->second_name === 'Mirzaev' ? 'SUCCESS' : 'FAIL') . "][\"second_name\"] Expected: \"Mirzaev\" (string). Actual: \"$record->second_name\" (" . gettype($record->second_name) . ")\n";
 echo '[' . $action . '][' . ++$test . '][' . ($record->age === 24 ? 'SUCCESS' : 'FAIL') . "][\"age\"] Expected: \"24\" (integer). Actual: \"$record->age\" (" . gettype($record->age) . ")\n";
 echo '[' . $action . '][' . ++$test . '][' . ($record->height === 165.5 ? 'SUCCESS' : 'FAIL') . "][\"height\"] Expected: \"165.5\" (double). Actual: \"$record->height\" (" . gettype($record->height) . ")\n";
+echo '[' . $action . '][' . ++$test . '][' . ($record->active === 1 ? 'SUCCESS' : 'FAIL') . "][\"active\"] Expected: \"1\" (integer). Actual: \"$record->active\" (" . gettype($record->active) . ")\n";
 
 echo '[' . $action . "] The record parameters checks have been completed\n";
 
@@ -77,6 +102,7 @@ $record_ivan = $database->record(
 	'Ivanov',
 	24,
 	(float) 210,
+	0
 );
 
 echo '[' . ++$action . "] Initialized the record\n";
@@ -92,6 +118,7 @@ $record_ivan = $database->record(
 	'Esenina',
 	19,
 	(float) 165,
+	1
 );
 
 echo '[' . ++$action . "] Initialized the record\n";