ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

switch to DictCursor

Browse source
This commit is contained in:
Dylan Martin 2013-10-02 13:00:07 -07:00
parent df529b9b69
commit 6b26a73681
1 changed files with 10 additions and 53 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

63
library/database/mysql_replication
View file

@ -294,69 +294,26 @@ def main():
db_connection = MySQLdb.connect(host=module.params["login_host"], unix_socket=module.params["login_unix_socket"], user=login_user, passwd=login_password, db="mysql") db_connection = MySQLdb.connect(host=module.params["login_host"], unix_socket=module.params["login_unix_socket"], user=login_user, passwd=login_password, db="mysql")
else: else:
db_connection = MySQLdb.connect(host=module.params["login_host"], user=login_user, passwd=login_password, db="mysql") db_connection = MySQLdb.connect(host=module.params["login_host"], user=login_user, passwd=login_password, db="mysql")
cursor = db_connection.cursor()
except Exception, e: except Exception, e:
module.fail_json(msg="unable to connect to database, check login_user and login_password are correct or ~/.my.cnf has the credentials") module.fail_json(msg="unable to connect to database, check login_user and login_password are correct or ~/.my.cnf has the credentials")
try:
cursor = db_connection.cursor(cursorclass=MySQLdb.cursors.DictCursor)
except Exception, e:
module.fail_json(msg="Trouble getting DictCursor from db_connection: %s" % e)
if mode in "getmaster": if mode in "getmaster":
masterstatus = get_master_status(cursor) masterstatus = get_master_status(cursor)
try: try:
module.exit_json( module.exit_json( **masterstatus )
File=masterstatus[0], except TypeError, e:
Position=masterstatus[1], module.fail_json(msg="Server is not configured as mysql master: %s" % e)
Binlog_Do_DB=masterstatus[2],
Binlog_Ignore_DB=masterstatus[3]
)
except TypeError:
module.fail_json(msg="Server is not configured as mysql master")
elif mode in "getslave": elif mode in "getslave":
slavestatus = get_slave_status(cursor) slavestatus = get_slave_status(cursor)
try: try:
module.exit_json( module.exit_json( **slavestatus )
Slave_IO_State=slavestatus[0], except TypeError, e:
Master_Host=slavestatus[1], module.fail_json(msg="Server is not configured as mysql slave: %s" % e)
Master_User=slavestatus[2],
Master_Port=slavestatus[3],
Connect_Retry=slavestatus[4],
Master_Log_File=slavestatus[5],
Read_Master_Log_Pos=slavestatus[6],
Relay_Log_File=slavestatus[7],
Relay_Log_Pos=slavestatus[8],
Relay_Master_Log_File=slavestatus[9],
Slave_IO_Running=slavestatus[10],
Slave_SQL_Running=slavestatus[11],
Replicate_Do_DB=slavestatus[12],
Replicate_Ignore_DB=slavestatus[13],
Replicate_Do_Table=slavestatus[14],
Replicate_Ignore_Table=slavestatus[15],
Replicate_Wild_Do_Table=slavestatus[16],
Replicate_Wild_Ignore_Table=slavestatus[17],
Last_Errno=slavestatus[18],
Last_Error=slavestatus[19],
Skip_Counter=slavestatus[20],
Exec_Master_Log_Pos=slavestatus[21],
Relay_Log_Space=slavestatus[22],
Until_Condition=slavestatus[23],
Until_Log_File=slavestatus[24],
Until_Log_Pos=slavestatus[25],
Master_SSL_Allowed=slavestatus[26],
Master_SSL_CA_File=slavestatus[27],
Master_SSL_CA_Path=slavestatus[28],
Master_SSL_Cert=slavestatus[29],
Master_SSL_Cipher=slavestatus[30],
Master_SSL_Key=slavestatus[31],
Seconds_Behind_Master=slavestatus[32],
Master_SSL_Verify_Server_Cert=slavestatus[33],
Last_IO_Errno=slavestatus[34],
Last_IO_Error=slavestatus[35],
Last_SQL_Errno=slavestatus[36],
Last_SQL_Error=slavestatus[37],
Replicate_Ignore_Server_Ids=slavestatus[38],
Master_Server_Id=slavestatus[39]
)
except TypeError:
module.fail_json(msg="Server is not configured as mysql slave")
elif mode in "changemaster": elif mode in "changemaster":
print "Change master" print "Change master"