<?php
namespace queasy\db\query;
use queasy\db\DbException;
class BatchNamedInsertQuery extends TableQuery
{
/**
* Execute multiple rows INSERT query using key-value arrays or objects.
*
* @param array $params Query parameters (array of key-value arrays or objects)
*
* @return int Number of inserted records
*
* @throws DbException On error
*/
public function run(array $params = array(), array $options = array())
{
if (!count($params)) {
throw new DbException('Query parameters are empty.');
}
$columnNames = array_keys($params[0]);
$columnsString = '`' . implode('`, `', $columnNames) . '`';
$paramsString = '';
$values = array();
$counter = 0;
foreach ($params as $row) {
$rowParams = array();
$columnIndex = 0;
foreach ($row as $value) {
$rowParams[] = $paramName = ':' . $columnNames[$columnIndex] . $counter;
$values[$paramName] = $value;
$columnIndex++;
}
$paramsString .= '(' . implode(', ', $rowParams) . '), ';
$counter++;
}
$paramsString = rtrim($paramsString, ', ');
$sql = sprintf('
INSERT INTO `%s` (%s)
VALUES %s',
$this->tableName(),
$columnsString,
$paramsString
);
$this->setSql($sql);
return parent::run($values, $options);
}
}
|
Download
