HughCube\Laravel\OTS\Ots

Complexity

Total Complexity

24

Size/Duplication

Total Lines	116
Duplicated Lines	0 %

Importance

Changes	2
Bugs	2	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	mustParseRowAutoId()	0	9	2
A	connection()	0	9	2
A	isBatchWriteSuccess()	0	15	6
A	parseRowAutoId()	0	9	5
A	parseRow()	0	12	3
A	throwBatchWriteException()	0	10	6

<?php
/**
 * Created by PhpStorm.
 * User: hugh.li
 * Date: 2021/6/8
 * Time: 5:47 下午.
 */

namespace HughCube\Laravel\OTS;

use Exception;
use Illuminate\Support\Facades\DB;

class Ots
{
    /**
     * @param string $name
     *
     * @throws
     *
     * @return Connection
     * @phpstan-ignore-next-line
     */
    public static function connection(string $name = 'ots'): Connection
    {
        $connection = DB::connection($name);

        if (!$connection instanceof Connection) {
            throw new Exception('Only ots connections can be obtained');
        }

        return $connection;
    }

    /**
     * @param mixed $row
     *
     * @return array
     */
    public static function parseRow($row): array
    {
        $row = array_merge(($row['primary_key'] ?? []), ($row['attribute_columns'] ?? []));

        $columns = [];
        foreach ($row as $item) {
            if (isset($item[0], $item[1])) {
                $columns[$item[0]] = $item[1];
            }
        }

        return $columns;
    }

    /**
     * @param mixed  $row
     * @param string $name
     *
     * @return int
     */
    public static function parseRowAutoId($row, string $name = 'id'): ?int
    {
        foreach (($row['primary_key'] ?? []) as $key) {
            if (isset($key[0], $key[1]) && $name === $key[0] && is_int($key[1])) {
                return $key[1];
            }
        }

        return null;
    }

    /**
     * @param mixed  $row
     * @param string $name
     *
     * @throws
     *
     * @return int
     * @phpstan-ignore-next-line
     */
    public static function mustParseRowAutoId($row, string $name = 'id'): int

The parameter $name is not used and could be removed.

    {
        $id = Ots::parseRowAutoId($row);

        if (!is_int($id)) {
            throw new Exception('Failed to obtain id.');
        }

        return $id;
    }

    /**
     * @param mixed $response
     *
     * @return bool
     */
    public static function isBatchWriteSuccess($response): bool
    {
        if (empty($response['tables']) || !is_array($response['tables'])) {
            return false;
        }

        foreach ($response['tables'] as $table) {
            foreach (($table['rows'] ?? []) as $row) {
                if (empty($row['is_ok'])) {
                    return false;
                }
            }
        }

        return true;
    }

    /**
     * @param mixed $response
     *
     * @throws Exception
     *
     * @return void
     */
    public static function throwBatchWriteException($response)
    {
        if (empty($response['tables']) || !is_array($response['tables'])) {
            throw new Exception('Abnormal operation.');
        }

        foreach ($response['tables'] as $table) {
            foreach ($table['rows'] as $row) {
                if (empty($row['is_ok'])) {
                    throw new Exception(sprintf('Failed to write the "%s" table.', $table['table_name']));
                }
            }
        }
    }
}