首页 算法正文

ecshop操作数据库类

小编 2026-06-15 阅读:1362 评论:0
ECShop v2.7.2没有使用一些开源的数据库操作类，比如adodb或者PEAR，而是封装了...

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] view plaincopy
  1. <?php  
  2.   
  3. define('IN_ECS', true);   
  4. define('EC_CHARSET', 'utf-8');  
  5. define('ROOT_PATH', 'D:/Program Files/Zend/Apache2/htdocs/ecshop/');  
  6. define('DATA_DIR', 'data');  
  7.   
  8. $db_host = "localhost:3306";   
  9. $db_name = "ecshop";   
  10. $db_user = "root";   
  11. $db_pass = "";   
  12.   
  13. require('../includes/cls_mysql.php');   
  14. $db = new cls_mysql($db_host, $db_user, $db_pass, $db_name);  

 

 

 

 

 获取所有记录

getAll方法用来从数据库中获取满足条件的所有记录。getAllCached是它的缓存版本，cache key是该方法的第二个参数，如果缓存有效，直接返回缓存结果，否则重新执行数据库查询。

 

将下面的代码加到test_mysql.php的最后：

 

[php] view plaincopy
  1. test_getAll();  
  2.   
  3. function test_getAll()  
  4. {  
  5.     global $db;  
  6.       
  7.     $sql = "SELECT user_id, user_name, email FROM ecs_admin_user";  
  8.     $result = $db->getAll($sql);  
  9.     print_r($result);  
  10. }  

 

修改以后的test_mysql.php执行结果如下：

 

[php] view plaincopy
  1. Array  
  2. (  
  3.     [0] => Array  
  4.         (  
  5.             [user_id] => 1  
  6.             [user_name] => admin  
  7.             [email] => admin@admin.com  
  8.         )  
  9.   
  10.     [1] => Array  
  11.         (  
  12.             [user_id] => 2  
  13.             [user_name] => bjgonghuo1  
  14.             [email] => bj@163.com  
  15.         )  
  16.   
  17.     [2] => Array  
  18.         (  
  19.             [user_id] => 3  
  20.             [user_name] => shhaigonghuo1  
  21.             [email] => shanghai@163.com  
  22.         )  
  23.   
  24.     [3] => Array  
  25.         (  
  26.             [user_id] => 4  
  27.             [user_name] => amonest  
  28.             [email] => amonest@foxmail.com  
  29.         )  
  30.   
  31. )  

 

 

 

 

 获取单行记录

getRow方法用来从数据库中获取满足条件的单行记录，或者说是第一条记录。getRowCached是它的缓存版本，cache key是该方法的第二个参数，如果缓存有效，直接返回缓存结果，否则重新执行数据库查询。

 

将下面的代码加到test_mysql.php的最后：

 

[php] view plaincopy
  1. test_getRow();  
  2.   
  3. function test_getRow()  
  4. {  
  5.     global $db;  
  6.       
  7.     $sql = "SELECT user_id, user_name, email FROM ecs_admin_user LIMIT 1";  
  8.     $result = $db->getRow($sql);  
  9.     print_r($result);  
  10. }  

 

修改以后的test_mysql.php执行结果如下：

 

[php] view plaincopy
  1. Array  
  2. (  
  3.     [user_id] => 1  
  4.     [user_name] => admin  
  5.     [email] => admin@admin.com  
  6. )  

 

 

 

 

 获取某栏位的所有值

getCol方法用来从数据库中获取满足条件的某个栏位的所有值。getColCached是它的缓存版本，cache key是该方法的第二个参数，如果缓存有效，直接返回缓存结果，否则重新执行数据库查询。

 

将下面的代码加到test_mysql.php的最后：

 

[php] view plaincopy
  1. test_getCol();  
  2.   
  3. function test_getCol()  
  4. {  
  5.     global $db;  
  6.       
  7.     $sql = "SELECT email FROM ecs_admin_user";  
  8.     $result = $db->getCol($sql);  
  9.     print_r($result);  
  10. }  

 

修改以后的test_mysql.php执行结果如下：

 

[php] view plaincopy
  1. Array  
  2. (  
  3.     [0] => admin@admin.com  
  4.     [1] => bj@163.com  
  5.     [2] => shanghai@163.com  
  6.     [3] => amonest@foxmail.com  
  7. )  

 

 

 

 

 获取单个值

getOne方法用来从数据库中获取满足条件的单个值。getOneCached是它的缓存版本，cache key是该方法的第二个参数，如果缓存有效，直接返回缓存结果，否则重新执行数据库查询。

 

将下面的代码加到test_mysql.php的最后：

 

[php] view plaincopy
  1. test_getOne();  
  2.   
  3. function test_getOne()  
  4. {  
  5.     global $db;  
  6.       
  7.     $sql = "SELECT email FROM ecs_admin_user WHERE user_id = 4";  
  8.     $result = $db->getOne($sql);  
  9.     print_r($result);  
  10. }  

 

修改以后的test_mysql.php执行结果如下：

 

 

 

 

 

 执行数据库查询

query方法用来执行数据库查询，例如INSERT，UPDATE，DELETE等。 

