Synnefo

        #create policy table

        columns=[]

        columns.append(Column('node', Integer,

                              ForeignKey('nodes.node',

                                         ondelete='CASCADE',

                                         onupdate='CASCADE'),

                              primary_key=True))

        columns.append(Column('key', String(255), primary_key=True))

        columns.append(Column('value', String(255)))

        self.policies = Table('policy', metadata, *columns, mysql_engine='InnoDB')

    def policy_get(self, node):

        s = select([self.policies.c.key, self.policies.c.value],

            self.policies.c.node==node)

        r = self.conn.execute(s)

        d = dict(r.fetchall())

        r.close()

        return d

    def policy_set(self, node, policy):

        #insert or replace

        for k, v in policy.iteritems():

            s = self.policies.update().where(and_(self.policies.c.node == node,

                                                  self.policies.c.key == k))

            s = s.values(value = v)

            rp = self.conn.execute(s)

            rp.close()

            if rp.rowcount == 0:

                s = self.policies.insert()

                values = {'node':node, 'key':k, 'value':v}

                r = self.conn.execute(s, values)

                r.close()