4

Raspberry Pi から離れたいくつかの 1wire センサーを監視し、結果を MySQL データベースに保存するための Python スクリプトを作成しています。MySQL Connector/Python ライブラリを使用すると、データベースに正常に接続してクエリを実行できますが、トランザクションが完全にコミットされていないようです。out パラメーターが新しい自動インクリメント ID に設定されているため、クエリが正常に実行されることはわかっています。

CREATE TABLE `lamp`.`sensors` (
 `SensorID` int(11) unsigned NOT NULL AUTO_INCREMENT,
 `SensorSerial` char(15) NOT NULL,
 `SensorFamily` tinyint(4) NOT NULL,
 PRIMARY KEY (`SensorID`),
 UNIQUE KEY `SensorID_UNIQUE` (`SensorID`),
 UNIQUE KEY `SensorSerial_UNIQUE` (`SensorSerial`)
)

CREATE PROCEDURE `lamp`.`AddSensor` (sensorSerial char(15),
                         sensorFamily tinyint, out returnValue int)
BEGIN
 INSERT INTO sensors (SensorSerial,SensorFamily) VALUES (sensorSerial,sensorFamily);
 SET returnValue=LAST_INSERT_ID();
END

ただし、テーブルにクエリを実行しようとすると (センサーから * を選択)、0 の結果が得られます。MySQL Workbench または .Net アプリケーションから手順を実行すると、すべてが期待どおりに機能します。つまり、Connector/Python に関しては何かが欠けていますが、何が何なのかわかりません。自動インクリメント値は増加しますが、レコードが追加されないため、非常に困惑しています。エラーも報告されていません

 def Test(self):
    #this line works fine
    #self.RunProcedure("INSERT INTO sensors (SensorSerial,SensorFamily) VALUES ('{0}',{1})".format(self.ID,self.Family),False,())
    #this line does not?
    args=self.RunProcedure('AddSensor',True,(self.ID,self.Family,-1))
    if args[2]>=1:
        logging.debug("Successfully added sensor data '{1}' for sensor '{0}' to the database".format(self.ID,value))
        return True
    else:
        logging.critical("Failed to add Data to Database for unknown reason. SensorID: {0} Type: {1} Data:{2}".format(self.ID,self.Family,value))

def RunProcedure(self,proc,isStored,args):
    try:
        logging.debug("Attempting to connect to database.")
        connection=mysql.connector.connect(user='root',password='1q2w3e4r',host='localhost',database='LAMP')
    except mysql.connector.Error as e:
        logging.exception("Failed to connect to mysql database.\r\n {0}".format(e))
    else:
        logging.debug("Successfully connected to database.")
        try:
            cursor=connection.cursor()
            if isStored:
                args = cursor.callproc(proc,args)
                return args
            else:
                cursor.execute(proc,args)
            #these do not seem to solve the issue.
            #cursor.execute("Commit;")
            #connection.commit()
        except mysql.connector.Error as e:
            logging.exception("Exception while running the command '{0}' with the args of '{1}' exception is {2}".format(proc,args,e))
        finally:
            logging.debug("Closing connection to database")
            cursor.close()
            connection.close()

からログへの出力は次のようになります。

2013-06-09 13:21:25,662 Attempting to connect to database.
2013-06-09 13:21:25,704 Successfully connected to database.
2013-06-09 13:21:25,720 Closing connection to database
2013-06-09 13:21:25,723 Successfully added sensor data '22.25' for sensor '10.85FDA8020800' to the database

**編集

理由はわかりませんが、 autocommit=True を connection.open パラメータに追加すると、問題が解決したようです。コミットの問題だったので、connection.commit() または cursor.execute('commit;') が問題を修正しなかったのはなぜですか?

4

1 に答える 1