CodeExplorer
You are a developer and looking for Shopware projects?
Apply Now!
arguments example
/**
* {@inheritdoc}
*/
public function Dconditions() {
return $this->query->conditions();
}
/** * {@inheritdoc} */
public function arguments() {
return $this->query->arguments();
}
/** * {@inheritdoc} */
public function where($snippet, $args = []) {
$this->query->where($snippet, $args);
return $this;
}
/** * {@inheritdoc} */
public function Dconditions() {
return $this->query->conditions();
}
/** * {@inheritdoc} */
public function arguments() {
return $this->query->arguments();
}
/** * {@inheritdoc} */
public function where($snippet, $args = []) {
$this->query->where($snippet, $args);
return $this;
}
/** * {@inheritdoc} */
protected function prepareArguments(array $arguments) {
foreach ($this->arguments() as $id => $argument) {
$argument += ['required' => TRUE];
// Check if the argument is required and, if so, has been provided. if ($argument['required']) {
if (!array_key_exists($id, $arguments)) {
// If the argument is required throw an exception. throw new \InvalidArgumentException("Argument '$id' expected by plugin '{$this->getPluginId()}' but not passed");
}
}
else {
// Optional arguments require a 'default' value. // We check this even if the argument is provided by the caller, as we
/**
* Executes the DELETE query.
*
* @return int
* The number of rows affected by the delete query.
*/
public function execute() {
$values = [];
if (count($this->condition)) {
$this->condition->compile($this->connection, $this);
$values = $this->condition->arguments();
}
$stmt = $this->connection->prepareStatement((string) $this, $this->queryOptions, TRUE);
try {
$stmt->execute($values, $this->queryOptions);
return $stmt->rowCount();
}
catch (\Exception $e) {
$this->connection->exceptionHandler()->handleExecutionException($e, $stmt, $values, $this->queryOptions);
}
}
public function execute() {
$values = [];
if (count($this->condition)) {
$this->condition->compile($this->connection, $this);
$values = $this->condition->arguments();
}
$stmt = $this->connection->prepareStatement((string) $this, $this->queryOptions, TRUE);
try {
$stmt->execute($values, $this->queryOptions);
return $stmt->rowCount();
}
catch (\Exception $e) {
$this->connection->exceptionHandler()->handleExecutionException($e, $stmt, $values, $this->queryOptions);
}
}
public function tableExists($table) {
$condition = $this->buildTableNameCondition($table);
$condition->compile($this->connection, $this);
// Normally, we would heartily discourage the use of string // concatenation for conditionals like this however, we // couldn't use \Drupal::database()->select() here because it would prefix // information_schema.tables and the query would fail. // Don't use {} around information_schema.tables table. return (bool) $this->connection->query("SELECT 1 FROM information_schema.tables WHERE " . (string) $condition, $condition->arguments())->fetchField();
}
/** * Finds all tables that are like the specified base table name. * * @param string $table_expression * A case-insensitive pattern against which table names are compared. Both * '_' and '%' are treated like wildcards in MySQL 'LIKE' expressions, where * '_' matches any single character and '%' matches an arbitrary number of * characters (including zero characters). So 'foo%bar' matches table names * like 'foobar', 'fooXBar', 'fooXBaR', or 'fooXxBar'; whereas 'foo_bar' * matches 'fooXBar' and 'fooXBaR' but not 'fooBar' or 'fooXxxBar'. * * @return array * Both the keys and the values are the matching tables. */
public function execute() {
// Expressions take priority over literal fields, so we process those first // and remove any literal fields that conflict. $fields = $this->fields;
$update_values = [];
foreach ($this->expressionFields as $field => $data) {
if (!empty($data['arguments'])) {
$update_values += $data['arguments'];
}
if ($data['expression'] instanceof SelectInterface) {
$data['expression']->compile($this->connection, $this);
$update_values += $data['expression']->arguments();
}
unset($fields[$field]);
}
// Because we filter $fields the same way here and in __toString(), the // placeholders will all match up properly. $max_placeholder = 0;
foreach ($fields as $value) {
$update_values[':db_update_placeholder_' . ($max_placeholder++)] = $value;
}
// Expressions take priority over literal fields, so we process those first // and remove any literal fields that conflict. $fields = $this->fields;
$update_values = [];
foreach ($this->expressionFields as $field => $data) {
if (!empty($data['arguments'])) {
$update_values += $data['arguments'];
}
if ($data['expression'] instanceof SelectInterface) {
$data['expression']->compile($this->connection, $this);
$update_values += $data['expression']->arguments();
}
unset($fields[$field]);
}
// Because we filter $fields the same way here and in __toString(), the // placeholders will all match up properly. $max_placeholder = 0;
foreach ($fields as $value) {
$update_values[':db_update_placeholder_' . ($max_placeholder++)] = $value;
}
/** * Retrieve a table or column comment. */
public function getComment($table, $column = NULL) {
$condition = $this->buildTableNameCondition($table);
if (isset($column)) {
$condition->condition('column_name', $column);
$condition->compile($this->connection, $this);
// Don't use {} around information_schema.columns table. return $this->connection->query("SELECT column_comment AS column_comment FROM information_schema.columns WHERE " . (string) $condition, $condition->arguments())->fetchField();
}
$condition->compile($this->connection, $this);
// Don't use {} around information_schema.tables table. $comment = $this->connection->query("SELECT table_comment AS table_comment FROM information_schema.tables WHERE " . (string) $condition, $condition->arguments())->fetchField();
// Work-around for MySQL 5.0 bug http://bugs.mysql.com/bug.php?id=11379 return preg_replace('/; InnoDB free:.*$/', '', $comment);
}
}
/** * @} End of "addtogroup schemaapi". */
/**
* {@inheritdoc}
*/
public function Dconditions() {
return $this->condition->conditions();
}
/** * {@inheritdoc} */
public function arguments() {
return $this->condition->arguments();
}
/** * {@inheritdoc} */
public function where($snippet, $args = []) {
$this->condition->where($snippet, $args);
return $this;
}
/** * {@inheritdoc} */
public function Dconditions() {
return $this->condition->conditions();
}
/** * {@inheritdoc} */
public function arguments() {
return $this->condition->arguments();
}
/** * {@inheritdoc} */
public function where($snippet, $args = []) {
$this->condition->where($snippet, $args);
return $this;
}
/** * {@inheritdoc} */
$query_placeholder->nextPlaceholder()->will(function D) use (&$counter) {
return $counter++;
});
$query_placeholder->uniqueIdentifier()->willReturn(4);
$query_placeholder = $query_placeholder->reveal();
$condition = $connection->condition('AND');
$condition->condition($field_name, 'value');
$condition->compile($connection, $query_placeholder);
$this->assertEquals($expected, $condition->__toString());
$this->assertEquals([':db_condition_placeholder_0' => 'value'], $condition->arguments());
}
/** * @covers ::compile * * @dataProvider dataProviderTestCompileWithKnownOperators * * @param string $expected * The expected generated SQL condition. * @param string $field * The field to pass into the condition() method. * @param mixed $value * The value to pass into the condition() method. * @param string $operator * The operator to pass into the condition() method. * @param mixed $expected_arguments * (optional) The expected set arguments. */
return $counter++;
});
$query_placeholder->uniqueIdentifier()->willReturn(4);
$query_placeholder = $query_placeholder->reveal();
$condition = $connection->condition('AND');
$condition->condition($field_name, 'value');
$condition->compile($connection, $query_placeholder);
$this->assertEquals($expected, $condition->__toString());
$this->assertEquals([':db_condition_placeholder_0' => 'value'], $condition->arguments());
}
/** * @covers ::compile * * @dataProvider dataProviderTestCompileWithKnownOperators * * @param string $expected * The expected generated SQL condition. * @param string $field * The field to pass into the condition() method. * @param mixed $value * The value to pass into the condition() method. * @param string $operator * The operator to pass into the condition() method. * @param mixed $expected_arguments * (optional) The expected set arguments. */
return $this->alterMetaData[$key] ?? NULL;
}
/** * {@inheritdoc} */
public function arguments() {
if (!$this->compiled()) {
return NULL;
}
$args = $this->condition->arguments() + $this->having->arguments();
foreach ($this->tables as $table) {
if ($table['arguments']) {
$args += $table['arguments'];
}
// If this table is a subquery, grab its arguments recursively. if ($table['table'] instanceof SelectInterface) {
$args += $table['table']->arguments();
}
// If the join condition is an object, grab its arguments recursively. if (!empty($table['condition']) && $table['condition'] instanceof ConditionInterface) {
}
/** * {@inheritdoc} */
public function arguments() {
if (!$this->compiled()) {
return NULL;
}
$args = $this->condition->arguments() + $this->having->arguments();
foreach ($this->tables as $table) {
if ($table['arguments']) {
$args += $table['arguments'];
}
// If this table is a subquery, grab its arguments recursively. if ($table['table'] instanceof SelectInterface) {
$args += $table['table']->arguments();
}
// If the join condition is an object, grab its arguments recursively. if (!empty($table['condition']) && $table['condition'] instanceof ConditionInterface) {
$or = $this->connection->condition('OR');
$or->condition($condition['field'], $condition['value'], $condition['operator']);
// Sadly, the Database layer doesn't allow us to build a condition // in the form ':placeholder = :placeholder2', because the 'field' // part of a condition is always escaped. // As a (cheap) workaround, we separately build a condition with no // field, and concatenate the field and the condition separately. $value_part = $this->connection->condition('AND');
$value_part->condition('anonymous_name', $condition['value'], $condition['operator']);
$value_part->compile($this->connection, $query);
$or->condition(($this->connection->condition('AND'))
->where(str_replace($query->escapeField('anonymous_name'), ':anonymous_name', (string) $value_part), $value_part->arguments() + [':anonymous_name' => \Drupal::config('user.settings')->get('anonymous')])
->condition('base_table.uid', 0)
);
$query->condition($or);
}
}
}
}
}
$or->condition($condition['field'], $condition['value'], $condition['operator']);
// Sadly, the Database layer doesn't allow us to build a condition // in the form ':placeholder = :placeholder2', because the 'field' // part of a condition is always escaped. // As a (cheap) workaround, we separately build a condition with no // field, and concatenate the field and the condition separately. $value_part = $this->connection->condition('AND');
$value_part->condition('anonymous_name', $condition['value'], $condition['operator']);
$value_part->compile($this->connection, $query);
$or->condition(($this->connection->condition('AND'))
->where(str_replace($query->escapeField('anonymous_name'), ':anonymous_name', (string) $value_part), $value_part->arguments() + [':anonymous_name' => \Drupal::config('user.settings')->get('anonymous')])
->condition('base_table.uid', 0)
);
$query->condition($or);
}
}
}
}
}
foreach ($conditions as $condition) {
// Process field. if ($condition['field'] instanceof ConditionInterface) {
// Left hand part is a structured condition or a subquery. Compile, // put brackets around it (if it is a query), and collect any // arguments. $condition['field']->compile($connection, $queryPlaceholder);
$field_fragment = (string) $condition['field'];
if ($condition['field'] instanceof SelectInterface) {
$field_fragment = '(' . $field_fragment . ')';
}
$arguments += $condition['field']->arguments();
// If the operator and value were not passed in to the // @see ConditionInterface::condition() method (and thus have the // default value as defined over there) it is assumed to be a valid // condition on its own: ignore the operator and value parts. $ignore_operator = $condition['operator'] === '=' && $condition['value'] === NULL;
}
elseif (!isset($condition['operator'])) {
// Left hand part is a literal string added with the // @see ConditionInterface::where() method. Put brackets around // the snippet and collect the arguments from the value part. // Also ignore the operator and value parts.
// Process field. if ($condition['field'] instanceof ConditionInterface) {
// Left hand part is a structured condition or a subquery. Compile, // put brackets around it (if it is a query), and collect any // arguments. $condition['field']->compile($connection, $queryPlaceholder);
$field_fragment = (string) $condition['field'];
if ($condition['field'] instanceof SelectInterface) {
$field_fragment = '(' . $field_fragment . ')';
}
$arguments += $condition['field']->arguments();
// If the operator and value were not passed in to the // @see ConditionInterface::condition() method (and thus have the // default value as defined over there) it is assumed to be a valid // condition on its own: ignore the operator and value parts. $ignore_operator = $condition['operator'] === '=' && $condition['value'] === NULL;
}
elseif (!isset($condition['operator'])) {
// Left hand part is a literal string added with the // @see ConditionInterface::where() method. Put brackets around // the snippet and collect the arguments from the value part. // Also ignore the operator and value parts.
foreach ($this->expressionFields as $field => $data) {
if (!empty($data['arguments'])) {
foreach ($data['arguments'] as $placeholder => $argument) {
// We assume that an expression will never happen on a BLOB field, // which is a fairly safe assumption to make since in most cases // it would be an invalid query anyway. $stmt->getClientStatement()->bindParam($placeholder, $data['arguments'][$placeholder]);
}
}
if ($data['expression'] instanceof SelectInterface) {
$data['expression']->compile($this->connection, $this);
$select_query_arguments = $data['expression']->arguments();
foreach ($select_query_arguments as $placeholder => $argument) {
$stmt->getClientStatement()->bindParam($placeholder, $select_query_arguments[$placeholder]);
}
}
unset($fields[$field]);
}
foreach ($fields as $field => $value) {
$placeholder = ':db_update_placeholder_' . ($max_placeholder++);
if (isset($table_information->blob_fields[$field]) && $value !== NULL) {
if (!empty($data['arguments'])) {
foreach ($data['arguments'] as $placeholder => $argument) {
// We assume that an expression will never happen on a BLOB field, // which is a fairly safe assumption to make since in most cases // it would be an invalid query anyway. $stmt->getClientStatement()->bindParam($placeholder, $data['arguments'][$placeholder]);
}
}
if ($data['expression'] instanceof SelectInterface) {
$data['expression']->compile($this->connection, $this);
$select_query_arguments = $data['expression']->arguments();
foreach ($select_query_arguments as $placeholder => $argument) {
$stmt->getClientStatement()->bindParam($placeholder, $select_query_arguments[$placeholder]);
}
}
unset($fields[$field]);
}
foreach ($fields as $field => $value) {
$placeholder = ':db_update_placeholder_' . ($max_placeholder++);
if (isset($table_information->blob_fields[$field]) && $value !== NULL) {