让我们来做个django小项目之二

上篇内容我们算是来了一个开场，创建了我们的项目，最后把数据库也建立完成了，这篇我们主要完成后台数据入库的部分，根据我们之前的思路，如果已经能实时获得每个站点性能信息了，如果能将每次获得信息插入到数据库中，这个就完成了我们的入库部分，这里说一下我们的数据库操作部分，要操作数据库，首先我们要跟数据库建立连接，然后进行常规的CRUD操作，操作完毕后再关闭数据库连接，这是一个基本流程，所以为了提高数据库的操作速度，我们可以把一些常用的操作封装成一个类，以下是我门数据库操作的类代码：

class database:
    def __init__(self, dbname=None, dbhost=None):
        self._logger = logger
        if dbname is None:
            self._dbname = DBNAME
        else:
            self._dbname = dbname
        if dbhost is None:
            self._dbhost = DBHOST
        else:
            self._dbhost = dbhost
            
        self._dbuser = DBUSER
        self._dbpassword = DBPWD
        self._dbport = int(DBPORT)
        self._conn = self.connectMySQL()
        
        if(self._conn):
            self._cursor = self._conn.cursor()
 
 
    def connectMySQL(self):
        conn = False
        try:
            conn = MySQLdb.connect(host=self._dbhost,user=self._dbuser,passwd=self._dbpassword,db=self._dbname,port=self._dbport)
        except Exception,data:
            self._logger.error("connect database failed, %s" % data)
            conn = False
        return conn
 
 
    def fetch_all(self, sql):
        res = ''
        if(self._conn):
            try:
                self._cursor.execute(sql)
                res = self._cursor.fetchall()
            except Exception, data:
                res = False
                self._logger.warn("query database exception, %s" % data)
        return res
 
 
    def update(self, sql):
        flag = False
        if(self._conn):
            try:
                self._cursor.execute(sql)
                self._conn.commit()
                flag = True
            except Exception, data:
                flag = False
                self._logger.warn("update database exception, %s" % data)
 
        return flag
 
    def close(self):
        if(self._conn):
            try:
                if(type(self._cursor)=='object'):
                    self._cursor.close()
                if(type(self._conn)=='object'):
                    self._conn.close()
            except Exception, data:
                self._logger.warn("close database exception, %s,%s,%s" % (data, type(self._cursor), type(self._conn)))    

在这个类中我们先定义了__init__方法，指定了数据库连接，用户，端口，用户等信息，接下来是定义了三个方法，分别是建立数据库连接，获取数据内容、更新数据库及最后关闭数据库连接，正题逻辑就是这样，代码没特别内容。