Как переделать из MYSQLi в PDO?

Question

[doublench21]

Как переделать этот код:

$mysqli = mysqli_connect('localhost', '***', '***', '***') or die('Error1!');
mysqli_set_charset($mysqli, 'utf8');

$sql = 'INSERT IGNORE page (url) VALUES ';
foreach ($all_articles_links as $value) {
    $sql .= "('http://minecraft.gamepedia.com" . $value . "'), ";
}
$sql = rtrim($sql, ", ");
mysqli_query($mysqli, $sql) or die('Error2!');

в соответствующий аналог на PDO ?

Answer 1

[FanatPHP]

Ты ж уже спрашивал два раза. Все никак не можешь осилить?
Тебе уже объясняли, что проблема не в названиях функций, а в подходе.

Переписывать этот мусор на ПДО нет ни малейшего смысла - выйдет то же самое.

Comments

[doublench21]

Ну так поясните верный подход. Что вы все такие "несубмиссивные" как вы где-то писали ... Вам таки сложно я понял

[FanatPHP]

Я уже не помню, в чем твои проблемы, а вопросы ты свои постирал. Пиши заново, объясняй над чем мучаешься.

[doublench21]

FanatPHP: Как верно составлять запросы на вставку или обновление сразу нескольких значений в бд используя, либо pdo, либо ооп mysqli ?

[FanatPHP]

Использовать ПОДГОТОВЛЕННЫЕ ВЫРАЖЕНИЯ - то, ради чего и pdo, и mysqli вообще создавались. Я тебе писал готовый код уже. Вместо него ты решил использовать говнокод, который по сути был старый не-ооп mysql, со всеми вытекающими проблемами. Вот я недавно писал пример вставки на пдо: toster.ru/answer?answer_id=442853 но боюсь, тебе не поможет - ты что-то глобально кривое делаешь

[doublench21]

FanatPHP: А если такс ?

$pdo = new PDO("mysql:host=localhost;dbname=***", '***', '***');
$pdo->query('SET NAMES utf8');
$query = $pdo->prepare("INSERT IGNORE page (url) VALUES (?)");
foreach ($all_articles_links as $value) {
    $query->execute([$value]);
}

[FanatPHP]

Этот код не аналогичен твоему. В твоем ты соединяешь $value с доменом. Но само по себе это будет работать. Если решит твою исходную задачу - хорошо. Если не решит - пиши, будем решать её.

[doublench21]

FanatPHP: Вроде заполнил всё верно.

$pdo = new PDO("mysql:host=localhost;dbname=***", '***', '***');
$pdo->query('SET NAMES utf8');
$query = $pdo->prepare("INSERT IGNORE page (url) VALUES (?)");
foreach ($all_articles_links as $value) {
    $query->execute(['http://minecraft.gamepedia.com' . $value]);
}
$pdo = null;

Всё ли правильно сделано ? И почему так сильно упала скорость работы скрипта ? Очень уж долго пишет в БД.

[FanatPHP]

правильно. Чтобы работало быстро, перед prepare напиши $pdo->beginTransaction(); а после цикла - $pdo->commit();

[doublench21]

FanatPHP: Вышло. Поясните зачем и что это даёт ?

[FanatPHP]

Долго объяснять. Коротко - причина в innodb, мой вариант самый простой. Можно гуглить innodb_flush_log_at_trx_commit если хочется подробностей.

[doublench21]

FanatPHP: То есть каждую множественную операцию я должен оборачивать в то, что вы подсказали ?

[FanatPHP]

Да, если тип таблицы - innodb. Если если функционал innodb не нужен, то можно сделать myisam и тогда задержек не будет

[doublench21]

FanatPHP: Ну кажись легче при создании таблицы указать myisam. До функционала innodb, как до луны. Вам огромное спасибо. До скорых встреч.

[doublench21]

FanatPHP: Сменил тип на MyISAM, убрал обертку. Скорость упала на нет. Хмм ?

[FanatPHP]

doublench21: значит тип таблицы не поменялся. на myisam должна быть скорость в десятки тысяч инсертов в секунду, а на innodb меньше тысячи

[doublench21]

FanatPHP: Можно к вам обратиться по поводу PDO ?

[FanatPHP]

doublench21: можно

[doublench21]

FanatPHP: Я в цикле получаю по одной строке из бд. И хочу его завершить, когда дойду до последней. Делаю это так:
$query = $pdo->prepare("SELECT COUNT(*) FROM page ORDER BY id LIMIT ?, 1");
$query->execute([$count]);
if (!($query->fetchColumn())) {
break;
}
Но этот запрос в PhpMyAdmin возвращает 941 на скажем SELECT COUNT(*) FROM page ORDER BY id LIMIT 0, 1

[FanatPHP]

полчай их не по одной, а все разом

Answer 2

[Евгений]

<?php
$db = new PDO('mysql:host=localhost;dbname=test', 'root', 'root', [PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"]);  

$stmt = $db->prepare("INSERT IGNORE INTO page (url) VALUES (?)");
$stmt->bindParam(1, $url);

$links = [
	'url1',
	'url2',
	'url3',
];
foreach ($links as $link) {
	$url = "$link/add";
	$stmt->execute();
}

Мне почему-то кажется, что эту проблему вообще можно на чистом sql решить.

Comments

[FanatPHP]

если заглянуть в комментарии под сосеним ответом, то можно увидеть, что аффтар осилил-таки этот сложный код самостоятельно :)

[Евгений]

FanatPHP: какой он молодец :)