OpenStack Study: db.py

**** CubicPower OpenStack Study ****

def initialize():

    db.configure_db()

**** CubicPower OpenStack Study ****

def add_pool_port(context, pool_id, port_id):

    session = context.session

    with session.begin(subtransactions=True):

        pool_port = models.PoolPort()

        pool_port.pool_id = pool_id

        pool_port.port_id = port_id

        session.add(pool_port)

**** CubicPower OpenStack Study ****

def get_pool_port(context, pool_id):

    return (context.session.query(models.PoolPort).filter_by(pool_id=pool_id).

            first())

**** CubicPower OpenStack Study ****

def delete_pool_backend(context, pool_id):

    session = context.session

    backend = (session.query(models.PoolPort).filter_by(

        pool_id=pool_id))

    for b in backend:

        delete_pool_port(context, b)

**** CubicPower OpenStack Study ****

def delete_pool_port(context, backend_port):

    session = context.session

    with session.begin(subtransactions=True):

        port = (session.query(nmodel.Port).filter_by(

            id=backend_port['port_id'])).first()

        if port:

            session.delete(backend_port)

            session.delete(port)