ecshop操作數據庫類

ECShop v2.7.2沒有使用一些開源的數據庫操作類，比如adodb或者PEAR，而是封裝了自己的實現。這樣做的好處是實現非常輕量，只有一個文件，27Kb，大大減小了分發包的文件大小。另外，當網站需要做memcached緩存時，也可以很方便的實現。當然，這樣做的后果就是數據庫的選擇非常狹窄，無法實現其它的非MySQL數據庫。

 

ECShop的數據操作類文件是includes/cls_mysql.php，類名是cls_mysql。該類主要提供了下面 一些比較有用的方法：

• getAll($sql)和getAllCached($sql, $cached = 'FILEFIRST')：獲取所有記錄。
• getRow($sql, $limited = false)和getRowCached($sql, $cached = 'FILEFIRST')：獲取單行記錄。
• getCol($sqlse)和getColCached($sql, $cached = 'FILEFIRST')：獲取某欄位的所有值。
• getOne($sql, $limited = false)和getOneCached($sql, $cached = 'FILEFIRST')：獲取單個數值。
• query($sql)：執行數據庫查詢。
• autoExecute($table, $field_values, $mode = 'INSERT', $where = '')：數據庫表操作。

現在我們以實例的方式來說明這些方法如何使用。首先，在ecshop/admin目錄下新增文件test_mysql.php，文件內容如下：

<?php

define('IN_ECS', true);
define('EC_CHARSET', 'utf-8');
define('ROOT_PATH', 'D:/Program Files/Zend/Apache2/htdocs/ecshop/');
define('DATA_DIR', 'data');

$db_host = "localhost:3306";
$db_name = "ecshop";
$db_user = "root";
$db_pass = "";

require('../includes/cls_mysql.php');
$db = new cls_mysql($db_host, $db_user, $db_pass, $db_name);

 

 

 

---

 

 獲取所有記錄

getAll方法用來從數據庫中獲取滿足條件的所有記錄。getAllCached是它的緩存版本，cache key是該方法的第二個參數，如果緩存有效，直接返回緩存結果，否則重新執行數據庫查詢。

 

將下面的代碼加到test_mysql.php的最后：

 

test_getAll();

function test_getAll()
{
    global $db;

    $sql = "SELECT user_id, user_name, email FROM ecs_admin_user";
    $result = $db->getAll($sql);
    print_r($result);
}

 

修改以后的test_mysql.php執行結果如下：

 

Array
(
    [0] => Array
        (
            [user_id] => 1
            [user_name] => admin
            [email] => [e-mail]
        )

    [1] => Array
        (
            [user_id] => 2
            [user_name] => bjgonghuo1
            [email] => [e-mail]
        )

    [2] => Array
        (
            [user_id] => 3
            [user_name] => shhaigonghuo1
            [email] => [e-mail]
        )

    [3] => Array
        (
            [user_id] => 4
            [user_name] => amonest
            [email] => [e-mail]
        )

)

 

 

 

---

 

 獲取單行記錄

getRow方法用來從數據庫中獲取滿足條件的單行記錄，或者說是第一條記錄。getRowCached是它的緩存版本，cache key是該方法的第二個參數，如果緩存有效，直接返回緩存結果，否則重新執行數據庫查詢。

 

將下面的代碼加到test_mysql.php的最后：

 

test_getRow();

function test_getRow()
{
    global $db;

    $sql = "SELECT user_id, user_name, email FROM ecs_admin_user LIMIT 1";
    $result = $db->getRow($sql);
    print_r($result);
}

 

修改以后的test_mysql.php執行結果如下：

 

Array
(
    [user_id] => 1
    [user_name] => admin
    [email] => [e-mail]
)

 

 

 

---

 

 獲取某欄位的所有值

getCol方法用來從數據庫中獲取滿足條件的某個欄位的所有值。getColCached是它的緩存版本，cache key是該方法的第二個參數，如果緩存有效，直接返回緩存結果，否則重新執行數據庫查詢。

 

將下面的代碼加到test_mysql.php的最后：

 

test_getCol();

function test_getCol()
{
    global $db;

    $sql = "SELECT email FROM ecs_admin_user";
    $result = $db->getCol($sql);
    print_r($result);
}

 

修改以后的test_mysql.php執行結果如下：

 

Array
(
    [0] => [e-mail]
    [1] => [e-mail]
    [2] => [e-mail]
    [3] => [e-mail]
)

 

 

 

---

 

 獲取單個值

getOne方法用來從數據庫中獲取滿足條件的單個值。getOneCached是它的緩存版本，cache key是該方法的第二個參數，如果緩存有效，直接返回緩存結果，否則重新執行數據庫查詢。

 

將下面的代碼加到test_mysql.php的最后：

 

test_getOne();

function test_getOne()
{
    global $db;

    $sql = "SELECT email FROM ecs_admin_user WHERE user_id = 4";
    $result = $db->getOne($sql);
    print_r($result);
}

 

修改以后的test_mysql.php執行結果如下：

 

 

 

 

---

 

 執行數據庫查詢

query方法用來執行數據庫查詢，例如INSERT，UPDATE，DELETE等。 

將下面的代碼加到test_mysql.php的最后：

 

test_query();

function test_query()
{
    global $db;

    $sql = "UPDATE ecs_admin_user SET todolist = '你有一封新郵件!' WHERE user_id = 4";
    $db->query($sql);
    $sql = "SELECT todolist FROM ecs_admin_user WHERE user_id = 4";
    $result = $db->getOne($sql);
    print_r($result);
}

 

修改以后的test_mysql.php執行結果如下：

 

 

 

 

---

 

 數據庫表操作

autoExecute方法用來簡化對數據表的INSERT和UPDATE。 

將下面的代碼加到test_mysql.php的最后：

 

test_autoExecute();

function test_autoExecute()
{
    global $db;

    $table = "ecs_role";
    $field_values = array("role_name" => "總經理辦", "role_describe" => "總經理辦", "action_list" => "all");
    $db->autoExecute($table, $field_values, "INSERT");
    // 執行的SQL：INSERT INTO ecs_role (role_name, action_list, role_describe) VALUES ('總經理辦', 'all', '總經理辦')

    $role_id = $db->insert_id(); // 新記錄的ID：5

    $field_values = array("action_list" => "goods_manage");
    $db->autoExecute($table, $field_values, "UPDATE", "role_id = $role_id");
    // 執行的SQL：UPDATE ecs_role SET action_list = 'goods_manage' WHERE role_id = 5

    $sql = "SELECT action_list FROM ecs_role WHERE role_id = $role_id";
    $result = $db->getOne($sql);
    print_r($result);
}

 

修改以后的test_mysql.php執行結果如下：

 

goods_manage