gian/phpmyadmin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

csv_replace & csv_ignore

Browse Source 
Signed-off-by: Kamil Tekiela <tekiela246@gmail.com>
This commit is contained in:
Kamil Tekiela 2024-03-18 16:11:25 +01:00
parent 866564bc9d
commit 7d5a811328
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Plugins/Import/ImportCsv.php
View File

@ -54,6 +54,8 @@ class ImportCsv extends AbstractImportCsv
*/
private bool $analyze = false;
private bool $replace = false;
private bool $ignore = false;
private string $terminated = '';
private string $enclosed = '';
private string $escaped = '';
@ -163,6 +165,8 @@ class ImportCsv extends AbstractImportCsv
public function setImportOptions(ServerRequest $request): void
{
$this->replace = $request->getParsedBodyParam('csv_replace') !== null;
$this->ignore = $request->getParsedBodyParam('csv_ignore') !== null;
$this->terminated = (string) $request->getParsedBodyParam('csv_terminated');
$this->enclosed = (string) $request->getParsedBodyParam('csv_enclosed');
$this->escaped = (string) $request->getParsedBodyParam('csv_escaped');
@ -183,9 +187,6 @@ class ImportCsv extends AbstractImportCsv
$GLOBALS['message'] ??= null;
$GLOBALS['errorUrl'] ??= null;
// $csv_replace and $csv_ignore should have been here,
// but we use directly from $_POST
$replacements = ['\\n' => "\n", '\\t' => "\t", '\\r' => "\r"];
$this->terminated = strtr($this->terminated, $replacements);
$this->enclosed = strtr($this->enclosed, $replacements);
@ -523,7 +524,7 @@ class ImportCsv extends AbstractImportCsv
}
$sql .= ')';
if (isset($_POST['csv_replace'])) {
if ($this->replace) {
$sql .= ' ON DUPLICATE KEY UPDATE ';
foreach ($fields as $field) {
$fieldName = Util::backquote($field);
@ -738,7 +739,7 @@ class ImportCsv extends AbstractImportCsv
$fields = [];
if (! $this->analyze && $db !== null && $table !== null) {
$sqlTemplate = 'INSERT';
if (isset($_POST['csv_ignore'])) {
if ($this->ignore) {
$sqlTemplate .= ' IGNORE';
}