public function dropSchemaFor(StreamName $streamName, $returnSql = false)
    {
        $dropTable = new DropTable($this->getTable($streamName));

        if ($returnSql) {
            return $dropTable->getSqlString($this->dbAdapter->getPlatform());
        }

        $this->dbAdapter->getDriver()
            ->getConnection()
            ->execute($dropTable->getSqlString($this->dbAdapter->getPlatform()));
    }