php - 使用数据库类在 php 中连接 2 个服务器

标签 php mysql class server connection

我知道有关于如何将 2 个服务器连接到数据库的答案,但我的情况有点不同,所以不要只是将我重定向到另一个答案。我的连接不是简单的 1 线,我正在寻找继续进行的最佳方式(放弃类(class)并做一些完全不同的事情,通过该类(class)连接 2 的方法等)。

这就是发生的事情。我目前在国外实习,我被分配了一项简单的任务,我必须使用一台服务器,完成所有工作,这似乎是故事的结局。然而,一旦我们将所有内容移至真实主机,结果我有 2 台服务器,而不是只有 1 台服务器。

这就是我的 1 服务器连接的样子:

类.数据库.inc

<?php

require_once(LIB_PATH . "config.php");

class MySQLDatabase {

private $connection;
public $last_query;
private $magic_quotes_active;
private $real_escape_string_exists;

function __construct() {
    $this->open_connection();
    $this->magic_quotes_active = get_magic_quotes_gpc();
    $this->real_escape_string_exists = function_exists("mysql_real_escape_string");
}

public function open_connection() {
    $this->connection = mysqli_connect(SERVER_ADDR, SERVER_USER, SERVER_PWD, SERVER_DB);
    if (mysqli_connect_errno()) {
        printf("Connect failed: %s\n", mysqli_connect_error());
        exit();
    } else {
        $db_select = $this->connection->query("SELECT DATABASE()");
        if (!$db_select) {
            printf("Database selection failed: %s\n", mysqli_connect_error());
            exit();
        }
    }
}

public function close_connection() {
    if (isset($this->connection)) {
        $this->connection->close();
        unset($this->connection);
    }
}

public function query($sql) {
    $this->last_query = $sql;
    $result = $this->connection->query($sql);
    $this->confirm_query($result);
    return $result;
}

public function escape_value($value) {
    if ($this->real_escape_string_exists) { // PHP v4.3.0 or higher
        // undo any magic quote effects so mysql_real_escape_string can do the work
        if ($this->magic_quotes_active) {
            $value = stripslashes($value);
        }
        $value = $this->connection->real_escape_string($value);
    } else { // before PHP v4.3.0
        // if magic quotes aren't already on then add slashes manually
        if (!$this->magic_quotes_active) {
            $value = addslashes($value);
        }
        // if magic quotes are active, then the slashes already exist
    }
    return $value;
}

// "database-neutral" methods
public function fetch_array($result_set) {
    return $result_set->fetch_array(MYSQLI_ASSOC);
}

public function num_rows($result_set) {
    return $result_set->num_rows;
}

public function insert_id() {
    // get the last id inserted over the current db connection
    return $this->connection->insert_id;
}

public function affected_rows() {
    return $this->connection->affected_rows;
}

private function confirm_query($result) {
    if (!$result) {
        $output = "Database query failed: " . mysqli_connect_error() . "<br /><br />";
        $output .= "Last SQL query: " . $this->last_query;
        die($output);
    }
}

}

$database = new MySQLDatabase();
$db = & $database;

在 config.php 文件中,我只有这个(删除了值,无论如何它现在都可以工作):

defined("SERVER_ADDR") ? null : define("SERVER_ADDR", );
//MYSQL username
defined("SERVER_USER") ? null : define("SERVER_USER", );
//MYSQL password
defined("SERVER_PWD") ? null : define("SERVER_PWD", );
//MYSQL database name
defined("SERVER_DB") ? null : define("SERVER_DB", );

所以问题是,最好的处理方法是什么。有没有一种方法可以添加另一个“config2.php”类型的文件并在类中进行一些更改以使所有这些功能在两个类上都有效,或者我应该做一些完全不同的事情。

一如既往,感谢您的回答,我真的很感激他们。

更新:

所以这是我尝试过的方法,但没有用。当我运行所需的 SQL 函数时,它确实显示了正确的表,但函数确认查询每次都失败。

    <?php

require_once(LIB_PATH . "config.php");

