Will create the schema in the database

def create_schema(self, connection):
        """
        Will create the schema in the database
        """
        if '.' not in self.table:
            return

        query = 'CREATE SCHEMA IF NOT EXISTS {schema_name};'.format(schema_name=self.table.split('.')[0])
        connection.cursor().execute(query)