try: import oursql as mysqldb except ImportError: import MySQLdb as mysqldb class MYSQL_RED: #Save mysqldb-connection as class attribute to use only one in descendant classes connection = False db_hostname='localhost' db_username='gwlocal' db_password='RigTawwewmyagPepotugco' db_name='gwlocal_wiki' def __init__( self ): """ Opens a connection to MySQL-DB @returns mysql-stream MySQL Connection """ # Connect to mysqldb only once if( type( self ).connection == False ): type( self ).connection = mysqldb.connect( host=type( self ).db_hostname, user=type( self ).db_username, passwd=type( self ).db_password, db=type( self ).db_name ) def __del__( self ): """ Before deleting class, close connection to MySQL-DB """ type( self ).connection.close() class MYSQL_RED_PAGE( MYSQL_RED ): def __init__( self, page_id ): """ Creates a new instance, runs __init__ of parent class """ super().__init__( ) self.__page_id = int( page_id ); self.data = self.get_page() def get_page( self ): """ Retrieves a red page row from MySQL-Database for given page_id @param int page_id MediaWiki page_id for page to retrieve @returns tuple Tuple with data for given page_id otherwise if none found bool FALSE """ cursor = type( self ).connection.cursor(mysqldb.DictCursor) cursor.execute( 'SELECT * FROM `red_pages` WHERE `page_id` = ?;', ( self.__page_id, ) ) res = cursor.fetchone() if res: return res else: return False def add_page( self, page_title, rev_id, status=0 ): """ Inserts a red page row in MySQL-Database for given page_id @param int rev_id MediaWiki current rev_id for page to update @param str page_title MediaWiki new page_title for page to update @param int status Page parsing status (0 - not (successfully) parsed; 1 - successfully parsed; 2 - successfully parsed archive) """ cursor = type( self ).connection.cursor() if not page_title: page_title = self.data[ 'page_title' ] if not rev_id: rev_id = self.data[ 'rev_id' ] query = 'INSERT INTO `red_pages` ( page_id, page_title, rev_id, status ) VALUES ( ?, ?, ?, ? );' data = ( self.__page_id, str( page_title ), int( rev_id ), int( status ) ) cursor.execute( query, data) type( self ).connection.commit() def update_page( self, rev_id=None, page_title=None, status=0 ): """ Updates the red page row in MySQL-Database for given page_id @param int rev_id MediaWiki current rev_id for page to update @param str page_title MediaWiki new page_title for page to update @param int status Page parsing status (0 - not (successfully) parsed; 1 - successfully parsed) """ cursor = type( self ).connection.cursor() if not page_title: page_title = self.data[ 'page_title' ] if not rev_id: rev_id = self.data[ 'rev_id' ] query = 'UPDATE `red_pages` SET `page_title` = ?, `rev_id` = ?, `status`= ? WHERE `page_id` = ?;' data = ( str( page_title ), int( rev_id ), int( status ), self.__page_id ) cursor.execute( query, data) type( self ).connection.commit() class MYSQL_RED_FAM( MYSQL_RED ): def __init__( self ): """ Creates a new instance, runs __init__ of parent class """ super().__init__( )