`
天梯梦
  • 浏览: 13729323 次
  • 性别: Icon_minigender_2
  • 来自: 洛杉矶
社区版块
存档分类
最新评论

Magento模块开发之数据库SQL操作方法说明

 
阅读更多

今天主要来看Magento中的Mysql4/Resource(资源) 如何对数据库进行操作, 来执行更为复杂的 sql 语句。 在Magento中Model 通常都会继承 Mage_Core_Model_Abstract, 而这个 Abstract 又继承了Varien_Object, 在 Abstract 类中包含许多常用的方法,例如: getId(), load(), save(), delete() 等等…而 Mysql4/Resource Model 则继承 Mage_Core_Model_Mysql4_Abstract, 而这个 Abstract 又继承了 Mage_Core_Model_Resource_Abstract

 

SQL 和 Mysql4 Resource 文件

Mysql4/Resource(资源) 文件, 用来和数据库中的表打交道,执行各类的数据库查询,在下面我会展示如何在 Resource(资源) 文件中进行 SQL 语句操作。

 

SELECT 操作

在这里,我就用 Test 模块中的 Mysql4/Resource 文件来举例。

PATH:  Excellence/Test/Model/Mysql4/Test.php
 
class Excellence_Test_Model_Mysql4_Test 
        extends Mage_Core_Model_Mysql4_Abstract
{
    public function _construct()
    {   
        $this->_init('test/test', 'test_id');
    }
     
    public function loadByField($field, $value)
    {
        $table  = $this->getMainTable();
        $where  = $this->_getReadAdapter()->quoteInto("$field = ?", $value);
        $select = $this->_getReadAdapter()
                       ->select()
                       ->from($table, array('test_id'))
                       ->where($where);
        $item   = $this->_getReadAdapter()->fetchOne($sql);
        return $item;
    }
}

 

这是我们的 Model 文件, Excellence/Test/Model/Test.php

class Excellence_Test_Model_Test 
            extends Mage_Core_Model_Abstract
{
    public function _construct()
    {
        parent::_construct();
        $this->_init('test/test');
    }
     
    public function loadByField($field, $value)
    {
        $id = $this->getResource()
                   ->loadByField($field, $value);
        $this->load($id);
    }
}

 

我们一个一个的来了解,首先,我们用到了这个方法

$id = $this->getResource()
           ->loadByField($field, $value);

 

这个方法 $this->getResource() 会返回出一个资源(Resource)模型类, 这样我们就可以很方便的在资源模型类里调用 loadyByField($field, $value)

 

getTable() 方法

在 我们的 Mysql4 文件里,方法 loadByField() 调用了 $table = $this->getMainTable(); 这个方法会返回出当前 Model 所对应的表名。 这个方法定义在其父类中, 如果你想进行连表查询或想获得另外一个表, 你可以这样操作:

$table = $this->getTable('newsletter/subscribe');

 

_getReadAdapter() 方法

现 在我们来看下这句: $where = $this->_getReadAdapter()->quoteInto(“$field = ?”, $value); 第一个方法是 $this->_getReadAdapter(), 该方法返回出一个对象,其包含许多方法可以用来执行数据库操作 在 Read 适配器(Adapter)里, 我们可以用到以下方法:

#1、 fetchAll()  
//单次 select 查询 - 以多维数组形式返回出数据表中的所有数据
//例: 'select * from `table_name`', 用该方法来获取所有数据
 
#2、 fetchRow()
//单次 select 查询 - 返回数据表中的一行数据
//例: "select * from `table` where `id` = ’1′", 用该方法来获取单条数据
 
#3、 fetchCol()
//单次 select 查询 - 返回数据表中的一列数据
//例: "select `name` from `table`", 用该方法来获取单条数据
 
#4、 fetchOne()
//单次 select 查询 - 返回数据表中单一的值
//例: "select count(*) from `table`", 我们就会用到该方法来获取单条数据
  $result = $this->_getReadAdapter()->fetchOne(
                'SELECT `user` FROM `table` WHERE `user` = :greatman',
                array('greatman' => 'shawn')
  );
  echo "$result";

 

在 Read 适配器中还有很多其他方法,可以仔细去了解下

 

quoteInto($text, $value) 方法

另一个常用的就是 quoteInto(), 这个方法就是用来创建我们的 WHERE 语句, 在执行该方法时,真正的值会把问号替换掉,语法书写格式如下:

//"user_id = 3″
$this->_getReadAdapter()
     ->quoteInto("user_id = ?", 3);
 
//"field in (1,2,3)"
$this->_getReadAdapter()
     ->quoteInto("$field IN(?)", array(1,2,3));
      
//如果含有多个 WHERE 的时候
$this->_getReadAdapter()->quoteInto("$field = ? AND ", $value)
     .
     $this->_getReadAdapter()->quoteInto("$field1 = ? OR ", $value1)
     .
     $this->_getReadAdapter()->quoteInto("$field2 = ?", $value2);

 

我们继续来说 loadByField() 方法, 接下来着重要说的就是:

$select = $this->_getReadAdapter()
               ->select()
               ->from($table, array('test_id'))
               ->where($where);

 

我们通过调用 select() 方法来获得到 select 对象,同时创建 select 查询, 然后它继续调用了 from() 方法

 

from($name, $cols = ‘*’, $schema = null) 方法

from() 这个方法带有多个参数,如果你只想执行 “select * from ” 语句, 你可以只填写第一个参数 from($table) 如果你想选择一列 test_id, 那么第二个参数就有用了, 同样的,如果想选择多列, 方法如下:

//单列 "select `test_id` from $table"
from($table, array('test_id'));
 
//多列 "select `test_id`, `col1`, `col2` from $table"
from($table, array('test_id', 'col1', 'col2'));
 
//多列带AS "select `test_id` as id, `col1` as column1 from $table"
from($table,array('id'=>'test_id', 'column1'=>'col1'));

 

还有,如果你想要输出自己刚写的 sql 语句,可以直接输出句柄

echo $select;

 

select 对象

select() 方法返回出一个 select 对象,该对象为我们提供了很多方法来执行 sql 语句, 其父类便是 Varien_Db_Select, 你可以在其类中找到更多的方法来更深一步的操作, 现在我们来看一个简单的php代码

public function getAll()
{
    $table  = $this->getMainTable();
    $where  = $this->_getReadAdapter()
                   ->quoteInto("id = ?", 123);
                    
    $select = $this->_getReadAdapter()
                   ->select()
                   ->from($table)
                   ->columns(array('test_id'))
                   ->where($where)
                   ->limit(10,5)
                   ->order('created_time')
                   ->group('list_id')
                   ->having('list_id > ?', 10);    
    echo $select;
}

 

从上你可以看出,这些方法都是来自于 select 对象, 并且都返回出自己所在的对象,这样的操作可以便于我们把多个方法串在一起。 现在让我们来逐个温习:

#1、 select()
//用来初始化 sql 语句操作, 返回出一个 select 对象, 基于这个对象,我们可以做更多的操作
 
#2、 from($name, $cols = '*', $schema = null)
//用来选择数据表的名字, 此时 select 已经初始化完成
 
#3、 columns($cols = '*', $correlationName = null)
//通过这个方法你可以指定列名
 
#4、 where($cond, $value = null, $type = null)
//用来声明 where 语句
 
#5、 limit($count = null, $offset = null)
//第一个参数代表想要返回多少条数据, 第二个参数代表 offset 偏移量
//在上面代码中就是: LIMIT 10 OFFSET 5, 而不是 LIMIT 10,5
 
#6、 order($spec)
//用来排序你所得的结果, 默认是: ascending
//如果想要是 descending, 可以写成 order(array('created_time' => Zend_Db_Select::SQL_DESC))
 
#7、 group($spec)
//相当于 group by 语句
 
#8、 having($cond, $value = null, $type = null)
//用来对 group by 语句的一个补充

 

 Joins 方法

public function joinUs()
{
    $table  = $this->getMainTable();
    $table2 = $this->getTable('customer/entity');
    $cond   = $this->_getReadAdapter()
                   ->quoteInto('t1.id = t2.customer_id','');
    $where  = $this->_getReadAdapter()
                   ->quoteInto('t1.list_id = ?', '123');
                    
    $select = $this->_getReadAdapter()
                   ->select()
                   ->from(array('t1'=>$table))
                   ->join(array('t2'=>$table2), $cond)
                   ->where($where);
    echo $select . "<br>";
     
    $select = $this->_getReadAdapter()
                   ->select()
                   ->from(array('t1'=>$table))
                   ->joinLeft(array('t2'=>$table2), $cond)
                   ->where($where);
    echo $select . "<br>";
     
    $select = $this->_getReadAdapter()
                   ->select()
                   ->from(array('t1'=>$table))
                   ->joinRight(array('t2'=>$table2), $cond)
                   ->where($where);
    echo $select . "<br>";
}

 

这是我输出所得的结果:

SELECT `t1`.*, `t2`.* FROM `szh` AS `t1` 
INNER JOIN `customer_entity` AS `t2` 
ON t1.id = t2.customer_id 
WHERE (t1.list_id = '123')
 
SELECT `t1`.*, `t2`.* FROM `szh` AS `t1` 
LEFT JOIN `customer_entity` AS `t2` 
ON t1.id = t2.customer_id 
WHERE (t1.list_id = '123')
 
SELECT `t1`.*, `t2`.* FROM `szh` AS `t1` 
RIGHT JOIN `customer_entity` AS `t2` 
ON t1.id = t2.customer_id 
WHERE (t1.list_id = '123')

 

相信如何使用 Joins 已经十分清晰了, 如果你想使用 joinCross, joinFull, joinNatural 等, 你可以自己动手仔细的看下 Varien_Db_Select 类。

 

COUNT,MAX 方法

继续来看一个简单的方法

public function countUs()
{
    $table  = $this->getMainTable();
    $where  = $this->_getReadAdapter()
                   ->quoteInto("id = ?", 123);
                    
    $select = $this->_getReadAdapter()
                   ->select()
                   ->from($table)
                   ->reset('columns')
                   ->columns(new Zend_Db_Expr('count(*)'));
    echo $select . '<br>';
     
    $select = $this->_getReadAdapter()
                   ->select()
                   ->from($table)
                   ->reset('columns')
                   ->columns(new Zend_Db_Expr('max(list_id)'));
    echo $select . '<br>';
}

 

所得的结果:

SELECT count(*) FROM `szh`
SELECT max("list_id") FROM `szh`

 

这里可以看出, 包括平均值等, 我们都可以采用 Zend_Db_Expr 类。

 

query() 方法

如果你有一个十分复杂的 sql 语句, 你也可以直接使用 query() 方法来执行

$sql = '...复杂的 sql 语句...';
$this->_getReadAdapter()->query($sql);

 

UPDATE 和 DELETE 方法

public function updateUs()
{
    $table = $this->getMainTable();
    $where = $this->_getWriteAdapter()
                  ->quoteInto('id = ?', 1);
                   
    $query = $this->_getWriteAdapter()
                  ->update($table, 
                           array('product_id' => 2, 'file_id' => 3),
                           $where
                    );
}

 

这里你可以看出如何来执行 Update(更新) 语句:

UPDATE `szh` SET `product_id` = 2, `file_id` = 3 WHERE (id = 1)

 

至于 Delete(删除) 语句, 如下:

$this->_getWriteAdapter()
     ->delete($table, $where)
     ->limit(1);

 

P.S 你可以在其他文件,如: model, phtml等获得到 Read Adapter(适配器), 但为了更好的体现出你代码的规整性及效率, 建议在 Resource 文件里执行这些 sql 语句

 

原文: http://blog.wangjunfeng.com/archives/569

转自:  Magento模块开发之数据库SQL操作方法说明

 

 

 

 

 

 

 

 

 

分享到:
评论

相关推荐

    我终于实现了 把 firephp 集成进 magento了 终于能监测 sql了

    2. 修改Magento核心或创建模块:为了使FirePHP能够在Magento中工作,你需要修改Magento的内核代码,或者创建一个新的Magento模块来插入FirePHP的代码。这通常涉及在控制器、模型、助手类或其他适当的地方引入FirePHP...

    magento新闻模块开发教程

    本教程将详细讲解如何开发一个新闻模块,帮助你深入理解Magento的二次开发。 首先,我们需要创建模块的骨架目录。在Magento中,每个模块都应遵循特定的目录结构,包括`block`、`controllers`、`etc`、`helper`、`...

    Magento 常用方法和插件

    这篇博文“Magento常用方法和插件”可能涵盖了Magento框架下的一些常见操作、开发技巧以及如何利用插件增强系统的功能。 在Magento中,常用方法主要包括模型(Model)、视图(View)、控制器(Controller)和模板...

    Magento-中文开发教程(技术重点2)

    每个子目录代表一个单独的模块,这些模块由 Magento 官方开发。而用户自定义的模块应放置在 `app/code/local/Packagename` 目录下,其中 "Packagename" 应是一个唯一的字符串,通常使用公司名称作为 Packagename。 ...

    magento入门文档

    模型中可以定义各种数据操作方法,例如查询、更新等。 **4.9 Magento中的CRUD操作** CRUD是指Create(创建)、Read(读取)、Update(更新)、Delete(删除),这是模型中最常见的操作。 **4.10 模型集合** 模型...

    Magento 后台管理插件示例

    你需要定义连接到数据库的SQL查询,以及相应的数据操作方法。 3. **控制器(Controller)**:控制器接收并处理HTTP请求,调用相应的模型和视图来执行任务。在后台管理插件中,你将创建一个或多个控制器来处理管理...

    深入理解magento

    本教程旨在深入解析Magento的模块开发,帮助开发者更好地理解和掌握其核心概念和技术。 一、请求分发与控制器 在Magento中,请求分发是系统处理HTTP请求的核心过程。当用户访问一个URL时,Magento的前端控制器...

    Magento Development Cookbook

    - **模块架构**:介绍Magento模块的基本结构,包括配置文件、模型、控制器等组成部分。 - **自定义模型**:用于处理数据库操作,实现数据的增删改查。 - **控制器开发**:负责处理用户的请求,并调用相应的模型来...

    Packt Publishing Magento 1.8 Development Cookbook.pdf

    - **数据库操作:** Magento 使用 SQL 数据库来存储数据,并提供了丰富的 API 来进行数据库操作。 - **缓存机制:** 为了提高性能,Magento 实现了多种缓存机制,包括页面缓存、块缓存等。 #### 四、Magento 电子...

    magento使用过程中六个常见的问题和解决方案

    解决这些问题通常需要对Magento架构有深入理解,包括数据库结构、MVC模式、模块化结构以及社区提供的各种资源。定期更新Magento到最新版本,保持安全性和兼容性也是很重要的。同时,使用缓存技术(如Varnish或Redis...

    Magento测试

    3. 系统测试:全面检查整个Magento系统,包括前后端功能、数据库交互等。 4. 性能测试:评估系统在高负载下的响应时间、吞吐量和资源消耗。 5. 安全测试:检查系统对各种攻击的防护能力,如SQL注入、XSS攻击等。 6. ...

    magento2-sonarqube:Sonarqube分析中适用于Magento2的规则

    例如,过度使用数据库查询或内存消耗高的操作,应尽量优化以提升 Magento 店铺的响应速度。 4. **重复代码**:SonarQube 可以识别代码库中的重复代码块,这不仅浪费存储空间,也可能导致维护困难。通过消除重复代码...

    Laravel开发-laragento

    Laragento 的出现,旨在利用 Laravel 的强大功能来优化 Magento 的开发体验,提高开发效率,并提供更好的可维护性。 **Laravel 的核心特性** 1. **路由系统**:Laravel 提供了一个清晰且灵活的路由定义方式,允许...

    基于PHP的BB中文版源码.zip

    2. **MySQL数据库**:使用SQL语句进行数据操作,理解数据库设计和关系模型。 3. **MVC架构**:Model-View-Controller模式,用于组织应用程序的逻辑。 4. **session和cookie**:用于管理用户状态和会话信息。 5. **...

    PHP学习总结

    通过类,我们可以定义属性(成员变量)和方法(成员函数),并通过实例化对象来调用这些属性和方法。此外,PHP还支持继承、多态性和封装等OOP原则,增强了代码的复用性和灵活性。 文件系统操作是PHP的另一个关键...

    一个旅游产品电子商务网站,基于SAE的PHP版.zip

    9. **性能优化**:如缓存策略、代码优化、数据库查询优化、CDN使用等提高网站性能的方法。 10. **API接口设计**:可能涉及到与其他系统或服务的接口通信,如支付平台API、物流API等。 通过学习和实践这个项目,...

    商店网站源代码,网上商城源代码

    4. **购物车功能**:源代码中包含购物车模块,允许用户添加商品、修改数量、查看总价,并能进行结算操作。购物车状态通常通过Cookie或Session在服务器端持久化。 5. **支付集成**:源代码需集成第三方支付接口,如...

    core:Mage2.PRO核心软件包

    这种自动化方法降低了出错的可能性,并提高了部署效率,对于那些不熟悉Magento 2后台操作或者希望节省时间的用户来说非常有利。 在Mage2.PRO的核心软件包中,`core-master`很可能是一个Git仓库的主分支,包含了所有...

    电子商务网站建设策划方案.doc

    3. 开发语言和框架:如PHP、Java、Python等,搭配如Magento、Shopify、Django等电商框架,可以快速开发并确保网站性能。 4. 数据库:MySQL、PostgreSQL等关系型数据库用于存储商品信息、用户数据和交易记录。 5. ...

Global site tag (gtag.js) - Google Analytics