db/db.py

#! /usr/bin/python

#  Copyright 2014 Linaro Limited
#  Author: Dave Pigott <dave.pigot@linaro.org>
#
#  This program is free software; you can redistribute it and/or modify
#  it under the terms of the GNU General Public License as published by
#  the Free Software Foundation; either version 2 of the License, or
#  (at your option) any later version.
#
#  This program is distributed in the hope that it will be useful,
#  but WITHOUT ANY WARRANTY; without even the implied warranty of
#  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
#  GNU General Public License for more details.
#
#  You should have received a copy of the GNU General Public License
#  along with this program; if not, write to the Free Software
#  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
#  MA 02110-1301, USA.

import psycopg2
import psycopg2.extras

class VlanDB:
    def __init__(self, db_name="vland", username="vland"):
        try:
            self.connection = psycopg2.connect(database=db_name, user=username,
                                               cursor_factory=psycopg2.extras.RealDictCursor)
            self.cursor = self.connection.cursor()
        except Exception as e:
            print "Failed to access database: %s" % e

    def __del__(self):
        self.cursor.close()
        self.connection.close()

    def create_switch(self, name, admin_password, cli_password):
        try:
            self.cursor("INSERT INTO switch (name, admin_pw, cli_pw) VALUES (%s, %s, %s) RETURNING switch_id" %
                        (name, admin_password, cli_password))
            switch_id = self.cursor.fetchone()[0]
            self.connection.commit()
        except:
            self.connection.rollback()
            raise
        return switch_id

    def create_port(self, name, switch_id, is_locked, is_trunk, default_vlan_id, base_vlan_id):
        try:
            self.cursor("INSERT INTO port (name, switch_id, is_locked, is_trunk, default_vlan_id, base_vlan_id)"
                        "VALUES (%s, %s, %s %s %s %s) RETURNING port_id" %
                        (name, switch_id, is_locked, is_trunk, default_vlan_id, base_vlan_id))
            port_id = self.cursor.fetchone()[0]
            self.connection.commit()
        except:
            self.connection.rollback()
            raise
        return port_id

    def create_vlan(self, name, tag, is_default_vlan):
        try:
            self.cursor("INSERT INTO vlan (name, tag, is_default_vlan)"
                        "VALUES (%s, %s, %s) RETURNING vlan_id" %
                        (name, tag, is_default_vlan))
            vlan_id = self.cursor.fetchone()[0]
            self.connection.commit()
        except:
            self.connection.rollback()
            raise
        return vlan_id

    def _delete_row(self, table, field, value):
        try:
            self.cursor.execute("DELETE FROM %s WHERE %s = %s" % (table, field, value))
            self.connection.commit()
        except:
            self.connection.rollback()
            raise

    def delete_switch(self, switch_id):
        self._delete_row("switch", "switch_id", switch_id)

    def delete_port(self, port_id):
        self._delete_row("port", "port_id", port_id)

    def delete_vlan(self, vlan_id):
        self._delete_row("vlan", "vlan_id", vlan_id)

    def _get_row(self, select_field, table, compare_field, value):
        self.cursor.execute("SELECT %s FROM %s WHERE %s = %s" % (select_field, table, compare_field, value))
        return self.cursor.fetchone()[0]

    def get_switch_id(self, name):
        return self._get_row("switch_id", "switch", "name", name)

    def get_port_id(self, name):
        return self._get_row("port_id", "port", "name", name)

    def get_vlan_id(self, name):
        return self._get_row("vlan_id", "vlan", "name", name)

    def get_switch_name(self, switch_id):
        return self._get_row("name", "switch", "switch_id", switch_id)

    def get_port_name(self, port_id):
        return self._get_row("port_name", "port", "port_id", port_id)

    def get_vlan_name(self, vlan_id):
        return self._get_row("vlan_name", "vlan", "vlan_id", vlan_id)

    def _dump_table(self, table):
        result = []
        self.cursor.execute("SELECT * FROM %s" % table)
        self.cursor.execute("SELECT * FROM switch")
        record = self.cursor.fetchone()
        while record != None:
            result += record
            record = self.cursor.fetchone()
        return result

    def all_switches(self):
        return self._dump_table("switch")

    def all_ports(self):
        return self._dump_table("port")

    def all_vlans(self):
        return self._dump_table("vlan")