python MySQLdbの利用について

Question

python2.7でMySQLにINSTERを行いたいのですが、上手くデータが入りません。
型が違うなどのエラー等も出ていない為、何故データが入らないのか不明なので、ご教示頂ければと思います。

mysql_connnect.py

#!/usr/bin/env python
# coding: utf-8

import MySQLdb
import yaml

CONFIG_FILE = "/Path/To/conf/dbconf.yaml"

f = open(CONFIG_FILE, 'r')
dbconf = yaml.load(f)
f.close()

class Mysql_con(object):
    def __init__(self,query):
        self.query   = query

    def execute(self):
        result = []
        connection   = MySQLdb.connect(
            host     = dbconf["dbhost"],
            db       = dbconf["dbname"],
            port     = dbconf["port"],
            user     = dbconf["user"],
            passwd   = dbconf["pass"] )

        con = connection.cursor()
        con.execute(self.query)

        for record in con.fetchall():
            result.extend(record)
            print result
        return result

        con.close()

呼び出し側

        query = "insert into aws_rds (project ,instance_name ,instance_type ,strage ,engine) \
        values (\'{project}\' , \'{instance_name}\' , \'{instance_type}\' , \'{strage}\' , \'{engine}\') \
        on duplicate key update \
        project          = \'{project}\' \
        ,instance_name   = \'{instance_name}\' \
        ,instance_type  = \'{instance_type}\' \
        ,strage         = \'{strage}\' \
        ,engine         = \'{engine}\'".format \
        ( project=rows[0], instance_name=rows[1], instance_type=rows[2], strage=rows[3], engine=rows[4] )

        add = Mysql_con(query)
        add.execute()

AWSのRDSインスタンスの状態を取得するスクリプトですが、
mysqlのクエリログには、適切にクエリが生成され発行されているようでした。
※ クエリログに記載されたSQL文を、コピペして実行するとデータが追加されます。

mysql> desc aws_rds;
+---------------+--------------+------+-----+---------+----------------+
| Field         | Type         | Null | Key | Default | Extra          |
+---------------+--------------+------+-----+---------+----------------+
| id            | int(11)      | NO   | PRI | NULL    | auto_increment |
| project       | varchar(100) | NO   | MUL | NULL    |                |
| instance_name | varchar(250) | NO   |     | NULL    |                |
| instance_type | varchar(250) | NO   |     | NULL    |                |
| strage        | int(11)      | NO   |     | NULL    |                |
| engine        | varchar(100) | NO   |     | NULL    |                |
+---------------+--------------+------+-----+---------+----------------+
6 rows in set (0.00 sec)

mysql_query.log

2248 Connect   root@localhost on DB名
2248 Query     set autocommit=0
2248 Query     insert into aws_rds (project ,instance_name ,instance_type ,strage ,engine)         values ('test-project' , 'dev-db001' , 'db.r3.large' , '1' , 'aurora')         on duplicate key update         project          = 'test-project'         ,instance_name   = 'dev-db001'         ,instance_type  = 'db.r3.large'         ,strage         = '1'         ,engine         = 'aurora'
2248 Quit

以上、宜しくお願いします。

Answer 1

ログをみて、ぱっと思いつく感じでは、

• MySQLサーバーがオートコミットがオフになっている
• INSERT実行後にcommitをしていない

という2点が原因となって、INSERTしたものがロールバックされているように見えます。

#!/usr/bin/env python
# coding: utf-8

import MySQLdb

# (略)

class Mysql_con(object):
    def __init__(self,query):
        self.query   = query

    def execute(self):
        # (略)

        con = connection.cursor()
        con.execute(self.query)
        connection.commit()  # <-- ここで、INSERTクエリをcommitする

        # (略)

上記のように、途中で明示的にcommit()を実行することで解消はするかと思います。

Comments

[JunMatsumoto]

connection.commit()を挟むことでデータが入りました。
ありがとうございました！