0

Zend Framework を使用し、子プロセスをフォークする CLI スクリプトがあります。CLIから起動するとうまくいきますが、bashスクリプトから起動すると、bashスクリプトが終了するとdb接続が閉じられます。

子に同じデータベースへの新しい db 接続を与える必要があると思います。残念ながら、元の接続の作成方法は私にはあまりにも不可解なので、既存の接続をベースに新しい接続を作成したいと思います。どうやってやるの？

これは、Bootstrap での作成方法と、後でアクセスする方法です。

$resource = $this->getPluginResource ( 'db' );
$db = $resource->getDbAdapter ();
Zend_Registry::getInstance ()->dbAdapter = $db;    

$this->db = Zend_Registry::get ( 'dbAdapter' );

そして、これは私が新しい接続を使用したい場所です:

public function start_daemon($worker) {
    if (file_exists ( $this->get_pidfile ( $worker ) ))
        die ( 'process is already running - process pidfile already exists -> ' . $this->get_pidfile ( $worker ) . "\n" );
    $cmd = 'php -f ' . __FILE__ . ' process';
    if ($this->is_win) {
        $WshShell = new COM ( "WScript.Shell" );
        $oExec = $WshShell->Run ( "$cmd /C dir /S %windir%", 0, false );
        exec ( 'TASKLIST /NH /FO "CSV" /FI "imagename eq php.exe" /FI "cputime eq 00:00:00"', $output );
        $output = explode ( '","', $output [0] );
        $pid = $output [1];
        file_put_contents ( $this->get_pidfile ( $worker ), $pid );
        echo ('JobQue daemon started with pidfile:' . $this->get_pidfile ( $worker ) . "\n");
    } else {
        $PID = pcntl_fork ();
        if ($PID) {
            file_put_contents ( $this->get_pidfile ( $worker ), $PID );
            echo ('JobQue daemon started with pidfile:' . $this->get_pidfile ( $worker ) . "\n");                               
            exit (); // kill parent
        }
        //!!Need to create a new db connection here
        //to make sure the child will have one
        //when the parent exits
        posix_setsid (); // become session leader
        chdir ( "/" );
        umask ( 0 ); // clear umask
        $this->proc_nice ( 19 );
        $this->process_jobs ();
    }
}
4

1 に答える 1

0

こんな感じでアクセスできます

public function start_daemon($worker) {

    $db = Zend_Registry::get ( 'dbAdapter' );
    //do database operations with db object

新しい接続用 

//if config is stored in registry,
$config= Zend_Registry::get ( 'config' );
$db = Zend_Db::factory($config['resources']['db']['adapter'], $config['resources']['db']['params']);

OR 

$db = Zend_Db::factory('Pdo_Mysql', array(
            'host'     => 'hostname',
            'username' => 'xxxxxxx',
            'password' => 'xxxxxxxx',
            'dbname'   => 'xxxxxxxxx'
        ));



 //set as default adapter
    Zend_Db_Table_Abstract::setDefaultAdapter($db);
于 2012-05-16T12:54:07.007 に答える