sql.py

#!/usr/bin/python

import config

import os
def processSql(sqlTmpDir, filename):
	log = "Processing sql sources\n"
	
	# First, let's make sure we're actually using the sql database source flag in config
	if config.sqlBackup == True:
		# If the SQL temp backup location doesn't exist, create it.
		if not os.path.exists(sqlTmpDir):
			os.makedirs(sqlTmpDir)
			
		# Then process each database
		for source in config.sqlServers:
			sql = createSqlConn(source[0], source[1], source[2], source[3])
			dbFileName = sqlTmpDir + "/" + source[0] + "_" + filename + ".sql"
			processBackup(sql, dbFileName)
			log += sql.log
	else:
		log += "SQL Backup not enabled\n"
		
	return {
		'log':log,
		'enabled':config.sqlBackup
		}

def createSqlConn(backend, db_user, db_pass, db_host):
	if backend == "mysql":
		import backup_sources.databases.mysql
		sql =  backup_sources.databases.mysql.sql(db_user, db_pass, db_host)
		return sql
	else:
		raise Exception("No valid SQL providers match the source given.")

def processBackup(sql, dbFileName):
	sql.obtainBackup(dbFileName)
	
def checkDir(d):
	if not os.path.exists(d):
		os.makedirs(d)

if __name__ == "__main__":
	processSql("temp")