cmueller/ansible
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

mysql_db now supports import and dump of gzip and bzip2 compressed files

Browse source
This commit is contained in:
Damian Moore 2013-09-30 19:09:32 +01:00
parent e1ff809d1a
commit 85ed9af959
1 changed files with 16 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
database/mysql_db
View file

@ -117,15 +117,25 @@ def db_delete(cursor, db):
return True return True
def db_dump(host, user, password, db_name, target): def db_dump(host, user, password, db_name, target):
res = os.system("/usr/bin/mysqldump -q -h "+host+" -u "+user+ " --password="+password+" " cmd = '/usr/bin/mysqldump -q -h ' + host + ' -u ' + user + ' --password=' + password + ' ' + db_name
+db_name+" > " if os.path.splitext(target)[-1] == '.gz':
+target) cmd = cmd + ' | gzip > ' + target
elif os.path.splitext(target)[-1] == '.bz2':
cmd = cmd + ' | bzip2 > ' + target
else:
cmd = cmd + ' > ' + target
res = os.system(cmd)
return (res == 0) return (res == 0)
def db_import(host, user, password, db_name, target): def db_import(host, user, password, db_name, target):
res = os.system("/usr/bin/mysql -h "+host+" -u "+user+" --password="+password+" " cmd = '/usr/bin/mysql -h ' + host + ' -u ' + user + ' --password=' + password + ' ' + db_name
+db_name+" < " if os.path.splitext(target)[-1] == '.gz':
+target) cmd = 'gunzip < ' + target + ' | ' + cmd
elif os.path.splitext(target)[-1] == '.bz2':
cmd = 'bunzip2 < ' + target + ' | ' + cmd
else:
cmd = cmd + ' < ' + target
res = os.system(cmd)
return (res == 0) return (res == 0)
def db_create(cursor, db, encoding, collation): def db_create(cursor, db, encoding, collation):