Php oracle insert vs update?

Question

[Sanya899]

Спасибо пользователю Kerm который мне помог поправить этот код все работает. Но теперь возник вопрос как сделать проверку на добавление записи, если существует то делать ничего не нужно , а вот если нету то добавить или обновить недостающие записи. Как правильно реализовать такой функционал ?
Смотрю в сторону merge, но не знаю как его реализовать. Прошу меня простить за создание нового вопроса т к предыдущий мой вопрос утонул.

<blockquote>require_once "simple_html_dom.php";

error_reporting(E_ALL);
ini_set('display_errors', '1');
$conn = oci_connect('ddd', 'ddd', '127.0.0.1/orcl', 'AL32UTF8');


$brands = array();

$html = str_get_html(file_get_contents('https://kolesa.kz/cars/'));
$i = 'INSERT ALL';
$select = $html->find('select[id=auto-car-mm-0]', 0);

foreach($select->find('option') as $opt)
{
  if($opt->value == '') continue;
  $i .= ' INTO kolesa_brands (id, name) VALUES('.$opt->value.', \''.$opt->plaintext.'\')';
  $brands[$opt->value] = $opt->plaintext; 
}

$insert = oci_parse($conn, $i.' SELECT * FROM dual;');

oci_execute($insert);</blockquote>

Comments

[Дмитрий]

https://stackoverflow.com/questions/1702832/insert...

Answer 1

[idShura]

Можно еще такой вариант попробовать

BEGIN   
   UPDATE kolesa_brands SET name = 'name' WHERE id = <id>;   
   
   IF SQL%NOTFOUND THEN   
      INSERT INTO kolesa_brands (id, name) VALUES (<id>, '<name>'); 
   END IF;   
END;

upd/
или вариант с merge (Вместо <id>, <name> нужно подставить значения $opt->value и $opt->plaintext). Так как для merge нужно две таблицы можно попробовать использовать виртуальную таблицу dual

merge into kolesa_brands t
using ( select <id> id, '<name>' name from dual ) n on ( t.id = n.id)
when matched then 
  update set t.name = n.name
when not matched then
  insert (t.id, t.name) values (n.id, n.name)

upd2

<blockquote>require_once "simple_html_dom.php";

error_reporting(E_ALL);
ini_set('display_errors', '1');
$conn = oci_connect('ddd', 'ddd', '127.0.0.1/orcl', 'AL32UTF8');


$brands = array();

$html = str_get_html(file_get_contents('https://kolesa.kz/cars/'));
$i = 'begin ';
$i .= '\r\n';

$select = $html->find('select[id=auto-car-mm-0]', 0);

foreach($select->find('option') as $opt)
{
  if($opt->value == '') continue;

  $i .= 'merge into kolesa_brands t ';
  $i .= 'using (select '.$opt->value.' id, \''.$opt->plaintext.'\' name from dual) n on (t.id = n.id) ';
  $i .= 'when matched then ';
  $i .= 'update set t.name = n.name ';
  $i .= 'when not matched then ';
  $i .= 'insert (t.id, t.name) values (n.id, n.name);';
  $i .= '\r\n';

  $brands[$opt->value] = $opt->plaintext; 
}

$i .= '\r\n';
$i .= 'end;';

$insert = oci_parse($conn, $i);

oci_execute($insert);</blockquote>

Comments

[Sanya899]

Да , видел такой вариант , а еще такой вариант:
Просто вопрос вот в чем мне приходит массив из марок авто, а в обоих вариантах кода везде INSERT INTO т,е вставить строку и нигде не упоминается о массовой вставке INSERT ALL . Я так понимаю мне нужно обернуть это в цикл и тогда все получится?

MERGE
   INTO users_dest dest
  USING( SELECT 1 user_id, 10 points FROM dual) src
     ON( dest.user_id = src.user_id )
 WHEN MATCHED THEN
   UPDATE SET points = src.points
 WHEN NOT MATCHED THEN
   INSERT( user_id, points ) 
     VALUES( src.user_id, src.points );

Если цикл, то как ? idShura спасибо

[idShura]

Sanya899, Нет, просто оберни все запросы в begin и end и затем отправь на сервер (oci_execute($insert);), например:

begin

--Первый запрос
merge into kolesa_brands t
using ( select <id> id, '<name>' name from dual ) n on ( t.id = n.id)
when matched then 
  update set t.name = n.name
when not matched then
  insert (t.id, t.name) values (n.id, n.name);
  
--Второй запрос
merge into kolesa_brands t
using ( select <id> id, '<name>' name from dual ) n on ( t.id = n.id)
when matched then 
  update set t.name = n.name
when not matched then
  insert (t.id, t.name) values (n.id, n.name);
  
 --и т.д. 
  
end;

[Sanya899]

Прокатило только в begin и end не смог обернуть засунул так. Конечно пришлось повозиться с этими точками и запятыми. Если я правильно понял у меня в массиве около 120 марок это, что же получается на каждую марку отдельный такой запрос надо делать?

[Sanya899]

вот правда нашел пример он вроде подходит под мою задачу как раз с циклом только вот как его подпилить под меня не в куриваю.

