1

我有以下查询

INSERT INTO `min01_aggregated_data_800` (`datenum`,`Timestamp`,`QFlag_R6_WYaw`)  VALUES ('734970.002777778','2012-04-11 00:04:00.000','989898') ON DUPLICATE KEY UPDATE `datenum`=VALUES(`datenum`);
INSERT INTO `min01_aggregated_data_100` (`datenum`,`Timestamp`,`QFlag_R6_WYaw`)  VALUES ('734970.002777778','2012-04-11 00:04:00.000','989898') ON DUPLICATE KEY UPDATE `datenum`=VALUES(`datenum`);
INSERT INTO `min01_aggregated_data_300` (`datenum`,`Timestamp`,`QFlag_R6_WYaw`)  VALUES ('734970.002777778','2012-04-11 00:04:00.000','989898') ON DUPLICATE KEY UPDATE `datenum`=VALUES(`datenum`);

我正在使用mysql.connector包将数据插入 MySQL

self.db = mysql.connector.Connect( host = self.m_host, user = self.m_user, password = self.m_passwd, \
        database = self.m_db, port = int( self.m_port ) )
self.con = self.db.cursor( cursor )

self.con.execute( query ) 
self.db.commit()  
self.db.close()
self.con.close()

但我收到以下错误Use multi=True when executing multiple statements

我尝试使用multi=True在这种情况下我没有得到任何异常，但数据不会被插入到 MySQL 中。如何插入多行？

4

2 回答 2

0

您有三个单独的查询，因此每个查询都应单独运行，即：

self.con.execute(query1)
self.con.execute(query2)
self.con.execute(query3)
于 2013-03-02T03:44:06.170 回答
0

我看到三个选项：

  1. 将每个查询分别发送到数据库：

    [...]
self.con.execute(query1)
self.con.execute(query2)
self.con.execute(query3)
[...]

  2. [已删除，因为它不适用于此处]

  3. 但是，我对此不是很熟悉multi=True；可能有一个解决方案可以self.con.nextset()反复调用。根据文档，这仅适用于多个结果集，但也许在多查询请求中也需要它。

于 2013-02-28T11:48:11.963 回答