class MySQLDatabase {

private $connection;
public $last_query;
private $magic_quotes_active;
private $real_escape_string_exists;

public $server;
public $user;
public $pw;
public $database;

function __construct() {
    $this->open_connection();
    $this->magic_quotes_active = get_magic_quotes_gpc();
    $this->real_escape_string_exists = function_exists("mysql_real_escape_string");
}

public function open_connection() {
    $this->connection = mysqli_connect($this->server, $this->user, $this->pw, $this->database);
    if (mysqli_connect_errno()) {
        printf("Connect failed: %s\n", mysqli_connect_error());
        exit();
    } else {
        $db_select = $this->connection->query("SELECT DATABASE()");
        if (!$db_select) {
            printf("Database selection failed: %s\n", mysqli_connect_error());
            exit();
        }
    }
}

public function close_connection() {
    if (isset($this->connection)) {
        $this->connection->close();
        unset($this->connection);
    }
}

public function query($sql) {
    $this->last_query = $sql;
    $result = $this->connection->query($sql);
    $this->confirm_query($result);
    return $result;
}

public function escape_value($value) {
    if ($this->real_escape_string_exists) { // PHP v4.3.0 or higher
        // undo any magic quote effects so mysql_real_escape_string can do the work
        if ($this->magic_quotes_active) {
            $value = stripslashes($value);
        }
        $value = $this->connection->real_escape_string($value);
    } else { // before PHP v4.3.0
        // if magic quotes aren't already on then add slashes manually
        if (!$this->magic_quotes_active) {
            $value = addslashes($value);
        }
        // if magic quotes are active, then the slashes already exist
    }
    return $value;
}

// "database-neutral" methods
public function fetch_array($result_set) {
    return $result_set->fetch_array(MYSQLI_ASSOC);
}

public function num_rows($result_set) {
    return $result_set->num_rows;
}

public function insert_id() {
    // get the last id inserted over the current db connection
    return $this->connection->insert_id;
}

public function affected_rows() {
    return $this->connection->affected_rows;
}

private function confirm_query($result) {
    if (!$result) {
        $output = "Database query failed: " . mysqli_connect_error() . "<br /><br />";
        $output .= "Last SQL query: " . $this->last_query;
        die($output);
    }
}

}

$database = new MySQLDatabase();
$database->server = SERVER_ADDR;
$database->user = SERVER_USER;
$database->pw = SERVER_PWD;
$database->database = SERVER_DB;

$db = & $database;

也许一些额外的信息会有所帮助,所以这是我使用 1 个函数从 SQL 获取数据的地方(它们现在都失败了,所以我想 1 个示例就足够了)。

用户.php:

//more code
 $max_users = User::count_all(); //max users   
//more code

class.database_query.inc:

require_once(LIB_PATH . "class.database.inc");

class DatabaseObject {

    protected static $table_name;

//more functions

//the one in use:
    public static function count_all() {
        global $database;
        $sql = "SELECT COUNT(*) FROM " . static::$table_name;
        $result_set = $database->query($sql);
        $row = $database->fetch_array($result_set);
        return array_shift($row);
    }

//more functions

}

这是我在加载 users.php 时得到的结果:

"数据库查询失败:

最后一个 SQL 查询:SELECT COUNT(*) FROM table_name" (当我直接在 phpmyadmin 中输入时,相同的 SQL 查询有效)。

是的.. 只要我只使用一个服务器(页面顶部的第一个 block ),它就可以正常工作。

最佳答案

为什么要依赖 define 常量语句?您可以编写 .ini 文件并使用 $array = parse_ini_file(filename) 读取配置.这样做,您可以使用特定配置的文件名(或更高级的部分名称)调用构造函数。

既然你在谈论“最好的进行方式”——如果你真的需要 mysql_real_escape_string(动态 $table_name 是一个原因,当没有其他办法时)并处理它可能不存在的情况,你应该(如果它不存在)拒绝任何访问或至少提供一个带有正则表达式的 polyfill。 mysqli 优于mysql,考虑使用PDO。尽可能使用参数化准备语句来提高安全性。

滥用类来提供仅静态方法是一个过时的概念,因为在较新的 PHP 版本中,命名空间可以很好地处理上下文分离。

关于php - 使用数据库类在 php 中连接 2 个服务器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36307347/

相关文章:

php - 停止缓存页面的特定元素

mysql - Magento - 使用存储过程数组结果集作为集合

python - 如何在Python中构建复数类?

php - 无法在mysql中加入3个表来链接用户ID

mysql - SQL 查询按以前数据的最高平均值排序

javascript - 如何将一个类的所有方法绑定(bind)到javascript中的 'this'变量

Python:当键是对象时,如何调用成员函数作为字典的键?

javascript - Window.location 在 ajax 中被取消

php - 从 nginx 接收内部服务器错误

php - NFS 从 Vagrant guest 挂起到 OSX