lsst.datarel.mysqlExecutor.MysqlExecutor Class Reference

Inheritance diagram for lsst.datarel.mysqlExecutor.MysqlExecutor:

Public Member Functions
def	__init__ (self, host, database, user, port=3306, password=None)
def	createDb (self, database, options=['-vvv'])
def	execStmt (self, stmt, stdout=sys.stdout, options=['-vvv'])
def	execScript (self, script, options=['-vvv'])
def	runQuery (self, query)
def	isView (self, table)
def	exists (self, table)
def	getConn (self)

Public Attributes
	host
	port
	user
	database
	password
	mysqlCmd

Detailed Description

Definition at line 35 of file mysqlExecutor.py.

Constructor & Destructor Documentation

__init__()

def lsst.datarel.mysqlExecutor.MysqlExecutor.__init__	(		self,
			host,
			database,
			user,
			port = 3306,
			password = None
	)

Definition at line 37 of file mysqlExecutor.py.

    def __init__(self, host, database, user, port=3306, password=None):
        self.host = host
        self.port = port
        self.user = user
        self.database = database
        if password is None:
            if self.host is not None and self.port is not None and \
                    DbAuth.available(self.host, str(self.port)):
                self.user = DbAuth.username(self.host, str(self.port))
                password = DbAuth.password(self.host, str(self.port))
            elif not os.path.exists(os.path.join(os.environ['HOME'], ".my.cnf")):
                password = getpass.getpass("%s's MySQL password: " % user)
        self.password = password
        self.mysqlCmd = ['mysql']
        if host is not None:
            self.mysqlCmd += ['-h', self.host]
        if port is not None:
            self.mysqlCmd += ['-P', str(self.port)]
        if user is not None:
            self.mysqlCmd += ['-u', self.user]
        if password is not None:
            self.mysqlCmd += ['-p' + self.password]

Member Function Documentation

createDb()

def lsst.datarel.mysqlExecutor.MysqlExecutor.createDb	(		self,
			database,
			options = ['-vvv']
	)

Definition at line 60 of file mysqlExecutor.py.

    def createDb(self, database, options=['-vvv']):
        if not isinstance(database, basestring):
            raise TypeError('database name is not a string')
        cmd = list(self.mysqlCmd)
        cmd += options
        cmd += ['-e', 'CREATE DATABASE %s;' % database]
        subprocess.check_call(cmd, stdout=sys.stdout, stderr=sys.stderr)
        sys.stdout.flush()
        sys.stderr.flush()

execScript()

def lsst.datarel.mysqlExecutor.MysqlExecutor.execScript	(		self,
			script,
			options = ['-vvv']
	)

Definition at line 82 of file mysqlExecutor.py.

    def execScript(self, script, options=['-vvv']):
        if not isinstance(script, basestring):
            raise TypeError('Script file name is not a string')
        if not os.path.isfile(script):
            raise RuntimeError(
                'Script %s does not exist or is not a file' % script)
        with open(script, 'rb') as f:
            cmd = list(self.mysqlCmd)
            if self.database is not None:
                cmd += ['-D', self.database]
            cmd += options
            subprocess.check_call(cmd, stdin=f,
                                  stdout=sys.stdout, stderr=sys.stderr)
            sys.stdout.flush()
            sys.stderr.flush()

execStmt()

def lsst.datarel.mysqlExecutor.MysqlExecutor.execStmt	(		self,
			stmt,
			stdout = sys.stdout,
			options = ['-vvv']
	)

Definition at line 70 of file mysqlExecutor.py.

    def execStmt(self, stmt, stdout=sys.stdout, options=['-vvv']):
        if not isinstance(stmt, basestring):
            raise TypeError('SQL statement is not a string')
        cmd = list(self.mysqlCmd)
        if self.database is not None:
            cmd += ['-D', self.database]
        cmd += options
        cmd += ['-e', stmt]
        subprocess.check_call(cmd, stdout=stdout, stderr=sys.stderr)
        stdout.flush()
        sys.stderr.flush()

exists()

def lsst.datarel.mysqlExecutor.MysqlExecutor.exists	(		self,
			table
	)

Definition at line 116 of file mysqlExecutor.py.

    def exists(self, table):
        with closing(self.getConn()) as conn:
            with closing(conn.cursor()) as cursor:
                cursor.execute('SELECT COUNT(*) FROM information_schema.tables '
                               'WHERE table_schema=%s AND table_name=%s',
                               (self.database, table))
                return cursor.fetchone()[0] == 1

getConn()

def lsst.datarel.mysqlExecutor.MysqlExecutor.getConn

(

self

)

Definition at line 124 of file mysqlExecutor.py.

    def getConn(self):
        kw = dict()
        if self.host is not None:
            kw['host'] = self.host
        if self.port is not None:
            kw['port'] = self.port
        if self.user is not None:
            kw['user'] = self.user
        if self.database is not None:
            kw['db'] = self.database
        if self.password is not None:
            kw['passwd'] = self.password
        return sql.connect(**kw)

isView()

def lsst.datarel.mysqlExecutor.MysqlExecutor.isView	(		self,
			table
	)

Definition at line 108 of file mysqlExecutor.py.

    def isView(self, table):
        with closing(self.getConn()) as conn:
            with closing(conn.cursor()) as cursor:
                cursor.execute('SELECT COUNT(*) FROM information_schema.tables '
                               'WHERE table_schema=%s AND table_name=%s AND '
                               'table_type=\'VIEW\'', (self.database, table))
                return cursor.fetchone()[0] == 1

runQuery()

def lsst.datarel.mysqlExecutor.MysqlExecutor.runQuery	(		self,
			query
	)

Definition at line 98 of file mysqlExecutor.py.

    def runQuery(self, query):
        if not isinstance(query, basestring):
            raise TypeError('Query is not a string')
        with closing(self.getConn()) as conn:
            with closing(conn.cursor()) as cursor:
                print(query)
                sys.stdout.flush()
                cursor.execute(query)
                return cursor.fetchall()

Member Data Documentation

database

lsst.datarel.mysqlExecutor.MysqlExecutor.database

Definition at line 41 of file mysqlExecutor.py.

host

lsst.datarel.mysqlExecutor.MysqlExecutor.host

Definition at line 38 of file mysqlExecutor.py.

mysqlCmd

lsst.datarel.mysqlExecutor.MysqlExecutor.mysqlCmd

Definition at line 50 of file mysqlExecutor.py.

password

lsst.datarel.mysqlExecutor.MysqlExecutor.password

Definition at line 49 of file mysqlExecutor.py.

port

lsst.datarel.mysqlExecutor.MysqlExecutor.port

Definition at line 39 of file mysqlExecutor.py.

user

lsst.datarel.mysqlExecutor.MysqlExecutor.user

Definition at line 40 of file mysqlExecutor.py.

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/snowflake/release/lsstsw/stack/Linux64/datarel/14.0+77/python/lsst/datarel/mysqlExecutor.py