db.py 文件源码

def load_schema(self, script):
        """Load the specified schema into the database"
           script: path to a SQL script"""
        try:
            s = open(script, "r").read()
            logger.debug("loaded schema %s", script)
            self.cursor.execute(s)
        except psycopg2.DatabaseError, e:
            logger.warning("error loading schema: %s", self.fmt_errmsg(e))