prepare example

$post_type        = $this->screen->post_type;
        $post_type_object = get_post_type_object( $post_type );

        $exclude_states = get_post_stati(
            array(
                'show_in_admin_all_list' => false,
            )
        );

        $this->user_posts_count = (int) $wpdb->get_var(
            $wpdb->prepare(
                "SELECT COUNT( 1 ) FROM $wpdb->posts WHERE post_type = %s AND post_status NOT IN ( '" . implode( "','", $exclude_states ) . "' ) AND post_author = %d",
                $post_type,
                get_current_user_id()
            )
        );

        if ( $this->user_posts_count
            

    private function updateLanguage(array $ids, Context $context, array $all): void
    {
        $versionId = Uuid::fromHexToBytes($context->getVersionId());
        $languageId = Uuid::fromHexToBytes($context->getLanguageId());

        /** @var CategoryCollection $categories */
        $categories = $this->categoryRepository
            ->search(new Criteria($all), $context)
            ->getEntities();

        $update = $this->connection->prepare(' INSERT INTO `category_translation` (`category_id`, `category_version_id`, `language_id`, `breadcrumb`, `created_at`) VALUES (:categoryId, :versionId, :languageId, :breadcrumb, DATE(NOW())) ON DUPLICATE KEY UPDATE `breadcrumb` = :breadcrumb ');
        $update = new RetryableQuery($this->connection, $update);

        foreach ($ids as $id) {
            try {
                $path = $this->buildBreadcrumb($id, $categories);
            } catch (CategoryNotFoundException) {
                continue;
            }

    public function executeInserts()
    {
        if (! $this->queuedInserts) {
            return [];
        }

        $postInsertIds  = [];
        $idGenerator    = $this->class->idGenerator;
        $isPostInsertId = $idGenerator->isPostInsertGenerator();

        $stmt      = $this->conn->prepare($this->getInsertSQL());
        $tableName = $this->class->getTableName();

        foreach ($this->queuedInserts as $entity) {
            $insertData = $this->prepareInsertData($entity);

            if (isset($insertData[$tableName])) {
                $paramIndex = 1;

                foreach ($insertData[$tableName] as $column => $value) {
                    $stmt->bindValue($paramIndex++, $value, $this->columnTypes[$column]);
                }
            }

function get_blog_list( $start = 0, $num = 10, $deprecated = '' ) {
    _deprecated_function( __FUNCTION__, '3.0.0', 'wp_get_sites()' );

    global $wpdb;
    $blogs = $wpdb->get_results( $wpdb->prepare( "SELECT blog_id, domain, path FROM $wpdb->blogs WHERE site_id = %d AND public = '1' AND archived = '0' AND mature = '0' AND spam = '0' AND deleted = '0' ORDER BY registered DESC", get_current_network_id() ), ARRAY_A );

    $blog_list = array();
    foreach ( (array) $blogs as $details ) {
        $blog_list[ $details['blog_id'] ] = $details;
        $blog_list[ $details['blog_id'] ]['postcount'] = $wpdb->get_var( "SELECT COUNT(ID) FROM " . $wpdb->get_blog_prefix( $details['blog_id'] ). "posts WHERE post_status='publish' AND post_type='post'" );
    }

    if ( ! $blog_list ) {
        return array();
    }

    

use Shopware\Components\Migrations\AbstractMigration;

class Migrations_Migration1718 extends AbstractMigration
{
    public function up($modus)
    {
        $statement = $this->connection->prepare(
            'UPDATE s_core_config_elements SET options = :option WHERE name = "argon2MemoryCost"'
        );
        $statement->execute([
            'option' => serialize(['minValue' => (string) (1 << 10), 'maxValue' => (string) (1 << 62)]),
        ]);
    }
}

  protected function setUp(): void {
    parent::setUp();
    $this->loadFixture($this->getModulePath('tracker') . '/tests/fixtures/drupal7.php');
  }

  /** * Tests the review page. */
  public function testMigrateUpgradeReviewPage() {
    $this->prepare();
    // Start the upgrade process.     $this->submitCredentialForm();

    $session = $this->assertSession();
    $this->submitForm([], 'I acknowledge I may lose data. Continue anyway.');
    $session->statusCodeEquals(200);

    // Confirm that Tracker will be upgraded.     $session->elementExists('xpath', "//td[contains(@class, 'checked') and text() = 'Tracker']");
    $session->elementNotExists('xpath', "//td[contains(@class, 'error') and text() = 'Tracker']");
  }

  

public function store()
    {
        $sql = <<<'sql' INSERT INTO s_core_config_values (element_id, shop_id, value) VALUES ( (SELECT id FROM s_core_config_elements WHERE name LIKE 'trackingUniqueId' LIMIT 1), 1, :value ) ON DUPLICATE KEY UPDATE value=:value sql;

        $serializedUniqueId = serialize($this->uniqueIdGenerator->getUniqueId());

        $statement = $this->connection->prepare($sql);
        $statement->bindParam('value', $serializedUniqueId);
        $statement->execute();
    }
}

$this->pdoStatement
      ->setFetchMode(Argument::any())
      ->shouldBeCalled()
      ->willReturn(TRUE);

    $this->pdoStatement
      ->execute(Argument::any())
      ->shouldBeCalled()
      ->willReturn(TRUE);

    $this->pdoConnection
      ->prepare('SELECT VERSION()', Argument::any())
      ->shouldBeCalled()
      ->willReturn($this->pdoStatement->reveal());

    /** @var \PDO $pdo_connection */
    $pdo_connection = $this->pdoConnection->reveal();

    return new class($pdo_connection) extends Connection {

      public function __construct(\PDO $connection) {
        $this->connection = $connection;
        $this->setPrefix('');
      }

#[Package('core')] class Migration1595492054SeoUrlTemplateData extends MigrationStep
{
    public function getCreationTimestamp(): int
    {
        return 1595492054;
    }

    public function update(Connection $connection): void
    {
        $stmt = $connection->prepare('SELECT count(`id`) FROM seo_url_template WHERE `entity_name` = ? AND `route_name` = ?');
        $result = $stmt->executeQuery([
            'product',
            ProductPageSeoUrlRoute::ROUTE_NAME,
        ]);

        if ((int) $result->fetchOne() === 0) {
            $connection->insert('seo_url_template', [
                'id' => Uuid::randomBytes(),
                'sales_channel_id' => null,
                'route_name' => ProductPageSeoUrlRoute::ROUTE_NAME,
                'entity_name' => 'product',
                

public function get_imported_posts( $importer_name, $blog_id ) {
        global $wpdb;

        $hashtable = array();

        $limit  = 100;
        $offset = 0;

        // Grab all posts in chunks.         do {
            $meta_key = $importer_name . '_' . $blog_id . '_permalink';
            $sql      = $wpdb->prepare( "SELECT post_id, meta_value FROM $wpdb->postmeta WHERE meta_key = %s LIMIT %d,%d", $meta_key, $offset, $limit );
            $results  = $wpdb->get_results( $sql );

            // Increment offset.             $offset = ( $limit + $offset );

            if ( ! empty( $results ) ) {
                foreach ( $results as $r ) {
                    // Set permalinks into array.                     $hashtable[ $r->meta_value ] = (int) $r->post_id;
                }
            }
        }

  protected function getStatement(string $query, ?array &$args = []): object {
    return $this->connection->prepare($query, $this->driverOptions);
  }

  /** * {@inheritdoc} */
  public function getQueryString() {
    return $this->queryString;
  }

  /** * {@inheritdoc} */

public static function get_instance( $id ) {
        global $wpdb;

        $comment_id = (int) $id;
        if ( ! $comment_id ) {
            return false;
        }

        $_comment = wp_cache_get( $comment_id, 'comment' );

        if ( ! $_comment ) {
            $_comment = $wpdb->get_row( $wpdb->prepare( "SELECT * FROM $wpdb->comments WHERE comment_ID = %d LIMIT 1", $comment_id ) );

            if ( ! $_comment ) {
                return false;
            }

            wp_cache_add( $_comment->comment_ID, $_comment, 'comment' );
        }

        return new WP_Comment( $_comment );
    }

    

class Migrations_Migration142 extends Shopware\Components\Migrations\AbstractMigration
{
    public function up($modus)
    {
        $statement = $this->getConnection()->prepare("SELECT id FROM s_core_config_elements WHERE name = 'useShortDescriptionInListing'");
        $statement->execute();
        $data = $statement->fetchAll();

        if (empty($data)) {
            $sql = <<<'EOD' SET @parentId = (SELECT id FROM s_core_config_forms WHERE name = 'Other' LIMIT 1); INSERT IGNORE INTO `s_core_config_forms` (`id`, `parent_id`, `name`, `label`, `description`, `position`, `scope`, `plugin_id`) VALUES (NULL, @parentId, 'LegacyOptions', 'Abwärtskompatibilität', NULL, '0', '0', NULL); SET @formId = (SELECT id FROM s_core_config_forms WHERE name = 'LegacyOptions' LIMIT 1); INSERT IGNORE INTO `s_core_config_form_translations` (`id`, `form_id`, `locale_id`, `label`, `description`) VALUES (NULL, @formId, '2', 'Legacy options', NULL); INSERT IGNORE INTO `s_core_config_elements` (`id`, `form_id`, `name`, `value`, `label`, `description`, `type`, `required`, `position`, `scope`, `filters`, `validators`) VALUES (NULL, @formId, 'useShortDescriptionInListing', 'b:1;', 'In Listen-Ansichten immer die Artikel-Kurzbeschreibung anzeigen', 'Beeinflusst: Topseller, Kategorielisten, Einkaufswelten', 'checkbox', '0', '0', '0', NULL, NULL); SET @elementId = (SELECT id FROM s_core_config_elements WHERE name = 'useShortDescriptionInListing' LIMIT 1); INSERT IGNORE INTO `s_core_config_element_translations` (`id`, `element_id`, `locale_id`, `label`, `description`) VALUES (NULL, @elementId, '2', 'Always display item descriptions in listing views', 'Affected views: Top seller, category listings, emotions');

$delete_limit = apply_filters( 'akismet_delete_comment_limit', defined( 'AKISMET_DELETE_LIMIT' ) ? AKISMET_DELETE_LIMIT : 10000 );
        $delete_limit = max( 1, intval( $delete_limit ) );

        /** * Determines how many days a comment will be left in the Spam queue before being deleted. * * @param int The default number of days. */
        $delete_interval = apply_filters( 'akismet_delete_comment_interval', 15 );
        $delete_interval = max( 1, intval( $delete_interval ) );

        while ( $comment_ids = $wpdb->get_col( $wpdb->prepare( "SELECT comment_id FROM {$wpdb->comments} WHERE DATE_SUB(NOW(), INTERVAL %d DAY) > comment_date_gmt AND comment_approved = 'spam' LIMIT %d", $delete_interval, $delete_limit ) ) ) {
            if ( empty( $comment_ids ) )
                return;

            $wpdb->queries = array();

            $comments = array();

            foreach ( $comment_ids as $comment_id ) {
                $comments[ $comment_id ] = get_comment( $comment_id );

                do_action( 'delete_comment', $comment_id, $comments[ $comment_id ] );
                

    /** * @depends testIndexing */
    public function testCalculatorBackwardsCompatibility(IdsCollection $ids): void
    {
        $connection = KernelLifecycleManager::getKernel()
            ->getContainer()
            ->get(Connection::class);

        $cheapestPriceQuery = $connection->prepare('UPDATE product SET cheapest_price = :price WHERE id = :id AND version_id = :version');

        /** @var string $prices */
        $prices = file_get_contents(__DIR__ . '/_fixtures/serialized_prices.json');
        foreach ($ids->all() as $key => $id) {
            $prices = str_replace(sprintf('__id_placeholder_%s__', $key), $id, $prices);
        }
        foreach (\json_decode($prices, true, 512, \JSON_THROW_ON_ERROR) as $productName => $serializedPrice) {
            $cheapestPriceQuery->executeStatement([
                'price' => $serializedPrice,
                'id' => $ids->getBytes($productName),
                'version' => Uuid::fromHexToBytes(Defaults::LIVE_VERSION),
            ]);