Mysql / PDO违反完整性的主数据库重复-尽管表中没有任何内容

云中怀

我已经看过SQL主键约束，尽管不存在记录，所以SO上所有问题中的哪个似乎最接近我的问题，但并不相同。
毫无疑问，我可能正在做一些愚蠢的事情，但是这里有：
我正在尝试编写一个脚本（用php编写），该脚本将从任何给定的PDO数据库迁移数据（没有结构，它假定结构已经完成）到任何其他给定的PDO数据库-
在我的情况下，我正在sqlite3上对其进行测试- > MySQL。
当我在测试数据库上运行脚本时，我收到“完整性约束冲突：1062项“ PRIMARY”的重复项“
1””，我不太了解，因为表中没有数据（即使在脚本运行之前也是如此） DELETE语句）。
我假设这与主键是auto_increment有关，但是我尝试将下一个增量值设置为除要插入的任何值之外的其他值（认为我尝试将其设置为80）-没什么区别。
我一直在寻找一种在交易过程中禁用auto_increment的方法，但没有事先更改表，然后再更改回去的方法，我想不出办法-
更改整个表似乎是错误的，我并不想参与任何DDL。
  1 setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
20
21       // connect to target
22       $target = new PDO($target_dsn, $target_username, $target_password);
23       $target->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
24
25       //TODO Generalise this statement to all database types.
26       $stmt = $source->prepare("SELECT * FROM sqlite_master WHERE type='table';");
27       $stmt->execute();
28
29       // get all tables
30       while($tablerow = $stmt->fetch(PDO::FETCH_ASSOC))
31       {
32                // TODO Generalise these statements to all database types.
33                $transfer_data[$tablerow['tbl_name']] = array();
34                $table_data[$tablerow['tbl_name']] = array();
35       }
36       $stmt->closeCursor();
37
38       // for each table, load data
39       foreach($transfer_data as $tablename => $void)
40       {
41                $stmt = $source->prepare("SELECT * FROM $tablename;");
42                $stmt->execute();
43                // load data row at a time
44                while($datarow = $stmt->fetch(PDO::FETCH_ASSOC))
45                {
46                      // store data for later
47                      $transfer_data[$tablename][] = $datarow;
48                      // if we haven't gained column data yet, do so now
49                      if(!array_key_exists($tablename,$table_data))
50                      {
51                               $t_data = array();
52                               foreach($datarow as $colname => $void)
53                               {
54                                        $t_data[] = $colname;
55                               }
56                               $table_data[$tablename] = $t_data;
57                      }
58                }
59                $stmt->closeCursor();
60                echo "Read $tablename\n";
61       }
62
63       //start a transaction (if driver supports transactions / if not then this is noop)
64       $target->beginTransaction();
65       // for each table clear existing data and insert copied data
66       foreach($table_data as $tablename => $columns)
67       {
68                // not using an empty/truncate because mysql and possibly others autocommit
69                $stmt = $target->prepare("DELETE FROM $tablename;");
70                $stmt->execute();
71                $stmt->closeCursor();
72
73                // prepare the insert statement - we don't know how many columns so is dynamic
74                $querystr = "INSERT INTO $tablename (".join(", ",$columns).") VALUES (";
75                foreach($columns as $k => $column)
76                {
77                      $columns[$k] = ':'.$column;
78                }
79                // using named placeholders so order doesn't matter
80                $querystr = $querystr.join(", ",$columns).");";
81                $stmt = $target->prepare($querystr);
82                //echo "Using: $querystr\n";
83                $rowcount = 0;
84                // for each row of data, bind data and execute insert statement
85                foreach($transfer_data[$tablename] as $rowdata)
86                {
87                      foreach($rowdata as $rowname => $rowvalue)
88                      {
89                               $stmt->bindParam(':'.$rowname, $rowvalue);
90                      }
91                      $stmt->execute();
92                      $stmt->closeCursor();
93                      $rowcount++;
94                }
95                echo "Written $rowcount rows to $tablename\n";
96       }
97       $target->commit();
98
99 }
100 catch (PDOException $e)
101 {
102       echo 'PDO Error: '.get_class($e).' - '.$e->getMessage()."\n";
103       echo 'Query String was: '.$querystr."\nData:\n";
104       var_export($transfer_data[$tablename]);
105       if($target->inTransaction()){
106                $target->rollBack();
107       }
108 }
109
现在我的目标数据库中有一个表，该表是：
+-------------------+------------------+------+-----+---------+----------------+
| Field          | Type          | Null | Key | Default | Extra       |
+-------------------+------------------+------+-----+---------+----------------+
| channel_id       | int(11)       | NO | PRI | NULL | auto_increment |
| channel_parent_id | int(10) unsigned | YES  |    | NULL |             |
| server_id       | int(10) unsigned | NO | MUL | NULL |             |
+-------------------+------------------+------+-----+---------+----------------+
输出为：
PDO Error: PDOException - SQLSTATE[23000]: Integrity constraint violation: 1062 Duplicate entry '1' for key 'PRIMARY'
Query String was: INSERT INTO channels (channel_id, channel_parent_id, server_id) VALUES (:channel_id, :channel_parent_id, :server_id);
Data:
array (
  0 =>
  array (
'channel_id' => '1',
'channel_parent_id' => '0',
'server_id' => '1',
  ),
  1 =>
  array (
'channel_id' => '24',
'channel_parent_id' => '0',
'server_id' => '1',
  ),
  2 =>
  array (
'channel_id' => '34',
'channel_parent_id' => '0',
'server_id' => '1',
  ),

解决方案:


            很高兴您解决了这个问题。然而，这是为了应对理由为什么bindParam()不为你工作。这不是错误，它是通过设计以这种方式工作的。
根据文档：

将PHP变量绑定到用于准备语句的SQL语句中的相应命名或问号占位符。与PDOStatement :: bindValue（）不同，该变量被绑定
为引用，并且仅在调用PDOStatement :: execute（）时进行评估 。

（强调我的）
考虑到上述情况，这是：
87                      foreach($rowdata as $rowname => $rowvalue)
88                      {
89                               $stmt->bindParam(':'.$rowname, $rowvalue);
90                      }
…将$rowvalue 通过查询将每个参数绑定到引用，在执行查询时，该引用将始终是1（的最后一个元素$rowdata）
使用它的方式bindParam()可能是这样的：
87                      foreach($rowdata as $rowname => $rowvalue)
88                      {
89                               $stmt->bindParam(':'.$rowname, $rowdata[$rowname]);
90                      }
…或者，甚至：
87                      foreach($rowdata as $rowname => &$rowvalue)
88                      {
89                               $stmt->bindParam(':'.$rowname, $rowvalue);
90                      }
…，以便每个参数都引用相应的array 元素。
如上所述，一种替代方法是 _通过值_而不是通过引用bindValue()绑定参数。这意味着将在调用该参数时对其进行评估，而不是在实际需要该参数时（即查询执行）进行评估：__bindValue()
87                      foreach($rowdata as $rowname => $rowvalue)
88                      {
89                               $stmt->bindValue(':'.$rowname, $rowvalue);
90                      }
当然，另一种选择是输入execute()一组参数，这可以execute()解析绑定部分（因此是我个人的最爱！）。

Mysql / PDO违反完整性的主数据库重复-尽管表中没有任何内容

云中怀 LV1