sports_collect/collectSports/models/model.py

import biz


class Model(dict):

    def __init__(self):
        self.db = biz.getDB()
        self.cursor = self.db.getCursor()
        self.conn = self.db.getConn()
        pass

    def query(self, sql, args=None):

        self.cursor.execute(sql, args)
        res = self.cursor.fetchall()
        return res

    def execute(self, sql, args=None):
        try:
            self.cursor.execute(sql, args)
            self.conn.commit()
        except BaseException as e:
            print(e)

    def select(self, conditions={}):
        where = fields = limit = orderby = ''
        limit = 'limit 1 offset 0'
        if 'where' in conditions:
            where = ' where ' + conditions['where']
        if 'fields' in conditions:
            fields = '  ' + conditions['fields']
        if 'limit' in conditions:
            limit_d = conditions['limit'].split(',')
            limit = ' limit ' + limit_d[0] + ' offset ' + limit_d[1]
        if 'orderby' in conditions:
            orderby = '  order by ' + conditions['orderby']
        s = "select %s from \"%s\" %s %s %s " % (fields, self.table_name, where, orderby, limit)
        return self.query(s)

    def update(self, data, where=''):
        values = []
        if where != '':
            where = ' where %s' % (where)

        for index in data:
            s = "%s='%s'" % (index, data[index])
            values.append(s)
        sql = "update \"%s\" set %s  %s" % (self.table_name, ','.join(values), where)
        return self.execute(sql)

    def save(self, data):
        fields = []
        values = []
        vls = ''

        for index in data:
            fields.append(index)
            values.append(data[index])
        if vls == '':
            vls = ''
        else:
            vls = vls + ','
        vls = vls + "('%s')" % '\',\''.join('%s' % id for id in values)
        sql = "insert into \"%s\"(%s) values %s" % (self.table_name, ','.join(fields), vls)
        return self.execute(sql)