文档参考:

$this->getDefault()
获取默认服务器连接,返回\Doctrine\DBAL\Connection对象
$this->getRead($name = null)
$this->getWrite($name = null)
获取写服务器连接,若name不填,随机读取。
$this->getAllRead()
$this->getAllWrite()
$this->querySql($sql, $type, $name = null)
具体业务中使用:
  1. namespace src\Service\User\Dao\Impl;
  2. use Dao;
  3. use src\Service\User\Dao\UserDao;
  4. class UserDaoImpl extends Dao implements UserDao
  5. protected $table = "user";
  6. public function getUser($id)
  7. {
  8. $queryBuilder = $this->getDefault()->createQueryBuilder();
  9. $queryBuilder
  10. ->select("*")
  11. ->from($this->table)
  12. ->setParameter(0, $id);
  13. return $queryBuilder->execute()->fetch();
  14. }
  15. public function addUser($user)
  16. {
  17. $conn = $this->getDefault();
  18. $affected = $conn->insert($this->table, $user);
  19. if ($affected <= 0) {
  20. }
  21. return $conn->lastInsertId();
  22. }
  23. {
  24. $queryBuilder = $this->getDefault()->createQueryBuilder();
  25. $queryBuilder
  26. ->select("*")
  27. ->from($this->table)
  28. ->where('mobile = ?')
  29. ->setParameter(0, $mobile);
  30. return $queryBuilder->execute()->fetch();
  31. }
  32. public function updateUserPassword($userId, $password)
  33. {
  34. return $this->getDefault()->update($this->table, ['password' => $password], ['id' => $userId]);