albertlast / SMF2.1

 * @param bool $disable_trans Whether to disable transactions

 * @param resource $connection The connection to use (if null, $db_connection is used)

 */

function smf_db_insert($method = 'replace', $table, $columns, $data, $keys, $disable_trans = false, $connection = null)

{

	global $smcFunc, $db_connection, $db_prefix;

	$connection = $connection === null ? $db_connection : $connection;

	// With nothing to insert, simply return.

	if (empty($data))

		return;

	// Replace the prefix holder with the actual prefix.

	$table = str_replace('{db_prefix}', $db_prefix, $table);

	// Inserting data as a single row can be done as a single array.

	if (!is_array($data[array_rand($data)]))

		$data = array($data);

	// Create the mold for a single row insert.

	$insertData = '(';

	foreach ($columns as $columnName => $type)

	{

		// Are we restricting the length?

		if (strpos($type, 'string-') !== false)

			$insertData .= sprintf('SUBSTRING({string:%1$s}, 1, ' . substr($type, 7) . '), ', $columnName);

		else

			$insertData .= sprintf('{%1$s:%2$s}, ', $type, $columnName);

	}

	$insertData = substr($insertData, 0, -2) . ')';

	// Create an array consisting of only the columns.

	$indexed_columns = array_keys($columns);

	// Here's where the variables are injected to the query.

	$insertRows = array();

	foreach ($data as $dataRow)

		$insertRows[] = smf_db_quote($insertData, array_combine($indexed_columns, $dataRow), $connection);

	// Determine the method of insertion.

	$queryTitle = $method == 'replace' ? 'REPLACE' : ($method == 'ignore' ? 'INSERT IGNORE' : 'INSERT');

	// Do the insert.

	$smcFunc['db_query']('', '

		' . $queryTitle . ' INTO ' . $table . '(`' . implode('`, `', $indexed_columns) . '`)

		VALUES

			' . implode(',

			', $insertRows),

		array(

			'security_override' => true,

			'db_error_skip' => $table === $db_prefix . 'log_errors',

		),

		$connection

	);

}

/**

 * This function tries to work out additional error information from a back trace.

 * @param bool $disable_trans Whether to disable transactions

 * @param object $connection The connection to use (if null, $db_connection is used)

 */

function smf_db_insert($method = 'replace', $table, $columns, $data, $keys, $disable_trans = false, $connection = null)

{

	global $smcFunc, $db_connection, $db_prefix;

	$connection = $connection === null ? $db_connection : $connection;

	// With nothing to insert, simply return.

	if (empty($data))

		return;

	// Replace the prefix holder with the actual prefix.

	$table = str_replace('{db_prefix}', $db_prefix, $table);

	// Inserting data as a single row can be done as a single array.

	if (!is_array($data[array_rand($data)]))

		$data = array($data);

	// Create the mold for a single row insert.

	$insertData = '(';

	foreach ($columns as $columnName => $type)

	{

		// Are we restricting the length?

		if (strpos($type, 'string-') !== false)

			$insertData .= sprintf('SUBSTRING({string:%1$s}, 1, ' . substr($type, 7) . '), ', $columnName);

		else

			$insertData .= sprintf('{%1$s:%2$s}, ', $type, $columnName);

	}

	$insertData = substr($insertData, 0, -2) . ')';

	// Create an array consisting of only the columns.

	$indexed_columns = array_keys($columns);

	// Here's where the variables are injected to the query.

	$insertRows = array();

	foreach ($data as $dataRow)

		$insertRows[] = smf_db_quote($insertData, array_combine($indexed_columns, $dataRow), $connection);

	// Determine the method of insertion.

	$queryTitle = $method == 'replace' ? 'REPLACE' : ($method == 'ignore' ? 'INSERT IGNORE' : 'INSERT');

	// Do the insert.

	$smcFunc['db_query']('', '

		' . $queryTitle . ' INTO ' . $table . '(`' . implode('`, `', $indexed_columns) . '`)

		VALUES

			' . implode(',

			', $insertRows),

		array(

			'security_override' => true,

			'db_error_skip' => $table === $db_prefix . 'log_errors',

		),

		$connection

	);

}

/**

 * This function tries to work out additional error information from a back trace.