MySql multi insert for ZF2

gistfile1.php

/**
 * Insert many rows as one query
 * @param array $data Insert array(array('field_name' => 'field_value'), array('field_name' => 'field_value_new'))
 * @return bool
 */
public function multiInsert(array $data)
{
    $sqlStringTemplate = 'INSERT INTO %s (%s) VALUES %s';
    $adapter = $this->tableGateway->adapter; /* Get adapter from tableGateway */
    $driver = $adapter->getDriver();
    $platform = $adapter->getPlatform();

    $tableName = $platform->quoteIdentifier('table_name');
    $parameterContainer = new ParameterContainer();
    $statementContainer = $adapter->createStatement();
    $statementContainer->setParameterContainer($parameterContainer);

    /* Preparation insert data */
    $insertQuotedValue = [];
    $insertQuotedColumns = [];
    $i = 0;
    foreach ($data as $insertData) {
        $fieldName = 'field' . ++$i . '_';
        $oneValueData = [];
        $insertQuotedColumns = [];
        foreach ($insertData as $column => $value) {
            $oneValueData[] = $driver->formatParameterName($fieldName . $column);
            $insertQuotedColumns[] = $platform->quoteIdentifier($column);
            $parameterContainer->offsetSet($fieldName . $column, $value);
        }
        $insertQuotedValue[] = '(' . implode(',', $oneValueData) . ')';
    }

    /* Preparation sql query */
    $query = sprintf(
        $sqlStringTemplate,
        $tableName,
        implode(',', $insertQuotedColumns),
        implode(',', array_values($insertQuotedValue))
    );

    $statementContainer->setSql($query);
    return $statementContainer->execute();
}

dear newage,

your function helped me a lot. Do you have the same for multiple update?
your other function (inserOrUpdate) only works for one row.

Thanks a lot! :))))

edit:

I have combined your multiInsert and insertOrUpdate function and it works like a charm.
Thanks a lot! :)

/**
* Insert or update many rows as one query
* @param array $data Insert array(array('field_name' => 'field_value'), array('field_name' => 'field_value_new'))
* @param array $excludedColumns For excluding update columns array('field_name1', 'field_name2')
* @return bool
*/

`public function multiInsertOrUpdate(array $data, array $excludedColumns)
{
    $sqlStringTemplate = 'INSERT INTO %s (%s) VALUES %s ON DUPLICATE KEY UPDATE %s';
    $adapter = $this->dbAdapter; /* Get adapter from tableGateway */
    $driver = $adapter->getDriver();
    $platform = $adapter->getPlatform();

    $tableName = $this->table;
    $parameterContainer = new \Zend\Db\Adapter\ParameterContainer();
    $statementContainer = $adapter->createStatement();
    $statementContainer->setParameterContainer($parameterContainer);

    /* add columns they should be updated */
    foreach ($data[0] as $column => $value) {
        if (false === array_search($column, $excludedColumns))
        {
            $updateQuotedValue[] = ($platform->quoteIdentifier($column)) . '=' . ('VALUES(' . ($platform->quoteIdentifier($column)) . ')');
        }
    }

    /* Preparation insert data */
    $insertQuotedValue = [];
    $insertQuotedColumns = [];
    $i = 0;
    foreach ($data as $insertData) {
        $fieldName = 'field' . ++$i . '_';
        $oneValueData = [];
        $insertQuotedColumns = [];
        foreach ($insertData as $column => $value) {
            $oneValueData[] = $driver->formatParameterName($fieldName . $column);
            $insertQuotedColumns[] = $platform->quoteIdentifier($column);
            $parameterContainer->offsetSet($fieldName . $column, $value);
        }
        $insertQuotedValue[] = '(' . implode(',', $oneValueData) . ')';
    }
    
    /* Preparation sql query */
    $query = sprintf(
        $sqlStringTemplate,
        $tableName,
        implode(',', $insertQuotedColumns),
        implode(',', array_values($insertQuotedValue)),
        implode(',', array_values($updateQuotedValue))
    );

    $statementContainer->setSql($query);
    return $statementContainer->execute();

}`

dear newage,

your function helped me a lot. Do you have the same for multiple update?
your other function (inserOrUpdate) only works for one row.

Thanks a lot! :))))

edit:

I have combined your multiInsert and insertOrUpdate function and it works like a charm.
Thanks a lot! :)

/**

• Insert or update many rows as one query
• @param array $data Insert array(array('field_name' => 'field_value'), array('field_name' => 'field_value_new'))
• @param array $excludedColumns For excluding update columns array('field_name1', 'field_name2')
• @return bool
  */

`public function multiInsertOrUpdate(array $data, array $excludedColumns)
{
    $sqlStringTemplate = 'INSERT INTO %s (%s) VALUES %s ON DUPLICATE KEY UPDATE %s';
    $adapter = $this->dbAdapter; /* Get adapter from tableGateway */
    $driver = $adapter->getDriver();
    $platform = $adapter->getPlatform();

    $tableName = $this->table;
    $parameterContainer = new \Zend\Db\Adapter\ParameterContainer();
    $statementContainer = $adapter->createStatement();
    $statementContainer->setParameterContainer($parameterContainer);

    /* add columns they should be updated */
    foreach ($data[0] as $column => $value) {
        if (false === array_search($column, $excludedColumns))
        {
            $updateQuotedValue[] = ($platform->quoteIdentifier($column)) . '=' . ('VALUES(' . ($platform->quoteIdentifier($column)) . ')');
        }
    }

    /* Preparation insert data */
    $insertQuotedValue = [];
    $insertQuotedColumns = [];
    $i = 0;
    foreach ($data as $insertData) {
        $fieldName = 'field' . ++$i . '_';
        $oneValueData = [];
        $insertQuotedColumns = [];
        foreach ($insertData as $column => $value) {
            $oneValueData[] = $driver->formatParameterName($fieldName . $column);
            $insertQuotedColumns[] = $platform->quoteIdentifier($column);
            $parameterContainer->offsetSet($fieldName . $column, $value);
        }
        $insertQuotedValue[] = '(' . implode(',', $oneValueData) . ')';
    }
    
    /* Preparation sql query */
    $query = sprintf(
        $sqlStringTemplate,
        $tableName,
        implode(',', $insertQuotedColumns),
        implode(',', array_values($insertQuotedValue)),
        implode(',', array_values($updateQuotedValue))
    );

    $statementContainer->setSql($query);
    return $statementContainer->execute();

}`

Thank you so much! Very useful and helpful!