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

Check for database ownership

Browse source
This commit is contained in:
Pepe Barbe 2012-08-22 12:20:51 -05:00
parent bf92a9e4e0
commit fdbc99dc28
1 changed files with 35 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

53
library/postgresql_db
View file

@ -27,26 +27,45 @@ else:
# PostgreSQL module specific support methods. # PostgreSQL module specific support methods.
# #
def set_owner(cursor, db, owner):
query = "ALTER DATABASE %s OWNER TO %s" % (db, owner)
cursor.execute(query)
return True
def db_owned_by(cursor, db, user):
query = """SELECT count(*) FROM pg_database JOIN pg_user ON datdba = usesysid
WHERE usename = %(user)s and datname = %(db)s"""
cursor.execute(query, {'db':db, 'user':user})
return cursor.rowcount == 1
def db_exists(cursor, db): def db_exists(cursor, db):
query = "SELECT * FROM pg_database WHERE datname=%(db)s" query = "SELECT * FROM pg_database WHERE datname=%(db)s"
cursor.execute(query, {'db': db}) cursor.execute(query, {'db': db})
return cursor.rowcount == 1 return cursor.rowcount == 1
def db_delete(cursor, db): def db_delete(cursor, db):
query = "DROP DATABASE %s" % db if db_exists(cursor, db):
cursor.execute(query) query = "DROP DATABASE %s" % db
return True cursor.execute(query)
return True
else:
return False
def db_create(cursor, db, owner, template, encoding): def db_create(cursor, db, owner, template, encoding):
if owner: if not db_exists(cursor, db):
owner = " OWNER %s" % owner if owner:
if template: owner = " OWNER %s" % owner
template = " TEMPLATE %s" % template if template:
if encoding: template = " TEMPLATE %s" % template
encoding = " ENCODING '%s'" % encoding if encoding:
query = "CREATE DATABASE %s%s%s%s" % (db, owner, template, encoding) encoding = " ENCODING '%s'" % encoding
cursor.execute(query) query = "CREATE DATABASE %s%s%s%s" % (db, owner, template, encoding)
return True cursor.execute(query)
return True
elif owner and not db_owned_by(cursor, db, owner):
return set_owner(cursor, db, owner)
else:
return False
# =========================================== # ===========================================
# Module execution. # Module execution.
@ -100,12 +119,10 @@ def main():
module.fail_json(msg="unable to connect to database: %s" % e) module.fail_json(msg="unable to connect to database: %s" % e)
try: try:
if db_exists(cursor, db): if state == "absent":
if state == "absent": changed = db_delete(cursor, db)
changed = db_delete(cursor, db) elif state == "present":
else: changed = db_create(cursor, db, owner, template, encoding)
if state == "present":
changed = db_create(cursor, db, owner, template, encoding)
except Exception, e: except Exception, e:
module.fail_json(msg="Database query failed: %s" % e) module.fail_json(msg="Database query failed: %s" % e)