将下面的代码加到test_mysql.php的最后：

 

[php] view plaincopy
 
  1. test_query();  
  2.   
  3. function test_query()  
  4. {  
  5.     global $db;  
  6.       
  7.     $sql = "UPDATE ecs_admin_user SET todolist = '你有一封新邮件!' WHERE user_id = 4";  
  8.     $db->query($sql);  
  9.     $sql = "SELECT todolist FROM ecs_admin_user WHERE user_id = 4";  
  10.     $result = $db->getOne($sql);  
  11.     print_r($result);  
  12. }  

 

修改以后的test_mysql.php执行结果如下：

 

 

 

 

 

 数据库表操作

autoExecute方法用来简化对数据表的INSERT和UPDATE。 

将下面的代码加到test_mysql.php的最后：

 

[php] view plaincopy
 
  1. test_autoExecute();  
  2.   
  3. function test_autoExecute()  
  4. {  
  5.     global $db;  
  6.       
  7.     $table = "ecs_role";  
  8.     $field_values = array("role_name" => "总经理办", "role_describe" => "总经理办", "action_list" => "all");  
  9.     $db->autoExecute($table, $field_values, "INSERT");  
  10.     // 执行的SQL：INSERT INTO ecs_role (role_name, action_list, role_describe) VALUES ('总经理办', 'all', '总经理办')  
  11.   
  12.     $role_id = $db->insert_id(); // 新记录的ID：5  
  13.       
  14.     $field_values = array("action_list" => "goods_manage");  
  15.     $db->autoExecute($table, $field_values, "UPDATE", "role_id = $role_id");  
  16.     // 执行的SQL：UPDATE ecs_role SET action_list = 'goods_manage' WHERE role_id = 5  
  17.   
  18.     $sql = "SELECT action_list FROM ecs_role WHERE role_id = $role_id";  
  19.     $result = $db->getOne($sql);  
  20.     print_r($result);  
  21. }  

 

修改以后的test_mysql.php执行结果如下：

 

[php] view plaincopy
  1. goods_manage  

 

版权声明

本文仅代表作者观点，不代表百度立场。
本文系作者授权百度百家发表，未经许可，不得转载。

上一篇：安全性和保密性设计---网络安全体系 下一篇：多元宇宙
相关阅读
热门文章

  • 机房智能化温湿度解决方式之POE供电以太网温湿度传感器

    机房智能化温湿度解决方式之POE供电以太网温湿度传感器
    机房智能化温湿度解决方式之POE供电以太网温湿度传感器 北京盈创力和电子科技有限公司 智能型TCP网口温湿度记录仪 北京IP网络温湿度记录仪厂家，北京盈创力和 北京智能型TCP网口温湿度记录仪IP网络温湿度记录仪是一种新型的基于TCP/IP协议双绞线以太网标准温湿度采集模块，利用它可以实现现场温度值、相对湿度值的采集，同时利用其自身的RJ45通信接口可以方便地和机房监控主机或交换机集线器进行联网。 工作于-40℃～85℃工业级带...

  • Sequential Monte Carlo Methods (SMC) 序列蒙特卡洛/粒子滤波/Bootstrap Filtering

    Sequential Monte Carlo Methods (SMC) 序列蒙特卡洛/粒子滤波/Bootstrap Filtering
    Problem Statement 我们考虑一个具有马尔可夫性质、非线性、非高斯的状态空间模型(State Space Model)：对于一个时间序列上的观测结果{yt,t∈N}\\{ y_t , t \\in N \\}{yt​,t∈N}，我们认为每个观测结果yty_tyt​的生成依赖于一个无法直接观察的隐变量xt∈{xt,t∈N}x_t \\in \\{x_t , t \\in N \\}xt​∈{xt​,t∈N}，即：p(...

  • HTTP状态保持的原理

    HTTP状态保持的原理
    a)在用户登录之后，浏览器返回响应的时候会在响应中添加上cookieb)浏览器接收到cookie之后会自动保存c)当用户再次请求同一服务器中的其他网页的时候，浏览器会自动带上之前保存的cookied)服务接收到请求之后可以请 request 对象中取到cookie 判断当前用户是否登录　　Http是无状态的，就是连接时数据互通，关闭后...

  • Hive 系统函数及示例

    Hive 系统函数及示例
    查看所有系统函数 show functions; 函数分类 内置函数【系统函数】 数学函数： floor、round、ceil、cos、log2等 字符串函数： length、reverse、trim、lower、get_json_object、repeat等 收集函数： size 转换函数： cast 日期函数： year、month、datediff、date、date_add等 条件函数： coalesce、case…w...

  • CSRF的原理和防范措施

    CSRF的原理和防范措施
    a)攻击原理：i.用户C访问正常网站A时进行登录，浏览器保存A的cookieii.用户C再访问攻击网站B，网站B上有某个隐藏的链接或者图片标签会自动请求网站A的URL地址,例如表单提交，传指定的参数iii.而攻击网站B在访问网站A的时候，浏览器会自动带上网站A的cookieiv.所以网站A在接收到请求之后可判断当前用户是登录状态，所以...
最近发表
标签列表

Powered By Z-BlogPHP  Theme By 老白编程