| @@ 55-68 (lines=14) @@ | ||
| 52 | * |
|
| 53 | * @return FileNodeInterface |
|
| 54 | */ |
|
| 55 | public function export(TableNodeInterface $table) |
|
| 56 | { |
|
| 57 | list ($sql, $bind) = $table->getAdapter()->getDialect()->getSelectSyntax($table); |
|
| 58 | ||
| 59 | $query = $this->getBuilder()->build(QueryNode::class, $table->getAdapter(), $sql, $bind); |
|
| 60 | ||
| 61 | $this->log(LogLevel::DEBUG, "Exporting redshift table: {table} to file: {file}", [ |
|
| 62 | 'table' => $table, |
|
| 63 | 'file' => $this->file, |
|
| 64 | ]); |
|
| 65 | ||
| 66 | $exporter = $this->getBuilder()->build(RedshiftQueryExporter::class, $this->file); |
|
| 67 | return $exporter->export($query); |
|
| 68 | } |
|
| 69 | } |
|
| 70 | ||
| @@ 45-58 (lines=14) @@ | ||
| 42 | * |
|
| 43 | * @return FileNodeInterface |
|
| 44 | */ |
|
| 45 | public function export(TableNodeInterface $table) |
|
| 46 | { |
|
| 47 | list ($sql, $bind) = $table->getAdapter()->getDialect()->getSelectSyntax($table); |
|
| 48 | ||
| 49 | $query = $this->getBuilder()->build(QueryNode::class, $table->getAdapter(), $sql, $bind); |
|
| 50 | ||
| 51 | $this->log(LogLevel::INFO, "Exporting table: {table} to file: {file}", [ |
|
| 52 | 'table' => $table, |
|
| 53 | 'file' => $this->file, |
|
| 54 | ]); |
|
| 55 | ||
| 56 | $exporter = $this->getBuilder()->build(QueryExporter::class, $this->file, $this->format); |
|
| 57 | return $exporter->export($query); |
|
| 58 | } |
|
| 59 | } |
|
| 60 | ||