PHP fork MySQLを使いデータベースの更新

Question

fork文の子プロセスの中でデータベースに接続し、データをアップデートしたいのですが、可能でしょうか？

500 Internal Server Errorとエラーメッセージが出てしまいます。

SQLを使いデータベースに格納できないので
配列に格納後、データベースに格納できないかと試しましたが
親プロセス終了後、格納した数値がなくなってしまいます。

DBに値を更新に行く方法はないでしょうか？

OSはCentOS 6です。
MySQLを使用しています。

よろしくお願いします。

Answer 1

いただいたソースをを書いてみます。

<?php
$pids = array();
for ($i=0; $i<$loop_number; $i++) {
  $pid = pcntl_fork(); 
  if ($pid == -1) {
    writeErrorLog('プロセスのフォークに失敗しました。');
    break;
  } else if ($pid) {
    // 親プロセスの場合
    $pids[] = $pid;
  } else {
    //******挿入するSQL文*******
    mysql_query('SET NAMES utf8', $sql );
    $link = mysql_connect('localhost', 'xxxxx', 'ps');

    if (!$link) {
      die('no conetct'.mysql_error());
    }

    $db_selected = mysql_select_db('DB', $link);

    if (!$db_selected){
      die('err'.mysql_error());
    }

    mysql_set_charset('utf8');

    echo $sql = sprintf(SQL文);
    $result_flag = mysql_query($sql);

    //******挿入するSQL文*******
    if ($close_flag<>1){
      print('<p>NOT KILL</p>');
    } 
  }
}

foreach ($pids as $pid) {
  pcntl_waitpid($pid, $status);
}

子プロセス側にexitがなく、子プロセス側でもforループが継続してしまうように見えますが、exitしてますか？

あと、Mysql APIは5.5で非推奨になり、7で削除されているので、MysqliかPDOに乗り換えることをお勧めします。
http://php.net/manual/ja/intro.mysql.php

Comments

[WADA1234]

すいません＾＾；
exitはしておりました。書き漏れです。

PDOでも一度試してみます。
ありがとうございますm(_ _)m

[shi_ue]

mysqlでエラーになっているわけではないと思います。
500エラーということなのですが、apacheのエラーログは見ましたか？

[WADA1234]

PDOでやってみました。成功しました！
すんなり行きました！検索してDPOというやり方も書いてあったのですが試していませんでした。行ってもらわなかったら試しませんでした。
apacheでエラーログを吐くんですね。知りませんでした！
ちょっとそこも調べてみます！

[shi_ue]

よかったです！引き続き頑張ってください！

[WADA1234]

ありがとうございます！助かりました＾＾

Answer 2

こちらのURLに解説があります。
http://lab.adn-mobasia.net/?p=106

プロセスをフォークする際、データベース接続には注意しなければなりません。親プロセスでDB接続をオープンしたままの状態で子プロセスを生成してしまうと、この参照がプロセス間で共有されてしまい、1つの子プロセスが終了した段階で他の全てのプロセスからはDB接続がクローズされてしまったように見えます。これを避けるためには、フォーク後に各子プロセスが自分専用のDB接続をオープンするとよいでしょう。

とありますが、どうでしょうか。そのようなことはしていないでしょうか？
出来ればソースを開示していただくと分かりやすいですね。

Comments

[WADA1234]

コメントありがとうございます。
このページも参考にしてプログラムを作っておりました。
親プロセスにはSQL処理をさせていません。
子プレセスの中にSQL文を入れたいと考えております。

下記のような構成となっています。
子プロセスがloop_number個並行処理される状態になると思います。
子プロセスでDBが開いている間に他の子プロセスが動いてしまい、エラーになっているのかと思うのですが、いかがでしょうか？

よろしくお願いします。

$pids = array();
for ($i=0; $i<$loop_number; $i++) {
$pid = pcntl_fork();
if ($pid == -1) {
writeErrorLog('プロセスのフォークに失敗しました。');
break;
} else if ($pid) {
// 親プロセスの場合
$pids[] = $pid;
} else {
　　******挿入するSQL文*******
mysql_query('SET NAMES utf8', $sql );
$link = mysql_connect('localhost', 'xxxxx', 'ps');

if (!$link) {
die('no conetct'.mysql_error());
}

$db_selected = mysql_select_db('DB', $link);

if (!$db_selected){
die('err'.mysql_error());
}

mysql_set_charset('utf8');

echo $sql = sprintf(SQL文);
$result_flag = mysql_query($sql);

******挿入するSQL文*******
if ($close_flag<>1){
print('<p>NOT KILL</p>');
}

}
}
foreach ($pids as $pid) {
pcntl_waitpid($pid, $status);