ECShop沒有使用一些開源的數據庫操作類,比如adodb或者PEAR,而是封裝了自己的實現。這樣做的好處是實現非常輕量,大大減小了分發包的文件大小。另外,當網站需要做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,文件內容如下:
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); }
獲取單行記錄
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); }
獲取某欄位的所有值
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); }
獲取單個值
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); }
執行數據庫查詢
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); }
數據庫表操作
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); }
$db->getAll($sql) 返回查詢數據表中所有結果,形式是一個二維關聯數組。如果把結果賦值給smarty非常方便通過循環在模板里面引用。
$db->getOne($sql) 返回查詢的第一個字段
比如:
$sql ="select count(*) from ecs_goods ";
$count = $db->getOne($sql);
$count 為 商品數據總個數
$db->getRow($sql) 則返回數據庫中一行數據 比如
$sql = "select * from ecs_goods ";
$row = $db->getRow($sql);
則$row 為一個一維的關聯數組 可以通過$row['goods_name'] 取得商品名稱 等等。。。
其實這里的結果
$row_all = $db->getAll($sql) ;
$row = $db->getRow($sql);
$row 其實等於 $row_all[0] 當然你可以通過循環 取得 其他的值 比如 $row_all[1] ...
$db->getOne 一行一個字段
$db->getRow 一行記錄
$db->getAll 全部記錄