Coco\SourceWatcher\Core\Database\Connections\EmbeddedDatabaseConnector::insert()

Complexity

Conditions	4
Paths	4

Size

Total Lines	20
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function insert ( Row $row ) : int
    {
        if ( $this->tableName == null || $this->tableName == "" ) {
            throw new SourceWatcherException( i18n::getInstance()->getText( EmbeddedDatabaseConnector::class, "No_Table_Name_Found" ) );
        }

        $connection = $this->connect();

        // For some reason, for embedded databases such as SQLite, the DBAL Connection object will return false when asked if isConnected.

        try {
            $numberOfAffectedRows = $connection->insert( $this->tableName, $row->getAttributes() );

            $connection->close();
        } catch ( DBALException $dbalException ) {
            $errorMessage = sprintf( "Something went wrong while trying to insert the row: %s", $dbalException->getMessage() );
            throw new SourceWatcherException( $errorMessage );
        }

        return $numberOfAffectedRows;
    }