public function setConnectionParams($params) {
    $this->connectionParams = $params;
    if (isset($this->connectionParams['dbPrefix'])) {
      $this->dbPrefix = $this->connectionParams['dbPrefix'];
    }
  }