(self, db)
Install cascading code to db.
Install cascading code to db.
Install cascading code to db .
def install_code(self, db):
        """Install cascading code to db."""
        objs = [
            skytools.DBLanguage("plpgsql"),
            #skytools.DBFunction("txid_current_snapshot", 0, sql_file="txid.sql"),
            skytools.DBSchema("pgq", sql_file="pgq.sql"),
            skytools.DBFunction("pgq.get_batch_cursor", 3, sql_file = "pgq.upgrade.2to3.sql"),
            skytools.DBSchema("pgq_ext", sql_file="pgq_ext.sql"), # not needed actually
            skytools.DBSchema("pgq_node", sql_file="pgq_node.sql"),
        ]
        objs += self.extra_objs
        skytools.db_install(db.cursor(), objs, self.log)
        db.commit()
def install_code ( self , db ) : objs = [ skytools . DBLanguage ( "plpgsql" ) , #skytools.DBFunction("txid_current_snapshot", 0, sql_file="txid.sql"), skytools . DBSchema ( "pgq" , sql_file = "pgq.sql" ) , skytools . DBFunction ( "pgq.get_batch_cursor" , 3 , sql_file = "pgq.upgrade.2to3.sql" ) , skytools . DBSchema ( "pgq_ext" , sql_file = "pgq_ext.sql" ) , # not needed actually skytools . DBSchema ( "pgq_node" , sql_file = "pgq_node.sql" ) , ] objs += self . extra_objs skytools . db_install ( db . cursor ( ) , objs , self . log ) db . commit ( )