mirror of
https://github.com/vrana/adminer.git
synced 2025-08-24 07:02:51 +02:00
MS SQL: Set identity_insert in CSV import
This commit is contained in:
@@ -187,15 +187,14 @@ if (isset($_GET["mssql"])) {
|
|||||||
|
|
||||||
function insertUpdate($table, $rows, $primary) {
|
function insertUpdate($table, $rows, $primary) {
|
||||||
$fields = fields($table);
|
$fields = fields($table);
|
||||||
|
queries("SET IDENTITY_INSERT " . table($table) . " ON");
|
||||||
foreach ($rows as $set) {
|
foreach ($rows as $set) {
|
||||||
$update = array();
|
$update = array();
|
||||||
$insert = array();
|
|
||||||
$where = array();
|
$where = array();
|
||||||
foreach ($set as $key => $val) {
|
foreach ($set as $key => $val) {
|
||||||
$name = idf_unescape($key);
|
$name = idf_unescape($key);
|
||||||
if (!$fields[$name]["auto_increment"]) {
|
if (!$fields[$name]["auto_increment"]) {
|
||||||
$update[] = "$key = $val";
|
$update[] = "$key = $val";
|
||||||
$insert[$key] = $val;
|
|
||||||
}
|
}
|
||||||
if (isset($primary[$name])) {
|
if (isset($primary[$name])) {
|
||||||
$where[] = "$key = $val";
|
$where[] = "$key = $val";
|
||||||
@@ -204,11 +203,12 @@ if (isset($_GET["mssql"])) {
|
|||||||
//! can use only one query for all rows
|
//! can use only one query for all rows
|
||||||
if (!queries("MERGE " . table($table) . " USING (VALUES(" . implode(", ", $set) . ")) AS source (c" . implode(", c", range(1, count($set))) . ") ON " . implode(" AND ", $where) //! source, c1 - possible conflict
|
if (!queries("MERGE " . table($table) . " USING (VALUES(" . implode(", ", $set) . ")) AS source (c" . implode(", c", range(1, count($set))) . ") ON " . implode(" AND ", $where) //! source, c1 - possible conflict
|
||||||
. " WHEN MATCHED THEN UPDATE SET " . implode(", ", $update)
|
. " WHEN MATCHED THEN UPDATE SET " . implode(", ", $update)
|
||||||
. " WHEN NOT MATCHED THEN INSERT (" . implode(", ", array_keys($insert)) . ") VALUES (" . implode(", ", $insert) . ");" // ; is mandatory
|
. " WHEN NOT MATCHED THEN INSERT (" . implode(", ", array_keys($set)) . ") VALUES (" . implode(", ", $set) . ");" // ; is mandatory
|
||||||
)) {
|
)) {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
queries("SET IDENTITY_INSERT " . table($table) . " OFF");
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user