for ($i = 0; $i < count($router); $i++) {
    $query = "MERGE INTO CORE_INTERFACES USING dual ON "
      // The next row is the match criteria, like If "HOSTNAME" AND "IFINDEX" exist, Then Update else INSERT NEW HOSTNAMES!   
      . "( HOSTNAME = '" . $hostname . "' AND IFINDEX = '" .    t trim($router_interface[0]) . "')" 
      . "WHEN MATCHED THEN UPDATE SET "
      . "IFNAME = '" . trim($router_interface[1]) . "',IFTYPE = '" . trim(clean_iftype($router_interface[2])) . "',IFADMINSTATUS = '" . trim(clean_output($router_interface[3])) . "',"
      . "LAST_UPDATE = CURRENT_TIMESTAMP "
. "WHEN NOT MATCHED THEN INSERT ("
      . "IF_ID,HOSTNAME,IFINDEX,IFNAME,IFTYPE,IFADMINSTATUS,"
      . "FIRST_SEEN "
      . ") VALUES ("
      . " core_interfaces_seq.nextval, "
      . "'" . $hostname . "',"        //$HOSTNAME
      . "'" . trim($router_interface[0]) . "',"       //ifIndex
      . "'" . trim($router_interface[1]) . "',"       //ifName
      . "'" . trim(clean_iftype($router_interface[2])) . "',"         //ifType
      . "'" . trim(clean_output($router_interface[3])) . "',"         //ifAdminState
      . " CURRENT_TIMESTAMP )";
   $stid = oci_parse($gnedb, $sql);
}

[idShura]

Sanya899, Если обернуть в begin и end то будет как "один запрос", иначе получатся отдельный запросы. Я в php не очень, но сейчас попробую что-нибудь изобразить.

[idShura]

Sanya899, Примерно вот так:

<blockquote>require_once "simple_html_dom.php";

error_reporting(E_ALL);
ini_set('display_errors', '1');
$conn = oci_connect('ddd', 'ddd', '127.0.0.1/orcl', 'AL32UTF8');


$brands = array();

$html = str_get_html(file_get_contents('https://kolesa.kz/cars/'));
$i = 'begin ';
$i .= '\r\n';

$select = $html->find('select[id=auto-car-mm-0]', 0);

foreach($select->find('option') as $opt)
{
  if($opt->value == '') continue;

  $i .= 'merge into kolesa_brands t ';
  $i .= 'using (select '.$opt->value.' id, \''.$opt->plaintext.'\' name from dual) n on (t.id = n.id) ';
  $i .= 'when matched then ';
  $i .= 'update set t.name = n.name ';
  $i .= 'when not matched then ';
  $i .= 'insert (t.id, t.name) values (n.id, n.name);';
  $i .= '\r\n';

  $brands[$opt->value] = $opt->plaintext; 
}

$i .= '\r\n';
$i .= 'end;';

$insert = oci_parse($conn, $i);

oci_execute($insert);</blockquote>

[idShura]

Sanya899, получилось?

[Sanya899]

Где то косяк по коду

Warning: oci_execute(): ORA-06550: line 1, column 6: PLS-00103: Encountered the symbol "\" when expecting one of the following: ( begin case declare exit for goto if loop mod null pragma raise return select update while with << continue close current delete fetch lock inser...

[idShura]

Sanya899, пришли получившийся запрос из переменной $i (перед строчкой $insert = oci_parse($conn, $i);)

[Sanya899]

Вот , короче походу r/n лишнее я их пытался убирать безрезультатно. Может я чего не так делал

begin\r\nmerge into kolesa_brands tusing (select 4 id, ARO name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 1 id, Acura name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 2 id, Alfa Romeo name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 3 id, Alpina name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 6 id, Aston Martin name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 7 id, Audi name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 150 id, BAW name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 11 id, BMW name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 15 id, BYD name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 9 id, Bentley name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 140 id, Brilliance name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 14 id, Buick name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 16 id, Cadillac name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 17 id, Chana name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 122 id, Changan name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 18 id, Chery name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 19 id, Chevrolet name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)\r\nmerge into kolesa_brands tusing (select 20 id, Chrysler name from dual) n on ( t.id = n.id)when matched thenupdate set t.name = n.namewhen not matched theninsert (t.id, t.name) values (n.id, n.name)

[idShura]

Sanya899, убери r\n\ или замени на перенос строки (я видимо неправильно написал). Также обрати внимание чтобы был пробел в конце склеиваемых строк ты их похоже убрал.

[idShura]

Sanya899, также не вижу точки запятой
$i .= 'insert (t.id, t.name) values (n.id, n.name);';

[Sanya899]

Спасибо тебе большое все прокатило. Блин жалко что тут в личку писать нельзя. Просто новые темы не хочется плодить.

[Sanya899]

Случаем тут нету возможности как то связаться с тобой если вдруг возникнут вопросы,чтобы не создавать темы?

[idShura]

Sanya899, в профиле добавил почту. Не забудь отметить ответ решением.

[Sanya899]

Отметил , спасибо добрый человек )!