12 Commits
Author SHA1 Message Date
bence e59d627080 Merge pull request 'feature/update-to-php81' (#29) from feature/update-to-php81 into master
soko-web/pipeline/head This commit looks good
Reviewed-on: #29
2023-09-27 22:11:05 +02:00
bence 3acca19d49 use new interface of TestCase
soko-web/pipeline/pr-master This commit looks good
2023-09-27 22:05:56 +02:00
bence 2226b88a88 adapt signature of DatabaseSessionHandler::gc to the parent class
soko-web/pipeline/pr-master There was a failure building this commit
2023-09-27 21:46:32 +02:00
bence 8e08b09ae8 generate composer.lock
soko-web/pipeline/pr-master There was a failure building this commit
2023-09-27 21:41:17 +02:00
bence a3bce1f2aa update composer packages 2023-09-27 21:38:59 +02:00
bence a84d3a3976 update to php 8.1 2023-09-27 21:35:44 +02:00
bence 7210b24aa3 Merge pull request 'log erros that were already caught' (#28) from feature/error-log into master
soko-web/pipeline/head This commit looks good
Reviewed-on: #28
2023-09-27 00:26:55 +02:00
bence 2d48f20aed log erros that were already caught
soko-web/pipeline/pr-master This commit looks good
2023-09-27 00:04:26 +02:00
bence ebe1fa2aa6 Merge pull request 'lazy create mysql connecion' (#27) from feature/lazy-create-mysql-connection into master
soko-web/pipeline/head This commit looks good
Reviewed-on: #27
2023-09-16 23:56:41 +02:00
bence bccee89c13 lazy create mysql connecion
soko-web/pipeline/pr-master This commit looks good
2023-09-16 13:18:42 +02:00
bence 8bf495c89b Merge pull request 'where should accept $relation as null' (#26) from bugfix/fix-where-closure into master
soko-web/pipeline/head This commit looks good
Reviewed-on: #26
2023-07-08 14:38:40 +02:00
bence 74cb576a2e where should accept $relation as null
soko-web/pipeline/pr-master This commit looks good
2023-07-08 14:36:22 +02:00
8 changed files with 426 additions and 608 deletions

No files matched your search

+1 -1
View File
@@ -1,4 +1,4 @@
FROM php:7.4.7-cli-buster
FROM php:8.1-cli-bookworm
RUN apt-get update && apt-get install -y unzip
RUN curl -sS https://getcomposer.org/installer | php -- --install-dir=/usr/local/bin --filename=composer
+3 -3
View File
@@ -5,12 +5,12 @@
"license": "GNU GPL 3.0",
"require": {
"vlucas/phpdotenv": "^5.5",
"symfony/console": "^5.4",
"symfony/console": "^6.3",
"phpmailer/phpmailer": "^6.8",
"cocur/slugify": "^4.3"
"cocur/slugify": "^4.5"
},
"require-dev": {
"phpunit/phpunit": "^9.6",
"phpunit/phpunit": "^10.3",
"phpstan/phpstan": "^1.10"
},
"autoload": {
Generated
+366 -568
View File
File diff suppressed because it is too large. Load diff
+44 -25
View File
@@ -7,48 +7,52 @@ use mysqli;
class Connection implements IConnection
{
private mysqli $connection;
private string $host;
private string $user;
private string $password;
private string $db;
private int $port;
private string $socket;
private ?mysqli $connection = null;
public function __construct(string $host, string $user, string $password, string $db, int $port = -1, string $socket = null)
{
if ($port < 0) {
$port = (int) ini_get('mysqli.default_port');
}
if ($socket === null) {
$socket = (string) ini_get('mysqli.default_socket');
}
mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
$this->connection = new mysqli($host, $user, $password, $db, $port, $socket);
$this->connection->set_charset('utf8mb4');
$this->host = $host;
$this->user = $user;
$this->password = $password;
$this->db = $db;
$this->port = $port < 0 ? (int) ini_get('mysqli.default_port') : $port;
$this->socket = $socket === null ? (string) ini_get('mysqli.default_socket') : $socket;
}
public function __destruct()
{
if ($this->connection === null) {
return;
}
$this->connection->close();
}
public function startTransaction(): void
{
$this->connection->autocommit(false);
$this->getConnection()->autocommit(false);
}
public function commit(): void
{
$this->connection->commit();
$this->connection->autocommit(true);
$this->getConnection()->commit();
$this->getConnection()->autocommit(true);
}
public function rollback(): void
{
$this->connection->rollback();
$this->connection->autocommit(true);
$this->getConnection()->rollback();
$this->getConnection()->autocommit(true);
}
public function query(string $query): ?IResultSet
{
$result = $this->connection->query($query);
$result = $this->getConnection()->query($query);
if ($result !== true) {
return new ResultSet($result);
@@ -59,36 +63,51 @@ class Connection implements IConnection
public function multiQuery(string $query): array
{
$this->connection->multi_query($query);
$this->getConnection()->multi_query($query);
$ret = [];
do {
if ($result = $this->connection->store_result()) {
if ($result = $this->getConnection()->store_result()) {
$ret[] = new ResultSet($result);
} else {
$ret[] = null;
}
$this->connection->more_results();
} while ($this->connection->next_result());
$this->getConnection()->more_results();
} while ($this->getConnection()->next_result());
return $ret;
}
public function prepare(string $query): IStatement
{
$stmt = $this->connection->prepare($query);
$stmt = $this->getConnection()->prepare($query);
return new Statement($stmt);
}
public function lastId(): int
{
return $this->connection->insert_id;
return $this->getConnection()->insert_id;
}
public function getAffectedRows(): int
{
return $this->connection->affected_rows;
return $this->getConnection()->affected_rows;
}
private function getConnection(): mysqli
{
if ($this->connection === null) {
$this->createConnection();
}
return $this->connection;
}
private function createConnection(): void
{
mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
$this->connection = new mysqli($this->host, $this->user, $this->password, $this->db, $this->port, $this->socket);
$this->connection->set_charset('utf8mb4');
}
}
+6 -6
View File
@@ -97,28 +97,28 @@ class Select
return $this;
}
public function where($column, string $relation = null, $value = null): Select
public function where($column, ?string $relation = null, $value = null): Select
{
$this->addWhereCondition('AND', $column, $relation, $value);
return $this;
}
public function orWhere($column, string $relation = null, $value = null): Select
public function orWhere($column, ?string $relation = null, $value = null): Select
{
$this->addWhereCondition('OR', $column, $relation, $value);
return $this;
}
public function having($column, string $relation = null, $value = null): Select
public function having($column, ?string $relation = null, $value = null): Select
{
$this->addHavingCondition('AND', $column, $relation, $value);
return $this;
}
public function orHaving($column, string $relation = null, $value = null): Select
public function orHaving($column, ?string $relation = null, $value = null): Select
{
$this->addHavingCondition('OR', $column, $relation, $value);
@@ -211,12 +211,12 @@ class Select
$this->joins[] = [$type, $table, $column1, $relation, $column2];
}
private function addWhereCondition(string $logic, $column, string $relation, $value): void
private function addWhereCondition(string $logic, $column, ?string $relation, $value): void
{
$this->conditions[self::CONDITION_WHERE][] = [$logic, $column, $relation, $value];
}
private function addHavingCondition(string $logic, $column, string $relation, $value): void
private function addHavingCondition(string $logic, $column, ?string $relation, $value): void
{
$this->conditions[self::CONDITION_HAVING][] = [$logic, $column, $relation, $value];
}
+1
View File
@@ -94,6 +94,7 @@ class HttpResponse
$response = call_user_func([$controller, $handler[1]]);
} catch (Exception $exception) {
$this->dbConnection->rollback();
error_log($exception);
$this->render500($exception);
return;
}
+2 -2
View File
@@ -86,12 +86,12 @@ class DatabaseSessionHandler implements ISessionHandler
return true;
}
public function gc($maxlifetime): bool
public function gc($maxlifetime): int|false
{
// empty on purpose
// old sessions are deleted by MaintainDatabaseCommand
return true;
return 1;
}
public function create_sid(): string
+3 -3
View File
@@ -17,7 +17,7 @@ final class GoogleOAuthTest extends TestCase
$redirectUrl = 'http://example.com/oauth';
$requestMock = $this->getMockBuilder(IRequest::class)
->setMethods(['setUrl', 'setMethod', 'setQuery', 'setHeaders', 'send'])
->onlyMethods(['setUrl', 'setMethod', 'setQuery', 'setHeaders', 'send'])
->getMock();
$googleOAuth = new GoogleOAuth($requestMock);
@@ -48,10 +48,10 @@ final class GoogleOAuthTest extends TestCase
$redirectUrl = 'http://example.com/oauth';
$requestMock = $this->getMockBuilder(IRequest::class)
->setMethods(['setUrl', 'setMethod', 'setQuery', 'setHeaders', 'send'])
->onlyMethods(['setUrl', 'setMethod', 'setQuery', 'setHeaders', 'send'])
->getMock();
$responseMock = $this->getMockBuilder(IResponse::class)
->setMethods(['getBody', 'getHeaders'])
->onlyMethods(['getBody', 'getHeaders'])
->getMock();
$googleOAuth = new GoogleOAuth($requestMock);