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
以上、宜しくお願いします。
回答1件
あなたの回答
tips
プレビュー
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。
2016/11/29 06:41