code: def create_schema(self, schema_name):
          
          try:
              self.cursor.execute('CREATE SCHEMA %s' % schema_name)
          except Exception as e:
              raise e
          finally:
              self.db.commit()
docs: Create schema. This method only implemented for this class