mysql - 使用 zend 框架 2 编写自定义查询

Question

我想在 zf2 中执行自定义查询。现在我有一个专辑控制器和专辑表。在 AlbumTable 中，我想执行一个连接操作。但我无法做到这一点。请给我一些建议。

在我的代码下方：

namespace WebApp\Table;

use Zend\Db\TableGateway\TableGateway;
use Zend\Db\Sql\Sql;

new Zend\Db\Adapter\Adapter;

class UserTable
{

   protected $tableGateway;

   public function __construct(TableGateway $tableGateway)
   {
       $this->tableGateway = $tableGateway;
   }

   public function searchUser($search)
   {

    $search    = "mehedi";
    $adapter   = new Adapter();
    $sql       = new Sql($adapter);
    $select    = $sql->select();
    $select->from('foo');
    $select->join('profiles', 'user.user_id = profiles.ownerId', array('name'));
    $select->where(array('id' => 2));
    $statement = $sql->prepareStatementForSqlObject($select);
    $results   = $statement->execute();
    return $results;
   }

}

Answer 1

通过帮助这里的所有人，我得到了这个问题的一些解决方案。

    $adapter = $this->tableGateway->getAdapter();

   /* $adapter variable is used to fetch Adapter 
   configuration from serivce manager. */

    $sql       = new Sql($adapter);
    $select    = $sql->select();
    $select->from('foo');
    $select->join('profile', 'foo.skillId = profile.id', array('name'));

    $statement = $sql->prepareStatementForSqlObject($select);
    $results   = $statement->execute();

   /* if you want you can see your
   desired output in here. */

    foreach ($results as $person) {
        echo "<pre>";
        print_r($person);
    }

    return $results;

Answer 2

问题是您尝试在没有参数的情况下实例化您的适配器，但它至少需要一个驱动程序：

 $adapter   = new Adapter(); // Bad
 $adapter   = new Adapter($driver); // ..

您应该使用 ServiceManager 来获取您的适配器，您是从 Skeleton Application 开始的吗？

它应该已经为您注入到 TableGateway 中。

$adapter = $this->getAdapter();

实例化适配器的示例：

$config = $serviceLocator->get('Config');
$adapter = new Adapter($config['db']);

在配置中指定设置的地方，local.php 将执行以下操作：

return array(
    /**
     * Database Config
     */
    'db' => array(
        'driver'    => 'pdo',
        'dsn'       => 'mysql:dbname=dbname;host=localhost',
        'username'  => 'root',
        'password'  => 'password',
    ),

Answer 3

这是因为 join 方法需要一个用于连接表的数组。此外，我个人会在查询中为表添加前缀，如下所示：-

 $search    = "mehedi";
 $adapter   = new Adapter();
 $sql       = new Sql($adapter);
 $select    = $sql->select();
 // PREFIXED THE foo table f
 $select->from(array('f' =>'foo'));
 // PREFIXED THE profiles table p 
 $select->join(array('p' => 'profiles'), 'user.user_id = profiles.ownerId', array('name'));
 $select->where(array('id' => 2));
 $statement = $sql->prepareStatementForSqlObject($select);
 $results   = $statement->execute();
 return $results;