ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: home / niazsaze / public_html / wp-content / plugins / wp-statistics / src / Service / Database / Operations

<?php

namespace WP_Statistics\Service\Database\Operations;

/**
 * Handles the creation of database tables.
 *
 * This class defines methods to execute table creation operations,
 * including generating SQL queries and ensuring transactional integrity.
 */
class Create extends AbstractTableOperation
{
    /**
     * Execute the table creation operation.
     *
     * @return self
     * @throws \RuntimeException
     */
    public function execute()
    {
        try {
            $this->ensureConnection();
            $this->validateTableName();
            $this->validateArgs();
            $this->setFullTableName();

return $this->transactionHandler->executeInTransaction([$this, 'createTable']);
        } catch (\Exception $e) {
            throw new \RuntimeException(
                sprintf("Failed to create table `%s`: %s", $this->tableName, $e->getMessage())
            );
        }
    }

/**
     * Create table operation to be executed in transaction.
     *
     * @return self
     * @throws \RuntimeException
     */
    public function createTable()
    {
        require_once(ABSPATH . 'wp-admin/includes/upgrade.php');

$sql = $this->buildCreateTableSql();
        $result = $this->wpdb->query($sql);

if ($result === false) {
            throw new \RuntimeException(
                sprintf('Failed to create table. MySQL Error: %s', $this->wpdb->last_error)
            );
        }

return $this;
    }

/**
     * Build the CREATE TABLE SQL query.
     *
     * @return string
     */
    private function buildCreateTableSql()
    {
        $charset_collate = $this->wpdb->get_charset_collate();
        $columns = $this->args['columns'] ?? [];
        $constraints = $this->args['constraints'] ?? [];

$columnsSql = array_map(function ($columnName, $definition) {
            return sprintf("`%s` %s", $columnName, $definition);
        }, array_keys($columns), $columns);

$allDefinitions = array_merge($columnsSql, $constraints);

return sprintf(
            "CREATE TABLE IF NOT EXISTS `%s` (\n%s\n) %s;",
            $this->fullName,
            implode(",\n", $allDefinitions),
            $charset_collate
        );
    }
}

[-] Create.php [edit]
[-] Repair.php [edit]
[-] Select.php [edit]
[-] AbstractTableOperation.php [edit]
[-] Update.php [edit]
[-] Drop.php [edit]
[-] Inspect.php [edit]
[-] Insert.php [edit]
[-] InspectColumns.php [edit]
[+] ..