Storage for ilLSPostConditions. More...

Collaboration diagram for ilLSPostConditionDB:

Public Member Functions
	__construct (\ilDBInterface $db)

	select (array $ref_ids)

	delete (array $ref_ids, \ilDBInterface $db=null)

	upsert (array $ls_post_conditions)

Data Fields
const	TABLE_NAME = 'post_conditions'

const	STD_ALWAYS_OPERATOR = 'always'

Protected Member Functions
	insert (array $ls_post_conditions, \ilDBInterface $db)

Protected Attributes
	$db

Detailed Description

Storage for ilLSPostConditions.

Author: Nils Haagen nils..nosp@m.haag.nosp@m.en@co.nosp@m.ncep.nosp@m.ts-an.nosp@m.d-tr.nosp@m.ainin.nosp@m.g.de

Definition at line 10 of file class.ilLSPostConditionDB.php.

Constructor & Destructor Documentation

◆ __construct()

ilLSPostConditionDB::__construct ( \ilDBInterface $db )

Definition at line 20 of file class.ilLSPostConditionDB.php.

    {
        $this->db = $db;
    }

References $db.

Member Function Documentation

◆ delete()

ilLSPostConditionDB::delete	(	array	$ref_ids,
		\ilDBInterface	$db = `null`
	)

Definition at line 61 of file class.ilLSPostConditionDB.php.

    {
        if (count($ref_ids) === 0) {
            return;
        }
 
        if (is_null($db)) {
            $db = $this->db;
        }
 
        $query = "DELETE FROM " . static::TABLE_NAME . PHP_EOL
            . "WHERE ref_id IN ("
            . implode(',', $ref_ids)
            . ")";
        $db->manipulate($query);
    }

References $db, and $query.

◆ insert()

ilLSPostConditionDB::insert	(	array	$ls_post_conditions,
		\ilDBInterface	$db
	)

protected

Definition at line 78 of file class.ilLSPostConditionDB.php.

    {
        foreach ($ls_post_conditions as $condition) {
            $values = array(
                "ref_id" => array("integer", $condition->getRefId()),
                "condition_operator" => array("text", $condition->getConditionOperator())
            );
            $db->insert(static::TABLE_NAME, $values);
        }
    }

References $db.

Referenced by upsert().

Here is the caller graph for this function:

◆ select()

ilLSPostConditionDB::select ( array $ref_ids )

Returns: ilLSPostCondition[]

Definition at line 28 of file class.ilLSPostConditionDB.php.

                                           : array
    {
        if (count($ref_ids) === 0) {
            return [];
        }
 
        $data = [];
        $query = "SELECT ref_id, condition_operator, value" . PHP_EOL
            . "FROM " . static::TABLE_NAME . PHP_EOL
            . "WHERE ref_id IN ("
            . implode(',', $ref_ids)
            . ")";
 
        $result = $this->db->query($query);
        while ($row = $this->db->fetchAssoc($result)) {
            $data[$row['ref_id']] = [$row['condition_operator'], (int) $row['value']];
        }
 
        $conditions = [];
        foreach ($ref_ids as $ref_id) {
            //always-condition, standard
            $op = self::STD_ALWAYS_OPERATOR;
            $value = null;
 
            //if from db: proper values
            if (array_key_exists($ref_id, $data)) {
                list($op, $value) = $data[$ref_id];
            }
            $conditions[] = new \ilLSPostCondition($ref_id, $op, $value);
        }
        return $conditions;
    }

References $data, $query, $result, and STD_ALWAYS_OPERATOR.

◆ upsert()

ilLSPostConditionDB::upsert ( array $ls_post_conditions )

Parameters

ilLSPostCondition[]

Definition at line 92 of file class.ilLSPostConditionDB.php.

    {
        if (count($ls_post_conditions) === 0) {
            return;
        }
 
        $ref_ids = array_map(
            function ($condition) {
                return (int) $condition->getRefId();
            },
            $ls_post_conditions
        );
 
        $ilAtomQuery = $this->db->buildAtomQuery();
        $ilAtomQuery->addTableLock(static::TABLE_NAME);
        $ilAtomQuery->addQueryCallable(
            function (\ilDBInterface $db) use ($ref_ids, $ls_post_conditions) {
                $this->delete($ref_ids, $db);
                $this->insert($ls_post_conditions, $db);
            }
        );
        $ilAtomQuery->run();
    }