그래서 내가 알아야 할 것은 어떻게 한 번에 두 개의 데이터베이스를 연결할 수 있는가입니다. 내가하고있는 일은 하나의 db 테이블에서 정보를 가져 와서 다른 DB로 옮기는 것입니다.OOPHP는 두 개의 DB를 연결합니다
나는 다음을 시도했다. http://www.php.net/mysql_connect과 설명서에서
이$db1 = mysql_connect(...);
$db2 = mysql_connect(...);
mysql_query('SELECT ...', $db1);
mysql_query('INSERT ...', $db2);
봐 :
public function sitelistingcron()
{
$sqlk = mysql_query("SELECT * FROM customer_detail WHERE approvedforsite = 2 OR approvedforsite = 3");
include_once('database2.php');
$fet = new Dbase();
$fet->Connect();
$fet->DB();
while($row = mysql_fetch_array($sqlk)){
//ADD
$this->customer_id = $row['customer_id'];
$this->tradingname = $row['TradingName'];
$this->phone = $row['Phone'];
$this->street = $row['Street'];
$this->city = $row['City'];
$this->state = $row['State'];
$this->postcode = $row['PostCode'];
$this->approved = $row['approvedforsite'];
$this->description = $row['Description'];
if($this->approved = 2)
{
$sqk = mysql_query("INSERT INTO approved_business_info (id, tradingname, phonenumber, street, postcode, suburb, discription) VALUES ({$this->customer_id}, '{$this->tradingname}', '{$this->phone}', '{$this->street}', '{$this->city}', '{$this->postcode}', '{$this->description}') ON DUPLICATE KEY UPDATE id = {$this->customer_id}, tradingname ='{$this->tradingname}', phonenumber ='{$this->phone}', street = '{$this->street}', postcode = '{$this->postcode}', suburb = '{$this->city}', discription = '{$this->discription}'") or mysql_error();
print "INSERT INTO approved_business_info (id, tradingname, phonenumber, street, postcode, suburb, discription) VALUES ({$this->customer_id}, '{$this->tradingname}', '{$this->phone}', '{$this->street}', '{$this->city}', '{$this->postcode}', '{$this->description}') ON DUPLICATE KEY UPDATE id = {$this->customer_id}, tradingname ='{$this->tradingname}', phonenumber ='{$this->phone}', street = '{$this->street}', postcode = '{$this->postcode}', suburb = '{$this->city}', discription = '{$this->discription}'";
}
//REMOVE
if($this->approved = 3)
{
$sqk = mysql_query("DELETE FROM `approved_business_info` WHERE id = {$this->customer_id}");
}
}
}
'$ result = sql_query ($ conn1, $ sql1); $ sql2 = makeInsertStatements ($ result); sql_update ($ conn2, $ sql2); ' – bdares
당신은 어떻게 * db *에 연결하고 있습니까? 두번 만 ...? – deceze
고대의 mysql_ * 함수를 사용하지 말고 [PDO] (http://php.net/pdo) 나 [MySQLi] (http://php.net/mysqli)를 준비된 문장으로 익히십시오. –