0

我正在寻找一个更好的 PDO 数据库连接，我可以在我拥有的不同类中使用它。例如我当前的代码是这样的：

核心.php

//Connecting to Database
        try {
        $db = new PDO("mysql:host=localhost;dbname=mydb", "project", "project123");
        } 
        catch(PDOException $e) {  
        echo $e->getMessage();  
        }

类核心{

protected $db;
    public function __construct(PDO $db) {
    $this->db = $db;
    }

function redirectTo($page,$mode = 'response',$message = '') {
        if($message != '') {
        header('Location: '.SITEURL.'/'.$page.'?'.$mode.'='.urlencode($message));
        } else {
        header('Location: '.SITEURL.'/'.$page);         
        }
        exit();
}

}

除此之外，我还有 2 个类：wall.php 和ticker.php

class Wall {

protected $db;
    public function __construct(PDO $db) {
    $this->db = $db;
    }
function addComment($uid, $fid, $comment) {
$time = time();
$ip = $_SERVER['REMOTE_ADDR'];

$query = $this->db->prepare('INSERT INTO wall_comments (comment, uid_fk, msg_id_fk, ip, created) VALUES (:comment, :uid, :fid, :ip, :time)');
$query->execute(array(':comment' => $comment, ':uid' => $uid, ':fid' => $fid, ':ip' => $ip, ':time' => $time));

$nofity_msg = "User commented on the post";
$setTicker = Ticker::addTicker($uid,$nofity_msg,'comment');                 

    if($setTicker) {
    Core::redirectTo('wall/view-'.$fid.'/','error','Oops, You have already posted it!');        
    } else {
    Core::redirectTo('wall/view-'.$fid.'/','error','Oops, Error Occured');  
    }
}

}

和ticker.php是：

class Ticker {  
    protected $db;
    public function __construct(PDO $db) {
    $this->db = $db;
    }


function addTicker($uid,$msg,$type) {
        $time = time();

        $query = $this->db->prepare('INSERT INTO tickers (uid_fk, message, type, created) VALUES (:uid, :message, :type, :time)');

        try {
                $query->execute(array(':uid' => $uid, ':message' => $msg, ':type' => $type, ':time' => $time));
                return $this->db->lastInsertId();
        }
        catch(PDOException $e) {  
                return 0;
        }  

}

}

现在我的问题是我需要调用函数 addComment() 并且在该函数内部还有对 Ticker 类中存在的函数 addTicker() 的进一步调用。这导致 Db 连接问题，因为在上一个类中已经创建了一个 db 实例。我不知道如何解决这个问题。

这是我在主索引文件中使用的代码：

$core = new Core($db);
$ticker = new Ticker($db);
$wall = new Wall($db);

$wall->addComment($uid, $fid, $add_comment); // This statement is not working.. :(

我的意图是拥有一个通用的主数据库连接，并在其他类中进一步使用该连接。有没有更好的方法来做到这一点..？

4

1 回答 1

0

在上一个类中已经创建了一个 db 实例

这实际上是单个实例，但复制到 2 个变量中。

这导致 Db 连接问题

你能对这样的问题更确定一点吗？你有什么特别的问题？

于 2013-01-10T09:44:15.407 回答