PHP函数中能否使用不同数据库的表？多数据库连接方案咨询

嘿，我来帮你搞定这个在单个函数里操作两个数据库的问题～你当前的Connect类实例只能绑定一个PDO连接，所以用$obj1调用manage_tables时，里面的update_rows只能用DB1的连接，自然没法操作DB2。这里给你几个实用的解决方案：

方案一：修改Connect类，让它管理多个数据库连接 #

这个方案适合需要频繁操作多个数据库的场景，把类改成可以存储多个连接，方法里指定使用哪个连接：

class Connect{
    private $connections = []; // 用数组存储多个数据库连接

    // 构造函数可传入多个连接，也可以后续添加
    public function __construct($connections = []) {
        foreach($connections as $key => $dbCon) {
            if($dbCon instanceof PDO) {
                $this->connections[$key] = $dbCon;
            }
        }
    }

    // 单独添加连接的方法
    public function addConnection($key, $dbCon) {
        if($dbCon instanceof PDO) {
            $this->connections[$key] = $dbCon;
        }
    }

    // 内部方法：获取指定连接
    private function getConnection($key) {
        return isset($this->connections[$key]) ? $this->connections[$key] : null;
    }

    // 修改查询方法，指定使用哪个连接
    public function select_rows($connKey, $table,$fieldlist,$condition,$data) {
        $dbh = $this->getConnection($connKey);
        if(!$dbh) {
            throw new Exception("Connection $connKey not found");
        }
        $stmt = $dbh->prepare("SELECT $fieldlist FROM $table $condition");
        $stmt->execute($data);
        return $stmt;
    }

    // 修改更新方法，指定使用哪个连接
    public function update_rows($connKey, $table,$fieldlist,$condition,$data) {
        $dbh = $this->getConnection($connKey);
        if(!$dbh) {
            throw new Exception("Connection $connKey not found");
        }
        $stmt = $dbh->prepare("UPDATE $table set $fieldlist $condition");
        $stmt->execute($data);
        return $stmt;
    }

    public function manage_tables($id1,$id2,$value1,$value2) {
        // 使用db1的连接查询DB1的表
        $cond_db1 = "WHERE ID=?";
        $data_db1 = array($id1);
        $pass_db1 = $this->select_rows('db1','table_from_db1','*',$cond_db1,$data_db1);
        
        if($pass_db1->rowCount()>0) {
            // 使用db2的连接更新DB2的表
            $field_db2 = "field1=?,field2=?";
            $cond_db2 = " WHERE cID=? ";
            $data_db2 = array($value1,$value2,$id2);
            $query_db2 = $this->update_rows("db2","table_from_db2",$field_db2,$cond_db2,$data_db2);
        }
    }
}

// 初始化两个PDO连接
$DB1 = new PDO("mysql:host=".DB_HOST.";dbname=".DB_NAME1,DB_USER1,DB_PASS1);
$DB1->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$DB1->setAttribute(PDO::ATTR_EMULATE_PREPARES, FALSE);

$DB2 = new PDO("mysql:host=".DB_HOST.";dbname=".DB_NAME2,DB_USER2,DB_PASS2);
$DB2->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$DB2->setAttribute(PDO::ATTR_EMULATE_PREPARES, FALSE);

// 创建Connect实例，传入两个连接
$dbManager = new Connect(['db1' => $DB1, 'db2' => $DB2]);
// 或者后续动态添加
// $dbManager->addConnection('db1', $DB1);
// $dbManager->addConnection('db2', $DB2);

// 调用方法
$dbManager->manage_tables($id1,$id2,$value1,$value2);

方案二：在manage_tables中传入另一个Connect实例 #

这个方案改动最小，适合临时需求，不需要修改类的核心结构，直接把操作DB2的对象传进去：

// 原Connect类基本不变，只修改manage_tables方法
class Connect{
    private $dbh;

    public function __construct($DB_con) {
        $this->dbh = $DB_con;
    }

    public function select_rows($table,$fieldlist,$condition,$data) {
        $stmt = $this->dbh->prepare("SELECT $fieldlist FROM $table $condition");
        $stmt->execute($data);
        return $stmt;
    }

    public function update_rows($table,$fieldlist,$condition,$data) {
        $stmt = $this->dbh->prepare("UPDATE $table set $fieldlist $condition");
        $stmt->execute($data);
        return $stmt;
    }

    // 添加参数，接收操作DB2的Connect对象
    public function manage_tables($id1,$id2,$value1,$value2, $db2Obj) {
        $cond_db1 = "WHERE ID=?";
        $data_db1 = array($id1);
        $pass_db1 = $this->select_rows('table_from_db1','*',$cond_db1,$data_db1);
        
        if($pass_db1->rowCount()>0) {
            $field_db2 = "field1=?,field2=?";
            $cond_db2 = " WHERE cID=? ";
            $data_db2 = array($value1,$value2,$id2);
            // 使用传入的db2Obj操作DB2
            $query_db2 = $db2Obj->update_rows("table_from_db2",$field_db2,$cond_db2,$data_db2);
        }
    }
}

// 初始化两个Connect对象
$obj1 = new Connect($DB1);
$obj2 = new Connect($DB2);

// 调用时传入操作DB2的对象
$obj1->manage_tables($id1,$id2,$value1,$value2, $obj2);

方案三：使用全局连接（不推荐） #

虽然可以把$DB1和$DB2设为全局变量，在manage_tables里直接调用，但这种方式耦合度极高，代码难以维护和调试，非常不推荐在正式项目中使用。

额外提醒 #

• 确保两个数据库的连接用户有足够的权限（比如DB2的用户需要有table_from_db2的更新权限）。
• 如果需要两个操作的原子性（比如查询DB1成功后，更新DB2必须成功，否则全部回滚），可以考虑使用数据库的跨库事务（比如MySQL的XA事务，或同一主机下的InnoDB跨库事务）。

内容的提问来源于stack exchange，提问作者NightOwl